org.apache.nifi.serialization.record

Class CommaSeparatedRecordReader

java.lang.Object

org.apache.nifi.components.AbstractConfigurableComponent

org.apache.nifi.controller.AbstractControllerService

org.apache.nifi.serialization.record.CommaSeparatedRecordReader

All Implemented Interfaces:

ConfigurableComponent, ControllerService, RecordReaderFactory

public class CommaSeparatedRecordReader
extends AbstractControllerService
implements RecordReaderFactory

Constructor Summary

Constructors

Constructor and Description
CommaSeparatedRecordReader()
CommaSeparatedRecordReader(int failAfterN)

Method Summary

Modifier and Type	Method and Description
RecordReader	createRecordReader(java.util.Map<java.lang.String,java.lang.String> variables, java.io.InputStream in, ComponentLog logger) Create a RecordReader instance to read records from specified InputStream.
void	failAfter(int failAfterN)

Methods inherited from class org.apache.nifi.controller.AbstractControllerService

abstractClearConfigContext, abstractStoreConfigContext, disabled, enabled, getConfigurationContext, getControllerServiceLookup, getIdentifier, getLogger, getProperty, getStateManager, init, initialize, isEnabled

Methods inherited from class org.apache.nifi.components.AbstractConfigurableComponent

customValidate, equals, getPropertyDescriptor, getPropertyDescriptors, getSupportedDynamicPropertyDescriptor, getSupportedPropertyDescriptors, hashCode, onPropertyModified, toString, validate

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.nifi.serialization.RecordReaderFactory

createRecordReader

Methods inherited from interface org.apache.nifi.controller.ControllerService

initialize

Methods inherited from interface org.apache.nifi.components.ConfigurableComponent

getIdentifier, getPropertyDescriptor, getPropertyDescriptors, onPropertyModified, validate

Constructor Detail

CommaSeparatedRecordReader

public CommaSeparatedRecordReader()

CommaSeparatedRecordReader

public CommaSeparatedRecordReader(int failAfterN)

Method Detail

failAfter

public void failAfter(int failAfterN)

createRecordReader

public RecordReader createRecordReader(java.util.Map<java.lang.String,java.lang.String> variables,
                                       java.io.InputStream in,
                                       ComponentLog logger)
                                throws java.io.IOException,
                                       SchemaNotFoundException

Description copied from interface: RecordReaderFactory

Create a RecordReader instance to read records from specified InputStream.

Specified by:

createRecordReader in interface RecordReaderFactory

Parameters:

variables - A map contains variables which is used to resolve Record Schema via Expression Language dynamically. This can be null or empty.

in - InputStream containing Records. This can be null or empty stream.

logger - A logger bind to a component

Returns:

Created RecordReader instance

Throws:

java.io.IOException

SchemaNotFoundException