org.apache.shardingsphere.data.pipeline.core.context

类 AbstractPipelineProcessContext

java.lang.Object

org.apache.shardingsphere.data.pipeline.core.context.AbstractPipelineProcessContext

所有已实现的接口:

PipelineProcessContext

直接已知子类:

MigrationProcessContext

public abstract class AbstractPipelineProcessContext
extends Object
implements PipelineProcessContext

Abstract pipeline process context.

构造器概要

构造器

构造器和说明
AbstractPipelineProcessContext(String jobId, PipelineProcessConfiguration originalProcessConfig)

方法概要

限定符和类型	方法和说明
ExecuteEngine	getImporterExecuteEngine() Get importer execute engine.
ExecuteEngine	getIncrementalDumperExecuteEngine() Get incremental dumper execute engine.
ExecuteEngine	getInventoryDumperExecuteEngine() Get inventory dumper execute engine.

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

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

从接口继承的方法 org.apache.shardingsphere.data.pipeline.api.context.PipelineProcessContext

getPipelineChannelCreator, getPipelineProcessConfig, getReadRateLimitAlgorithm, getWriteRateLimitAlgorithm

构造器详细资料

AbstractPipelineProcessContext

public AbstractPipelineProcessContext(String jobId,
                                      PipelineProcessConfiguration originalProcessConfig)

方法详细资料

getInventoryDumperExecuteEngine

public ExecuteEngine getInventoryDumperExecuteEngine()

Get inventory dumper execute engine.

返回:

inventory dumper execute engine

getIncrementalDumperExecuteEngine

public ExecuteEngine getIncrementalDumperExecuteEngine()

Get incremental dumper execute engine.

返回:

incremental dumper execute engine

getImporterExecuteEngine

public ExecuteEngine getImporterExecuteEngine()

Get importer execute engine.

返回:

importer execute engine