org.apache.flink.table.planner.calcite

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 of SchemaVersion to specify the snapshot at the specific time.

Method Summary

Modifier and Type	Method and Description
long	getTimestamp()
boolean	isBefore(org.apache.calcite.schema.SchemaVersion other)
static org.apache.calcite.schema.SchemaVersion	of(long timestamp)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

of

public static org.apache.calcite.schema.SchemaVersion of(long timestamp)

getTimestamp

public long getTimestamp()

isBefore

public boolean isBefore(org.apache.calcite.schema.SchemaVersion other)

Specified by:

isBefore in interface org.apache.calcite.schema.SchemaVersion