/* * 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 kinesisanalytics-2015-08-14.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.KinesisAnalytics.Model { /// /// When you configure the application input, you specify the streaming source, the in-application /// stream name that is created, and the mapping between the two. For more information, /// see Configuring /// Application Input. /// 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. /// /// /// /// Data from your source is routed to these in-application input streams. /// /// /// /// (see Configuring /// Application Input. /// /// 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 Firehose delivery stream, identifies /// the delivery stream's ARN and an IAM role that enables Amazon Kinesis Analytics to /// access the stream on your behalf. /// /// /// /// Note: Either KinesisStreamsInput or KinesisFirehoseInput /// is required. /// /// 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 stream, identifies the stream's Amazon /// Resource Name (ARN) and an IAM role that enables Amazon Kinesis Analytics to access /// the stream on your behalf. /// /// /// /// Note: Either KinesisStreamsInput or KinesisFirehoseInput /// is required. /// /// 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. /// /// Name prefix to use when creating an in-application stream. Suppose that you specify /// a prefix "MyInApplicationStream." Amazon Kinesis Analytics then creates one or more /// (as per the InputParallelism count you specified) in-application streams /// with 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; } } }