Struct aws_sdk_kinesisanalyticsv2::types::builders::InputBuilder
source · #[non_exhaustive]pub struct InputBuilder { /* private fields */ }
Expand description
A builder for Input
.
Implementations§
source§impl InputBuilder
impl InputBuilder
sourcepub fn name_prefix(self, input: impl Into<String>) -> Self
pub fn name_prefix(self, input: impl Into<String>) -> Self
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.
sourcepub fn set_name_prefix(self, input: Option<String>) -> Self
pub fn set_name_prefix(self, input: Option<String>) -> Self
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.
sourcepub fn get_name_prefix(&self) -> &Option<String>
pub fn get_name_prefix(&self) -> &Option<String>
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.
sourcepub fn input_processing_configuration(
self,
input: InputProcessingConfiguration,
) -> Self
pub fn input_processing_configuration( self, input: InputProcessingConfiguration, ) -> Self
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
.
sourcepub fn set_input_processing_configuration(
self,
input: Option<InputProcessingConfiguration>,
) -> Self
pub fn set_input_processing_configuration( self, input: Option<InputProcessingConfiguration>, ) -> Self
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
.
sourcepub fn get_input_processing_configuration(
&self,
) -> &Option<InputProcessingConfiguration>
pub fn get_input_processing_configuration( &self, ) -> &Option<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
.
sourcepub fn kinesis_streams_input(self, input: KinesisStreamsInput) -> Self
pub fn kinesis_streams_input(self, input: KinesisStreamsInput) -> Self
If the streaming source is an Amazon Kinesis data stream, identifies the stream's Amazon Resource Name (ARN).
sourcepub fn set_kinesis_streams_input(
self,
input: Option<KinesisStreamsInput>,
) -> Self
pub fn set_kinesis_streams_input( self, input: Option<KinesisStreamsInput>, ) -> Self
If the streaming source is an Amazon Kinesis data stream, identifies the stream's Amazon Resource Name (ARN).
sourcepub fn get_kinesis_streams_input(&self) -> &Option<KinesisStreamsInput>
pub fn get_kinesis_streams_input(&self) -> &Option<KinesisStreamsInput>
If the streaming source is an Amazon Kinesis data stream, identifies the stream's Amazon Resource Name (ARN).
sourcepub fn kinesis_firehose_input(self, input: KinesisFirehoseInput) -> Self
pub fn kinesis_firehose_input(self, input: KinesisFirehoseInput) -> Self
If the streaming source is an Amazon Kinesis Data Firehose delivery stream, identifies the delivery stream's ARN.
sourcepub fn set_kinesis_firehose_input(
self,
input: Option<KinesisFirehoseInput>,
) -> Self
pub fn set_kinesis_firehose_input( self, input: Option<KinesisFirehoseInput>, ) -> Self
If the streaming source is an Amazon Kinesis Data Firehose delivery stream, identifies the delivery stream's ARN.
sourcepub fn get_kinesis_firehose_input(&self) -> &Option<KinesisFirehoseInput>
pub fn get_kinesis_firehose_input(&self) -> &Option<KinesisFirehoseInput>
If the streaming source is an Amazon Kinesis Data Firehose delivery stream, identifies the delivery stream's ARN.
sourcepub fn input_parallelism(self, input: InputParallelism) -> Self
pub fn input_parallelism(self, input: InputParallelism) -> Self
Describes the number of in-application streams to create.
sourcepub fn set_input_parallelism(self, input: Option<InputParallelism>) -> Self
pub fn set_input_parallelism(self, input: Option<InputParallelism>) -> Self
Describes the number of in-application streams to create.
sourcepub fn get_input_parallelism(&self) -> &Option<InputParallelism>
pub fn get_input_parallelism(&self) -> &Option<InputParallelism>
Describes the number of in-application streams to create.
sourcepub fn input_schema(self, input: SourceSchema) -> Self
pub fn input_schema(self, input: SourceSchema) -> Self
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.
This field is required.sourcepub fn set_input_schema(self, input: Option<SourceSchema>) -> Self
pub fn set_input_schema(self, input: Option<SourceSchema>) -> Self
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.
sourcepub fn get_input_schema(&self) -> &Option<SourceSchema>
pub fn get_input_schema(&self) -> &Option<SourceSchema>
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.
Trait Implementations§
source§impl Clone for InputBuilder
impl Clone for InputBuilder
source§fn clone(&self) -> InputBuilder
fn clone(&self) -> InputBuilder
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moresource§impl Debug for InputBuilder
impl Debug for InputBuilder
source§impl Default for InputBuilder
impl Default for InputBuilder
source§fn default() -> InputBuilder
fn default() -> InputBuilder
source§impl PartialEq for InputBuilder
impl PartialEq for InputBuilder
source§fn eq(&self, other: &InputBuilder) -> bool
fn eq(&self, other: &InputBuilder) -> bool
self
and other
values to be equal, and is used
by ==
.impl StructuralPartialEq for InputBuilder
Auto Trait Implementations§
impl Freeze for InputBuilder
impl RefUnwindSafe for InputBuilder
impl Send for InputBuilder
impl Sync for InputBuilder
impl Unpin for InputBuilder
impl UnwindSafe for InputBuilder
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoEither for T
impl<T> IntoEither for T
source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moresource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read more