#[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
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> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
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 moreSource§impl<T> Paint for Twhere
T: ?Sized,
impl<T> Paint for Twhere
T: ?Sized,
Source§fn fg(&self, value: Color) -> Painted<&T>
fn fg(&self, value: Color) -> Painted<&T>
Returns a styled value derived from self with the foreground set to
value.
This method should be used rarely. Instead, prefer to use color-specific
builder methods like red() and
green(), which have the same functionality but are
pithier.
§Example
Set foreground color to white using fg():
use yansi::{Paint, Color};
painted.fg(Color::White);Set foreground color to white using white().
use yansi::Paint;
painted.white();Source§fn bright_black(&self) -> Painted<&T>
fn bright_black(&self) -> Painted<&T>
Source§fn bright_red(&self) -> Painted<&T>
fn bright_red(&self) -> Painted<&T>
Source§fn bright_green(&self) -> Painted<&T>
fn bright_green(&self) -> Painted<&T>
Source§fn bright_yellow(&self) -> Painted<&T>
fn bright_yellow(&self) -> Painted<&T>
Source§fn bright_blue(&self) -> Painted<&T>
fn bright_blue(&self) -> Painted<&T>
Source§fn bright_magenta(&self) -> Painted<&T>
fn bright_magenta(&self) -> Painted<&T>
Source§fn bright_cyan(&self) -> Painted<&T>
fn bright_cyan(&self) -> Painted<&T>
Source§fn bright_white(&self) -> Painted<&T>
fn bright_white(&self) -> Painted<&T>
Source§fn bg(&self, value: Color) -> Painted<&T>
fn bg(&self, value: Color) -> Painted<&T>
Returns a styled value derived from self with the background set to
value.
This method should be used rarely. Instead, prefer to use color-specific
builder methods like on_red() and
on_green(), which have the same functionality but
are pithier.
§Example
Set background color to red using fg():
use yansi::{Paint, Color};
painted.bg(Color::Red);Set background color to red using on_red().
use yansi::Paint;
painted.on_red();Source§fn on_primary(&self) -> Painted<&T>
fn on_primary(&self) -> Painted<&T>
Source§fn on_magenta(&self) -> Painted<&T>
fn on_magenta(&self) -> Painted<&T>
Source§fn on_bright_black(&self) -> Painted<&T>
fn on_bright_black(&self) -> Painted<&T>
Source§fn on_bright_red(&self) -> Painted<&T>
fn on_bright_red(&self) -> Painted<&T>
Source§fn on_bright_green(&self) -> Painted<&T>
fn on_bright_green(&self) -> Painted<&T>
Source§fn on_bright_yellow(&self) -> Painted<&T>
fn on_bright_yellow(&self) -> Painted<&T>
Source§fn on_bright_blue(&self) -> Painted<&T>
fn on_bright_blue(&self) -> Painted<&T>
Source§fn on_bright_magenta(&self) -> Painted<&T>
fn on_bright_magenta(&self) -> Painted<&T>
Source§fn on_bright_cyan(&self) -> Painted<&T>
fn on_bright_cyan(&self) -> Painted<&T>
Source§fn on_bright_white(&self) -> Painted<&T>
fn on_bright_white(&self) -> Painted<&T>
Source§fn attr(&self, value: Attribute) -> Painted<&T>
fn attr(&self, value: Attribute) -> Painted<&T>
Enables the styling Attribute value.
This method should be used rarely. Instead, prefer to use
attribute-specific builder methods like bold() and
underline(), which have the same functionality
but are pithier.
§Example
Make text bold using attr():
use yansi::{Paint, Attribute};
painted.attr(Attribute::Bold);Make text bold using using bold().
use yansi::Paint;
painted.bold();Source§fn rapid_blink(&self) -> Painted<&T>
fn rapid_blink(&self) -> Painted<&T>
Source§fn quirk(&self, value: Quirk) -> Painted<&T>
fn quirk(&self, value: Quirk) -> Painted<&T>
Enables the yansi Quirk value.
This method should be used rarely. Instead, prefer to use quirk-specific
builder methods like mask() and
wrap(), which have the same functionality but are
pithier.
§Example
Enable wrapping using .quirk():
use yansi::{Paint, Quirk};
painted.quirk(Quirk::Wrap);Enable wrapping using wrap().
use yansi::Paint;
painted.wrap();Source§fn clear(&self) -> Painted<&T>
👎Deprecated since 1.0.1: renamed to resetting() due to conflicts with Vec::clear().
The clear() method will be removed in a future release.
fn clear(&self) -> Painted<&T>
resetting() due to conflicts with Vec::clear().
The clear() method will be removed in a future release.Source§fn whenever(&self, value: Condition) -> Painted<&T>
fn whenever(&self, value: Condition) -> Painted<&T>
Conditionally enable styling based on whether the Condition value
applies. Replaces any previous condition.
See the crate level docs for more details.
§Example
Enable styling painted only when both stdout and stderr are TTYs:
use yansi::{Paint, Condition};
painted.red().on_yellow().whenever(Condition::STDOUTERR_ARE_TTY);