Bulk Operation

FLINK-21091 Support StreamExecValues json serialization/deserialization

FLINK-21091 Support StreamExecPythonOverAggregate json serialization/deserialization

FLINK-21091 Support StreamExecPythonGroupWindowAggregate json serialization/deserialization

FLINK-21091 Support StreamExecPythonGroupAggregate json serialization/deserialization

FLINK-21091 Support StreamExecPythonCorrelate json serialization/deserialization

FLINK-21091 Support StreamExecPythonCalc json serialization/deserialization

FLINK-21091 The result of LogicalWindowJsonDeserializer is incorrect

FLINK-21091 The ExecNode's id should always start from 1 in json plan test

FLINK-21091 Reduce the ExecNode scan scope to improve performance when converting json plan to ExecNodeGraph

FLINK-21091 Reflections ClassNotFound when trying to deserialize a json plan in deployment envrionment

FLINK-21091 Check whether TemporalTableSourceSpec can be serialized or not

FLINK-21091 RelDataType of TableFunction different in local and CI

FLINK-21091 Support StreamExecTemporalSort json serialization/deserialization

FLINK-21091 Support StreamExecLookupJoin json serialization/deserialization

FLINK-21091 Support StreamExecTemporalJoin json serialization/deserialization

FLINK-21091 Support StreamExecIncrementalGroupAggregate json serialization/deserialization

FLINK-21091 Support StreamExecExpand json serialization/deserialization

FLINK-21091 Support StreamExecGroupWindowAggregate json ser/de

FLINK-21091 Support StreamExecIntervalJoin json ser/de

FLINK-21091 Support StreamExecMatch json ser/de

FLINK-21091 Support StreamExecUnion json ser/de

FLINK-21091 Support StreamExecOverAggregate json ser/de

FLINK-21091 Support StreamExecJoin json serialization/deserialization

FLINK-21091 Support StreamExecRank and StreamExecSortLimit and StreamExecLimit Json ser/de

FLINK-21091 LogicalTypeJsonDeserializer/Serializer custom RowType/MapType/ArrayType/MultisetType

FLINK-21091 Support StreamExecLocalGroupAggregate and StreamExecGlobalGroupAggregate json serialization/deserialization

FLINK-21091 Support StreamExecCorrelate json serde

FLINK-21091 Support StreamExecWatermarkAssigner json serialization/deserialization

FLINK-21091 Support StreamExecDeduplicate json serialization/deserialization

FLINK-21091 Introduce ExecNodeTranslator

FLINK-21091 Support StreamExecChangelogNormalize and StreamExecDropUpdateBefore json serde

FLINK-21091 Support StreamExecMiniBatchAssigner json serialization/deserialization

FLINK-21091 Support StreamExecWindowAggregate json serialization/deserialization

FLINK-21091 Introduce StateDeclaration

FLINK-21091 Support StreamExecGroupAggregate json serialization/deserialization

FLINK-21091 Support json serialization/deserialization for the push-down result of DynamicTableSource and DynamicTableSink

FLINK-21091 Support StreamExecCalc json serialization/deserialization

FLINK-21091 Introduce e2e test framework for json plan test

FLINK-21091 Introduce ExecNodeGraphJsonPlanGenerator to serialize ExecNodeGraph to json plan and deserialize json plan to ExecNodeGraph

FLINK-21091 Support StreamExecSink json serialization/deserialization

FLINK-21091 Support StreamExecTableSource json serialization/deserialization

FLINK-21091 Introduce getJsonPlan, explainJsonPlan and executeJsonPlan in TableEnvironmentInternal