Skip to main content
Ctrl+K
PyFlink 1.20+vvr.11.7.dev0 documentation - Home PyFlink 1.20+vvr.11.7.dev0 documentation - Home
  • API Reference
  • Examples
  • API Reference
  • Examples

Section Navigation

  • PyFlink Table
  • PyFlink DataStream
    • StreamExecutionEnvironment
    • DataStream
    • Functions
    • State
    • Timer
    • Window
    • Checkpoint
    • Side Outputs
    • Asynchronous I/O
    • Connectors
    • Formats
  • PyFlink DataFrame
  • PyFlink Common
  • API Reference
  • PyFlink DataStream
  • State
  • pyflink.datastream.state.MergingState

pyflink.datastream.state.MergingState#

class MergingState[source]#

Extension of AppendingState that allows merging of state. That is, two instance of MergingState can be combined into a single instance that contains all the information of the two merged states.

Methods

add(value)

Adding the given value to the tail of this list state.

clear()

Removes the value mapped under the current key.

get()

Returns the elements under the current key.

previous

pyflink.datastream.state.AppendingState

next

pyflink.datastream.state.ReducingState

On this page
  • MergingState

This Page

  • Show Source

Created using Sphinx 7.4.7.

Built with the PyData Sphinx Theme 0.16.1.