Ctrl+K
Logo image Logo image

Site Navigation

  • API Reference
  • Examples

Site Navigation

  • API Reference
  • Examples

Section Navigation

  • PyFlink Table
  • PyFlink DataStream
    • StreamExecutionEnvironment
    • DataStream
    • Functions
    • State
    • Timer
    • Window
    • Checkpoint
    • Side Outputs
    • Connectors
    • Formats
  • PyFlink Common

pyflink.datastream.state.ReadOnlyBroadcastState#

class ReadOnlyBroadcastState(*args, **kwds)[source]#

A read-only view of the BroadcastState. Although read-only, the user code should not modify the value returned by the get() or the items returned by items(), as this can lead to inconsistent states. The reason for this is that we do not create extra copies of the elements for performance reasons.

Methods

clear()

Removes the value mapped under the current key.

contains(key)

Returns whether there exists the given mapping.

get(key)

Returns the current value associated with the given key.

is_empty()

Returns true if this state contains no key-value mappings, otherwise false.

items()

Returns all the mappings in the state.

keys()

Returns all the keys in the state.

values()

Returns all the values in the state.

previous

pyflink.datastream.state.MapState

next

pyflink.datastream.state.BroadcastState

On this page
  • ReadOnlyBroadcastState
Show Source

Created using Sphinx 5.3.0.