Uses of Class
org.apache.storm.kafka.trident.TridentKafkaState

Packages that use TridentKafkaState

Package	Description
org.apache.storm.kafka.trident

Uses of TridentKafkaState in org.apache.storm.kafka.trident

Methods in org.apache.storm.kafka.trident that return TridentKafkaState

Modifier and Type	Method	Description
TridentKafkaState<K,V>	TridentKafkaState.withKafkaTopicSelector(KafkaTopicSelector selector)
TridentKafkaState<K,V>	TridentKafkaState.withTridentTupleToKafkaMapper(TridentTupleToKafkaMapper<K,V> mapper)

Methods in org.apache.storm.kafka.trident with parameters of type TridentKafkaState

Modifier and Type	Method	Description
void	TridentKafkaStateUpdater.updateState(TridentKafkaState<K,V> state, List<TridentTuple> tuples, TridentCollector collector)