类的使用
org.apache.shardingsphere.data.pipeline.core.execute.ExecuteEngine

使用ExecuteEngine的程序包

程序包	说明
org.apache.shardingsphere.data.pipeline.core.context
org.apache.shardingsphere.data.pipeline.core.execute
org.apache.shardingsphere.data.pipeline.core.task

org.apache.shardingsphere.data.pipeline.core.context中ExecuteEngine的使用

返回ExecuteEngine的org.apache.shardingsphere.data.pipeline.core.context中的方法

限定符和类型	方法和说明
ExecuteEngine	AbstractInventoryIncrementalProcessContext.getIncrementalExecuteEngine() Get incremental execute engine.
ExecuteEngine	InventoryIncrementalProcessContext.getInventoryDumperExecuteEngine() Get inventory dumper execute engine.
ExecuteEngine	AbstractInventoryIncrementalProcessContext.getInventoryDumperExecuteEngine()
ExecuteEngine	InventoryIncrementalProcessContext.getInventoryImporterExecuteEngine() Get inventory importer execute engine.
ExecuteEngine	AbstractInventoryIncrementalProcessContext.getInventoryImporterExecuteEngine()

org.apache.shardingsphere.data.pipeline.core.execute中ExecuteEngine的使用

返回ExecuteEngine的org.apache.shardingsphere.data.pipeline.core.execute中的方法

限定符和类型	方法和说明
static ExecuteEngine	ExecuteEngine.newCachedThreadInstance(String threadName) Create task execute engine instance with cached thread pool.
static ExecuteEngine	ExecuteEngine.newFixedThreadInstance(int threadNumber, String threadName) Create task execute engine instance with fixed thread pool.

org.apache.shardingsphere.data.pipeline.core.task中ExecuteEngine的使用

参数类型为ExecuteEngine的org.apache.shardingsphere.data.pipeline.core.task中的构造器

构造器和说明
IncrementalTask(int concurrency, DumperConfiguration dumperConfig, ImporterConfiguration importerConfig, PipelineChannelCreator pipelineChannelCreator, PipelineDataSourceManager dataSourceManager, PipelineTableMetaDataLoader sourceMetaDataLoader, ExecuteEngine incrementalExecuteEngine, PipelineJobProgressListener jobProgressListener)
InventoryTask(InventoryDumperConfiguration inventoryDumperConfig, ImporterConfiguration importerConfig, PipelineChannelCreator pipelineChannelCreator, PipelineDataSourceManager dataSourceManager, DataSource sourceDataSource, PipelineTableMetaDataLoader sourceMetaDataLoader, ExecuteEngine inventoryDumperExecuteEngine, ExecuteEngine inventoryImporterExecuteEngine, PipelineJobProgressListener jobProgressListener)