Package com.kodexa.client.store

Class AbstractFileSystemDocumentStore

java.lang.Object

com.kodexa.client.store.AbstractFileSystemDocumentStore

All Implemented Interfaces:

Connector, Sink, DocumentStore, Iterator<Document>

Direct Known Subclasses:

JsonDocumentStore, MsgPackDocumentStore

public abstract class AbstractFileSystemDocumentStore
extends Object
implements Sink, Connector, DocumentStore

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	forceInitialize
protected List<String>	index
protected File	indexFile
protected static com.fasterxml.jackson.databind.ObjectMapper	OBJECT_MAPPER
protected String	path
protected File	storeFolder

Constructor Summary

Constructors

Constructor	Description
AbstractFileSystemDocumentStore(String path, boolean forceInitialize)

Method Summary

Modifier and Type	Method	Description
int	getCount()
abstract Document	getDocument(int position)
protected abstract String	getExtension()
protected File	getFile(String uuid)
String	getName()
InputStream	getSource(Document document)
boolean	hasNext()
Document	next()
void	readIndex()
void	resetConnector()
void	saveIndex()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining, remove

Methods inherited from interface com.kodexa.client.sink.Sink

sink

Field Detail

OBJECT_MAPPER

protected static final com.fasterxml.jackson.databind.ObjectMapper OBJECT_MAPPER

path

protected final String path

forceInitialize

protected final boolean forceInitialize

storeFolder

protected final File storeFolder

indexFile

protected final File indexFile

index

protected List<String> index

Constructor Detail

AbstractFileSystemDocumentStore

public AbstractFileSystemDocumentStore(String path,
                                       boolean forceInitialize)

Method Detail

getExtension

protected abstract String getExtension()

readIndex

public void readIndex()

saveIndex

public void saveIndex()

getSource

public InputStream getSource(Document document)

Specified by:

getSource in interface Connector

getFile

protected File getFile(String uuid)

getName

public String getName()

Specified by:

getName in interface Connector

Specified by:

getName in interface Sink

getCount

public int getCount()

Specified by:

getCount in interface Sink

resetConnector

public void resetConnector()

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<Document>

next

public Document next()

Specified by:

next in interface Iterator<Document>

getDocument

public abstract Document getDocument(int position)