Package org.apache.nifi.util

Class FlowFileUnpackagerV2

java.lang.Object

org.apache.nifi.util.FlowFileUnpackagerV2

All Implemented Interfaces:

FlowFileUnpackager

public class FlowFileUnpackagerV2
extends Object
implements FlowFileUnpackager

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	haveReadSomething
private Map<String,String>	nextAttributes
private final byte[]	readBuffer

Constructor Summary

Constructors

Constructor	Description
FlowFileUnpackagerV2()

Method Summary

Modifier and Type	Method	Description
protected long	copy(InputStream in, OutputStream out, long numBytes)
private void	fillBuffer(InputStream in, byte[] buffer, int length)
boolean	hasMoreData()
protected Map<String,String>	readAttributes(InputStream in)
private Integer	readFieldLength(InputStream in)
protected long	readLong(InputStream in)
protected String	readString(InputStream in)
Map<String,String>	unpackageFlowFile(InputStream in, OutputStream out)

Methods inherited from class java.lang.Object

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

Field Details

readBuffer

private final byte[] readBuffer

nextAttributes

private Map<String,String> nextAttributes

haveReadSomething

private boolean haveReadSomething

Constructor Details

FlowFileUnpackagerV2

public FlowFileUnpackagerV2()

Method Details

hasMoreData

public boolean hasMoreData()
                    throws IOException

Specified by:

hasMoreData in interface FlowFileUnpackager

Throws:

IOException

readAttributes

protected Map<String,String> readAttributes(InputStream in)
                                     throws IOException

Throws:

IOException

unpackageFlowFile

public Map<String,String> unpackageFlowFile(InputStream in,
 OutputStream out)
                                     throws IOException

Specified by:

unpackageFlowFile in interface FlowFileUnpackager

Throws:

IOException

readString

protected String readString(InputStream in)
                     throws IOException

Throws:

IOException

fillBuffer

private void fillBuffer(InputStream in,
 byte[] buffer,
 int length)
                 throws IOException

Throws:

IOException

copy

protected long copy(InputStream in,
 OutputStream out,
 long numBytes)
             throws IOException

Throws:

IOException

readLong

protected long readLong(InputStream in)
                 throws IOException

Throws:

IOException

readFieldLength

private Integer readFieldLength(InputStream in)
                         throws IOException

Throws:

IOException