org.apache.storm.kafka.trident

Class TridentKafkaEmitter

java.lang.Object

org.apache.storm.kafka.trident.TridentKafkaEmitter

public class TridentKafkaEmitter
extends Object

Constructor Summary

Constructors

Constructor and Description
TridentKafkaEmitter(Map conf, TopologyContext context, TridentKafkaConfig config, String topologyInstanceId)

Method Summary

Modifier and Type	Method and Description
IOpaquePartitionedTridentSpout.Emitter<List<GlobalPartitionInformation>,Partition,Map>	asOpaqueEmitter()
IPartitionedTridentSpout.Emitter	asTransactionalEmitter()

Methods inherited from class java.lang.Object

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

Constructor Detail

TridentKafkaEmitter

public TridentKafkaEmitter(Map conf,
                           TopologyContext context,
                           TridentKafkaConfig config,
                           String topologyInstanceId)

Method Detail

asOpaqueEmitter

public IOpaquePartitionedTridentSpout.Emitter<List<GlobalPartitionInformation>,Partition,Map> asOpaqueEmitter()

asTransactionalEmitter

public IPartitionedTridentSpout.Emitter asTransactionalEmitter()