org.apache.spark.examples.streaming

Class KinesisWordProducerASL

java.lang.Object

org.apache.spark.examples.streaming.KinesisWordProducerASL

public class KinesisWordProducerASL
extends java.lang.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

Constructors

Constructor and Description
KinesisWordProducerASL()

Method Summary

Methods

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

Methods inherited from class java.lang.Object

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

Constructor Detail

KinesisWordProducerASL

public KinesisWordProducerASL()

Method Detail

main

public static void main(java.lang.String[] args)

generate

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