THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
This section will describe how other systems can integrate to support TimeTravel.
Compatibility, Deprecation, and Migration Plan
This is a newly added feature, so there will be no compatibility issues
Code Block | ||
---|---|---|
| ||
/** Catalog for paimon. */ public class FlinkCatalog extends AbstractCatalog { ... @Override public CatalogTable getTable(ObjectPath tablePath) throws TableNotExistException, CatalogException { Table table; try { table = catalog.getTable(toIdentifier(tablePath)); } catch (Catalog.TableNotExistException e) { throw new TableNotExistException(getName(), tablePath); } if (table instanceof FileStoreTable) { return toCatalogTable(table); } else { return new SystemCatalogTable(table); } } @Override public CatalogTable getTable(ObjectPath tablePath, long timestamp) throws TableNotExistException, CatalogException { CatalogTable catalogTable = this.getTable(tablePath); Options option = new Options() .set(CoreOptions.SCAN_TIMESTAMP_MILLIS, timestamp) .set(CoreOptions.SCAN_MODE, CoreOptions.StartupMode.FROM_TIMESTAMP); return catalogTable.copy(option.toMap()); } .... } |
Compatibility, Deprecation, and Migration Plan
This is a newly added feature, so there will be no compatibility issues
Test Plan
UT&IT
Whether to support other syntax implementations
...