/** * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved. * SPDX-License-Identifier: Apache-2.0. */ #pragma once #include #include #include namespace Aws { namespace Utils { namespace Json { class JsonValue; class JsonView; } // namespace Json } // namespace Utils namespace KinesisAnalytics { namespace Model { /** *

Describes the point at which the application reads from the streaming * source.

See Also:

AWS * API Reference

*/ class InputStartingPositionConfiguration { public: AWS_KINESISANALYTICS_API InputStartingPositionConfiguration(); AWS_KINESISANALYTICS_API InputStartingPositionConfiguration(Aws::Utils::Json::JsonView jsonValue); AWS_KINESISANALYTICS_API InputStartingPositionConfiguration& operator=(Aws::Utils::Json::JsonView jsonValue); AWS_KINESISANALYTICS_API Aws::Utils::Json::JsonValue Jsonize() const; /** *

The starting position on the stream.

  • NOW - * Start reading just after the most recent record in the stream, start at the * request time stamp that the customer issued.

  • * TRIM_HORIZON - Start reading at the last untrimmed record in the * stream, which is the oldest record available in the stream. This option is not * available for an Amazon Kinesis Firehose delivery stream.

  • * LAST_STOPPED_POINT - Resume reading from where the application last * stopped reading.

*/ inline const InputStartingPosition& GetInputStartingPosition() const{ return m_inputStartingPosition; } /** *

The starting position on the stream.

  • NOW - * Start reading just after the most recent record in the stream, start at the * request time stamp that the customer issued.

  • * TRIM_HORIZON - Start reading at the last untrimmed record in the * stream, which is the oldest record available in the stream. This option is not * available for an Amazon Kinesis Firehose delivery stream.

  • * LAST_STOPPED_POINT - Resume reading from where the application last * stopped reading.

*/ inline bool InputStartingPositionHasBeenSet() const { return m_inputStartingPositionHasBeenSet; } /** *

The starting position on the stream.

  • NOW - * Start reading just after the most recent record in the stream, start at the * request time stamp that the customer issued.

  • * TRIM_HORIZON - Start reading at the last untrimmed record in the * stream, which is the oldest record available in the stream. This option is not * available for an Amazon Kinesis Firehose delivery stream.

  • * LAST_STOPPED_POINT - Resume reading from where the application last * stopped reading.

*/ inline void SetInputStartingPosition(const InputStartingPosition& value) { m_inputStartingPositionHasBeenSet = true; m_inputStartingPosition = value; } /** *

The starting position on the stream.

  • NOW - * Start reading just after the most recent record in the stream, start at the * request time stamp that the customer issued.

  • * TRIM_HORIZON - Start reading at the last untrimmed record in the * stream, which is the oldest record available in the stream. This option is not * available for an Amazon Kinesis Firehose delivery stream.

  • * LAST_STOPPED_POINT - Resume reading from where the application last * stopped reading.

*/ inline void SetInputStartingPosition(InputStartingPosition&& value) { m_inputStartingPositionHasBeenSet = true; m_inputStartingPosition = std::move(value); } /** *

The starting position on the stream.

  • NOW - * Start reading just after the most recent record in the stream, start at the * request time stamp that the customer issued.

  • * TRIM_HORIZON - Start reading at the last untrimmed record in the * stream, which is the oldest record available in the stream. This option is not * available for an Amazon Kinesis Firehose delivery stream.

  • * LAST_STOPPED_POINT - Resume reading from where the application last * stopped reading.

*/ inline InputStartingPositionConfiguration& WithInputStartingPosition(const InputStartingPosition& value) { SetInputStartingPosition(value); return *this;} /** *

The starting position on the stream.

  • NOW - * Start reading just after the most recent record in the stream, start at the * request time stamp that the customer issued.

  • * TRIM_HORIZON - Start reading at the last untrimmed record in the * stream, which is the oldest record available in the stream. This option is not * available for an Amazon Kinesis Firehose delivery stream.

  • * LAST_STOPPED_POINT - Resume reading from where the application last * stopped reading.

*/ inline InputStartingPositionConfiguration& WithInputStartingPosition(InputStartingPosition&& value) { SetInputStartingPosition(std::move(value)); return *this;} private: InputStartingPosition m_inputStartingPosition; bool m_inputStartingPositionHasBeenSet = false; }; } // namespace Model } // namespace KinesisAnalytics } // namespace Aws