org.apache.spark.examples.streaming
Class KinesisWordProducerASL

Object
  org.apache.spark.examples.streaming.KinesisWordProducerASL

public class KinesisWordProducerASL
extends Object

Usage: KinesisWordProducerASL \

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: $ SPARK_HOME/bin/run-example streaming.KinesisWordProducerASL mySparkStream \ https://kinesis.us-east-1.amazonaws.com us-east-1 10 5

Constructor Summary

KinesisWordProducerASL()

Method Summary

static scala.collection.Seq<scala.Tuple2<String,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

KinesisWordProducerASL

public KinesisWordProducerASL()

Method Detail

main

public static void main(String[] args)

generate

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