com.streambase.sb.feedsim

Class FeedSimTupleInputStream

java.lang.Object

java.io.InputStream

com.streambase.sb.feedsim.FeedSimCSVInputStream

com.streambase.sb.feedsim.FeedSimTupleInputStream

All Implemented Interfaces:

Closeable, AutoCloseable

public abstract class FeedSimTupleInputStream
extends FeedSimCSVInputStream

FeedSim can be configured to use classes that extend this abstract class. This allows users to read proprietary formated files and deliver their contents so that FeedSim can play their data like any other product supported format. This interface may be helpful for proprietary data formats where converting to CSV is relatively expensive when compared with using native data types and converting directly to a StreamBase tuple. Note that the underlying read() method is still used in the FeedSim editor to display preview contents, etc. If the FeedSim field mapping or the Timestamp builder is used, then the readTuple interface will not be called, and data will only be delivered via the read() method.

Since:

6.5.8

Constructor Summary

Constructors

Constructor and Description
FeedSimTupleInputStream(String path)

Method Summary

Methods

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 implemenation.
abstract Tuple	readTuple() This method is called by a FeedSim thread to get the next tuple to send.

Methods inherited from class com.streambase.sb.feedsim.FeedSimCSVInputStream

getPath

Methods inherited from class java.io.InputStream

available, mark, markSupported, read, read, reset, skip

Methods inherited from class java.lang.Object

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

Constructor Detail

FeedSimTupleInputStream

public FeedSimTupleInputStream(String path)
                        throws IOException

Throws:

IOException

Method Detail

getSchema

public abstract Schema getSchema()
                          throws StreamBaseException

This method must return the Schema of the data to be returned by readTuple()

Returns:

The Schema of the data to be returned by readTuple()

Throws:

StreamBaseException

readTuple

public abstract Tuple readTuple()
                         throws StreamBaseException

This method is called by a FeedSim thread to get the next tuple to send. A null returned means end of data.

Returns:

Next Tuple to be sent to the FeedSim Stream

Throws:

StreamBaseException

read

public int read()
         throws IOException

Provide a default implementation for the required read() method that uses the readTuple implemenation.

Specified by:

read in class InputStream

Returns:

the next character in the CSV representation of the input

Throws:

IOException

Since:

7.4

close

public void close()
           throws IOException

Close that cleans up the default read() state

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class InputStream

Throws:

IOException

Since:

7.4