public class PirkTopology
extends java.lang.Object
| Constructor and Description |
|---|
PirkTopology() |
| Modifier and Type | Method and Description |
|---|---|
static org.apache.storm.Config |
createStormConf() |
static org.apache.storm.generated.StormTopology |
getPirkTopology(org.apache.storm.kafka.SpoutConfig kafkaConfig)
Creates Pirk topology: KafkaSpout -> PartitionDataBolt -> EncRowCalcBolt -> EncColMultBolt -> OutputBolt Requires KafkaConfig to initialize KafkaSpout.
|
static void |
runPirkTopology() |
public static void runPirkTopology()
throws PIRException
PIRExceptionpublic static org.apache.storm.generated.StormTopology getPirkTopology(org.apache.storm.kafka.SpoutConfig kafkaConfig)
kafkaConfig - public static org.apache.storm.Config createStormConf()