Class KinesisInitialPositions

Object
org.apache.spark.streaming.kinesis.KinesisInitialPositions

public class KinesisInitialPositions extends Object
  • Constructor Details

    • KinesisInitialPositions

      public KinesisInitialPositions()
  • Method Details

    • fromKinesisInitialPosition

      public static org.apache.spark.streaming.kinesis.KinesisInitialPosition fromKinesisInitialPosition(com.amazonaws.services.kinesis.clientlibrary.lib.worker.InitialPositionInStream initialPositionInStream) throws UnsupportedOperationException
      Returns instance of [[KinesisInitialPosition]] based on the passed [[InitialPositionInStream]]. This method is used in KinesisUtils for translating the InitialPositionInStream to InitialPosition. This function would be removed when we deprecate the KinesisUtils.
      Returns:
      [[InitialPosition]]
      Throws:
      UnsupportedOperationException