| 限定符和类型 | 方法和说明 |
|---|---|
IncrementalDumper |
IncrementalDumperCreator.createIncrementalDumper(DumperConfiguration dumperConfig,
IngestPosition<P> position,
PipelineChannel channel,
PipelineTableMetaDataLoader metaDataLoader)
Create incremental dumper.
|
InventoryDumper |
InventoryDumperCreator.createInventoryDumper(InventoryDumperConfiguration inventoryDumperConfig,
PipelineChannel channel,
DataSource sourceDataSource,
PipelineTableMetaDataLoader sourceMetaDataLoader)
Create Inventory Dumper.
|
InventoryDumper |
DefaultInventoryDumperCreator.createInventoryDumper(InventoryDumperConfiguration inventoryDumperConfig,
PipelineChannel channel,
DataSource sourceDataSource,
PipelineTableMetaDataLoader sourceMetaDataLoader) |
| 构造器和说明 |
|---|
AbstractIncrementalDumper(DumperConfiguration dumperConfig,
IngestPosition<P> position,
PipelineChannel channel,
PipelineTableMetaDataLoader metaDataLoader) |
AbstractInventoryDumper(InventoryDumperConfiguration inventoryDumperConfig,
PipelineChannel channel,
DataSource dataSource,
PipelineTableMetaDataLoader metaDataLoader) |
DefaultInventoryDumper(InventoryDumperConfiguration inventoryDumperConfig,
PipelineChannel channel,
DataSource dataSource,
PipelineTableMetaDataLoader metaDataLoader) |
| 构造器和说明 |
|---|
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) |
| 限定符和类型 | 方法和说明 |
|---|---|
PipelineTableMetaDataLoader |
MigrationJobItemContext.getSourceMetaDataLoader()
Get source metadata loader.
|
Copyright © 2022 The Apache Software Foundation. All rights reserved.