org.apache.nifi.provenance

Class StandardRecordWriter

java.lang.Object

org.apache.nifi.provenance.AbstractRecordWriter

org.apache.nifi.provenance.serialization.CompressableRecordWriter

org.apache.nifi.provenance.StandardRecordWriter

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, RecordWriter

Deprecated.

Deprecated in favor of SchemaRecordWriter

@Deprecated
public class StandardRecordWriter
extends CompressableRecordWriter
implements RecordWriter

Field Summary

Fields

Modifier and Type	Field and Description
static int	MAX_ALLOWED_UTF_LENGTH Deprecated.
static java.lang.String	SERIALIZATION_NAME Deprecated.
static int	SERIALIZATION_VERISON Deprecated.

Constructor Summary

Constructors

Constructor and Description
StandardRecordWriter(java.io.File file, java.util.concurrent.atomic.AtomicLong idGenerator, TocWriter writer, boolean compressed, int uncompressedBlockSize) Deprecated.
StandardRecordWriter(java.io.OutputStream out, java.lang.String storageLocation, java.util.concurrent.atomic.AtomicLong idGenerator, TocWriter tocWriter, boolean compressed, int uncompressedBlockSize) Deprecated.

Method Summary

Modifier and Type	Method and Description
protected java.lang.String	getSerializationName() Deprecated.
protected int	getSerializationVersion() Deprecated.
java.lang.String	toString() Deprecated.
protected void	writeHeader(long firstEventId, java.io.DataOutputStream out) Deprecated.
protected void	writeNullableString(java.io.DataOutputStream out, java.lang.String toWrite, java.lang.String fieldName) Deprecated.
protected void	writeRecord(ProvenanceEventRecord record, long recordIdentifier, java.io.DataOutputStream out) Deprecated.
protected void	writeUUID(java.io.DataOutputStream out, java.lang.String uuid) Deprecated.
protected void	writeUUIDs(java.io.DataOutputStream out, java.util.Collection<java.lang.String> list) Deprecated.

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

ensureStreamState, flush, getBufferedOutputStream, getBytesWritten, getIdGenerator, getRecordsWritten, getUnderlyingOutputStream, isCompressed, resetWriteStream, syncUnderlyingOutputStream, writeHeader, writeRecord

Methods inherited from class org.apache.nifi.provenance.AbstractRecordWriter

close, getFile, getStorageLocation, getTocWriter, isClosed, isDirty, lock, markDirty, resetDirtyFlag, sync, tryLock, unlock

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.nifi.provenance.serialization.RecordWriter

flush, getBytesWritten, getFile, getRecordsWritten, getTocWriter, isClosed, isDirty, lock, markDirty, sync, tryLock, unlock, writeHeader, writeRecord

Methods inherited from interface java.io.Closeable

close

Field Detail

MAX_ALLOWED_UTF_LENGTH

public static final int MAX_ALLOWED_UTF_LENGTH

Deprecated.

See Also:

Constant Field Values

SERIALIZATION_VERISON

public static final int SERIALIZATION_VERISON

Deprecated.

See Also:

Constant Field Values

SERIALIZATION_NAME

public static final java.lang.String SERIALIZATION_NAME

Deprecated.

See Also:

Constant Field Values

Constructor Detail

StandardRecordWriter

public StandardRecordWriter(java.io.File file,
                            java.util.concurrent.atomic.AtomicLong idGenerator,
                            TocWriter writer,
                            boolean compressed,
                            int uncompressedBlockSize)
                     throws java.io.IOException

Deprecated.

Throws:

java.io.IOException

StandardRecordWriter

public StandardRecordWriter(java.io.OutputStream out,
                            java.lang.String storageLocation,
                            java.util.concurrent.atomic.AtomicLong idGenerator,
                            TocWriter tocWriter,
                            boolean compressed,
                            int uncompressedBlockSize)
                     throws java.io.IOException

Deprecated.

Throws:

java.io.IOException

Method Detail

getSerializationName

protected java.lang.String getSerializationName()

Deprecated.

Specified by:

getSerializationName in class CompressableRecordWriter

getSerializationVersion

protected int getSerializationVersion()

Deprecated.

Specified by:

getSerializationVersion in class CompressableRecordWriter

writeHeader

protected void writeHeader(long firstEventId,
                           java.io.DataOutputStream out)
                    throws java.io.IOException

Deprecated.

Specified by:

writeHeader in class CompressableRecordWriter

Throws:

java.io.IOException

writeRecord

protected void writeRecord(ProvenanceEventRecord record,
                           long recordIdentifier,
                           java.io.DataOutputStream out)
                    throws java.io.IOException

Deprecated.

Specified by:

writeRecord in class CompressableRecordWriter

Throws:

java.io.IOException

writeUUID

protected void writeUUID(java.io.DataOutputStream out,
                         java.lang.String uuid)
                  throws java.io.IOException

Deprecated.

Throws:

java.io.IOException

writeUUIDs

protected void writeUUIDs(java.io.DataOutputStream out,
                          java.util.Collection<java.lang.String> list)
                   throws java.io.IOException

Deprecated.

Throws:

java.io.IOException

writeNullableString

protected void writeNullableString(java.io.DataOutputStream out,
                                   java.lang.String toWrite,
                                   java.lang.String fieldName)
                            throws java.io.IOException

Deprecated.

Throws:

java.io.IOException

toString

public java.lang.String toString()

Deprecated.

Overrides:

toString in class java.lang.Object