/** * 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 { /** *

Provides a description of 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 AWS Lambda.

See * Also:

AWS * API Reference

*/ class InputProcessingConfiguration { public: AWS_KINESISANALYTICS_API InputProcessingConfiguration(); AWS_KINESISANALYTICS_API InputProcessingConfiguration(Aws::Utils::Json::JsonView jsonValue); AWS_KINESISANALYTICS_API InputProcessingConfiguration& operator=(Aws::Utils::Json::JsonView jsonValue); AWS_KINESISANALYTICS_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 KinesisAnalytics } // namespace Aws