org.apache.storm.sql.runtime

Class SimpleSqlTridentConsumer

java.lang.Object

org.apache.storm.sql.runtime.SimpleSqlTridentConsumer

All Implemented Interfaces:

ISqlTridentDataSource.SqlTridentConsumer

public class SimpleSqlTridentConsumer
extends Object
implements ISqlTridentDataSource.SqlTridentConsumer

Constructor Summary

Constructors

Constructor and Description
SimpleSqlTridentConsumer(StateFactory stateFactory, StateUpdater stateUpdater)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleSqlTridentConsumer

public SimpleSqlTridentConsumer(StateFactory stateFactory,
                                StateUpdater stateUpdater)

Method Detail

getStateFactory

public StateFactory getStateFactory()

Specified by:

getStateFactory in interface ISqlTridentDataSource.SqlTridentConsumer

getStateUpdater

public StateUpdater getStateUpdater()

Specified by:

getStateUpdater in interface ISqlTridentDataSource.SqlTridentConsumer