Package org.apache.nifi.processors.standard

Class UnpackContent.ZipUnpacker.ZipInputStreamCallback

java.lang.Object

org.apache.nifi.processors.standard.UnpackContent.ZipUnpacker.ZipInputStreamCallback

All Implemented Interfaces:

org.apache.nifi.processor.io.InputStreamCallback

Direct Known Subclasses:

UnpackContent.ZipUnpacker.CompressedZipInputStreamCallback, UnpackContent.ZipUnpacker.EncryptedZipInputStreamCallback

Enclosing class:

UnpackContent.ZipUnpacker

private abstract static class UnpackContent.ZipUnpacker.ZipInputStreamCallback
extends Object
implements org.apache.nifi.processor.io.InputStreamCallback

Field Summary

Fields

Modifier and Type	Field	Description
private final Pattern	fileFilter
private final String	fragmentId
private int	fragmentIndex
private static final String	PATH_SEPARATOR
private final org.apache.nifi.processor.ProcessSession	session
private final org.apache.nifi.flowfile.FlowFile	sourceFlowFile
private final List<org.apache.nifi.flowfile.FlowFile>	unpacked

Constructor Summary

Constructors

Modifier	Constructor	Description
private	ZipInputStreamCallback(Pattern fileFilter, org.apache.nifi.processor.ProcessSession session, org.apache.nifi.flowfile.FlowFile sourceFlowFile, List<org.apache.nifi.flowfile.FlowFile> unpacked, String fragmentId)

Method Summary

Modifier and Type	Method	Description
protected void	addEncryptionMethodAttribute(net.lingala.zip4j.model.enums.EncryptionMethod encryptionMethod, Map<String,String> attributes)
protected void	addFilePermissionsAttribute(int mode, Map<String,String> attributes)
protected void	addFileSizeAttribute(long fileSize, Map<String,String> attributes)
protected void	addZipEntryTimeAttributes(Instant lastModified, Instant creation, Instant lastAccess, Map<String,String> attributes)
protected boolean	isFileEntryMatched(boolean directory, String fileName)
protected void	processEntry(InputStream zipInputStream, boolean directory, String zipEntryName, Map<String,String> attributes)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.nifi.processor.io.InputStreamCallback

process

Field Details

PATH_SEPARATOR

private static final String PATH_SEPARATOR

See Also:

• Constant Field Values

fileFilter

private final Pattern fileFilter

session

private final org.apache.nifi.processor.ProcessSession session

sourceFlowFile

private final org.apache.nifi.flowfile.FlowFile sourceFlowFile

unpacked

private final List<org.apache.nifi.flowfile.FlowFile> unpacked

fragmentId

private final String fragmentId

fragmentIndex

private int fragmentIndex

Constructor Details

ZipInputStreamCallback

private ZipInputStreamCallback(Pattern fileFilter,
 org.apache.nifi.processor.ProcessSession session,
 org.apache.nifi.flowfile.FlowFile sourceFlowFile,
 List<org.apache.nifi.flowfile.FlowFile> unpacked,
 String fragmentId)

Method Details

isFileEntryMatched

protected boolean isFileEntryMatched(boolean directory,
 String fileName)

processEntry

protected void processEntry(InputStream zipInputStream,
 boolean directory,
 String zipEntryName,
 Map<String,String> attributes)

addFileSizeAttribute

protected void addFileSizeAttribute(long fileSize,
 Map<String,String> attributes)

addEncryptionMethodAttribute

protected void addEncryptionMethodAttribute(net.lingala.zip4j.model.enums.EncryptionMethod encryptionMethod,
 Map<String,String> attributes)

addFilePermissionsAttribute

protected void addFilePermissionsAttribute(int mode,
 Map<String,String> attributes)

addZipEntryTimeAttributes

protected void addZipEntryTimeAttributes(Instant lastModified,
 Instant creation,
 Instant lastAccess,
 Map<String,String> attributes)