risingwave_connector::sink::file_sink

Module opendal_sink

Source

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