public abstract class FeedSimTupleInputStream extends FeedSimCSVInputStream
Constructor and Description |
---|
FeedSimTupleInputStream(String path) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Close that cleans up the default read() state
|
abstract Schema |
getSchema()
This method must return the Schema of the data to be returned by readTuple()
|
int |
read()
Provide a default implementation for the required read() method
that uses the readTuple implementation.
|
abstract Tuple |
readTuple()
This method is called by a FeedSim thread to get the next tuple to send.
|
getPath
available, mark, markSupported, read, read, reset, skip
public FeedSimTupleInputStream(String path) throws IOException
IOException
public abstract Schema getSchema() throws StreamBaseException
StreamBaseException
public abstract Tuple readTuple() throws StreamBaseException
StreamBaseException
public int read() throws IOException
read
in class InputStream
IOException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
close
in class InputStream
IOException