Package org.apache.nifi.repository.schema

Class SchemaRecordWriter

java.lang.Object

org.apache.nifi.repository.schema.SchemaRecordWriter

public class SchemaRecordWriter
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private static final ByteArrayCache	byteArrayCache
private static final int	CACHE_BUFFER_SIZE
(package private) static final int	EXTERNAL_FILE_INDICATOR
(package private) static final int	INLINE_RECORD_INDICATOR
private static final org.slf4j.Logger	logger
static final int	MAX_ALLOWED_UTF_LENGTH

Constructor Summary

Constructors

Constructor	Description
SchemaRecordWriter()

Method Summary

Modifier and Type	Method	Description
private boolean	allSingleByteInUtf8(String value)
(package private) static int	getCharsInUTF8Limit(String str, int utf8Limit)
void	writeExternalFileReference(DataOutputStream out, File externalFile)
private void	writeFieldRepetitionAndValue(RecordField field, Object value, DataOutputStream dos, byte[] buffer)
private void	writeFieldValue(RecordField field, Object value, DataOutputStream out, byte[] buffer)
void	writeRecord(Record record, OutputStream out)
private void	writeRecordFields(Record record, OutputStream out, byte[] buffer)
private void	writeRecordFields(Record record, RecordSchema schema, OutputStream out, byte[] buffer)
private void	writeUTFLimited(DataOutputStream out, String utfString, String fieldName)

Methods inherited from class java.lang.Object

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

Field Details

INLINE_RECORD_INDICATOR

static final int INLINE_RECORD_INDICATOR

See Also:

• Constant Field Values

EXTERNAL_FILE_INDICATOR

static final int EXTERNAL_FILE_INDICATOR

See Also:

• Constant Field Values

MAX_ALLOWED_UTF_LENGTH

public static final int MAX_ALLOWED_UTF_LENGTH

See Also:

• Constant Field Values

logger

private static final org.slf4j.Logger logger

CACHE_BUFFER_SIZE

private static final int CACHE_BUFFER_SIZE

See Also:

• Constant Field Values

byteArrayCache

private static final ByteArrayCache byteArrayCache

Constructor Details

SchemaRecordWriter

public SchemaRecordWriter()

Method Details

writeRecord

public void writeRecord(Record record,
 OutputStream out)
                 throws IOException

Throws:

IOException

writeRecordFields

private void writeRecordFields(Record record,
 OutputStream out,
 byte[] buffer)
                        throws IOException

Throws:

IOException

writeRecordFields

private void writeRecordFields(Record record,
 RecordSchema schema,
 OutputStream out,
 byte[] buffer)
                        throws IOException

Throws:

IOException

writeFieldRepetitionAndValue

private void writeFieldRepetitionAndValue(RecordField field,
 Object value,
 DataOutputStream dos,
 byte[] buffer)
                                   throws IOException

Throws:

IOException

allSingleByteInUtf8

private boolean allSingleByteInUtf8(String value)

writeFieldValue

private void writeFieldValue(RecordField field,
 Object value,
 DataOutputStream out,
 byte[] buffer)
                      throws IOException

Throws:

IOException

writeUTFLimited

private void writeUTFLimited(DataOutputStream out,
 String utfString,
 String fieldName)
                      throws IOException

Throws:

IOException

getCharsInUTF8Limit

static int getCharsInUTF8Limit(String str,
 int utf8Limit)

writeExternalFileReference

public void writeExternalFileReference(DataOutputStream out,
 File externalFile)
                                throws IOException

Throws:

IOException