public class FileReaderProvider extends Object implements org.apache.streams.core.StreamsProvider
Constructor and Description |
---|
FileReaderProvider(String filePathInResources,
StreamsDatumConverter converter) |
Modifier and Type | Method and Description |
---|---|
void |
cleanUp() |
String |
getId() |
boolean |
isRunning() |
void |
prepare(Object configurationObject) |
org.apache.streams.core.StreamsResultSet |
readCurrent() |
org.apache.streams.core.StreamsResultSet |
readNew(BigInteger sequence) |
org.apache.streams.core.StreamsResultSet |
readRange(org.joda.time.DateTime start,
org.joda.time.DateTime end) |
void |
startStream() |
public FileReaderProvider(String filePathInResources, StreamsDatumConverter converter)
public String getId()
getId
in interface org.apache.streams.core.StreamsOperation
public void startStream()
startStream
in interface org.apache.streams.core.StreamsProvider
public org.apache.streams.core.StreamsResultSet readCurrent()
readCurrent
in interface org.apache.streams.core.StreamsProvider
public org.apache.streams.core.StreamsResultSet readNew(BigInteger sequence)
readNew
in interface org.apache.streams.core.StreamsProvider
public org.apache.streams.core.StreamsResultSet readRange(org.joda.time.DateTime start, org.joda.time.DateTime end)
readRange
in interface org.apache.streams.core.StreamsProvider
public boolean isRunning()
isRunning
in interface org.apache.streams.core.StreamsProvider
public void prepare(Object configurationObject)
prepare
in interface org.apache.streams.core.StreamsOperation
public void cleanUp()
cleanUp
in interface org.apache.streams.core.StreamsOperation
Copyright © 2012–2016 The Apache Software Foundation. All rights reserved.