@Generated(value="com.amazonaws:aws-java-sdk-code-generator") public class InputDescription extends Object implements Serializable, Cloneable, StructuredPojo
Describes the application input configuration for a SQL-based Kinesis Data Analytics application.
Constructor and Description |
---|
InputDescription() |
Modifier and Type | Method and Description |
---|---|
InputDescription |
clone() |
boolean |
equals(Object obj) |
List<String> |
getInAppStreamNames()
Returns the in-application stream names that are mapped to the stream source.
|
String |
getInputId()
The input ID that is associated with the application input.
|
InputParallelism |
getInputParallelism()
Describes the configured parallelism (number of in-application streams mapped to the streaming source).
|
InputProcessingConfigurationDescription |
getInputProcessingConfigurationDescription()
The description of the preprocessor that executes on records in this input before the application's code is run.
|
SourceSchema |
getInputSchema()
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.
|
InputStartingPositionConfiguration |
getInputStartingPositionConfiguration()
The point at which the application is configured to read from the input stream.
|
KinesisFirehoseInputDescription |
getKinesisFirehoseInputDescription()
If a Kinesis Data Firehose delivery stream is configured as a streaming source, provides the delivery stream's
ARN.
|
KinesisStreamsInputDescription |
getKinesisStreamsInputDescription()
If a Kinesis data stream is configured as a streaming source, provides the Kinesis data stream's Amazon Resource
Name (ARN).
|
String |
getNamePrefix()
The in-application name prefix.
|
int |
hashCode() |
void |
marshall(ProtocolMarshaller protocolMarshaller)
Marshalls this structured data using the given
ProtocolMarshaller . |
void |
setInAppStreamNames(Collection<String> inAppStreamNames)
Returns the in-application stream names that are mapped to the stream source.
|
void |
setInputId(String inputId)
The input ID that is associated with the application input.
|
void |
setInputParallelism(InputParallelism inputParallelism)
Describes the configured parallelism (number of in-application streams mapped to the streaming source).
|
void |
setInputProcessingConfigurationDescription(InputProcessingConfigurationDescription inputProcessingConfigurationDescription)
The description of the preprocessor that executes on records in this input before the application's code is run.
|
void |
setInputSchema(SourceSchema 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.
|
void |
setInputStartingPositionConfiguration(InputStartingPositionConfiguration inputStartingPositionConfiguration)
The point at which the application is configured to read from the input stream.
|
void |
setKinesisFirehoseInputDescription(KinesisFirehoseInputDescription kinesisFirehoseInputDescription)
If a Kinesis Data Firehose delivery stream is configured as a streaming source, provides the delivery stream's
ARN.
|
void |
setKinesisStreamsInputDescription(KinesisStreamsInputDescription kinesisStreamsInputDescription)
If a Kinesis data stream is configured as a streaming source, provides the Kinesis data stream's Amazon Resource
Name (ARN).
|
void |
setNamePrefix(String namePrefix)
The in-application name prefix.
|
String |
toString()
Returns a string representation of this object.
|
InputDescription |
withInAppStreamNames(Collection<String> inAppStreamNames)
Returns the in-application stream names that are mapped to the stream source.
|
InputDescription |
withInAppStreamNames(String... inAppStreamNames)
Returns the in-application stream names that are mapped to the stream source.
|
InputDescription |
withInputId(String inputId)
The input ID that is associated with the application input.
|
InputDescription |
withInputParallelism(InputParallelism inputParallelism)
Describes the configured parallelism (number of in-application streams mapped to the streaming source).
|
InputDescription |
withInputProcessingConfigurationDescription(InputProcessingConfigurationDescription inputProcessingConfigurationDescription)
The description of the preprocessor that executes on records in this input before the application's code is run.
|
InputDescription |
withInputSchema(SourceSchema 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.
|
InputDescription |
withInputStartingPositionConfiguration(InputStartingPositionConfiguration inputStartingPositionConfiguration)
The point at which the application is configured to read from the input stream.
|
InputDescription |
withKinesisFirehoseInputDescription(KinesisFirehoseInputDescription kinesisFirehoseInputDescription)
If a Kinesis Data Firehose delivery stream is configured as a streaming source, provides the delivery stream's
ARN.
|
InputDescription |
withKinesisStreamsInputDescription(KinesisStreamsInputDescription kinesisStreamsInputDescription)
If a Kinesis data stream is configured as a streaming source, provides the Kinesis data stream's Amazon Resource
Name (ARN).
|
InputDescription |
withNamePrefix(String namePrefix)
The in-application name prefix.
|
public void setInputId(String inputId)
The input ID that is associated with the application input. This is the ID that Kinesis Data Analytics assigns to each input configuration that you add to your application.
inputId
- The input ID that is associated with the application input. This is the ID that Kinesis Data Analytics
assigns to each input configuration that you add to your application.public String getInputId()
The input ID that is associated with the application input. This is the ID that Kinesis Data Analytics assigns to each input configuration that you add to your application.
public InputDescription withInputId(String inputId)
The input ID that is associated with the application input. This is the ID that Kinesis Data Analytics assigns to each input configuration that you add to your application.
inputId
- The input ID that is associated with the application input. This is the ID that Kinesis Data Analytics
assigns to each input configuration that you add to your application.public void setNamePrefix(String namePrefix)
The in-application name prefix.
namePrefix
- The in-application name prefix.public String getNamePrefix()
The in-application name prefix.
public InputDescription withNamePrefix(String namePrefix)
The in-application name prefix.
namePrefix
- The in-application name prefix.public List<String> getInAppStreamNames()
Returns the in-application stream names that are mapped to the stream source.
public void setInAppStreamNames(Collection<String> inAppStreamNames)
Returns the in-application stream names that are mapped to the stream source.
inAppStreamNames
- Returns the in-application stream names that are mapped to the stream source.public InputDescription withInAppStreamNames(String... inAppStreamNames)
Returns the in-application stream names that are mapped to the stream source.
NOTE: This method appends the values to the existing list (if any). Use
setInAppStreamNames(java.util.Collection)
or withInAppStreamNames(java.util.Collection)
if you
want to override the existing values.
inAppStreamNames
- Returns the in-application stream names that are mapped to the stream source.public InputDescription withInAppStreamNames(Collection<String> inAppStreamNames)
Returns the in-application stream names that are mapped to the stream source.
inAppStreamNames
- Returns the in-application stream names that are mapped to the stream source.public void setInputProcessingConfigurationDescription(InputProcessingConfigurationDescription inputProcessingConfigurationDescription)
The description of the preprocessor that executes on records in this input before the application's code is run.
inputProcessingConfigurationDescription
- The description of the preprocessor that executes on records in this input before the application's code
is run.public InputProcessingConfigurationDescription getInputProcessingConfigurationDescription()
The description of the preprocessor that executes on records in this input before the application's code is run.
public InputDescription withInputProcessingConfigurationDescription(InputProcessingConfigurationDescription inputProcessingConfigurationDescription)
The description of the preprocessor that executes on records in this input before the application's code is run.
inputProcessingConfigurationDescription
- The description of the preprocessor that executes on records in this input before the application's code
is run.public void setKinesisStreamsInputDescription(KinesisStreamsInputDescription kinesisStreamsInputDescription)
If a Kinesis data stream is configured as a streaming source, provides the Kinesis data stream's Amazon Resource Name (ARN).
kinesisStreamsInputDescription
- If a Kinesis data stream is configured as a streaming source, provides the Kinesis data stream's Amazon
Resource Name (ARN).public KinesisStreamsInputDescription getKinesisStreamsInputDescription()
If a Kinesis data stream is configured as a streaming source, provides the Kinesis data stream's Amazon Resource Name (ARN).
public InputDescription withKinesisStreamsInputDescription(KinesisStreamsInputDescription kinesisStreamsInputDescription)
If a Kinesis data stream is configured as a streaming source, provides the Kinesis data stream's Amazon Resource Name (ARN).
kinesisStreamsInputDescription
- If a Kinesis data stream is configured as a streaming source, provides the Kinesis data stream's Amazon
Resource Name (ARN).public void setKinesisFirehoseInputDescription(KinesisFirehoseInputDescription kinesisFirehoseInputDescription)
If a Kinesis Data Firehose delivery stream is configured as a streaming source, provides the delivery stream's ARN.
kinesisFirehoseInputDescription
- If a Kinesis Data Firehose delivery stream is configured as a streaming source, provides the delivery
stream's ARN.public KinesisFirehoseInputDescription getKinesisFirehoseInputDescription()
If a Kinesis Data Firehose delivery stream is configured as a streaming source, provides the delivery stream's ARN.
public InputDescription withKinesisFirehoseInputDescription(KinesisFirehoseInputDescription kinesisFirehoseInputDescription)
If a Kinesis Data Firehose delivery stream is configured as a streaming source, provides the delivery stream's ARN.
kinesisFirehoseInputDescription
- If a Kinesis Data Firehose delivery stream is configured as a streaming source, provides the delivery
stream's ARN.public void setInputSchema(SourceSchema 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.
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.public SourceSchema getInputSchema()
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.
public InputDescription withInputSchema(SourceSchema 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.
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.public void setInputParallelism(InputParallelism inputParallelism)
Describes the configured parallelism (number of in-application streams mapped to the streaming source).
inputParallelism
- Describes the configured parallelism (number of in-application streams mapped to the streaming source).public InputParallelism getInputParallelism()
Describes the configured parallelism (number of in-application streams mapped to the streaming source).
public InputDescription withInputParallelism(InputParallelism inputParallelism)
Describes the configured parallelism (number of in-application streams mapped to the streaming source).
inputParallelism
- Describes the configured parallelism (number of in-application streams mapped to the streaming source).public void setInputStartingPositionConfiguration(InputStartingPositionConfiguration inputStartingPositionConfiguration)
The point at which the application is configured to read from the input stream.
inputStartingPositionConfiguration
- The point at which the application is configured to read from the input stream.public InputStartingPositionConfiguration getInputStartingPositionConfiguration()
The point at which the application is configured to read from the input stream.
public InputDescription withInputStartingPositionConfiguration(InputStartingPositionConfiguration inputStartingPositionConfiguration)
The point at which the application is configured to read from the input stream.
inputStartingPositionConfiguration
- The point at which the application is configured to read from the input stream.public String toString()
toString
in class Object
Object.toString()
public InputDescription clone()
public void marshall(ProtocolMarshaller protocolMarshaller)
StructuredPojo
ProtocolMarshaller
.marshall
in interface StructuredPojo
protocolMarshaller
- Implementation of ProtocolMarshaller
used to marshall this object's data.