public interface KinesisDataGenerator
A wrapper interface that will allow us to consolidate the code for synthetic data generation.
-
Method Summary
Sends the data to Kinesis and returns the metadata for everything that has been sent.
-
Method Details
-
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.