/** * 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 KinesisAnalyticsV2 { namespace Model { /** *

For a SQL-based Kinesis Data Analytics application, describes a processor * that is used to preprocess the records in the stream before being processed by * your application code. Currently, the only input processor available is Amazon Lambda.

See * Also:

AWS * API Reference

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

The InputLambdaProcessor that is used to preprocess the records in the * stream before being processed by your application code.

*/ inline const InputLambdaProcessor& GetInputLambdaProcessor() const{ return m_inputLambdaProcessor; } /** *

The InputLambdaProcessor that is used to preprocess the records in the * stream before being processed by your application code.

*/ inline bool InputLambdaProcessorHasBeenSet() const { return m_inputLambdaProcessorHasBeenSet; } /** *

The InputLambdaProcessor that is used to preprocess the records in the * stream before being processed by your application code.

*/ inline void SetInputLambdaProcessor(const InputLambdaProcessor& value) { m_inputLambdaProcessorHasBeenSet = true; m_inputLambdaProcessor = value; } /** *

The InputLambdaProcessor that is used to preprocess the records in the * stream before being processed by your application code.

*/ inline void SetInputLambdaProcessor(InputLambdaProcessor&& value) { m_inputLambdaProcessorHasBeenSet = true; m_inputLambdaProcessor = std::move(value); } /** *

The InputLambdaProcessor that is used to preprocess the records in the * stream before being processed by your application code.

*/ inline InputProcessingConfiguration& WithInputLambdaProcessor(const InputLambdaProcessor& value) { SetInputLambdaProcessor(value); return *this;} /** *

The InputLambdaProcessor that is used to preprocess the records in the * stream before being processed by your application code.

*/ inline InputProcessingConfiguration& WithInputLambdaProcessor(InputLambdaProcessor&& value) { SetInputLambdaProcessor(std::move(value)); return *this;} private: InputLambdaProcessor m_inputLambdaProcessor; bool m_inputLambdaProcessorHasBeenSet = false; }; } // namespace Model } // namespace KinesisAnalyticsV2 } // namespace Aws