public static class RewriteFileIndexSink.FileIndexProcessor extends Object
Constructor and Description |
---|
FileIndexProcessor(FileStoreTable table) |
Modifier and Type | Method and Description |
---|---|
DataFileMeta |
process(BinaryRow partition,
int bucket,
DataFileMeta dataFileMeta) |
public FileIndexProcessor(FileStoreTable table)
public DataFileMeta process(BinaryRow partition, int bucket, DataFileMeta dataFileMeta) throws IOException
IOException
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.