public interface BundleFileStoreWriter extends FileStoreWrite<InternalRow>
FileStoreWrite.State<T>
Modifier and Type | Method and Description |
---|---|
void |
writeBundle(BinaryRow partition,
int bucket,
BundleRecords bundle)
Write the batch data to the store according to the partition and bucket.
|
close, compact, notifyNewFiles, prepareCommit, withCompactExecutor, withExecutionMode, withIgnorePreviousFiles, withInsertOnly, withIOManager, withMemoryPool, withMemoryPoolFactory, withMetricRegistry, write
checkpoint, restore
void writeBundle(BinaryRow partition, int bucket, BundleRecords bundle) throws Exception
partition
- the partition of the databucket
- the bucket id of the databundle
- the given dataException
- the thrown exception when writing the recordCopyright © 2023–2024 The Apache Software Foundation. All rights reserved.