org.apache.spark.streaming.kinesis

Interface KinesisDataGenerator

public interface KinesisDataGenerator

A wrapper interface that will allow us to consolidate the code for synthetic data generation.

Method Summary

Modifier and Type	Method and Description
scala.collection.immutable.Map<String,scala.collection.Seq<scala.Tuple2<Object,String>>>	sendData(String streamName, scala.collection.Seq<Object> data) Sends the data to Kinesis and returns the metadata for everything that has been sent.

Method Detail

sendData

scala.collection.immutable.Map<String,scala.collection.Seq<scala.Tuple2<Object,String>>> sendData(String streamName,
                                                                                                  scala.collection.Seq<Object> data)

Sends the data to Kinesis and returns the metadata for everything that has been sent.