org.apache.storm.sql.runtime

Interface ISqlTridentDataSource

public interface ISqlTridentDataSource

A ISqlTridentDataSource specifies how an external data source produces and consumes data.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	ISqlTridentDataSource.SqlTridentConsumer SqlTridentConsumer is a data structure containing StateFactory and StateUpdater for consuming tuples with State.

Method Summary

Modifier and Type	Method and Description
ISqlTridentDataSource.SqlTridentConsumer	getConsumer() Provides instance of SqlTridentConsumer which can be used as consumer (State) in Trident.
ITridentDataSource	getProducer() Provides instance of ITridentDataSource which can be used as producer in Trident.

Method Detail

getProducer

ITridentDataSource getProducer()

Provides instance of ITridentDataSource which can be used as producer in Trident.

Since ITridentDataSource is a marker interface for Trident Spout interfaces, this method should effectively return an instance of one of these interfaces (can be changed if Trident API evolves) or descendants: - IBatchSpout - ITridentSpout - IPartitionedTridentSpout - IOpaquePartitionedTridentSpout

See Also:

ITridentDataSource, IBatchSpout, ITridentSpout, IPartitionedTridentSpout, IOpaquePartitionedTridentSpout

getConsumer

ISqlTridentDataSource.SqlTridentConsumer getConsumer()

Provides instance of SqlTridentConsumer which can be used as consumer (State) in Trident.

See Also:

ISqlTridentDataSource.SqlTridentConsumer