Package org.apache.nifi.util

Class FlowFilePackagerV1

java.lang.Object

org.apache.nifi.util.FlowFilePackagerV1

All Implemented Interfaces:

FlowFilePackager

public class FlowFilePackagerV1
extends Object
implements FlowFilePackager

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_TAR_PERMISSIONS
static final String	FILENAME_ATTRIBUTES
static final String	FILENAME_CONTENT
private final int	tarPermissions

Constructor Summary

Constructors

Constructor	Description
FlowFilePackagerV1()
FlowFilePackagerV1(int tarPermissions)

Method Summary

Modifier and Type	Method	Description
static long	copy(InputStream source, OutputStream destination)
void	packageFlowFile(InputStream in, OutputStream out, Map<String,String> attributes, long fileSize)
private void	writeAttributesEntry(Map<String,String> attributes, org.apache.commons.compress.archivers.tar.TarArchiveOutputStream tout)
private void	writeContentEntry(org.apache.commons.compress.archivers.tar.TarArchiveOutputStream tarOut, InputStream inStream, long fileSize)

Methods inherited from class java.lang.Object

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

Field Details

FILENAME_ATTRIBUTES

public static final String FILENAME_ATTRIBUTES

See Also:

• Constant Field Values

FILENAME_CONTENT

public static final String FILENAME_CONTENT

See Also:

• Constant Field Values

DEFAULT_TAR_PERMISSIONS

public static final int DEFAULT_TAR_PERMISSIONS

See Also:

• Constant Field Values

tarPermissions

private final int tarPermissions

Constructor Details

FlowFilePackagerV1

public FlowFilePackagerV1()

FlowFilePackagerV1

public FlowFilePackagerV1(int tarPermissions)

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

writeAttributesEntry

private void writeAttributesEntry(Map<String,String> attributes,
 org.apache.commons.compress.archivers.tar.TarArchiveOutputStream tout)
                           throws IOException

Throws:

IOException

writeContentEntry

private void writeContentEntry(org.apache.commons.compress.archivers.tar.TarArchiveOutputStream tarOut,
 InputStream inStream,
 long fileSize)
                        throws IOException

Throws:

IOException

copy

public static long copy(InputStream source,
 OutputStream destination)
                 throws IOException

Throws:

IOException