pub struct WriteOperationV2 {
pub input: Option<Relation>,
pub table_name: String,
pub provider: Option<String>,
pub partitioning_columns: Vec<Expression>,
pub options: HashMap<String, String>,
pub table_properties: HashMap<String, String>,
pub mode: i32,
pub overwrite_condition: Option<Expression>,
}
Expand description
As writes are not directly handled during analysis and planning, they are modeled as commands.
Fields§
§input: Option<Relation>
(Required) The output of the input
relation will be persisted according to the options.
table_name: String
(Required) The destination of the write operation must be either a path or a table.
provider: Option<String>
(Optional) A provider for the underlying output data source. Spark’s default catalog supports “parquet”, “json”, etc.
partitioning_columns: Vec<Expression>
(Optional) List of columns for partitioning for output table created by create
,
createOrReplace
, or replace
options: HashMap<String, String>
(Optional) A list of configuration options.
table_properties: HashMap<String, String>
(Optional) A list of table properties.
mode: i32
(Required) Write mode.
overwrite_condition: Option<Expression>
(Optional) A condition for overwrite saving mode
Implementations§
Trait Implementations§
Source§impl Clone for WriteOperationV2
impl Clone for WriteOperationV2
Source§fn clone(&self) -> WriteOperationV2
fn clone(&self) -> WriteOperationV2
Returns a copy of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moreSource§impl Debug for WriteOperationV2
impl Debug for WriteOperationV2
Source§impl Default for WriteOperationV2
impl Default for WriteOperationV2
Source§impl Message for WriteOperationV2
impl Message for WriteOperationV2
Source§fn encoded_len(&self) -> usize
fn encoded_len(&self) -> usize
Returns the encoded length of the message without a length delimiter.
Source§fn encode<B>(&self, buf: &mut B) -> Result<(), EncodeError>
fn encode<B>(&self, buf: &mut B) -> Result<(), EncodeError>
Encodes the message to a buffer. Read more
Source§fn encode_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
fn encode_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
Encodes the message to a newly allocated buffer.
Source§fn encode_length_delimited<B>(&self, buf: &mut B) -> Result<(), EncodeError>
fn encode_length_delimited<B>(&self, buf: &mut B) -> Result<(), EncodeError>
Encodes the message with a length-delimiter to a buffer. Read more
Source§fn encode_length_delimited_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
fn encode_length_delimited_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
Encodes the message with a length-delimiter to a newly allocated buffer.
Source§fn decode<B>(buf: B) -> Result<Self, DecodeError>
fn decode<B>(buf: B) -> Result<Self, DecodeError>
Decodes an instance of the message from a buffer. Read more
Source§fn decode_length_delimited<B>(buf: B) -> Result<Self, DecodeError>
fn decode_length_delimited<B>(buf: B) -> Result<Self, DecodeError>
Decodes a length-delimited instance of the message from the buffer.
Source§fn merge<B>(&mut self, buf: B) -> Result<(), DecodeError>
fn merge<B>(&mut self, buf: B) -> Result<(), DecodeError>
Decodes an instance of the message from a buffer, and merges it into
self
. Read moreSource§fn merge_length_delimited<B>(&mut self, buf: B) -> Result<(), DecodeError>
fn merge_length_delimited<B>(&mut self, buf: B) -> Result<(), DecodeError>
Decodes a length-delimited instance of the message from buffer, and
merges it into
self
.Source§impl PartialEq for WriteOperationV2
impl PartialEq for WriteOperationV2
impl StructuralPartialEq for WriteOperationV2
Auto Trait Implementations§
impl Freeze for WriteOperationV2
impl RefUnwindSafe for WriteOperationV2
impl Send for WriteOperationV2
impl Sync for WriteOperationV2
impl Unpin for WriteOperationV2
impl UnwindSafe for WriteOperationV2
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
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
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> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request