storm.kafka.trident
Class TridentKafkaEmitter

java.lang.Object
  extended by storm.kafka.trident.TridentKafkaEmitter

public class TridentKafkaEmitter
extends Object


Field Summary
static org.slf4j.Logger LOG
           
 
Constructor Summary
TridentKafkaEmitter(Map conf, TopologyContext context, TridentKafkaConfig config, String topologyInstanceId)
           
 
Method Summary
 IOpaquePartitionedTridentSpout.Emitter<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
 

Field Detail

LOG

public static final org.slf4j.Logger LOG
Constructor Detail

TridentKafkaEmitter

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

asOpaqueEmitter

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

asTransactionalEmitter

public IPartitionedTridentSpout.Emitter asTransactionalEmitter()


Copyright © 2016 The Apache Software Foundation. All Rights Reserved.