org.apache.paimon.benchmark.utils

Class BenchmarkGlobalConfiguration

java.lang.Object

org.apache.paimon.benchmark.utils.BenchmarkGlobalConfiguration

public final class BenchmarkGlobalConfiguration
extends Object

Global configuration object for benchmark. Similar to Java properties configuration objects it includes key-value pairs which represent the framework's configuration.

Field Summary

Fields

Modifier and Type	Field and Description
static String	BENCHMARK_CONF_FILENAME

Method Summary

Modifier and Type	Method and Description
static org.apache.flink.configuration.Configuration	loadConfiguration() Loads the global configuration from the environment.
static org.apache.flink.configuration.Configuration	loadConfiguration(org.apache.flink.configuration.Configuration dynamicProperties) Loads the global configuration and adds the given dynamic properties configuration.
static org.apache.flink.configuration.Configuration	loadConfiguration(String configDir) Loads the configuration files from the specified directory.
static org.apache.flink.configuration.Configuration	loadConfiguration(String configDir, org.apache.flink.configuration.Configuration dynamicProperties) Loads the configuration files from the specified directory.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

BENCHMARK_CONF_FILENAME

public static final String BENCHMARK_CONF_FILENAME

See Also:

Constant Field Values

Method Detail

loadConfiguration

public static org.apache.flink.configuration.Configuration loadConfiguration()

Loads the global configuration from the environment. Fails if an error occurs during loading. Returns an empty configuration object if the environment variable is not set. In production this variable is set but tests and local execution/debugging don't have this environment variable set. That's why we should fail if it is not set.

Returns:

Returns the Configuration

loadConfiguration

public static org.apache.flink.configuration.Configuration loadConfiguration(org.apache.flink.configuration.Configuration dynamicProperties)

Loads the global configuration and adds the given dynamic properties configuration.

Parameters:

dynamicProperties - The given dynamic properties

Returns:

Returns the loaded global configuration with dynamic properties

loadConfiguration

public static org.apache.flink.configuration.Configuration loadConfiguration(String configDir)

Loads the configuration files from the specified directory.

YAML files are supported as configuration files.

Parameters:

configDir - the directory which contains the configuration files

loadConfiguration

public static org.apache.flink.configuration.Configuration loadConfiguration(String configDir,
                                                                             @Nullable
                                                                             org.apache.flink.configuration.Configuration dynamicProperties)

Loads the configuration files from the specified directory. If the dynamic properties configuration is not null, then it is added to the loaded configuration.

Parameters:

configDir - directory to load the configuration from

dynamicProperties - configuration file containing the dynamic properties. Null if none.

Returns:

The configuration loaded from the given configuration directory