Struct aws_sdk_kinesisanalytics::operation::discover_input_schema::builders::DiscoverInputSchemaOutputBuilder

#[non_exhaustive]
pub struct DiscoverInputSchemaOutputBuilder { /* private fields */ }

A builder for DiscoverInputSchemaOutput.

Implementations

impl DiscoverInputSchemaOutputBuilder

pub fn input_schema(self, input: SourceSchema) -> Self

Schema inferred from the streaming source. It identifies the format of the data in the streaming source and how each data element maps to corresponding columns in the in-application stream that you can create.

pub fn set_input_schema(self, input: Option<SourceSchema>) -> Self

Schema inferred from the streaming source. It identifies the format of the data in the streaming source and how each data element maps to corresponding columns in the in-application stream that you can create.

pub fn get_input_schema(&self) -> &Option<SourceSchema>

Schema inferred from the streaming source. It identifies the format of the data in the streaming source and how each data element maps to corresponding columns in the in-application stream that you can create.

pub fn parsed_input_records(self, input: Vec<String>) -> Self

Appends an item to parsed_input_records.

To override the contents of this collection use set_parsed_input_records.

An array of elements, where each element corresponds to a row in a stream record (a stream record can have more than one row).

pub fn set_parsed_input_records(self, input: Option<Vec<Vec<String>>>) -> Self

An array of elements, where each element corresponds to a row in a stream record (a stream record can have more than one row).

pub fn get_parsed_input_records(&self) -> &Option<Vec<Vec<String>>>

An array of elements, where each element corresponds to a row in a stream record (a stream record can have more than one row).

pub fn processed_input_records(self, input: impl Into<String>) -> Self

Appends an item to processed_input_records.

To override the contents of this collection use set_processed_input_records.

Stream data that was modified by the processor specified in the InputProcessingConfiguration parameter.

pub fn set_processed_input_records(self, input: Option<Vec<String>>) -> Self

Stream data that was modified by the processor specified in the InputProcessingConfiguration parameter.

pub fn get_processed_input_records(&self) -> &Option<Vec<String>>

Stream data that was modified by the processor specified in the InputProcessingConfiguration parameter.

pub fn raw_input_records(self, input: impl Into<String>) -> Self

Appends an item to raw_input_records.

To override the contents of this collection use set_raw_input_records.

Raw stream data that was sampled to infer the schema.

pub fn set_raw_input_records(self, input: Option<Vec<String>>) -> Self

Raw stream data that was sampled to infer the schema.

pub fn get_raw_input_records(&self) -> &Option<Vec<String>>

Raw stream data that was sampled to infer the schema.

pub fn build(self) -> DiscoverInputSchemaOutput

Consumes the builder and constructs a DiscoverInputSchemaOutput.

Trait Implementations

impl Clone for DiscoverInputSchemaOutputBuilder

fn clone(&self) -> DiscoverInputSchemaOutputBuilder

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for DiscoverInputSchemaOutputBuilder

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for DiscoverInputSchemaOutputBuilder

fn default() -> DiscoverInputSchemaOutputBuilder

Returns the “default value” for a type.

impl PartialEq for DiscoverInputSchemaOutputBuilder

fn eq(&self, other: &DiscoverInputSchemaOutputBuilder) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for DiscoverInputSchemaOutputBuilder