Struct deltalake::datafusion::datasource::file_format::json::JsonSink

pub struct JsonSink { /* private fields */ }

Implements DataSink for writing to a Json file.

Implementations

impl JsonSink

pub fn new( config: FileSinkConfig, writer_options: JsonWriterOptions ) -> JsonSink

Create from config.

pub fn config(&self) -> &FileSinkConfig

Retrieve the inner FileSinkConfig.

pub fn writer_options(&self) -> &JsonWriterOptions

Retrieve the writer options

Trait Implementations

impl DataSink for JsonSink

fn as_any(&self) -> &(dyn Any + 'static)

Returns the data sink as Any so that it can be downcast to a specific implementation.

fn metrics(&self) -> Option<MetricsSet>

Return a snapshot of the MetricsSet for this DataSink.

fn write_all<'life0, 'life1, 'async_trait>( &'life0 self, data: Pin<Box<dyn RecordBatchStream<Item = Result<RecordBatch, DataFusionError>> + Send>>, context: &'life1 Arc<TaskContext> ) -> Pin<Box<dyn Future<Output = Result<u64, DataFusionError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, JsonSink: 'async_trait,

Writes the data to the sink, returns the number of values written

impl Debug for JsonSink

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

Formats the value using the given formatter.

impl DisplayAs for JsonSink

fn fmt_as( &self, t: DisplayFormatType, f: &mut Formatter<'_> ) -> Result<(), Error>

Format according to DisplayFormatType, used when verbose representation looks different from the default one

impl TryFrom<&JsonSink> for JsonSink

type Error = DataFusionError

The type returned in the event of a conversion error.

fn try_from( value: &JsonSink ) -> Result<JsonSink, <JsonSink as TryFrom<&JsonSink>>::Error>

Performs the conversion.