#[non_exhaustive]pub struct SourceSchemaBuilder { /* private fields */ }Expand description
A builder for SourceSchema.
Implementations§
source§impl SourceSchemaBuilder
impl SourceSchemaBuilder
sourcepub fn record_format(self, input: RecordFormat) -> Self
pub fn record_format(self, input: RecordFormat) -> Self
Specifies the format of the records on the streaming source.
This field is required.sourcepub fn set_record_format(self, input: Option<RecordFormat>) -> Self
pub fn set_record_format(self, input: Option<RecordFormat>) -> Self
Specifies the format of the records on the streaming source.
sourcepub fn get_record_format(&self) -> &Option<RecordFormat>
pub fn get_record_format(&self) -> &Option<RecordFormat>
Specifies the format of the records on the streaming source.
sourcepub fn record_encoding(self, input: impl Into<String>) -> Self
pub fn record_encoding(self, input: impl Into<String>) -> Self
Specifies the encoding of the records in the streaming source. For example, UTF-8.
sourcepub fn set_record_encoding(self, input: Option<String>) -> Self
pub fn set_record_encoding(self, input: Option<String>) -> Self
Specifies the encoding of the records in the streaming source. For example, UTF-8.
sourcepub fn get_record_encoding(&self) -> &Option<String>
pub fn get_record_encoding(&self) -> &Option<String>
Specifies the encoding of the records in the streaming source. For example, UTF-8.
sourcepub fn record_columns(self, input: RecordColumn) -> Self
pub fn record_columns(self, input: RecordColumn) -> Self
Appends an item to record_columns.
To override the contents of this collection use set_record_columns.
A list of RecordColumn objects.
sourcepub fn set_record_columns(self, input: Option<Vec<RecordColumn>>) -> Self
pub fn set_record_columns(self, input: Option<Vec<RecordColumn>>) -> Self
A list of RecordColumn objects.
sourcepub fn get_record_columns(&self) -> &Option<Vec<RecordColumn>>
pub fn get_record_columns(&self) -> &Option<Vec<RecordColumn>>
A list of RecordColumn objects.
sourcepub fn build(self) -> Result<SourceSchema, BuildError>
pub fn build(self) -> Result<SourceSchema, BuildError>
Consumes the builder and constructs a SourceSchema.
This method will fail if any of the following fields are not set:
Trait Implementations§
source§impl Clone for SourceSchemaBuilder
impl Clone for SourceSchemaBuilder
source§fn clone(&self) -> SourceSchemaBuilder
fn clone(&self) -> SourceSchemaBuilder
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moresource§impl Debug for SourceSchemaBuilder
impl Debug for SourceSchemaBuilder
source§impl Default for SourceSchemaBuilder
impl Default for SourceSchemaBuilder
source§fn default() -> SourceSchemaBuilder
fn default() -> SourceSchemaBuilder
source§impl PartialEq for SourceSchemaBuilder
impl PartialEq for SourceSchemaBuilder
source§fn eq(&self, other: &SourceSchemaBuilder) -> bool
fn eq(&self, other: &SourceSchemaBuilder) -> bool
self and other values to be equal, and is used
by ==.