org.apache.nifi.provenance

Class EventIdFirstSchemaRecordReader

java.lang.Object

org.apache.nifi.provenance.serialization.CompressableRecordReader

org.apache.nifi.provenance.EventIdFirstSchemaRecordReader

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, RecordReader

Direct Known Subclasses:

EncryptedSchemaRecordReader

public class EventIdFirstSchemaRecordReader
extends CompressableRecordReader

Constructor Summary

Constructors

Constructor and Description
EventIdFirstSchemaRecordReader(java.io.InputStream in, java.lang.String filename, TocReader tocReader, int maxAttributeChars)

Method Summary

Modifier and Type	Method and Description
protected boolean	isData(java.io.InputStream in)
protected StandardProvenanceEventRecord	nextRecord(java.io.DataInputStream in, int serializationVersion)
protected void	readHeader(java.io.DataInputStream in, int serializationVersion)
protected java.util.Optional<StandardProvenanceEventRecord>	readToEvent(long eventId, java.io.DataInputStream dis, int serializationVersion)
java.lang.String	toString()
protected void	verifySerializationVersion(int serializationVersion)

Methods inherited from class org.apache.nifi.provenance.serialization.CompressableRecordReader

close, getBlockIndex, getBlockIndex, getBytesConsumed, getFilename, getMaxAttributeLength, getMaxEventId, getTocReader, isBlockIndexAvailable, isData, nextRecord, skip, skipTo, skipToBlock, skipToEvent

Methods inherited from class java.lang.Object

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

Constructor Detail

EventIdFirstSchemaRecordReader

public EventIdFirstSchemaRecordReader(java.io.InputStream in,
                                      java.lang.String filename,
                                      TocReader tocReader,
                                      int maxAttributeChars)
                               throws java.io.IOException

Throws:

java.io.IOException

Method Detail

verifySerializationVersion

protected void verifySerializationVersion(int serializationVersion)

readHeader

protected void readHeader(java.io.DataInputStream in,
                          int serializationVersion)
                   throws java.io.IOException

Overrides:

readHeader in class CompressableRecordReader

Throws:

java.io.IOException

nextRecord

protected StandardProvenanceEventRecord nextRecord(java.io.DataInputStream in,
                                                   int serializationVersion)
                                            throws java.io.IOException

Specified by:

nextRecord in class CompressableRecordReader

Throws:

java.io.IOException

isData

protected boolean isData(java.io.InputStream in)
                  throws java.io.IOException

Throws:

java.io.IOException

readToEvent

protected java.util.Optional<StandardProvenanceEventRecord> readToEvent(long eventId,
                                                                        java.io.DataInputStream dis,
                                                                        int serializationVersion)
                                                                 throws java.io.IOException

Overrides:

readToEvent in class CompressableRecordReader

Throws:

java.io.IOException

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object