Class TimestampSchemaVersion
- java.lang.Object
-
- org.apache.flink.table.planner.calcite.TimestampSchemaVersion
-
- All Implemented Interfaces:
org.apache.calcite.schema.SchemaVersion
public class TimestampSchemaVersion extends Object implements org.apache.calcite.schema.SchemaVersion
The implementation ofSchemaVersion
to specify the snapshot at the specific time.
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description long
getTimestamp()
boolean
isBefore(org.apache.calcite.schema.SchemaVersion other)
static org.apache.calcite.schema.SchemaVersion
of(long timestamp)
-