Mode | Name | Size | |
---|---|---|---|
-rw-r--r-- | direct_kafka_wordcount.py | 2101 | logplainblame |
-rw-r--r-- | flume_wordcount.py | 2024 | logplainblame |
-rw-r--r-- | hdfs_wordcount.py | 1865 | logplainblame |
-rw-r--r-- | kafka_wordcount.py | 2081 | logplainblame |
-rw-r--r-- | network_wordcount.py | 1915 | logplainblame |
-rw-r--r-- | queue_stream.py | 1776 | logplainblame |
-rw-r--r-- | recoverable_network_wordcount.py | 3348 | logplainblame |
-rw-r--r-- | sql_network_wordcount.py | 3092 | logplainblame |
-rw-r--r-- | stateful_network_wordcount.py | 2123 | logplainblame |