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
PIRException
public static org.apache.storm.generated.StormTopology getPirkTopology(org.apache.storm.kafka.SpoutConfig kafkaConfig)
kafkaConfig
- public static org.apache.storm.Config createStormConf()