Module chunk_builder

Structs

DeleteAction 🔒

InsertAction 🔒

SourceStreamChunkBuilder

A builder for building a [StreamChunk] from SourceColumnDesc.

SourceStreamChunkRowWriter

SourceStreamChunkRowWriter is responsible to write one or more records to the [StreamChunk], where each contains either one row (Insert/Delete) or two rows (Update) that can be written atomically.

Transaction 🔒

Represents an ongoing transaction.

UpdateAction 🔒

Constants

MAX_TRANSACTION_SIZE 🔒

Maximum number of rows in a transaction. If a transaction is larger than this, it will be force committed to avoid potential OOM.

Traits

RowWriterAction 🔒