Path	Lines of Code
README-gradle.md	29
README.md	63
gradle.properties	22
src/main/config/azure-application-local-runner.properties	26
src/main/config/azure-blob-application.properties	35
src/main/config/couchbase-table-example.properties	26
src/main/config/filter-example.properties	26
src/main/config/join-example.properties	26
src/main/config/kinesis-hello-samza.properties	49
src/main/config/remote-table-join-example.properties	26
src/main/config/session-window-example.properties	26
src/main/config/stream-table-join-example.properties	26
src/main/config/tumbling-window-example.properties	26
src/main/config/wikipedia-application-local-runner.properties	30
src/main/config/wikipedia-application.properties	38
src/main/config/wikipedia-feed.properties	28
src/main/config/wikipedia-parser.properties	26
src/main/config/wikipedia-stats.properties	46
src/main/java/samza/examples/azure/AzureApplication.java	43
src/main/java/samza/examples/azure/AzureBlobApplication.java	51
src/main/java/samza/examples/azure/AzureZKLocalApplication.java	16
src/main/java/samza/examples/azure/data/PageViewAvroRecord.java	42
src/main/java/samza/examples/cookbook/CouchbaseTableExample.java	120
src/main/java/samza/examples/cookbook/FilterExample.java	44
src/main/java/samza/examples/cookbook/JoinExample.java	90
src/main/java/samza/examples/cookbook/RemoteTableJoinExample.java	118
src/main/java/samza/examples/cookbook/SessionWindowExample.java	57
src/main/java/samza/examples/cookbook/StreamTableJoinExample.java	99
src/main/java/samza/examples/cookbook/TumblingWindowExample.java	57
src/main/java/samza/examples/cookbook/data/AdClick.java	33
src/main/java/samza/examples/cookbook/data/PageView.java	15
src/main/java/samza/examples/cookbook/data/Profile.java	12
src/main/java/samza/examples/cookbook/data/UserPageViews.java	18
src/main/java/samza/examples/kinesis/KinesisHelloSamza.java	16
src/main/java/samza/examples/sql/samza-sql-casewhen/src/main/sql/samza.sql	5
src/main/java/samza/examples/sql/samza-sql-filter/src/main/sql/samza.sql	4
src/main/java/samza/examples/sql/samza-sql-groupby/src/main/java/samza/sql/PageViewGroupByOutput.json	18
src/main/java/samza/examples/sql/samza-sql-groupby/src/main/sql/samza.sql	4
src/main/java/samza/examples/sql/samza-sql-stream-table-join/src/main/sql/samza.sql	5
src/main/java/samza/examples/wikipedia/application/WikipediaApplication.java	197
src/main/java/samza/examples/wikipedia/application/WikipediaZkLocalApplication.java	16
src/main/java/samza/examples/wikipedia/model/WikipediaParser.java	50
src/main/java/samza/examples/wikipedia/system/WikipediaConsumer.java	47
src/main/java/samza/examples/wikipedia/system/WikipediaFeed.java	254
src/main/java/samza/examples/wikipedia/system/WikipediaSystemFactory.java	26
src/main/java/samza/examples/wikipedia/system/descriptors/WikipediaInputDescriptor.java	16
src/main/java/samza/examples/wikipedia/system/descriptors/WikipediaSystemDescriptor.java	27
src/main/java/samza/examples/wikipedia/task/WikipediaFeedStreamTask.java	17
src/main/java/samza/examples/wikipedia/task/WikipediaParserStreamTask.java	29
src/main/java/samza/examples/wikipedia/task/WikipediaStatsStreamTask.java	63
src/main/java/samza/examples/wikipedia/task/application/WikipediaFeedTaskApplication.java	41
src/main/java/samza/examples/wikipedia/task/application/WikipediaParserTaskApplication.java	33
src/main/java/samza/examples/wikipedia/task/application/WikipediaStatsTaskApplication.java	31
src/test/java/samza/examples/cookbook/test/TestSamzaCookBookExamples.java	123
src/test/java/samza/examples/test/utils/TestUtils.java	65
src/test/java/samza/examples/wikipedia/application/test/TestWikipediaApplication.java	47
src/test/java/samza/examples/wikipedia/task/test/TestWikipediaTask.java	42
src/test/resources/WikinewsEditEvents.txt	104
src/test/resources/WikipediaEditEvents.txt	882
src/test/resources/WikitionaryEditEvents.txt	9
wikipedia-raw.json	1000