Apache Samza のプログラミングモデル
動かしついでに Hello Samza のソースを見てみることに。
まずは一覧。
./src/main/java/samza/examples/wikipedia/system/WikipediaConsumer.java
./src/main/java/samza/examples/wikipedia/system/WikipediaFeed.java
./src/main/java/samza/examples/wikipedia/system/WikipediaSystemAdmin.java
./src/main/java/samza/examples/wikipedia/system/WikipediaSystemFactory.java
./src/main/java/samza/examples/wikipedia/task/WikipediaFeedStreamTask.java
./src/main/java/samza/examples/wikipedia/task/WikipediaParserStreamTask.java
./src/main/java/samza/examples/wikipedia/task/WikipediaStatsStreamTask.java
中身は、、、後で。