Struct CopySink

pub struct CopySink {
    pub write_batch_size: Option<Value>,
    pub write_batch_timeout: Option<Value>,
    pub sink_retry_count: Option<Value>,
    pub sink_retry_wait: Option<Value>,
    pub max_concurrent_connections: Option<Value>,
    pub disable_metrics_collection: Option<Value>,
}

A copy activity sink.

Fields

write_batch_size: Option<Value>

Write batch size. Type: integer (or Expression with resultType integer), minimum: 0.

write_batch_timeout: Option<Value>

Write batch timeout. Type: string (or Expression with resultType string), pattern: ((\d+).)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).

sink_retry_count: Option<Value>

Sink retry count. Type: integer (or Expression with resultType integer).

sink_retry_wait: Option<Value>

Sink retry wait. Type: string (or Expression with resultType string), pattern: ((\d+).)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).

max_concurrent_connections: Option<Value>

The maximum concurrent connection count for the sink data store. Type: integer (or Expression with resultType integer).

disable_metrics_collection: Option<Value>

If true, disable data store metrics collection. Default is false. Type: boolean (or Expression with resultType boolean).

Implementations

impl CopySink

pub fn new() -> Self

Trait Implementations

impl Clone for CopySink

fn clone(&self) -> CopySink

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CopySink

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for CopySink

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for CopySink

fn eq(&self, other: &CopySink) -> 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 Serialize for CopySink

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for CopySink