/* * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved. * * Licensed under the Apache License, Version 2.0 (the "License"). * You may not use this file except in compliance with the License. * A copy of the License is located at * * http://aws.amazon.com/apache2.0 * * or in the "license" file accompanying this file. This file is distributed * on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either * express or implied. See the License for the specific language governing * permissions and limitations under the License. */ /* * Do not modify this file. This file is generated from the kinesisanalyticsv2-2018-05-23.normal.json service model. */ using System; using System.Collections.Generic; using System.Xml.Serialization; using System.Text; using System.IO; using System.Net; using Amazon.Runtime; using Amazon.Runtime.Internal; namespace Amazon.KinesisAnalyticsV2.Model { /// /// When you configure the application input for a SQL-based Kinesis Data Analytics application, /// you specify the streaming source, the in-application stream name that is created, /// and the mapping between the two. /// public partial class Input { private InputParallelism _inputParallelism; private InputProcessingConfiguration _inputProcessingConfiguration; private SourceSchema _inputSchema; private KinesisFirehoseInput _kinesisFirehoseInput; private KinesisStreamsInput _kinesisStreamsInput; private string _namePrefix; /// /// Gets and sets the property InputParallelism. /// /// Describes the number of in-application streams to create. /// /// public InputParallelism InputParallelism { get { return this._inputParallelism; } set { this._inputParallelism = value; } } // Check to see if InputParallelism property is set internal bool IsSetInputParallelism() { return this._inputParallelism != null; } /// /// Gets and sets the property InputProcessingConfiguration. /// /// The InputProcessingConfiguration for the input. An input processor transforms /// records as they are received from the stream, before the application's SQL code executes. /// Currently, the only input processing configuration available is InputLambdaProcessor. /// /// /// public InputProcessingConfiguration InputProcessingConfiguration { get { return this._inputProcessingConfiguration; } set { this._inputProcessingConfiguration = value; } } // Check to see if InputProcessingConfiguration property is set internal bool IsSetInputProcessingConfiguration() { return this._inputProcessingConfiguration != null; } /// /// Gets and sets the property InputSchema. /// /// Describes the format of the data in the streaming source, and how each data element /// maps to corresponding columns in the in-application stream that is being created. /// /// /// /// Also used to describe the format of the reference data source. /// /// [AWSProperty(Required=true)] public SourceSchema InputSchema { get { return this._inputSchema; } set { this._inputSchema = value; } } // Check to see if InputSchema property is set internal bool IsSetInputSchema() { return this._inputSchema != null; } /// /// Gets and sets the property KinesisFirehoseInput. /// /// If the streaming source is an Amazon Kinesis Data Firehose delivery stream, identifies /// the delivery stream's ARN. /// /// public KinesisFirehoseInput KinesisFirehoseInput { get { return this._kinesisFirehoseInput; } set { this._kinesisFirehoseInput = value; } } // Check to see if KinesisFirehoseInput property is set internal bool IsSetKinesisFirehoseInput() { return this._kinesisFirehoseInput != null; } /// /// Gets and sets the property KinesisStreamsInput. /// /// If the streaming source is an Amazon Kinesis data stream, identifies the stream's /// Amazon Resource Name (ARN). /// /// public KinesisStreamsInput KinesisStreamsInput { get { return this._kinesisStreamsInput; } set { this._kinesisStreamsInput = value; } } // Check to see if KinesisStreamsInput property is set internal bool IsSetKinesisStreamsInput() { return this._kinesisStreamsInput != null; } /// /// Gets and sets the property NamePrefix. /// /// The name prefix to use when creating an in-application stream. Suppose that you specify /// a prefix "MyInApplicationStream." Kinesis Data Analytics then creates /// one or more (as per the InputParallelism count you specified) in-application /// streams with the names "MyInApplicationStream_001," "MyInApplicationStream_002," /// and so on. /// /// [AWSProperty(Required=true, Min=1, Max=32)] public string NamePrefix { get { return this._namePrefix; } set { this._namePrefix = value; } } // Check to see if NamePrefix property is set internal bool IsSetNamePrefix() { return this._namePrefix != null; } } }