Module opendal_sink 

Structs

BatchingStrategy

BatchingStrategy represents the strategy for batching data before writing to files.

FileSink

The FileSink struct represents a file sink that uses the OpendalSinkBackend trait for its backend implementation.

OpenDalSinkWriter

Enums

EngineType

FileWriterEnum 🔒

The FileWriterEnum enum represents different types of file writers used for various sink implementations.

PathPartitionPrefix

PathPartitionPrefix defines the granularity of file partitions based on creation time.

Constants

DEFAULT_MAX_ROW_COUNR

DEFAULT_ROLLOVER_SECONDS

Traits

OpendalSinkBackend

The OpendalSinkBackend trait unifies the behavior of various sink backends implemented through OpenDAL(<https://github.com/apache/opendal>).

Functions

convert_rw_schema_to_arrow_schema 🔒

default_max_row_count

default_rollover_seconds