类的使用
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	AbstractPipelineProcessContext.getImporterExecuteEngine() Get importer execute engine.
ExecuteEngine	AbstractPipelineProcessContext.getIncrementalDumperExecuteEngine() Get incremental dumper execute engine.
ExecuteEngine	AbstractPipelineProcessContext.getInventoryDumperExecuteEngine() Get inventory dumper execute engine.

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 incrementalDumperExecuteEngine, PipelineJobProgressListener jobProgressListener)
InventoryTask(InventoryDumperConfiguration inventoryDumperConfig, ImporterConfiguration importerConfig, PipelineChannelCreator pipelineChannelCreator, PipelineDataSourceManager dataSourceManager, DataSource sourceDataSource, PipelineTableMetaDataLoader sourceMetaDataLoader, ExecuteEngine importerExecuteEngine, PipelineJobProgressListener jobProgressListener)