org.apache.storm.sql.runtime

Interface ISqlTridentDataSource.SqlTridentConsumer

All Known Implementing Classes:

SimpleSqlTridentConsumer

Enclosing interface:

ISqlTridentDataSource

public static interface ISqlTridentDataSource.SqlTridentConsumer

SqlTridentConsumer is a data structure containing StateFactory and StateUpdater for consuming tuples with State.

Please note that StateFactory and StateUpdater should use same class which implements State.

See Also:

StateFactory, StateUpdater

Method Summary

Modifier and Type	Method and Description
StateFactory	getStateFactory()
StateUpdater	getStateUpdater()

Method Detail

getStateFactory

StateFactory getStateFactory()

getStateUpdater

StateUpdater getStateUpdater()