storm-python-example/topology.properties at master · randerzander/storm-python-example · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
topologyName=mtr
numWorkers=1
localMode=true

#Kill any running topology of the same name?
#killIfRunning=true

#Spouts
mtr.spoutType=KafkaSpout
mtr.topic=mtr
mtr.zk.host=n0.dev:2181

#Bolts
#hdfs.boltType=HDFSBolt
#hdfs.source=mtr
#hdfs.countSyncPolicy=1000
#hdfs.withFsUrl=hdfs://n0.dev:8020/user/dev/storm-staging
#hdfs.outDir=/user/dev/storm-staging/mtr_raw/

parse.boltType=PyBolt
parse.script=mtr-parse.py
parse.source=mtr
parse.fields=source_ip,target_ip,local_time,loss,avg_latency,stddev_latency

#hbase.boltType=HBaseBolt
#hbase.source=parse
#hbase.table=mtr
#hbase.rowKeyField=source_ip
#hbase.cf=0
#hbase.fields=source_ip,target_ip,local_time,loss,avg_latency,stddev_latency

phoenix.boltType=PhoenixBolt
phoenix.source=parse
phoenix.tables=mtr.mtr
phoenix.mtr.mtr.source=parse
phoenix.jdbcURL=jdbc:phoenix:n0.dev:2181:/hbase-unsecure
phoenix.countSynchPolicy=100