Ctrl+K
Logo image Logo image

Site Navigation

  • API Reference
  • Examples

Site Navigation

  • API Reference
  • Examples

Section Navigation

  • PyFlink Table
  • PyFlink DataStream
  • PyFlink Common
    • Config
    • Serializer
    • Job Information
    • Serializer

pyflink.common.configuration.Configuration#

class Configuration(other: Optional[Configuration] = None, j_configuration: Optional[JavaObject] = None)[source]#

Lightweight configuration object which stores key/value pairs.

Methods

add_all(other[, prefix])

Adds all entries from the given configuration into this configuration.

add_all_to_dict(target_dict)

Adds all entries in this configuration to the given dict.

contains_key(key)

Checks whether there is an entry with the specified key.

get_boolean(key, default_value)

Returns the value associated with the given key as a boolean.

get_bytearray(key, default_value)

Returns the value associated with the given key as a byte array.

get_float(key, default_value)

Returns the value associated with the given key as a float.

get_integer(key, default_value)

Returns the value associated with the given key as an integer.

get_string(key, default_value)

Returns the value associated with the given key as a string.

key_set()

Returns the keys of all key/value pairs stored inside this configuration object.

remove_config(key)

Removes given config key from the configuration.

set_boolean(key, value)

Adds the given key/value pair to the configuration object.

set_bytearray(key, value)

Adds the given byte array to the configuration object.

set_float(key, value)

Adds the given key/value pair to the configuration object.

set_integer(key, value)

Adds the given key/value pair to the configuration object.

set_string(key, value)

Adds the given key/value pair to the configuration object.

to_dict()

Converts the configuration into a dict representation of string key-pair.

previous

Config

next

pyflink.common.config_options.ConfigOptions

On this page
  • Configuration
Show Source

Created using Sphinx 5.3.0.