Package | Description |
---|---|
org.apache.paimon.flink.utils | |
org.apache.paimon.operation | |
org.apache.paimon.privilege | |
org.apache.paimon.stats | |
org.apache.paimon.table |
Modifier and Type | Method and Description |
---|---|
static Statistics |
TableStatsUtil.createTableColumnStats(FileStoreTable table,
org.apache.flink.table.catalog.stats.CatalogColumnStatistics columnStatistics)
Create Paimon statistics from given Flink columnStatistics.
|
static Statistics |
TableStatsUtil.createTableStats(FileStoreTable table,
org.apache.flink.table.catalog.stats.CatalogTableStatistics catalogTableStatistics)
create Paimon statistics.
|
Modifier and Type | Method and Description |
---|---|
void |
FileStoreCommitImpl.commitStatistics(Statistics stats,
long commitIdentifier) |
void |
FileStoreCommit.commitStatistics(Statistics stats,
long commitIdentifier)
Commit new statistics.
|
Modifier and Type | Method and Description |
---|---|
Optional<Statistics> |
PrivilegedFileStoreTable.statistics() |
Modifier and Type | Method and Description |
---|---|
static Statistics |
Statistics.fromJson(String json) |
static Statistics |
Statistics.fromPath(FileIO fileIO,
Path path) |
Statistics |
StatsFile.read(String fileName)
Read stats from stat file name.
|
Modifier and Type | Method and Description |
---|---|
Optional<Statistics> |
StatsFileHandler.readStats()
Read stats of the latest snapshot.
|
Optional<Statistics> |
StatsFileHandler.readStats(long snapshotId)
Read stats of the specified snapshot.
|
Optional<Statistics> |
StatsFileHandler.readStats(Snapshot snapshot) |
Modifier and Type | Method and Description |
---|---|
String |
StatsFile.write(Statistics stats)
Write stats to a stats file.
|
String |
StatsFileHandler.writeStats(Statistics stats)
Write stats to a stats file.
|
Modifier and Type | Method and Description |
---|---|
Optional<Statistics> |
Table.statistics()
Optional statistics of this table.
|
default Optional<Statistics> |
FormatTable.statistics() |
default Optional<Statistics> |
ReadonlyTable.statistics() |
Optional<Statistics> |
DelegatedFileStoreTable.statistics() |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.