Class KinesisInitialPositions.TrimHorizon

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

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

    • TrimHorizon

      public TrimHorizon()
  • Method Details

    • getPosition

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