Package 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	Description
static class	KinesisInitialPositions.AtTimestamp
static class	KinesisInitialPositions.Latest
static class	KinesisInitialPositions.TrimHorizon

Constructor Summary

Constructors

Constructor	Description
KinesisInitialPositions()

Method Summary

Modifier and Type	Method	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 java.lang.Object

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

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