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

接口 InventoryIncrementalProcessContext

所有超级接口:

PipelineProcessContext

所有已知实现类:

AbstractInventoryIncrementalProcessContext, MigrationProcessContext

public interface InventoryIncrementalProcessContext
extends PipelineProcessContext

Inventory incremental process context.

方法概要

限定符和类型	方法和说明
ExecuteEngine	getInventoryDumperExecuteEngine() Get inventory dumper execute engine.
ExecuteEngine	getInventoryImporterExecuteEngine() Get inventory importer execute engine.
PipelineChannelCreator	getPipelineChannelCreator() Get pipeline channel creator.
JobRateLimitAlgorithm	getReadRateLimitAlgorithm() Get job read rate limit algorithm.
JobRateLimitAlgorithm	getWriteRateLimitAlgorithm() Get job write rate limit algorithm.

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

getPipelineProcessConfig

方法详细资料

getPipelineChannelCreator

PipelineChannelCreator getPipelineChannelCreator()

Get pipeline channel creator.

返回:

pipeline channel creator

getInventoryDumperExecuteEngine

ExecuteEngine getInventoryDumperExecuteEngine()

Get inventory dumper execute engine.

返回:

inventory dumper execute engine

getInventoryImporterExecuteEngine

ExecuteEngine getInventoryImporterExecuteEngine()

Get inventory importer execute engine.

返回:

inventory importer execute engine

getReadRateLimitAlgorithm

JobRateLimitAlgorithm getReadRateLimitAlgorithm()

Get job read rate limit algorithm.

返回:

job read rate limit algorithm

getWriteRateLimitAlgorithm

JobRateLimitAlgorithm getWriteRateLimitAlgorithm()

Get job write rate limit algorithm.

返回:

job write rate limit algorithm