org.apache.storm.kafka.trident

Class OpaqueTridentKafkaSpout

java.lang.Object

org.apache.storm.kafka.trident.OpaqueTridentKafkaSpout

All Implemented Interfaces:

Serializable, IOpaquePartitionedTridentSpout<List<GlobalPartitionInformation>,Partition,Map>, ITridentDataSource

Deprecated.

storm-kafka has been deprecated and will be removed in a future Storm release. Please upgrade to storm-kafka-client. If you need to migrate the committed offsets to the new spout, consider using the storm-kafka-migration tool.

@Deprecated
public class OpaqueTridentKafkaSpout
extends Object
implements IOpaquePartitionedTridentSpout<List<GlobalPartitionInformation>,Partition,Map>

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.storm.trident.spout.IOpaquePartitionedTridentSpout

IOpaquePartitionedTridentSpout.Coordinator<Partitions>, IOpaquePartitionedTridentSpout.Emitter<Partitions,Partition extends ISpoutPartition,M>

Constructor Summary

Constructors

Constructor and Description
OpaqueTridentKafkaSpout(TridentKafkaConfig config) Deprecated.

Method Summary

Modifier and Type	Method and Description
Map<String,Object>	getComponentConfiguration() Deprecated.
IOpaquePartitionedTridentSpout.Coordinator	getCoordinator(Map conf, TopologyContext tc) Deprecated.
IOpaquePartitionedTridentSpout.Emitter<List<GlobalPartitionInformation>,Partition,Map>	getEmitter(Map conf, TopologyContext context) Deprecated.
Fields	getOutputFields() Deprecated.

Methods inherited from class java.lang.Object

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

Constructor Detail

OpaqueTridentKafkaSpout

public OpaqueTridentKafkaSpout(TridentKafkaConfig config)

Deprecated.

Method Detail

getEmitter

public IOpaquePartitionedTridentSpout.Emitter<List<GlobalPartitionInformation>,Partition,Map> getEmitter(Map conf,
                                                                                                         TopologyContext context)

Deprecated.

Specified by:

getEmitter in interface IOpaquePartitionedTridentSpout<List<GlobalPartitionInformation>,Partition,Map>

getCoordinator

public IOpaquePartitionedTridentSpout.Coordinator getCoordinator(Map conf,
                                                                 TopologyContext tc)

Deprecated.

Specified by:

getCoordinator in interface IOpaquePartitionedTridentSpout<List<GlobalPartitionInformation>,Partition,Map>

getOutputFields

public Fields getOutputFields()

Deprecated.

Specified by:

getOutputFields in interface IOpaquePartitionedTridentSpout<List<GlobalPartitionInformation>,Partition,Map>

getComponentConfiguration

public Map<String,Object> getComponentConfiguration()

Deprecated.

Specified by:

getComponentConfiguration in interface IOpaquePartitionedTridentSpout<List<GlobalPartitionInformation>,Partition,Map>