case class Builder(_table: Table, _recordFormatter: RecordFormatter[Record], _fileFormat: FileFormat, _fileCommitStrategy: MultiFileCommitStrategy, _writeProperties: Map[String, String]) extends Product with Serializable
- Alphabetic
- By Inheritance
- Builder
- Serializable
- Product
- Equals
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new Builder(_table: Table, _recordFormatter: RecordFormatter[Record], _fileFormat: FileFormat, _fileCommitStrategy: MultiFileCommitStrategy, _writeProperties: Map[String, String])
Value Members
- def build(): IcebergRecordBatcher
- def fileCommitStrategy(strategy: MultiFileCommitStrategy): Builder
Sets the strategy for determining if a batch of files (one per partition) is ready to be stored.
- def fileFormat(format: FileFormat): Builder
Sets the file format to use.
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- def recordFormatter(formatter: RecordFormatter[Record]): Builder
Sets the record formatter that converts from consumer records to Iceberg records.
- def table(table: Table): Builder
Sets the Iceberg table to build batches for.
- def writeProperties(properties: Map[String, String]): Builder
Sets any additional properties for the underlying data file builder.