Package org.apache.nifi.util

Class FlowFileUnpackagerV1

java.lang.Object

org.apache.nifi.util.FlowFileUnpackagerV1

All Implemented Interfaces:

FlowFileUnpackager

public class FlowFileUnpackagerV1
extends Object
implements FlowFileUnpackager

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	FlowFileUnpackagerV1.NonCloseableInputStream

Field Summary

Fields

Modifier and Type	Field	Description
private int	flowFilesRead

Constructor Summary

Constructors

Constructor	Description
FlowFileUnpackagerV1()

Method Summary

Modifier and Type	Method	Description
protected Map<String,String>	getAttributes(org.apache.commons.compress.archivers.tar.TarArchiveInputStream stream)
boolean	hasMoreData()
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

flowFilesRead

private int flowFilesRead

Constructor Details

FlowFileUnpackagerV1

public FlowFileUnpackagerV1()

Method Details

unpackageFlowFile

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

Specified by:

unpackageFlowFile in interface FlowFileUnpackager

Throws:

IOException

getAttributes

protected Map<String,String> getAttributes(org.apache.commons.compress.archivers.tar.TarArchiveInputStream stream)
                                    throws IOException

Throws:

IOException

hasMoreData

public boolean hasMoreData()
                    throws IOException

Specified by:

hasMoreData in interface FlowFileUnpackager

Throws:

IOException