| Mode | Name | Size | |
|---|---|---|---|
| -rw-r--r-- | direct_kafka_wordcount.py | 2142 | logplainblame |
| -rw-r--r-- | flume_wordcount.py | 2032 | logplainblame |
| -rw-r--r-- | hdfs_wordcount.py | 1865 | logplainblame |
| -rw-r--r-- | kafka_wordcount.py | 2089 | logplainblame |
| -rw-r--r-- | mqtt_wordcount.py | 2119 | logplainblame |
| -rw-r--r-- | network_wordcount.py | 1915 | logplainblame |
| -rw-r--r-- | network_wordjoinsentiments.py | 3093 | logplainblame |
| -rw-r--r-- | queue_stream.py | 1774 | logplainblame |
| -rw-r--r-- | recoverable_network_wordcount.py | 4423 | logplainblame |
| -rw-r--r-- | sql_network_wordcount.py | 3082 | logplainblame |
| -rw-r--r-- | stateful_network_wordcount.py | 2269 | logplainblame |
 |
index : spark | |
| Mirror of Apache Spark |
| aboutsummaryrefslogtreecommitdiff |