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§

Traits§

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

Functions§