/*
* 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;
}
}
}