org.apache.spark.examples.streaming

Class KinesisWordCountProducerASL

Object

org.apache.spark.examples.streaming.KinesisWordCountProducerASL

public class KinesisWordCountProducerASL
extends Object

Usage: KinesisWordCountProducerASL is the name of the Kinesis stream (ie. mySparkStream) is the endpoint of the Kinesis service (ie. https://kinesis.us-east-1.amazonaws.com) is the rate of records per second to put onto the stream is the rate of records per second to put onto the stream

Example: $ export AWS_ACCESS_KEY_ID= $ export AWS_SECRET_KEY= $ $SPARK_HOME/bin/run-example \ org.apache.spark.examples.streaming.KinesisWordCountProducerASL mySparkStream \ https://kinesis.us-east-1.amazonaws.com 10 5

Constructor Summary

Constructors

Constructor and Description
KinesisWordCountProducerASL()

Method Summary

Methods

Modifier and Type	Method and Description
static scala.collection.Seq<scala.Tuple2<Object,Object>>	generate(String stream, String endpoint, int recordsPerSecond, int wordsPerRecord)
static void	main(String[] args)

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KinesisWordCountProducerASL

public KinesisWordCountProducerASL()

Method Detail

main

public static void main(String[] args)

generate

public static scala.collection.Seq<scala.Tuple2<Object,Object>> generate(String stream,
                                                         String endpoint,
                                                         int recordsPerSecond,
                                                         int wordsPerRecord)