Versions Compared

Old Version 6

changes.mady.by.user Shuiqiang Chen

Saved on

compared with

New Version 7

changes.mady.by.user Shuiqiang Chen

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

  1. Provide state access APIs in KeyedStream.
  2. Support ValueState, ListState, MapState, ReducingState and AggregatingState.

Non-Goals:

      1. Support for State migration will be introduced in a separated FLIP;

      2. A Python queryable state client for Queryable state in Python operators will not be covered in this FLIP.

Background

PyFlink leverages the Beam portability framework to start a Python process to execute user defined Python functions.

...