How to use the pyflink.common.Configuration function in pyflink
To help you get started, we’ve selected a few pyflink examples, based on popular ways it is used in public projects.
Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
apache / flink / flink-python / pyflink / table / table_config.py View on Github 
def get_configuration(self):
"""
Gives direct access to the underlying key-value map for advanced configuration.
:return: Entire key-value configuration.
:rtype: Configuration
"""
return Configuration(j_configuration=self._j_table_config.getConfiguration())def get_configuration(self):
"""
Gives direct access to the underlying key-value map for advanced configuration.
:return: Entire key-value configuration.
:rtype: Configuration
"""
return Configuration(j_configuration=self._j_table_config.getConfiguration())pyflink
Flink Python API
Apache-2.0
Latest version published 6 years agoPackage Health Score
42 / 100Popular pyflink functions
- pyflink.common.Configuration
- pyflink.common.dependency_manager.DependencyManager
- pyflink.common.restart_strategy.RestartStrategies._from_j_restart_strategy
- pyflink.dataset.ExecutionEnvironment.get_execution_environment
- pyflink.datastream.stream_execution_environment.StreamExecutionEnvironment
- pyflink.datastream.stream_execution_environment.StreamExecutionEnvironment.get_execution_environment
- pyflink.datastream.StreamExecutionEnvironment.get_execution_environment
- pyflink.fn_execution.coder_impl
- pyflink.java_gateway.get_gateway
- pyflink.table.BatchTableEnvironment.create
- pyflink.table.EnvironmentSettings.new_instance
- pyflink.table.StreamTableEnvironment
- pyflink.table.StreamTableEnvironment.create
- pyflink.table.Table
- pyflink.table.types._to_java_type
- pyflink.table.types.DataTypes
- pyflink.table.types.DataTypes.STRING
- pyflink.util.utils
- pyflink.util.utils.load_java_class
- pyflink.util.utils.to_jarray