Seth Wiesman created FLINK-21341:
------------------------------------
Summary: Update state reader to return InputFormat
Key: FLINK-21341
URL: https://issues.apache.org/jira/browse/FLINK-21341
Project: Flink
Issue Type: Improvement
Components: API / State Processor
Affects Versions: 1.13.0
Reporter: Seth Wiesman
The state processor api on read currently takes an ExecutionEnvironment and
returns a DataSet. As Flink now supports Bounded DataStream we want to support
that as well but not have to maintain parallel apis. To that end we propose the
following.
Introduce a new `load` method to Savepoint.
{code:java}
SavepointReader Savepoint#load(String path, StateBackend backend);
{code}
SavepointReader will contain the same read methods as ExistingSavepoint but
they will instead return InputFormat<T, ?>. This way the input format can be
used with either DataSet, DataStream, or Table API.
The reader methods in ExistingSavepoint should be deprecated.
Additionally, OperatorStateInputFormat and KeyedStateInputFormat should both
now extend ResultTypeQueryable so users get efficient serializer for their
reads.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
