Class KinesisInitialPositions.AtTimestamp

Object
org.apache.spark.streaming.kinesis.KinesisInitialPositions.AtTimestamp
All Implemented Interfaces:
Serializable
Enclosing class:
KinesisInitialPositions

public static class KinesisInitialPositions.AtTimestamp extends Object implements Serializable
See Also:
  • Constructor Details

    • AtTimestamp

      public AtTimestamp(Date timestamp)
  • Method Details

    • getPosition

      public com.amazonaws.services.kinesis.clientlibrary.lib.worker.InitialPositionInStream getPosition()
    • getTimestamp

      public Date getTimestamp()