com.northconcepts.datapipeline.filesystem.zip

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

public class ZipFileSystem
extends FileSystem

Class for accessing zips as file systems.

Field Summary

Fields inherited from class com.northconcepts.datapipeline.core.Endpoint

BUFFER_SIZE, captureElapsedTime, DEFAULT_READ_BUFFER_SIZE

Fields inherited from class com.northconcepts.datapipeline.core.DataObject

id, log, name, TIMESTAMP_FORMAT

Constructor Summary

Constructors

Constructor and Description
ZipFileSystem(File file)

Method Summary

Modifier and Type	Method and Description
void	close() Indicates that this endpoint has finished reading or writing.
<T extends ZipEntry> Iterator<T>	listEntries()
<T extends ZipEntry> Iterator<T>	listEntries(ZipEntryFilter filter)
void	open() 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.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

Methods inherited from class com.northconcepts.datapipeline.core.DataObject

exception, exception, exception, getId, getName, resetID

Methods inherited from class java.lang.Object

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

Constructor Detail

ZipFileSystem

public ZipFileSystem(File file)

Method Detail

open

public void open()
          throws DataException

Description copied from class: Endpoint

Makes this endpoint ready for reading or writing.

Overrides:

open in class Endpoint

Throws:

DataException

close

public void close()
           throws DataException

Description copied from class: Endpoint

Indicates that this endpoint has finished reading or writing.

Overrides:

close in class Endpoint

Throws:

DataException

listEntries

public <T extends ZipEntry> Iterator<T> listEntries()
                                             throws Throwable

Throws:

Throwable

listEntries

public <T extends ZipEntry> Iterator<T> listEntries(ZipEntryFilter filter)
                                             throws Throwable

Throws:

Throwable

readEntries

public <T extends ZipEntry> Iterator<DataReader> readEntries(ZipEntryFilter filter,
                                                             ZipDataReaderFactory factory)
                                                      throws Throwable

Throws:

Throwable