org.apache.shardingsphere.data.pipeline.core.metadata.node

类 PipelineMetaDataNode

java.lang.Object

org.apache.shardingsphere.data.pipeline.core.metadata.node.PipelineMetaDataNode

public final class PipelineMetaDataNode
extends Object

Pipeline meta data node.

字段概要

字段

限定符和类型	字段和说明
static Pattern	BARRIER_PATTERN
static Pattern	CONFIG_PATTERN

构造器概要

构造器

构造器和说明
PipelineMetaDataNode()

方法概要

限定符和类型	方法和说明
static String	getCheckJobIdPath(String jobId, String checkJobId) Get check job id path.
static String	getCheckJobIdsRootPath(String jobId) Get check job ids root path.
static String	getCheckJobResultPath(String jobId, String checkJobId) Get check job result path.
static String	getCheckLatestJobIdPath(String jobId) Get check latest job id path.
static String	getElasticJobNamespace() Get ElasticJob namespace.
static String	getJobBarrierDisablePath(String jobId) Get job barrier disable path.
static String	getJobBarrierEnablePath(String jobId) Get job barrier enable path.
static String	getJobConfigPath(String jobId) Get job config path.
static String	getJobItemErrorMessagePath(String jobId, int shardingItem) Get job item error msg.
static String	getJobOffsetItemPath(String jobId, int shardingItem) Get job offset item path.
static String	getJobOffsetPath(String jobId) Get job offset path.
static String	getJobRootPath(String jobId) Get job root path.
static String	getMetaDataDataSourcesPath(JobType jobType) Get metadata data sources path.
static String	getMetaDataProcessConfigPath(JobType jobType) Get metadata process configuration path.

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

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

字段详细资料

CONFIG_PATTERN

public static final Pattern CONFIG_PATTERN

BARRIER_PATTERN

public static final Pattern BARRIER_PATTERN

构造器详细资料

PipelineMetaDataNode

public PipelineMetaDataNode()

方法详细资料

getMetaDataDataSourcesPath

public static String getMetaDataDataSourcesPath(JobType jobType)

Get metadata data sources path.

参数:

jobType - job type

返回:

data sources path

getMetaDataProcessConfigPath

public static String getMetaDataProcessConfigPath(JobType jobType)

Get metadata process configuration path.

参数:

jobType - job type

返回:

data sources path

getElasticJobNamespace

public static String getElasticJobNamespace()

Get ElasticJob namespace.

返回:

namespace

getJobRootPath

public static String getJobRootPath(String jobId)

Get job root path.

参数:

jobId - job id.

返回:

root path

getJobOffsetItemPath

public static String getJobOffsetItemPath(String jobId,
                                          int shardingItem)

Get job offset item path.

参数:

jobId - job id

shardingItem - sharding item

返回:

job offset path

getJobOffsetPath

public static String getJobOffsetPath(String jobId)

Get job offset path.

参数:

jobId - job id

返回:

job offset path

getJobConfigPath

public static String getJobConfigPath(String jobId)

Get job config path.

参数:

jobId - job id

返回:

job configuration path

getCheckLatestJobIdPath

public static String getCheckLatestJobIdPath(String jobId)

Get check latest job id path.

参数:

jobId - job id

返回:

check latest job id path

getCheckJobResultPath

public static String getCheckJobResultPath(String jobId,
                                           String checkJobId)

Get check job result path.

参数:

jobId - job id

checkJobId - check job id

返回:

check latest result path

getCheckJobIdsRootPath

public static String getCheckJobIdsRootPath(String jobId)

Get check job ids root path.

参数:

jobId - job id

返回:

check job ids root path

getCheckJobIdPath

public static String getCheckJobIdPath(String jobId,
                                       String checkJobId)

Get check job id path.

参数:

jobId - job id

checkJobId - check job id

返回:

check job id path

getJobBarrierEnablePath

public static String getJobBarrierEnablePath(String jobId)

Get job barrier enable path.

参数:

jobId - job id

返回:

job barrier enable path

getJobBarrierDisablePath

public static String getJobBarrierDisablePath(String jobId)

Get job barrier disable path.

参数:

jobId - job id

返回:

job barrier disable path

getJobItemErrorMessagePath

public static String getJobItemErrorMessagePath(String jobId,
                                                int shardingItem)

Get job item error msg.

参数:

jobId - job id

shardingItem - sharding item

返回:

job item error msg