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