org.apache.storm.kafka.trident

Class TridentKafkaConsumerTopology

java.lang.Object

org.apache.storm.kafka.trident.TridentKafkaConsumerTopology

public class TridentKafkaConsumerTopology
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
TridentKafkaConsumerTopology()

Method Summary

Modifier and Type	Method and Description
static StormTopology	newTopology(ITridentDataSource tridentSpout) See newTopology(LocalDRPC, ITridentDataSource)
static StormTopology	newTopology(org.apache.storm.LocalDRPC drpc, ITridentDataSource tridentSpout)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final org.slf4j.Logger LOG

Constructor Detail

TridentKafkaConsumerTopology

public TridentKafkaConsumerTopology()

Method Detail

newTopology

public static StormTopology newTopology(ITridentDataSource tridentSpout)

See newTopology(LocalDRPC, ITridentDataSource)

newTopology

public static StormTopology newTopology(org.apache.storm.LocalDRPC drpc,
                                        ITridentDataSource tridentSpout)

Parameters:

drpc - The DRPC stream to be used in querying the word counts. Can be null in distributed mode

Returns:

a trident topology that consumes sentences from the kafka topic specified using a TransactionalTridentKafkaSpout computes the word count and stores it in a MemoryMapState.