Package 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
    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 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.