#[non_exhaustive]pub struct InputUpdateBuilder { /* private fields */ }Expand description
A builder for InputUpdate.
Implementations§
source§impl InputUpdateBuilder
impl InputUpdateBuilder
sourcepub fn input_id(self, input: impl Into<String>) -> Self
pub fn input_id(self, input: impl Into<String>) -> Self
The input ID of the application input to be updated.
This field is required.sourcepub fn set_input_id(self, input: Option<String>) -> Self
pub fn set_input_id(self, input: Option<String>) -> Self
The input ID of the application input to be updated.
sourcepub fn get_input_id(&self) -> &Option<String>
pub fn get_input_id(&self) -> &Option<String>
The input ID of the application input to be updated.
sourcepub fn name_prefix_update(self, input: impl Into<String>) -> Self
pub fn name_prefix_update(self, input: impl Into<String>) -> Self
The name prefix for in-application streams that Kinesis Data Analytics creates for the specific streaming source.
sourcepub fn set_name_prefix_update(self, input: Option<String>) -> Self
pub fn set_name_prefix_update(self, input: Option<String>) -> Self
The name prefix for in-application streams that Kinesis Data Analytics creates for the specific streaming source.
sourcepub fn get_name_prefix_update(&self) -> &Option<String>
pub fn get_name_prefix_update(&self) -> &Option<String>
The name prefix for in-application streams that Kinesis Data Analytics creates for the specific streaming source.
sourcepub fn input_processing_configuration_update(
self,
input: InputProcessingConfigurationUpdate
) -> Self
pub fn input_processing_configuration_update( self, input: InputProcessingConfigurationUpdate ) -> Self
Describes updates to an InputProcessingConfiguration.
sourcepub fn set_input_processing_configuration_update(
self,
input: Option<InputProcessingConfigurationUpdate>
) -> Self
pub fn set_input_processing_configuration_update( self, input: Option<InputProcessingConfigurationUpdate> ) -> Self
Describes updates to an InputProcessingConfiguration.
sourcepub fn get_input_processing_configuration_update(
&self
) -> &Option<InputProcessingConfigurationUpdate>
pub fn get_input_processing_configuration_update( &self ) -> &Option<InputProcessingConfigurationUpdate>
Describes updates to an InputProcessingConfiguration.
sourcepub fn kinesis_streams_input_update(
self,
input: KinesisStreamsInputUpdate
) -> Self
pub fn kinesis_streams_input_update( self, input: KinesisStreamsInputUpdate ) -> Self
If a Kinesis data stream is the streaming source to be updated, provides an updated stream Amazon Resource Name (ARN).
sourcepub fn set_kinesis_streams_input_update(
self,
input: Option<KinesisStreamsInputUpdate>
) -> Self
pub fn set_kinesis_streams_input_update( self, input: Option<KinesisStreamsInputUpdate> ) -> Self
If a Kinesis data stream is the streaming source to be updated, provides an updated stream Amazon Resource Name (ARN).
sourcepub fn get_kinesis_streams_input_update(
&self
) -> &Option<KinesisStreamsInputUpdate>
pub fn get_kinesis_streams_input_update( &self ) -> &Option<KinesisStreamsInputUpdate>
If a Kinesis data stream is the streaming source to be updated, provides an updated stream Amazon Resource Name (ARN).
sourcepub fn kinesis_firehose_input_update(
self,
input: KinesisFirehoseInputUpdate
) -> Self
pub fn kinesis_firehose_input_update( self, input: KinesisFirehoseInputUpdate ) -> Self
If a Kinesis Data Firehose delivery stream is the streaming source to be updated, provides an updated stream ARN.
sourcepub fn set_kinesis_firehose_input_update(
self,
input: Option<KinesisFirehoseInputUpdate>
) -> Self
pub fn set_kinesis_firehose_input_update( self, input: Option<KinesisFirehoseInputUpdate> ) -> Self
If a Kinesis Data Firehose delivery stream is the streaming source to be updated, provides an updated stream ARN.
sourcepub fn get_kinesis_firehose_input_update(
&self
) -> &Option<KinesisFirehoseInputUpdate>
pub fn get_kinesis_firehose_input_update( &self ) -> &Option<KinesisFirehoseInputUpdate>
If a Kinesis Data Firehose delivery stream is the streaming source to be updated, provides an updated stream ARN.
sourcepub fn input_schema_update(self, input: InputSchemaUpdate) -> Self
pub fn input_schema_update(self, input: InputSchemaUpdate) -> Self
Describes the data format on the streaming source, and how record elements on the streaming source map to columns of the in-application stream that is created.
sourcepub fn set_input_schema_update(self, input: Option<InputSchemaUpdate>) -> Self
pub fn set_input_schema_update(self, input: Option<InputSchemaUpdate>) -> Self
Describes the data format on the streaming source, and how record elements on the streaming source map to columns of the in-application stream that is created.
sourcepub fn get_input_schema_update(&self) -> &Option<InputSchemaUpdate>
pub fn get_input_schema_update(&self) -> &Option<InputSchemaUpdate>
Describes the data format on the streaming source, and how record elements on the streaming source map to columns of the in-application stream that is created.
sourcepub fn input_parallelism_update(self, input: InputParallelismUpdate) -> Self
pub fn input_parallelism_update(self, input: InputParallelismUpdate) -> Self
Describes the parallelism updates (the number of in-application streams Kinesis Data Analytics creates for the specific streaming source).
sourcepub fn set_input_parallelism_update(
self,
input: Option<InputParallelismUpdate>
) -> Self
pub fn set_input_parallelism_update( self, input: Option<InputParallelismUpdate> ) -> Self
Describes the parallelism updates (the number of in-application streams Kinesis Data Analytics creates for the specific streaming source).
sourcepub fn get_input_parallelism_update(&self) -> &Option<InputParallelismUpdate>
pub fn get_input_parallelism_update(&self) -> &Option<InputParallelismUpdate>
Describes the parallelism updates (the number of in-application streams Kinesis Data Analytics creates for the specific streaming source).
sourcepub fn build(self) -> Result<InputUpdate, BuildError>
pub fn build(self) -> Result<InputUpdate, BuildError>
Consumes the builder and constructs a InputUpdate.
This method will fail if any of the following fields are not set:
Trait Implementations§
source§impl Clone for InputUpdateBuilder
impl Clone for InputUpdateBuilder
source§fn clone(&self) -> InputUpdateBuilder
fn clone(&self) -> InputUpdateBuilder
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moresource§impl Debug for InputUpdateBuilder
impl Debug for InputUpdateBuilder
source§impl Default for InputUpdateBuilder
impl Default for InputUpdateBuilder
source§fn default() -> InputUpdateBuilder
fn default() -> InputUpdateBuilder
source§impl PartialEq for InputUpdateBuilder
impl PartialEq for InputUpdateBuilder
source§fn eq(&self, other: &InputUpdateBuilder) -> bool
fn eq(&self, other: &InputUpdateBuilder) -> bool
self and other values to be equal, and is used
by ==.