Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

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
languagejava
/** 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

...