org.apache.storm.kafka.trident

Class TridentKafkaState

java.lang.Object

org.apache.storm.kafka.trident.TridentKafkaState

All Implemented Interfaces:

State

Deprecated.

storm-kafka has been deprecated and will be removed in a future Storm release. Please upgrade to storm-kafka-client.

@Deprecated
public class TridentKafkaState
extends Object
implements State

Constructor Summary

Constructors

Constructor and Description
TridentKafkaState() Deprecated.

Method Summary

Modifier and Type	Method and Description
void	beginCommit(Long txid) Deprecated.
void	commit(Long txid) Deprecated.
void	prepare(Properties options) Deprecated.
void	updateState(List<TridentTuple> tuples, TridentCollector collector) Deprecated.
TridentKafkaState	withKafkaTopicSelector(KafkaTopicSelector selector) Deprecated.
TridentKafkaState	withTridentTupleToKafkaMapper(TridentTupleToKafkaMapper mapper) Deprecated.

Methods inherited from class java.lang.Object

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

Constructor Detail

TridentKafkaState

public TridentKafkaState()

Deprecated.

Method Detail

withTridentTupleToKafkaMapper

public TridentKafkaState withTridentTupleToKafkaMapper(TridentTupleToKafkaMapper mapper)

Deprecated.

withKafkaTopicSelector

public TridentKafkaState withKafkaTopicSelector(KafkaTopicSelector selector)

Deprecated.

beginCommit

public void beginCommit(Long txid)

Deprecated.

Specified by:

beginCommit in interface State

commit

public void commit(Long txid)

Deprecated.

Specified by:

commit in interface State

prepare

public void prepare(Properties options)

Deprecated.

updateState

public void updateState(List<TridentTuple> tuples,
                        TridentCollector collector)

Deprecated.