storm-sample:在 Hortonworks HDP 中构建风暴拓扑的示例代码-源码

[{"title":"（ 23 个子文件 38KB ） storm-sample:在 Hortonworks HDP 中构建风暴拓扑的示例代码-源码","children":[{"title":"storm-sample-master","children":[{"title":".gitignore <span style='color:#111;'> 7B </span>","children":null,"spread":false},{"title":"src","children":[{"title":"main","children":[{"title":"resources","children":[{"title":"config.properties <span style='color:#111;'> 1.47KB </span>","children":null,"spread":false},{"title":"hbase-site.xml <span style='color:#111;'> 4.43KB </span>","children":null,"spread":false},{"title":"jms-activemq.xml <span style='color:#111;'> 1.40KB </span>","children":null,"spread":false},{"title":"log4j.xml <span style='color:#111;'> 1.18KB </span>","children":null,"spread":false}],"spread":true},{"title":"java","children":[{"title":"com","children":[{"title":"hortonworks","children":[{"title":"streaming","children":[{"title":"impl","children":[{"title":"topologies","children":[{"title":"BaseTruckEventTopology.java <span style='color:#111;'> 875B </span>","children":null,"spread":false},{"title":"TruckEventProcessorKafkaTopology.java <span style='color:#111;'> 8.78KB </span>","children":null,"spread":false}],"spread":true},{"title":"TruckEventRuleEngine.java <span style='color:#111;'> 6.79KB </span>","children":null,"spread":false},{"title":"bolts","children":[{"title":"WebSocketBoltOld.java <span style='color:#111;'> 5.65KB </span>","children":null,"spread":false},{"title":"solr","children":[{"title":"TruckEvent.java <span style='color:#111;'> 2.76KB </span>","children":null,"spread":false},{"title":"SolrIndexingBolt.java <span style='color:#111;'> 3.88KB </span>","children":null,"spread":false}],"spread":false},{"title":"WebSocketBolt.java <span style='color:#111;'> 5.83KB </span>","children":null,"spread":false},{"title":"hive","children":[{"title":"HiveTablePartitionAction.java <span style='color:#111;'> 4.42KB </span>","children":null,"spread":false},{"title":"BackupHiveTablePartitionAction.java <span style='color:#111;'> 4.18KB </span>","children":null,"spread":false}],"spread":false},{"title":"TruckEventRuleBolt.java <span style='color:#111;'> 2.26KB </span>","children":null,"spread":false},{"title":"TruckHBaseBolt.java <span style='color:#111;'> 8.41KB </span>","children":null,"spread":false},{"title":"hdfs","children":[{"title":"FileTimeRotationPolicy.java <span style='color:#111;'> 1.68KB </span>","children":null,"spread":false}],"spread":false},{"title":"TruckPhoenixHBaseBolt.java <span style='color:#111;'> 8.32KB </span>","children":null,"spread":false}],"spread":true},{"title":"utils","children":[{"title":"EventMailer.java <span style='color:#111;'> 1.01KB </span>","children":null,"spread":false}],"spread":true},{"title":"kafka","children":[{"title":"TruckScheme2.java <span style='color:#111;'> 1.98KB </span>","children":null,"spread":false}],"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"LICENSE <span style='color:#111;'> 11.06KB </span>","children":null,"spread":false},{"title":"pom.xml <span style='color:#111;'> 8.57KB </span>","children":null,"spread":false},{"title":"README.md <span style='color:#111;'> 1.21KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}]