Page History

CREATE TABLE state_table (
  `k` BIGINT,
  `operator-uid` STRING,
  `KeyedAvroValue` ROW<myLong1 BIGINT, myLong2 BIGINT>,
  PRIMARY KEY (k) NOT ENFORCED
)
with (
  'connector' = 'savepoint',
  'state.path' = '/root/dir/of/checkpoint-data',
  'operator.uid' = 'keyed-state-process-uid',
  'fields.KeyedAvroValue.value-type-info-factory' = 'org.apache.flink.state.table.AvroSavepointTypeInformationFactory'
);


SELECT * FROM state_table;