Package org.apache.nifi.util

Class FlowFilePackagerV3

java.lang.Object

org.apache.nifi.util.FlowFilePackagerV3

All Implemented Interfaces:

FlowFilePackager

public class FlowFilePackagerV3
extends Object
implements FlowFilePackager

Field Summary

Fields

Modifier and Type	Field	Description
static final byte[]	MAGIC_HEADER
private static final int	MAX_VALUE_2_BYTES
private final byte[]	writeBuffer

Constructor Summary

Constructors

Constructor	Description
FlowFilePackagerV3()

Method Summary

Modifier and Type	Method	Description
private void	copy(InputStream in, OutputStream out)
void	packageFlowFile(InputStream in, OutputStream out, Map<String,String> attributes, long fileSize)
private void	writeFieldLength(OutputStream out, int numBytes)
private void	writeLong(OutputStream out, long val)
private void	writeString(String val, OutputStream out)

Methods inherited from class java.lang.Object

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

Field Details

MAGIC_HEADER

public static final byte[] MAGIC_HEADER

MAX_VALUE_2_BYTES

private static final int MAX_VALUE_2_BYTES

See Also:

• Constant Field Values

writeBuffer

private final byte[] writeBuffer

Constructor Details

FlowFilePackagerV3

public FlowFilePackagerV3()

Method Details

packageFlowFile

public void packageFlowFile(InputStream in,
 OutputStream out,
 Map<String,String> attributes,
 long fileSize)
                     throws IOException

Specified by:

packageFlowFile in interface FlowFilePackager

Throws:

IOException

copy

private void copy(InputStream in,
 OutputStream out)
           throws IOException

Throws:

IOException

writeString

private void writeString(String val,
 OutputStream out)
                  throws IOException

Throws:

IOException

writeFieldLength

private void writeFieldLength(OutputStream out,
 int numBytes)
                       throws IOException

Throws:

IOException

writeLong

private void writeLong(OutputStream out,
 long val)
                throws IOException

Throws:

IOException