org.apache.nifi.serialization.record

Class MockRecordParser

java.lang.Object

org.apache.nifi.components.AbstractConfigurableComponent

org.apache.nifi.controller.AbstractControllerService

org.apache.nifi.serialization.record.MockRecordParser

All Implemented Interfaces:

ConfigurableComponent, ControllerService, RecordReaderFactory

public class MockRecordParser
extends AbstractControllerService
implements RecordReaderFactory

Constructor Summary

Constructors

Constructor and Description
MockRecordParser()
MockRecordParser(int failAfterN)

Method Summary

Modifier and Type	Method and Description
void	addRecord(java.lang.Object... values)
void	addSchemaField(java.lang.String fieldName, RecordFieldType type)
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

MockRecordParser

public MockRecordParser()

MockRecordParser

public MockRecordParser(int failAfterN)

Method Detail

failAfter

public void failAfter(int failAfterN)

addSchemaField

public void addSchemaField(java.lang.String fieldName,
                           RecordFieldType type)

addRecord

public void addRecord(java.lang.Object... values)

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