Struct aws_sdk_glue::types::S3HudiDirectTarget
source · #[non_exhaustive]pub struct S3HudiDirectTarget {
pub name: String,
pub inputs: Vec<String>,
pub path: String,
pub compression: HudiTargetCompressionType,
pub partition_keys: Option<Vec<Vec<String>>>,
pub format: TargetFormat,
pub additional_options: HashMap<String, String>,
pub schema_change_policy: Option<DirectSchemaChangePolicy>,
}Expand description
Specifies a target that writes to a Hudi data source in Amazon S3.
Fields (Non-exhaustive)§
This struct is marked as non-exhaustive
Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.name: StringThe name of the data target.
inputs: Vec<String>The nodes that are inputs to the data target.
path: StringThe Amazon S3 path of your Hudi data source to write to.
compression: HudiTargetCompressionTypeSpecifies how the data is compressed. This is generally not necessary if the data has a standard file extension. Possible values are "gzip" and "bzip").
partition_keys: Option<Vec<Vec<String>>>Specifies native partitioning using a sequence of keys.
format: TargetFormatSpecifies the data output format for the target.
additional_options: HashMap<String, String>Specifies additional connection options for the connector.
schema_change_policy: Option<DirectSchemaChangePolicy>A policy that specifies update behavior for the crawler.
Implementations§
source§impl S3HudiDirectTarget
impl S3HudiDirectTarget
sourcepub fn compression(&self) -> &HudiTargetCompressionType
pub fn compression(&self) -> &HudiTargetCompressionType
Specifies how the data is compressed. This is generally not necessary if the data has a standard file extension. Possible values are "gzip" and "bzip").
sourcepub fn partition_keys(&self) -> &[Vec<String>]
pub fn partition_keys(&self) -> &[Vec<String>]
Specifies native partitioning using a sequence of keys.
If no value was sent for this field, a default will be set. If you want to determine if no value was sent, use .partition_keys.is_none().
sourcepub fn format(&self) -> &TargetFormat
pub fn format(&self) -> &TargetFormat
Specifies the data output format for the target.
sourcepub fn additional_options(&self) -> &HashMap<String, String>
pub fn additional_options(&self) -> &HashMap<String, String>
Specifies additional connection options for the connector.
sourcepub fn schema_change_policy(&self) -> Option<&DirectSchemaChangePolicy>
pub fn schema_change_policy(&self) -> Option<&DirectSchemaChangePolicy>
A policy that specifies update behavior for the crawler.
source§impl S3HudiDirectTarget
impl S3HudiDirectTarget
sourcepub fn builder() -> S3HudiDirectTargetBuilder
pub fn builder() -> S3HudiDirectTargetBuilder
Creates a new builder-style object to manufacture S3HudiDirectTarget.
Trait Implementations§
source§impl Clone for S3HudiDirectTarget
impl Clone for S3HudiDirectTarget
source§fn clone(&self) -> S3HudiDirectTarget
fn clone(&self) -> S3HudiDirectTarget
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moresource§impl Debug for S3HudiDirectTarget
impl Debug for S3HudiDirectTarget
source§impl PartialEq for S3HudiDirectTarget
impl PartialEq for S3HudiDirectTarget
source§fn eq(&self, other: &S3HudiDirectTarget) -> bool
fn eq(&self, other: &S3HudiDirectTarget) -> bool
self and other values to be equal, and is used
by ==.impl StructuralPartialEq for S3HudiDirectTarget
Auto Trait Implementations§
impl Freeze for S3HudiDirectTarget
impl RefUnwindSafe for S3HudiDirectTarget
impl Send for S3HudiDirectTarget
impl Sync for S3HudiDirectTarget
impl Unpin for S3HudiDirectTarget
impl UnwindSafe for S3HudiDirectTarget
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