org.apache.spark.streaming.kinesis

Class KinesisInitialPositions

Object

org.apache.spark.streaming.kinesis.KinesisInitialPositions

public class KinesisInitialPositions
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	KinesisInitialPositions.AtTimestamp
static class	KinesisInitialPositions.Latest
static class	KinesisInitialPositions.TrimHorizon

Constructor Summary

Constructors

Constructor and Description
KinesisInitialPositions()

Method Summary

Modifier and Type	Method and Description
static org.apache.spark.streaming.kinesis.KinesisInitialPosition	fromKinesisInitialPosition(com.amazonaws.services.kinesis.clientlibrary.lib.worker.InitialPositionInStream initialPositionInStream) Returns instance of [[KinesisInitialPosition]] based on the passed [[InitialPositionInStream]].

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KinesisInitialPositions

public KinesisInitialPositions()

Method Detail

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