public class DataFileMeta extends Object
Modifier and Type | Field and Description |
---|---|
static int |
DUMMY_LEVEL |
static BinaryTableStats |
EMPTY_KEY_STATS |
static org.apache.flink.table.data.binary.BinaryRowData |
EMPTY_MAX_KEY |
static org.apache.flink.table.data.binary.BinaryRowData |
EMPTY_MIN_KEY |
Constructor and Description |
---|
DataFileMeta(String fileName,
long fileSize,
long rowCount,
org.apache.flink.table.data.binary.BinaryRowData minKey,
org.apache.flink.table.data.binary.BinaryRowData maxKey,
BinaryTableStats keyStats,
BinaryTableStats valueStats,
long minSequenceNumber,
long maxSequenceNumber,
long schemaId,
int level) |
DataFileMeta(String fileName,
long fileSize,
long rowCount,
org.apache.flink.table.data.binary.BinaryRowData minKey,
org.apache.flink.table.data.binary.BinaryRowData maxKey,
BinaryTableStats keyStats,
BinaryTableStats valueStats,
long minSequenceNumber,
long maxSequenceNumber,
long schemaId,
int level,
List<String> extraFiles) |
Modifier and Type | Method and Description |
---|---|
DataFileMeta |
copy(List<String> newExtraFiles) |
boolean |
equals(Object o) |
List<String> |
extraFiles()
Usage:
Table Store 0.2
Stores changelog files for
CoreOptions.ChangelogProducer#INPUT . |
String |
fileName() |
long |
fileSize() |
static DataFileMeta |
forAppend(String fileName,
long fileSize,
long rowCount,
BinaryTableStats rowStats,
long minSequenceNumber,
long maxSequenceNumber,
long schemaId) |
static long |
getMaxSequenceNumber(List<DataFileMeta> fileMetas) |
int |
hashCode() |
BinaryTableStats |
keyStats() |
int |
level() |
org.apache.flink.table.data.binary.BinaryRowData |
maxKey() |
long |
maxSequenceNumber() |
org.apache.flink.table.data.binary.BinaryRowData |
minKey() |
long |
minSequenceNumber() |
long |
rowCount() |
static org.apache.flink.table.types.logical.RowType |
schema() |
long |
schemaId() |
String |
toString() |
DataFileMeta |
upgrade(int newLevel) |
BinaryTableStats |
valueStats() |
public static final BinaryTableStats EMPTY_KEY_STATS
public static final org.apache.flink.table.data.binary.BinaryRowData EMPTY_MIN_KEY
public static final org.apache.flink.table.data.binary.BinaryRowData EMPTY_MAX_KEY
public static final int DUMMY_LEVEL
public DataFileMeta(String fileName, long fileSize, long rowCount, org.apache.flink.table.data.binary.BinaryRowData minKey, org.apache.flink.table.data.binary.BinaryRowData maxKey, BinaryTableStats keyStats, BinaryTableStats valueStats, long minSequenceNumber, long maxSequenceNumber, long schemaId, int level)
public DataFileMeta(String fileName, long fileSize, long rowCount, org.apache.flink.table.data.binary.BinaryRowData minKey, org.apache.flink.table.data.binary.BinaryRowData maxKey, BinaryTableStats keyStats, BinaryTableStats valueStats, long minSequenceNumber, long maxSequenceNumber, long schemaId, int level, List<String> extraFiles)
public static DataFileMeta forAppend(String fileName, long fileSize, long rowCount, BinaryTableStats rowStats, long minSequenceNumber, long maxSequenceNumber, long schemaId)
public String fileName()
public long fileSize()
public long rowCount()
public org.apache.flink.table.data.binary.BinaryRowData minKey()
public org.apache.flink.table.data.binary.BinaryRowData maxKey()
public BinaryTableStats keyStats()
public BinaryTableStats valueStats()
public long minSequenceNumber()
public long maxSequenceNumber()
public long schemaId()
public int level()
public List<String> extraFiles()
CoreOptions.ChangelogProducer#INPUT
. Changelog
files are moved to NewFilesIncrement
since Table Store 0.3.
public DataFileMeta upgrade(int newLevel)
public DataFileMeta copy(List<String> newExtraFiles)
public static org.apache.flink.table.types.logical.RowType schema()
public static long getMaxSequenceNumber(List<DataFileMeta> fileMetas)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.