spark
spark.examples
(object)
BroadcastTest
(object)
ExceptionHandlingTest
(object)
GroupByTest
(object)
HdfsTest
(object)
(class)
JavaHdfsLR
(object)
(class)
JavaKMeans
(object)
(class)
JavaLogQuery
(object)
(class)
JavaSparkPi
(object)
(class)
JavaTC
(object)
(class)
JavaWordCount
(object)
LocalALS
(object)
LocalFileLR
(object)
LocalKMeans
(object)
LocalLR
(object)
LocalPi
(object)
LogQuery
(object)
MultiBroadcastTest
(object)
SimpleSkewedGroupByTest
(object)
SkewedGroupByTest
(object)
SparkALS
(object)
SparkHdfsLR
(object)
SparkKMeans
(object)
SparkLR
(object)
SparkPi
(object)
SparkTC
spark.streaming
spark.streaming.examples
(object)
ActorWordCount
(object)
(class)
FeederActor
(object)
FlumeEventCount
(object)
HdfsWordCount
(object)
(class)
JavaFlumeEventCount
(object)
(class)
JavaNetworkWordCount
(object)
(class)
JavaQueueStream
(object)
KafkaWordCount
(object)
KafkaWordCountProducer
(object)
NetworkWordCount
(object)
QueueStream
(object)
RawNetworkGrep
(class)
SampleActorReceiver
(object)
SimpleZeroMQPublisher
(object)
StatefulNetworkWordCount
(case class)
SubscribeReceiver
(object)
TwitterAlgebirdCMS
(object)
TwitterAlgebirdHLL
(object)
TwitterPopularTags
(case class)
UnsubscribeReceiver
(object)
ZeroMQWordCount
spark.streaming.examples.clickstream
(object)
(class)
PageView
(object)
PageViewGenerator
(object)
PageViewStream