public class MergeTreeBenchmark extends Object
Modifier and Type | Class and Description |
---|---|
static class |
MergeTreeBenchmark.KeyValueData
Key value data to be written in
MergeTreeWriterBenchmark . |
Modifier and Type | Field and Description |
---|---|
protected int |
batchCount |
protected List<DataFileMeta> |
compactedFiles |
protected Comparator<org.apache.flink.table.data.RowData> |
comparator |
protected int |
countPerBatch |
protected File |
file |
protected String |
format |
protected KeyValue |
kv |
protected CoreOptions |
options |
protected KeyValueFileReaderFactory |
readerFactory |
protected long |
sequenceNumber |
protected ExecutorService |
service |
protected RecordWriter<KeyValue> |
writer |
protected KeyValueFileWriterFactory |
writerFactory |
Constructor and Description |
---|
MergeTreeBenchmark() |
Modifier and Type | Method and Description |
---|---|
protected void |
cleanUp() |
protected void |
createRecordWriter() |
protected void |
mergeCompacted(Set<String> newFileNames,
List<DataFileMeta> compactedFiles,
RecordWriter.CommitIncrement increment) |
protected String format
protected ExecutorService service
protected File file
protected Comparator<org.apache.flink.table.data.RowData> comparator
protected CoreOptions options
protected KeyValueFileReaderFactory readerFactory
protected KeyValueFileWriterFactory writerFactory
protected List<DataFileMeta> compactedFiles
protected RecordWriter<KeyValue> writer
protected int batchCount
protected int countPerBatch
protected KeyValue kv
protected long sequenceNumber
protected void createRecordWriter()
protected void mergeCompacted(Set<String> newFileNames, List<DataFileMeta> compactedFiles, RecordWriter.CommitIncrement increment)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.