LocalALS SparkALS

BroadcastTest ExceptionHandlingTest GroupByTest HdfsTest JavaHdfsLR JavaKMeans JavaLogQuery JavaSparkPi JavaTC JavaWordCount LocalALS LocalFileLR LocalKMeans LocalLR LocalPi LogQuery MultiBroadcastTest SimpleSkewedGroupByTest SkewedGroupByTest SparkALS SparkHdfsLR SparkKMeans SparkLR SparkPi SparkTC ActorWordCount PageViewGenerator PageViewStream FeederActor FlumeEventCount HdfsWordCount JavaFlumeEventCount JavaNetworkWordCount JavaQueueStream KafkaWordCount KafkaWordCountProducer NetworkWordCount QueueStream RawNetworkGrep SimpleZeroMQPublisher StatefulNetworkWordCount TwitterAlgebirdCMS TwitterAlgebirdHLL TwitterPopularTags ZeroMQWordCount

FeederActor

Stats

examples