Class ZipFileSystem
java.lang.Object
com.northconcepts.datapipeline.core.DataObject
com.northconcepts.datapipeline.core.Endpoint
com.northconcepts.datapipeline.internal.lang.FileSystem
com.northconcepts.datapipeline.filesystem.zip.ZipFileSystem
Class for accessing zips as file systems.
-
Field Summary
Fields inherited from class com.northconcepts.datapipeline.core.Endpoint
BUFFER_SIZE, captureElapsedTime, DEFAULT_READ_BUFFER_SIZEFields inherited from class com.northconcepts.datapipeline.core.DataObject
id, log, name, TIMESTAMP_FORMAT -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidclose()Wipes this connection cycle's credentials snapshot, then closes this endpoint.Returns an iterator over the zip file's entries, which must be used beforeclose().listEntries(ZipEntryFilter filter) Returns an iterator over the zip file's entries that the filter accepts, which must be used beforeclose().voidopen()Makes this endpoint ready for reading or writing.<T extends ZipEntry>
Iterator<DataReader> readEntries(ZipEntryFilter filter, ZipDataReaderFactory factory) Methods inherited from class com.northconcepts.datapipeline.internal.lang.FileSystem
credentialValue, getCredentialsResolver, getCurrentCredentials, refreshCredentials, resolveCredentials, setCredentialsResolverMethods inherited from class com.northconcepts.datapipeline.core.Endpoint
addElapsedtime, addExceptionProperties, assertClosed, assertNotOpened, assertOpened, finalize, getClosedOn, getDescription, getElapsedTime, getElapsedTimeAsString, getNestedEndpoint, getOpenedOn, getOpenElapsedTime, getOpenElapsedTimeAsString, getRootEndpoint, getSelfTime, getSelfTimeAsString, getState, isCaptureElapsedTime, isClosed, isOpen, setCaptureElapsedTime, setDescription, toString
-
Constructor Details
-
ZipFileSystem
-
-
Method Details
-
open
Description copied from class:EndpointMakes this endpoint ready for reading or writing.- Overrides:
openin classEndpoint- Throws:
DataException
-
close
Description copied from class:FileSystemWipes this connection cycle's credentials snapshot, then closes this endpoint.- Overrides:
closein classFileSystem- Throws:
DataException
-
listEntries
Returns an iterator over the zip file's entries, which must be used beforeclose().- Throws:
Throwable
-
listEntries
Returns an iterator over the zip file's entries that the filter accepts, which must be used beforeclose().- Throws:
Throwable
-
readEntries
public <T extends ZipEntry> Iterator<DataReader> readEntries(ZipEntryFilter filter, ZipDataReaderFactory factory) throws Throwable - Throws:
Throwable
-