Struct mz_compute_types::sinks::CopyToS3OneshotSinkConnection

pub struct CopyToS3OneshotSinkConnection {
    pub upload_info: S3UploadInfo,
    pub aws_connection: AwsConnection,
    pub connection_id: CatalogItemId,
    pub output_batch_count: u64,
}

Connection attributes required to do a oneshot copy to s3.

Fields

upload_info: S3UploadInfo

Information specific to the upload.

aws_connection: AwsConnection

The AWS connection information to do the writes.

connection_id: CatalogItemId

The ID of the Connection object, used to generate the External ID when using AssumeRole with AWS connection.

output_batch_count: u64

The number of batches the COPY TO output will be divided into where each worker will process 0 or more batches of data.

Trait Implementations

impl Arbitrary for CopyToS3OneshotSinkConnection

type Parameters = (<S3UploadInfo as Arbitrary>::Parameters, <AwsConnection as Arbitrary>::Parameters, <CatalogItemId as Arbitrary>::Parameters, <u64 as Arbitrary>::Parameters)

The type of parameters that arbitrary_with accepts for configuration of the generated Strategy. Parameters must implement Default.

type Strategy = Map<(<S3UploadInfo as Arbitrary>::Strategy, <AwsConnection as Arbitrary>::Strategy, <CatalogItemId as Arbitrary>::Strategy, <u64 as Arbitrary>::Strategy), fn(_: (S3UploadInfo, AwsConnection, CatalogItemId, u64)) -> CopyToS3OneshotSinkConnection>

The type of Strategy used to generate values of type Self.

fn arbitrary_with(_top: Self::Parameters) -> Self::Strategy

Generates a Strategy for producing arbitrary values of type the implementing type (Self). The strategy is passed the arguments given in args.

fn arbitrary() -> Self::Strategy

Generates a Strategy for producing arbitrary values of type the implementing type (Self).

impl Clone for CopyToS3OneshotSinkConnection

fn clone(&self) -> CopyToS3OneshotSinkConnection

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for CopyToS3OneshotSinkConnection

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for CopyToS3OneshotSinkConnection

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for CopyToS3OneshotSinkConnection

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

Tests for self and other values to be equal, and is used by ==.

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

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

impl RustType<ProtoCopyToS3OneshotSinkConnection> for CopyToS3OneshotSinkConnection

fn into_proto(&self) -> ProtoCopyToS3OneshotSinkConnection

Convert a Self into a Proto value.

fn from_proto( proto: ProtoCopyToS3OneshotSinkConnection, ) -> Result<Self, TryFromProtoError>

Consume and convert a Proto back into a Self value.

fn into_proto_owned(self) -> Proto

A zero clone version of Self::into_proto that types can optionally implement, otherwise, the default implementation delegates to Self::into_proto.

impl Serialize for CopyToS3OneshotSinkConnection

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for CopyToS3OneshotSinkConnection

impl StructuralPartialEq for CopyToS3OneshotSinkConnection