package iceberg
Ordering
- Alphabetic
Visibility
- Public
- Protected
Type Members
- case class IcebergRecordBatch(dataWriteResult: DataWriteResult, recordRanges: Seq[StreamRange]) extends RecordBatch with AppendableRecordBatch[IcebergRecordBatch] with Product with Serializable
- class IcebergRecordBatchBuilder extends RecordBatchBuilder[IcebergRecordBatch]
Record batch builder that collects records to files per partition.
- class IcebergRecordBatchStorage extends InDataOffsetBatchStorage[IcebergRecordBatch]
Iceberg record batch storage that appends multiple files and stores Kafka offsets in table properties in a single atomic table transaction.
Iceberg record batch storage that appends multiple files and stores Kafka offsets in table properties in a single atomic table transaction. An optional lock can be specified to use when committing batches in order to reduce possible commit storms.
- class IcebergRecordBatcher extends RecordBatcher[IcebergRecordBatch]
Value Members
- object IcebergRecordBatchStorage
- object IcebergRecordBatcher