Uses of Class
org.apache.storm.trident.TridentState

Packages that use TridentState

Package	Description
org.apache.storm.trident
org.apache.storm.trident.fluent

Uses of TridentState in org.apache.storm.trident

Methods in org.apache.storm.trident that return TridentState

Modifier and Type	Method and Description
protected TridentState	TridentTopology.addSourcedStateNode(List<Stream> sources, Node newNode)
protected TridentState	TridentTopology.addSourcedStateNode(Stream source, Node newNode)
TridentState	TridentTopology.newStaticState(StateFactory factory)
TridentState	TridentTopology.newStaticState(StateSpec spec)
TridentState	TridentState.parallelismHint(int parallelism)
TridentState	Stream.partitionPersist(StateFactory stateFactory, Fields inputFields, StateUpdater updater)
TridentState	Stream.partitionPersist(StateFactory stateFactory, Fields inputFields, StateUpdater updater, Fields functionFields)
TridentState	Stream.partitionPersist(StateFactory stateFactory, StateUpdater updater)
TridentState	Stream.partitionPersist(StateFactory stateFactory, StateUpdater updater, Fields functionFields)
TridentState	Stream.partitionPersist(StateSpec stateSpec, Fields inputFields, StateUpdater updater)
TridentState	Stream.partitionPersist(StateSpec stateSpec, Fields inputFields, StateUpdater updater, Fields functionFields)
TridentState	Stream.partitionPersist(StateSpec stateSpec, StateUpdater updater)
TridentState	Stream.partitionPersist(StateSpec stateSpec, StateUpdater updater, Fields functionFields)
TridentState	Stream.persistentAggregate(StateFactory stateFactory, CombinerAggregator agg, Fields functionFields)
TridentState	Stream.persistentAggregate(StateFactory stateFactory, Fields inputFields, CombinerAggregator agg, Fields functionFields)
TridentState	Stream.persistentAggregate(StateFactory stateFactory, Fields inputFields, ReducerAggregator agg, Fields functionFields)
TridentState	Stream.persistentAggregate(StateFactory stateFactory, ReducerAggregator agg, Fields functionFields)
TridentState	Stream.persistentAggregate(StateSpec spec, CombinerAggregator agg, Fields functionFields)
TridentState	Stream.persistentAggregate(StateSpec spec, Fields inputFields, CombinerAggregator agg, Fields functionFields)
TridentState	Stream.persistentAggregate(StateSpec spec, Fields inputFields, ReducerAggregator agg, Fields functionFields)
TridentState	Stream.persistentAggregate(StateSpec spec, ReducerAggregator agg, Fields functionFields)
TridentState	TridentState.setCPULoad(Number load)
TridentState	TridentState.setMemoryLoad(Number onHeap)
TridentState	TridentState.setMemoryLoad(Number onHeap, Number offHeap)

Methods in org.apache.storm.trident with parameters of type TridentState

Modifier and Type	Method and Description
Stream	Stream.stateQuery(TridentState state, Fields inputFields, QueryFunction function, Fields functionFields)
Stream	Stream.stateQuery(TridentState state, QueryFunction function, Fields functionFields)

Uses of TridentState in org.apache.storm.trident.fluent

Methods in org.apache.storm.trident.fluent that return TridentState

Modifier and Type	Method and Description
TridentState	GroupedStream.persistentAggregate(StateFactory stateFactory, CombinerAggregator agg, Fields functionFields)
TridentState	GroupedStream.persistentAggregate(StateFactory stateFactory, Fields inputFields, CombinerAggregator agg, Fields functionFields)
TridentState	GroupedStream.persistentAggregate(StateFactory stateFactory, Fields inputFields, ReducerAggregator agg, Fields functionFields)
TridentState	GroupedStream.persistentAggregate(StateFactory stateFactory, ReducerAggregator agg, Fields functionFields)
TridentState	GroupedStream.persistentAggregate(StateSpec spec, CombinerAggregator agg, Fields functionFields)
TridentState	GroupedStream.persistentAggregate(StateSpec spec, Fields inputFields, CombinerAggregator agg, Fields functionFields)
TridentState	GroupedStream.persistentAggregate(StateSpec spec, Fields inputFields, ReducerAggregator agg, Fields functionFields)
TridentState	GroupedStream.persistentAggregate(StateSpec spec, ReducerAggregator agg, Fields functionFields)

Methods in org.apache.storm.trident.fluent with parameters of type TridentState

Modifier and Type	Method and Description
Stream	GroupedStream.stateQuery(TridentState state, Fields inputFields, QueryFunction function, Fields functionFields)
Stream	GroupedStream.stateQuery(TridentState state, QueryFunction function, Fields functionFields)