Package org.apache.nifi.repository.schema

Class SchemaRecordReader

java.lang.Object

org.apache.nifi.repository.schema.SchemaRecordReader

public class SchemaRecordReader
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private final FieldCache	fieldCache
private final RecordSchema	schema

Constructor Summary

Constructors

Modifier	Constructor	Description
private	SchemaRecordReader(RecordSchema schema, FieldCache fieldCache)

Method Summary

Modifier and Type	Method	Description
private static void	fillBuffer(InputStream in, byte[] destination)
static SchemaRecordReader	fromSchema(RecordSchema schema, FieldCache fieldCache)
private Object	readField(InputStream in, RecordField field)
private Object	readFieldValue(InputStream in, FieldType fieldType, String fieldName, List<RecordField> subFields)
private Record	readInlineRecord(InputStream in)
private int	readInt(InputStream in)
Record	readRecord(InputStream in)
RecordIterator	readRecords(InputStream in)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

schema

private final RecordSchema schema

fieldCache

private final FieldCache fieldCache

Constructor Details

SchemaRecordReader

private SchemaRecordReader(RecordSchema schema,
 FieldCache fieldCache)

Method Details

fromSchema

public static SchemaRecordReader fromSchema(RecordSchema schema,
 FieldCache fieldCache)

fillBuffer

private static void fillBuffer(InputStream in,
 byte[] destination)
                        throws IOException

Throws:

IOException

readRecord

public Record readRecord(InputStream in)
                  throws IOException

Throws:

IOException

readInlineRecord

private Record readInlineRecord(InputStream in)
                         throws IOException

Throws:

IOException

readRecords

public RecordIterator readRecords(InputStream in)
                           throws IOException

Throws:

IOException

readField

private Object readField(InputStream in,
 RecordField field)
                  throws IOException

Throws:

IOException

readFieldValue

private Object readFieldValue(InputStream in,
 FieldType fieldType,
 String fieldName,
 List<RecordField> subFields)
                       throws IOException

Throws:

IOException

readInt

private int readInt(InputStream in)
             throws IOException

Throws:

IOException