通過TopologyBuilder建立topology。 使用Storm Submitter，將topology遞交給集群。以topology的名字、配置和topology的對象作為參數(shù)。 提交topology。 Listing Eight：建立和執(zhí)行topology。
- public class StormMain
- {
- public static void main(String[] args) throws AlreadyAliveException,
- InvalidTopologyException,
- InterruptedException
-
44/47 首頁 上一頁 42 43 44 45 46 47 下一頁 尾頁
