org.apache.shardingsphere.data.pipeline.core.config.process

类 PipelineProcessConfigurationUtil

java.lang.Object

org.apache.shardingsphere.data.pipeline.core.config.process.PipelineProcessConfigurationUtil

public final class PipelineProcessConfigurationUtil
extends Object

Pipeline process configuration util.

构造器概要

构造器

构造器和说明
PipelineProcessConfigurationUtil()

方法概要

限定符和类型	方法和说明
static PipelineProcessConfiguration	convertWithDefaultValue(PipelineProcessConfiguration originalConfig) Convert with default value.
static void	fillInDefaultValue(YamlPipelineProcessConfiguration yamlConfig) Fill in default value.
static void	setFieldsNullByConfPath(YamlPipelineProcessConfiguration targetYamlProcessConfig, String confPath) Set fields to null by configuration path.
static void	verifyConfPath(String confPath) Verify configuration path valid or not.

从类继承的方法 java.lang.Object

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

构造器详细资料

PipelineProcessConfigurationUtil

public PipelineProcessConfigurationUtil()

方法详细资料

convertWithDefaultValue

public static PipelineProcessConfiguration convertWithDefaultValue(PipelineProcessConfiguration originalConfig)

Convert with default value.

参数:

originalConfig - original process configuration, nullable

返回:

process configuration

fillInDefaultValue

public static void fillInDefaultValue(YamlPipelineProcessConfiguration yamlConfig)

Fill in default value.

参数:

yamlConfig - YAML configuration, non-null

verifyConfPath

public static void verifyConfPath(String confPath)

Verify configuration path valid or not.

参数:

confPath - configuration path

抛出:

IllegalArgumentException - if path doesn't match pattern

setFieldsNullByConfPath

public static void setFieldsNullByConfPath(YamlPipelineProcessConfiguration targetYamlProcessConfig,
                                           String confPath)

Set fields to null by configuration path.

参数:

targetYamlProcessConfig - target YAML process configuration

confPath - configuration path, e.g. /, /READ, /READ/RATE_LIMITER