索引 (shardingsphere-data-pipeline-core 5.2.1 API)

A B C D E F G H I L M N O P Q R S T U V W Y

A

AbstractDataConsistencyCalculateAlgorithm - org.apache.shardingsphere.data.pipeline.core.check.consistency.algorithm中的类: Abstract data consistency calculate algorithm.
AbstractDataConsistencyCalculateAlgorithm() - 类的构造器org.apache.shardingsphere.data.pipeline.core.check.consistency.algorithm.AbstractDataConsistencyCalculateAlgorithm
AbstractDataSourceChecker - org.apache.shardingsphere.data.pipeline.core.check.datasource中的类: Abstract data source checker.
AbstractDataSourceChecker() - 类的构造器org.apache.shardingsphere.data.pipeline.core.check.datasource.AbstractDataSourceChecker
AbstractDataSourcePreparer - org.apache.shardingsphere.data.pipeline.core.prepare.datasource中的类: Abstract data source preparer.
AbstractDataSourcePreparer() - 类的构造器org.apache.shardingsphere.data.pipeline.core.prepare.datasource.AbstractDataSourcePreparer
AbstractInventoryIncrementalJobAPIImpl - org.apache.shardingsphere.data.pipeline.core.api.impl中的类: Abstract inventory incremental job API implementation.
AbstractInventoryIncrementalJobAPIImpl() - 类的构造器org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractInventoryIncrementalJobAPIImpl
AbstractInventoryIncrementalProcessContext - org.apache.shardingsphere.data.pipeline.core.context中的类: Abstract inventory incremental process context.
AbstractInventoryIncrementalProcessContext(String, PipelineProcessConfiguration) - 类的构造器org.apache.shardingsphere.data.pipeline.core.context.AbstractInventoryIncrementalProcessContext
AbstractPipelineJob - org.apache.shardingsphere.data.pipeline.core.job中的类: Abstract pipeline job.
AbstractPipelineJob() - 类的构造器org.apache.shardingsphere.data.pipeline.core.job.AbstractPipelineJob
AbstractPipelineJobAPIImpl - org.apache.shardingsphere.data.pipeline.core.api.impl中的类: Abstract pipeline job API impl.
AbstractPipelineJobAPIImpl() - 类的构造器org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractPipelineJobAPIImpl
AbstractPipelineJobId - org.apache.shardingsphere.data.pipeline.core.job中的类: Abstract pipeline job id.
AbstractPipelineJobId(JobType, String) - 类的构造器org.apache.shardingsphere.data.pipeline.core.job.AbstractPipelineJobId
AbstractPipelineSQLBuilder - org.apache.shardingsphere.data.pipeline.core.sqlbuilder中的类: Abstract pipeline SQL builder.
AbstractPipelineSQLBuilder() - 类的构造器org.apache.shardingsphere.data.pipeline.core.sqlbuilder.AbstractPipelineSQLBuilder
AbstractStreamingDataConsistencyCalculateAlgorithm - org.apache.shardingsphere.data.pipeline.core.check.consistency.algorithm中的类: Streaming data consistency calculate algorithm.
AbstractStreamingDataConsistencyCalculateAlgorithm() - 类的构造器org.apache.shardingsphere.data.pipeline.core.check.consistency.algorithm.AbstractStreamingDataConsistencyCalculateAlgorithm
ack(List<Record>) - 类中的方法org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory.MultiplexMemoryPipelineChannel
ack(List<Record>) - 类中的方法org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory.SimpleMemoryPipelineChannel
addIfNotExistsForCreateTableSQL(String) - 类中的方法org.apache.shardingsphere.data.pipeline.core.prepare.datasource.AbstractDataSourcePreparer
addJob(String, PipelineJob) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.job.PipelineJobCenter: Add job.
addJobProgressPersistContext(String, int) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.job.progress.persist.PipelineJobProgressPersistService: Add job progress persist context.
AddMigrationSourceResourceException - org.apache.shardingsphere.data.pipeline.core.exception.connection中的异常错误: Add migration source resource exception.
AddMigrationSourceResourceException(Collection<String>) - 异常错误的构造器org.apache.shardingsphere.data.pipeline.core.exception.connection.AddMigrationSourceResourceException
addMigrationSourceResources(Map<String, DataSourceProperties>) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPIImpl
aggregateDataConsistencyCheckResults(String, Map<String, DataConsistencyCheckResult>) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractInventoryIncrementalJobAPIImpl
aggregateDataConsistencyCheckResults(String, Map<String, DataConsistencyCheckResult>) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.api.InventoryIncrementalJobAPI: Aggregate data consistency check results.
allInventoryTasksFinished(Collection<InventoryTask>) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.job.progress.PipelineJobProgressDetector: All inventory tasks is finished.
AlterNotExistProcessConfigurationException - org.apache.shardingsphere.data.pipeline.core.exception.metadata中的异常错误: Alter not exist process configuration exception.
AlterNotExistProcessConfigurationException() - 异常错误的构造器org.apache.shardingsphere.data.pipeline.core.exception.metadata.AlterNotExistProcessConfigurationException
alterProcessConfiguration(PipelineProcessConfiguration) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractInventoryIncrementalJobAPIImpl
await(String, long, TimeUnit) - 类中的方法org.apache.shardingsphere.data.pipeline.core.util.PipelineDistributedBarrier: Await until all children node is ready.

B

BARRIER_PATTERN - 类中的静态变量org.apache.shardingsphere.data.pipeline.core.metadata.node.PipelineMetaDataNode
BarrierMetaDataChangedEventHandler - org.apache.shardingsphere.data.pipeline.core.metadata.node.event.handler.impl中的类: Barrier meta data changed event handler.
BarrierMetaDataChangedEventHandler() - 类的构造器org.apache.shardingsphere.data.pipeline.core.metadata.node.event.handler.impl.BarrierMetaDataChangedEventHandler
BasicColumnValueReader - org.apache.shardingsphere.data.pipeline.core.ingest.dumper中的类: Basic column value reader.
BasicColumnValueReader() - 类的构造器org.apache.shardingsphere.data.pipeline.core.ingest.dumper.BasicColumnValueReader
BasicDataSourceChecker - org.apache.shardingsphere.data.pipeline.core.check.datasource中的类: Basic data source checker.
BasicDataSourceChecker() - 类的构造器org.apache.shardingsphere.data.pipeline.core.check.datasource.BasicDataSourceChecker
BinlogSyncChannelAlreadyClosedException - org.apache.shardingsphere.data.pipeline.core.exception.job中的异常错误: Binlog sync channel already closed exception.
BinlogSyncChannelAlreadyClosedException() - 异常错误的构造器org.apache.shardingsphere.data.pipeline.core.exception.job.BinlogSyncChannelAlreadyClosedException
BLOCK_QUEUE_SIZE_DEFAULT_VALUE - 类中的静态变量org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory.MemoryPipelineChannelCreator
BLOCK_QUEUE_SIZE_KEY - 类中的静态变量org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory.MemoryPipelineChannelCreator
buildCheckEmptySQL(String, String) - 类中的方法org.apache.shardingsphere.data.pipeline.core.sqlbuilder.AbstractPipelineSQLBuilder
buildCheckEmptySQL(String, String) - 类中的方法org.apache.shardingsphere.data.pipeline.core.sqlbuilder.OraclePipelineSQLBuilder
buildChunkedQuerySQL(String, String, String, boolean) - 类中的方法org.apache.shardingsphere.data.pipeline.core.sqlbuilder.AbstractPipelineSQLBuilder
buildChunkedQuerySQL(String, String, String, boolean) - 类中的方法org.apache.shardingsphere.data.pipeline.core.sqlbuilder.OraclePipelineSQLBuilder
buildCountSQL(String, String) - 类中的方法org.apache.shardingsphere.data.pipeline.core.sqlbuilder.AbstractPipelineSQLBuilder
buildDataConsistencyCalculateAlgorithm(PipelineJobConfiguration, String, Properties) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractInventoryIncrementalJobAPIImpl
buildDataConsistencyCalculateAlgorithm(PipelineJobConfiguration, String, Properties) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.api.InventoryIncrementalJobAPI: Build data consistency calculate algorithm.
buildDeleteSQL(String, DataRecord, Collection<Column>) - 类中的方法org.apache.shardingsphere.data.pipeline.core.sqlbuilder.AbstractPipelineSQLBuilder
buildDivisibleInventoryDumpSQL(String, String, String, int, boolean) - 类中的方法org.apache.shardingsphere.data.pipeline.core.sqlbuilder.AbstractPipelineSQLBuilder
buildDivisibleInventoryDumpSQL(String, String, String, int, boolean) - 类中的方法org.apache.shardingsphere.data.pipeline.core.sqlbuilder.OraclePipelineSQLBuilder
buildDropSQL(String, String) - 类中的方法org.apache.shardingsphere.data.pipeline.core.sqlbuilder.AbstractPipelineSQLBuilder
buildIndivisibleInventoryDumpSQL(String, String, String, int, boolean) - 类中的方法org.apache.shardingsphere.data.pipeline.core.sqlbuilder.AbstractPipelineSQLBuilder
buildIndivisibleInventoryDumpSQL(String, String, String, int, boolean) - 类中的方法org.apache.shardingsphere.data.pipeline.core.sqlbuilder.OraclePipelineSQLBuilder
buildInsertSQL(String, DataRecord, Map<LogicTableName, Set<String>>) - 类中的方法org.apache.shardingsphere.data.pipeline.core.sqlbuilder.AbstractPipelineSQLBuilder
buildInsertSQL(String, DataRecord, Map<LogicTableName, Set<String>>) - 类中的方法org.apache.shardingsphere.data.pipeline.core.sqlbuilder.OraclePipelineSQLBuilder
buildPipelineDataConsistencyChecker(PipelineJobConfiguration, InventoryIncrementalProcessContext, ConsistencyCheckJobItemContext) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractInventoryIncrementalJobAPIImpl
buildPipelineDataConsistencyChecker(PipelineJobConfiguration, InventoryIncrementalProcessContext, ConsistencyCheckJobItemContext) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPIImpl
buildPipelineProcessContext(PipelineJobConfiguration) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractInventoryIncrementalJobAPIImpl
buildPipelineProcessContext(PipelineJobConfiguration) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.api.PipelineJobAPI: Build pipeline process context.
buildPipelineProcessContext(PipelineJobConfiguration) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobAPIImpl
buildPipelineProcessContext(PipelineJobConfiguration) - 接口中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPI
buildPipelineProcessContext(PipelineJobConfiguration) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPIImpl
buildSplitByPrimaryKeyRangeSQL(String, String, String) - 类中的方法org.apache.shardingsphere.data.pipeline.core.sqlbuilder.AbstractPipelineSQLBuilder
buildSplitByPrimaryKeyRangeSQL(String, String, String) - 类中的方法org.apache.shardingsphere.data.pipeline.core.sqlbuilder.OraclePipelineSQLBuilder
buildTaskConfiguration(PipelineJobConfiguration, int, PipelineProcessConfiguration) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.api.PipelineJobAPI: Build task configuration.
buildTaskConfiguration(PipelineJobConfiguration, int, PipelineProcessConfiguration) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobAPIImpl
buildTaskConfiguration(PipelineJobConfiguration, int, PipelineProcessConfiguration) - 接口中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPI
buildTaskConfiguration(PipelineJobConfiguration, int, PipelineProcessConfiguration) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPIImpl
buildUpdateSQL(String, DataRecord, Collection<Column>, Map<LogicTableName, Set<String>>) - 类中的方法org.apache.shardingsphere.data.pipeline.core.sqlbuilder.AbstractPipelineSQLBuilder
buildWithDefaultValue() - 类中的静态方法org.apache.shardingsphere.data.pipeline.yaml.process.YamlPipelineReadConfiguration: Build with default value.
buildWithDefaultValue() - 类中的静态方法org.apache.shardingsphere.data.pipeline.yaml.process.YamlPipelineWriteConfiguration: Build with default value.

C

calculate(DataConsistencyCalculateParameter) - 类中的方法org.apache.shardingsphere.data.pipeline.core.check.consistency.algorithm.AbstractStreamingDataConsistencyCalculateAlgorithm
calculate(DataConsistencyCalculateParameter) - 类中的方法org.apache.shardingsphere.data.pipeline.core.check.consistency.algorithm.CRC32MatchDataConsistencyCalculateAlgorithm
calculateChunk(DataConsistencyCalculateParameter) - 类中的方法org.apache.shardingsphere.data.pipeline.core.check.consistency.algorithm.AbstractStreamingDataConsistencyCalculateAlgorithm: Calculate chunked records at one time.
calculateChunk(DataConsistencyCalculateParameter) - 类中的方法org.apache.shardingsphere.data.pipeline.core.check.consistency.algorithm.DataMatchDataConsistencyCalculateAlgorithm
cancel() - 类中的方法org.apache.shardingsphere.data.pipeline.core.check.consistency.algorithm.AbstractDataConsistencyCalculateAlgorithm
ChangedJobConfigurationDispatcher - org.apache.shardingsphere.data.pipeline.core.metadata.node.event.handler.impl中的类: Changed job configuration dispatcher.
ChangedJobConfigurationDispatcher() - 类的构造器org.apache.shardingsphere.data.pipeline.core.metadata.node.event.handler.impl.ChangedJobConfigurationDispatcher
check(DataConsistencyCalculateAlgorithm) - 类中的方法org.apache.shardingsphere.data.pipeline.core.check.consistency.SingleTableInventoryDataConsistencyChecker: Data consistency check.
check(DataConsistencyCalculateAlgorithm) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationDataConsistencyChecker
checkChildrenNodeCount(DataChangedEvent) - 类中的方法org.apache.shardingsphere.data.pipeline.core.util.PipelineDistributedBarrier: Check child node count equal shardingCount.
checkConnection(Collection<? extends DataSource>) - 类中的方法org.apache.shardingsphere.data.pipeline.core.check.datasource.AbstractDataSourceChecker
checkModeConfig() - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractPipelineJobAPIImpl
checkPrivilege(Collection<? extends DataSource>) - 类中的方法org.apache.shardingsphere.data.pipeline.core.check.datasource.BasicDataSourceChecker
checkSourceDataSource(String, Collection<? extends DataSource>) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.prepare.PipelineJobPreparerUtils: Check data source.
checkTargetDataSource(String, ImporterConfiguration, Collection<? extends DataSource>) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.prepare.PipelineJobPreparerUtils: Check target data source.
checkTargetTable(Collection<? extends DataSource>, TableNameSchemaNameMapping, Collection<String>) - 类中的方法org.apache.shardingsphere.data.pipeline.core.check.datasource.AbstractDataSourceChecker
checkVariable(Collection<? extends DataSource>) - 类中的方法org.apache.shardingsphere.data.pipeline.core.check.datasource.BasicDataSourceChecker
choose(DatabaseType, DatabaseType) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.check.consistency.DataConsistencyCalculateAlgorithmChooser: Choose data consistency calculate algorithm when it's not defined.
cleanJobItemErrorMessage(String, int) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.api.GovernanceRepositoryAPI: Clean job item error message.
cleanJobItemErrorMessage(String, int) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractPipelineJobAPIImpl
cleanJobItemErrorMessage(String, int) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.GovernanceRepositoryAPIImpl
cleanJobItemErrorMessage(String, int) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.api.PipelineJobAPI: Clean job item error message.
cleanup(MigrationJobConfiguration) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobPreparer: Do cleanup work.
clear(long) - 类中的方法org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory.ManualBitSet: Clear expire BitSet.
close() - 类中的方法org.apache.shardingsphere.data.pipeline.core.datasource.DefaultPipelineDataSourceManager: Close, close cached data source.
close() - 类中的方法org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory.MultiplexMemoryPipelineChannel
close() - 类中的方法org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory.SimpleMemoryPipelineChannel
close() - 类中的方法org.apache.shardingsphere.data.pipeline.core.task.IncrementalTask
close() - 类中的方法org.apache.shardingsphere.data.pipeline.core.task.InventoryTask
ColumnValueReaderFactory - org.apache.shardingsphere.data.pipeline.core.ingest.dumper中的类: Column value reader factory.
ColumnValueReaderFactory() - 类的构造器org.apache.shardingsphere.data.pipeline.core.ingest.dumper.ColumnValueReaderFactory
commit(String) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPIImpl
CONFIG_PATTERN - 类中的静态变量org.apache.shardingsphere.data.pipeline.core.metadata.node.PipelineMetaDataNode
ConsistencyCheckChangedJobConfigurationProcessor - org.apache.shardingsphere.data.pipeline.scenario.consistencycheck中的类: Consistency check changed job configuration processor.
ConsistencyCheckChangedJobConfigurationProcessor() - 类的构造器org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckChangedJobConfigurationProcessor
ConsistencyCheckJob - org.apache.shardingsphere.data.pipeline.scenario.consistencycheck中的类: Consistency check job.
ConsistencyCheckJob() - 类的构造器org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJob
ConsistencyCheckJobAPI - org.apache.shardingsphere.data.pipeline.scenario.consistencycheck中的接口: Consistency check job API.
ConsistencyCheckJobAPIFactory - org.apache.shardingsphere.data.pipeline.scenario.consistencycheck中的类: Consistency check job API factory.
ConsistencyCheckJobAPIFactory() - 类的构造器org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobAPIFactory
ConsistencyCheckJobAPIImpl - org.apache.shardingsphere.data.pipeline.scenario.consistencycheck中的类: Consistency check job API impl.
ConsistencyCheckJobAPIImpl() - 类的构造器org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobAPIImpl
ConsistencyCheckJobId - org.apache.shardingsphere.data.pipeline.scenario.consistencycheck中的类: Consistency check job id.
ConsistencyCheckJobId(String, int) - 类的构造器org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobId
ConsistencyCheckJobItemContext - org.apache.shardingsphere.data.pipeline.scenario.consistencycheck中的类: Consistency check job item context.
ConsistencyCheckJobItemContext(ConsistencyCheckJobConfiguration, int, JobStatus) - 类的构造器org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobItemContext
ConsistencyCheckTasksRunner - org.apache.shardingsphere.data.pipeline.scenario.consistencycheck中的类: Consistency check tasks runner.
ConsistencyCheckTasksRunner(ConsistencyCheckJobItemContext) - 类的构造器org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckTasksRunner
convertWithDefaultValue(PipelineProcessConfiguration) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.config.process.PipelineProcessConfigurationUtil: Convert with default value.
CoordinatorRegistryCenterInitializer - org.apache.shardingsphere.data.pipeline.core.registry中的类: CoordinatorRegistryCenter initializer.
CoordinatorRegistryCenterInitializer() - 类的构造器org.apache.shardingsphere.data.pipeline.core.registry.CoordinatorRegistryCenterInitializer
copyNonNullFields(YamlPipelineProcessConfiguration) - 类中的方法org.apache.shardingsphere.data.pipeline.yaml.process.YamlPipelineProcessConfiguration: Copy non-null fields from another.
copyNonNullFields(YamlPipelineReadConfiguration) - 类中的方法org.apache.shardingsphere.data.pipeline.yaml.process.YamlPipelineReadConfiguration: Copy non-null fields from another.
copyNonNullFields(YamlPipelineWriteConfiguration) - 类中的方法org.apache.shardingsphere.data.pipeline.yaml.process.YamlPipelineWriteConfiguration: Copy non-null fields from another.
CRC32MatchDataConsistencyCalculateAlgorithm - org.apache.shardingsphere.data.pipeline.core.check.consistency.algorithm中的类: CRC32 match data consistency calculate algorithm.
CRC32MatchDataConsistencyCalculateAlgorithm() - 类的构造器org.apache.shardingsphere.data.pipeline.core.check.consistency.algorithm.CRC32MatchDataConsistencyCalculateAlgorithm
CreateExistsProcessConfigurationException - org.apache.shardingsphere.data.pipeline.core.exception.metadata中的异常错误: Create exists process configuration exception.
CreateExistsProcessConfigurationException() - 异常错误的构造器org.apache.shardingsphere.data.pipeline.core.exception.metadata.CreateExistsProcessConfigurationException
createImporter(ImporterConfiguration, PipelineDataSourceManager, PipelineChannel, PipelineJobProgressListener) - 类中的方法org.apache.shardingsphere.data.pipeline.core.importer.DefaultImporterCreator
createJobAndStart(CreateConsistencyCheckJobParameter) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobAPIImpl
createJobAndStart(CreateMigrationJobParameter) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPIImpl
createPipelineChannel(int, AckCallback) - 类中的方法org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory.MemoryPipelineChannelCreator
createPipelineDataSource(Object) - 类中的方法org.apache.shardingsphere.data.pipeline.core.datasource.creator.impl.StandardPipelineDataSourceCreator
createPipelineDataSource(Object) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.datasource.creator.PipelineDataSourceCreator: Create pipeline data source.
createProcessConfiguration(PipelineProcessConfiguration) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractInventoryIncrementalJobAPIImpl
createRegistryCenter(ModeConfiguration, String) - 类中的方法org.apache.shardingsphere.data.pipeline.core.registry.CoordinatorRegistryCenterInitializer: Create registry center instance.
CreateTableSQLGenerateException - org.apache.shardingsphere.data.pipeline.core.exception.syntax中的异常错误: Create table SQL generate exception.
CreateTableSQLGenerateException(String) - 异常错误的构造器org.apache.shardingsphere.data.pipeline.core.exception.syntax.CreateTableSQLGenerateException
CURRENT_VERSION - 类中的静态变量org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobId
CURRENT_VERSION - 类中的静态变量org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobId

D

DATA_PIPELINE_NODE_NAME - 类中的静态变量org.apache.shardingsphere.data.pipeline.core.constant.DataPipelineConstants: Data pipeline node name.
DATA_PIPELINE_ROOT - 类中的静态变量org.apache.shardingsphere.data.pipeline.core.constant.DataPipelineConstants: Data pipeline root path.
DataConsistencyCalculateAlgorithmChooser - org.apache.shardingsphere.data.pipeline.core.check.consistency中的类: Data consistency calculate algorithm chooser.
DataConsistencyCalculateAlgorithmChooser() - 类的构造器org.apache.shardingsphere.data.pipeline.core.check.consistency.DataConsistencyCalculateAlgorithmChooser
dataConsistencyCheck(PipelineJobConfiguration, DataConsistencyCalculateAlgorithm, ConsistencyCheckJobItemContext) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractInventoryIncrementalJobAPIImpl
dataConsistencyCheck(PipelineJobConfiguration, DataConsistencyCalculateAlgorithm, ConsistencyCheckJobItemContext) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.api.InventoryIncrementalJobAPI: Do data consistency check.
DataConsistencyCheckUtils - org.apache.shardingsphere.data.pipeline.core.check.consistency中的类: Data consistency check utils.
DataConsistencyCheckUtils() - 类的构造器org.apache.shardingsphere.data.pipeline.core.check.consistency.DataConsistencyCheckUtils
DataMatchDataConsistencyCalculateAlgorithm - org.apache.shardingsphere.data.pipeline.core.check.consistency.algorithm中的类: Data match data consistency calculate algorithm.
DataMatchDataConsistencyCalculateAlgorithm() - 类的构造器org.apache.shardingsphere.data.pipeline.core.check.consistency.algorithm.DataMatchDataConsistencyCalculateAlgorithm
DataPipelineConstants - org.apache.shardingsphere.data.pipeline.core.constant中的类: Data pipeline constants.
DataPipelineConstants() - 类的构造器org.apache.shardingsphere.data.pipeline.core.constant.DataPipelineConstants
DataRecordMerger - org.apache.shardingsphere.data.pipeline.core.importer中的类: Data Record merger.
DataRecordMerger() - 类的构造器org.apache.shardingsphere.data.pipeline.core.importer.DataRecordMerger
DataSourceCheckerFactory - org.apache.shardingsphere.data.pipeline.core.check.datasource中的类: Data source checker.
DataSourceCheckerFactory() - 类的构造器org.apache.shardingsphere.data.pipeline.core.check.datasource.DataSourceCheckerFactory
DataSourcePreparer - org.apache.shardingsphere.data.pipeline.core.prepare.datasource中的接口: Data source preparer.
DataSourcePreparerFactory - org.apache.shardingsphere.data.pipeline.core.prepare.datasource中的类: Data source preparer factory.
DataSourcePreparerFactory() - 类的构造器org.apache.shardingsphere.data.pipeline.core.prepare.datasource.DataSourcePreparerFactory
DATE_TIME_FORMATTER - 类中的静态变量org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractPipelineJobAPIImpl
DefaultImporter - org.apache.shardingsphere.data.pipeline.core.importer中的类: Default importer.
DefaultImporter(ImporterConfiguration, PipelineDataSourceManager, PipelineChannel, PipelineJobProgressListener) - 类的构造器org.apache.shardingsphere.data.pipeline.core.importer.DefaultImporter
DefaultImporterCreator - org.apache.shardingsphere.data.pipeline.core.importer中的类: Default importer creator.
DefaultImporterCreator() - 类的构造器org.apache.shardingsphere.data.pipeline.core.importer.DefaultImporterCreator
DefaultPipelineDataSourceManager - org.apache.shardingsphere.data.pipeline.core.datasource中的类: Default pipeline data source manager.
DefaultPipelineDataSourceManager() - 类的构造器org.apache.shardingsphere.data.pipeline.core.datasource.DefaultPipelineDataSourceManager
DefaultPipelineSQLBuilder - org.apache.shardingsphere.data.pipeline.core.sqlbuilder中的类: Default pipeline SQL builder.
DefaultPipelineSQLBuilder() - 类的构造器org.apache.shardingsphere.data.pipeline.core.sqlbuilder.DefaultPipelineSQLBuilder
DefaultPositionInitializer - org.apache.shardingsphere.data.pipeline.core.ingest.position中的类: Default position initializer.
DefaultPositionInitializer() - 类的构造器org.apache.shardingsphere.data.pipeline.core.ingest.position.DefaultPositionInitializer
DELETE - 类中的静态变量org.apache.shardingsphere.data.pipeline.core.ingest.IngestDataChangeType: Delete flag.
deleteCheckJobResult(String, String) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.api.GovernanceRepositoryAPI: Delete check job result.
deleteCheckJobResult(String, String) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.GovernanceRepositoryAPIImpl
deleteJob(String) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.api.GovernanceRepositoryAPI: Delete job.
deleteJob(String) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.GovernanceRepositoryAPIImpl
destroyPosition(String, PipelineDataSourceConfiguration) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.prepare.PipelineJobPreparerUtils: Cleanup job preparer.
doStop() - 类中的方法org.apache.shardingsphere.data.pipeline.core.importer.DefaultImporter
doStop() - 类中的方法org.apache.shardingsphere.data.pipeline.core.ingest.dumper.InventoryDumper
dropJob(String) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractPipelineJobAPIImpl
DropMigrationSourceResourceException - org.apache.shardingsphere.data.pipeline.core.exception.connection中的异常错误: Drop migration source resource exception.
DropMigrationSourceResourceException(Collection<String>) - 异常错误的构造器org.apache.shardingsphere.data.pipeline.core.exception.connection.DropMigrationSourceResourceException
dropMigrationSourceResources(Collection<String>) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPIImpl
dropProcessConfiguration(String) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractInventoryIncrementalJobAPIImpl

E

EmptyAckCallback - org.apache.shardingsphere.data.pipeline.core.ingest.channel中的类: Empty implementation of record acknowledged callback.
EmptyAckCallback() - 类的构造器org.apache.shardingsphere.data.pipeline.core.ingest.channel.EmptyAckCallback
execute(ShardingContext) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJob
execute(ShardingContext) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJob
ExecuteCallback - org.apache.shardingsphere.data.pipeline.core.execute中的接口: Task execute callback.
ExecuteEngine - org.apache.shardingsphere.data.pipeline.core.execute中的类: Executor engine.
ExecuteEngine() - 类的构造器org.apache.shardingsphere.data.pipeline.core.execute.ExecuteEngine
executeTargetTableSQL(Connection, String) - 类中的方法org.apache.shardingsphere.data.pipeline.core.prepare.datasource.AbstractDataSourcePreparer
extendYamlJobConfiguration(YamlPipelineJobConfiguration) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.api.PipelineJobAPI: Extend YAML job configuration.
extendYamlJobConfiguration(YamlPipelineJobConfiguration) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobAPIImpl
extendYamlJobConfiguration(YamlPipelineJobConfiguration) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPIImpl
extractConditionColumns(DataRecord, Set<String>) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.record.RecordUtil: Extract condition columns(include primary and sharding columns) from data record.
extractPrimaryColumns(DataRecord) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.record.RecordUtil: Extract primary columns from data record.
extractUpdatedColumns(DataRecord) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.record.RecordUtil: Extract updated columns from data record.
extractUpdatedColumns(DataRecord, Map<LogicTableName, Set<String>>) - 类中的方法org.apache.shardingsphere.data.pipeline.core.sqlbuilder.AbstractPipelineSQLBuilder

F

fetchRecords(int, int) - 类中的方法org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory.MultiplexMemoryPipelineChannel
fetchRecords(int, int) - 类中的方法org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory.SimpleMemoryPipelineChannel
fillInDefaultValue(YamlPipelineProcessConfiguration) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.config.process.PipelineProcessConfigurationUtil: Fill in default value.
fillInNullFieldsWithDefaultValue() - 类中的方法org.apache.shardingsphere.data.pipeline.yaml.process.YamlPipelineReadConfiguration: Fill in null fields with default value.
fillInNullFieldsWithDefaultValue() - 类中的方法org.apache.shardingsphere.data.pipeline.yaml.process.YamlPipelineWriteConfiguration: Fill in null fields with default value.
findAllInstances() - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.metadata.node.event.handler.PipelineMetaDataChangedEventHandlerFactory: Get instances.

G

generateLogicDDL(DatabaseType, DataSource, String, String, String, ShardingSphereSQLParserEngine) - 类中的方法org.apache.shardingsphere.data.pipeline.core.metadata.generator.PipelineDDLGenerator: Generate logic DDL.
get(long, long) - 类中的方法org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory.ManualBitSet: Get BitSet with specified range.
getCachedDataSource(PipelineDataSourceManager, PipelineDataSourceConfiguration) - 类中的方法org.apache.shardingsphere.data.pipeline.core.prepare.datasource.AbstractDataSourcePreparer
getCheckJobIdPath(String, String) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.metadata.node.PipelineMetaDataNode: Get check job id path.
getCheckJobIdsRootPath(String) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.metadata.node.PipelineMetaDataNode: Get check job ids root path.
getCheckJobResult(String, String) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.api.GovernanceRepositoryAPI: Get check job result.
getCheckJobResult(String, String) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.GovernanceRepositoryAPIImpl
getCheckJobResultPath(String, String) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.metadata.node.PipelineMetaDataNode: Get check job result path.
getCheckLatestJobId(String) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.api.GovernanceRepositoryAPI: Get check latest job id.
getCheckLatestJobId(String) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.GovernanceRepositoryAPIImpl
getCheckLatestJobIdPath(String) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.metadata.node.PipelineMetaDataNode: Get check latest job id path.
getChildrenKeys(String) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.api.GovernanceRepositoryAPI: Get node's sub-nodes list.
getChildrenKeys(String) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.GovernanceRepositoryAPIImpl
getContextManager() - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.context.PipelineContext: Get context manager.
getCreateTargetTableSQL(CreateTableConfiguration.CreateTableEntry, PipelineDataSourceManager, ShardingSphereSQLParserEngine) - 类中的方法org.apache.shardingsphere.data.pipeline.core.prepare.datasource.AbstractDataSourcePreparer
getDatabaseType() - 类中的方法org.apache.shardingsphere.data.pipeline.core.check.datasource.AbstractDataSourceChecker
getDatabaseType() - 类中的方法org.apache.shardingsphere.data.pipeline.core.check.datasource.BasicDataSourceChecker
getDataSource(PipelineDataSourceConfiguration) - 类中的方法org.apache.shardingsphere.data.pipeline.core.datasource.DefaultPipelineDataSourceManager: Get cached data source.
getDataSourceManager() - 接口中的方法org.apache.shardingsphere.data.pipeline.core.context.InventoryIncrementalJobItemContext: Get data source manager.
getDefaultSchema(PipelineDataSourceConfiguration) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.metadata.loader.PipelineSchemaUtil: Get default schema by connection.getSchema().
getDescription() - 类中的方法org.apache.shardingsphere.data.pipeline.core.check.consistency.algorithm.CRC32MatchDataConsistencyCalculateAlgorithm
getDescription() - 类中的方法org.apache.shardingsphere.data.pipeline.core.check.consistency.algorithm.DataMatchDataConsistencyCalculateAlgorithm
getElasticJobConfigPOJO(String) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractPipelineJobAPIImpl
getElasticJobNamespace() - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.metadata.node.PipelineMetaDataNode: Get ElasticJob namespace.
getEndIndex(long, int) - 类中的方法org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory.ManualBitSet: Get end index.
getEventListenerExecutor() - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.context.PipelineContext: Get pipeline executor.
getFieldValue(Object, String, Class<T>) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.util.ReflectionUtil: Get field value from instance target object.
getGovernanceRepositoryAPI() - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.api.PipelineAPIFactory: Get governance repository API.
getIncrementalExecuteEngine() - 类中的方法org.apache.shardingsphere.data.pipeline.core.context.AbstractInventoryIncrementalProcessContext: Get incremental execute engine.
getIncrementalPosition(JobItemIncrementalTasksProgress, DumperConfiguration, PipelineDataSourceManager) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.prepare.PipelineJobPreparerUtils: Get incremental position.
getIncrementalTasks() - 接口中的方法org.apache.shardingsphere.data.pipeline.core.context.InventoryIncrementalJobItemContext: Get incremental tasks.
getInitProgress() - 接口中的方法org.apache.shardingsphere.data.pipeline.core.context.InventoryIncrementalJobItemContext: Get init progress.
getInstance(String) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.check.datasource.DataSourceCheckerFactory: Get instance of data source checker.
getInstance(String) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.datasource.creator.PipelineDataSourceCreatorFactory: Get pipeline data source creator instance.
getInstance(String) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.ingest.dumper.ColumnValueReaderFactory: Get column value reader instance.
getInstance(JobType) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.metadata.node.event.handler.PipelineChangedJobConfigurationProcessorFactory: Get instance.
getInstance() - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.metadata.node.PipelineMetaDataNodeWatcher: Get instance.
getInstance(String) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.prepare.datasource.DataSourcePreparerFactory: Get Data source preparer instance.
getInstance(String) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.sqlbuilder.PipelineSQLBuilderFactory: Get instance of pipeline SQL builder.
getInstance() - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.util.PipelineDistributedBarrier: Get instance.
getInstance() - 类中的静态方法org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobAPIFactory: Get instance of migration job API.
getInstance() - 类中的静态方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPIFactory: Get instance of migration job API.
getInventoryDumperExecuteEngine() - 类中的方法org.apache.shardingsphere.data.pipeline.core.context.AbstractInventoryIncrementalProcessContext
getInventoryDumperExecuteEngine() - 接口中的方法org.apache.shardingsphere.data.pipeline.core.context.InventoryIncrementalProcessContext: Get inventory dumper execute engine.
getInventoryImporterExecuteEngine() - 类中的方法org.apache.shardingsphere.data.pipeline.core.context.AbstractInventoryIncrementalProcessContext
getInventoryImporterExecuteEngine() - 接口中的方法org.apache.shardingsphere.data.pipeline.core.context.InventoryIncrementalProcessContext: Get inventory importer execute engine.
getInventoryTasks() - 接口中的方法org.apache.shardingsphere.data.pipeline.core.context.InventoryIncrementalJobItemContext: Get inventory tasks.
getJobBarrierDisablePath(String) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.metadata.node.PipelineMetaDataNode: Get job barrier disable path.
getJobBarrierEnablePath(String) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.metadata.node.PipelineMetaDataNode: Get job barrier enable path.
getJobClassName() - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractPipelineJobAPIImpl
getJobClassName() - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobAPIImpl
getJobClassName() - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPIImpl
getJobConfigPath(String) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.metadata.node.PipelineMetaDataNode: Get job config path.
getJobConfiguration(JobConfigurationPOJO) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractPipelineJobAPIImpl
getJobConfiguration(String) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.api.PipelineJobAPI: Get job configuration.
getJobConfiguration(String) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobAPIImpl
getJobConfiguration(JobConfigurationPOJO) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobAPIImpl
getJobConfiguration(String) - 接口中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPI
getJobConfiguration(String) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPIImpl
getJobConfiguration(JobConfigurationPOJO) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPIImpl
getJobConfigurationAPI() - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.api.PipelineAPIFactory: Get job configuration API.
getJobInfo(String) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractPipelineJobAPIImpl
getJobInfo(String) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobAPIImpl
getJobInfo(String) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPIImpl
getJobItemContext(String, int) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.job.PipelineJobCenter: Get job item context.
getJobItemErrorMessage(String, int) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.api.GovernanceRepositoryAPI: Get job item error msg.
getJobItemErrorMessage(String, int) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractPipelineJobAPIImpl
getJobItemErrorMessage(String, int) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.GovernanceRepositoryAPIImpl
getJobItemErrorMessage(String, int) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.api.PipelineJobAPI: Get job item error message.
getJobItemErrorMessagePath(String, int) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.metadata.node.PipelineMetaDataNode: Get job item error msg.
getJobItemProgress(String, int) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.api.GovernanceRepositoryAPI: Get job item progress.
getJobItemProgress(String, int) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractInventoryIncrementalJobAPIImpl
getJobItemProgress(String, int) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.GovernanceRepositoryAPIImpl
getJobItemProgress(String, int) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.InventoryIncrementalJobItemAPIImpl
getJobItemProgress(String, int) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.api.InventoryIncrementalJobAPI
getJobItemProgress(String, int) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.api.PipelineJobItemAPI: Get job item progress.
getJobItemProgress(String, int) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobAPIImpl
getJobOffsetItemPath(String, int) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.metadata.node.PipelineMetaDataNode: Get job offset item path.
getJobOffsetPath(String) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.metadata.node.PipelineMetaDataNode: Get job offset path.
getJobOperateAPI() - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.api.PipelineAPIFactory: Get job operate API.
getJobProcessContext() - 接口中的方法org.apache.shardingsphere.data.pipeline.core.context.InventoryIncrementalJobItemContext
getJobProcessContext() - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobItemContext
getJobProgress(String) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractInventoryIncrementalJobAPIImpl
getJobProgress(PipelineJobConfiguration) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractInventoryIncrementalJobAPIImpl
getJobProgress(PipelineJobConfiguration) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.api.InventoryIncrementalJobAPI: Get job progress.
getJobProgressInfo(String) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobAPIImpl
getJobRootPath(String) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.metadata.node.PipelineMetaDataNode: Get job root path.
getJobStatisticsAPI() - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.api.PipelineAPIFactory: Get job statistics API.
getJobType() - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobAPIImpl
getJobType() - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPIImpl
getJobTypeCode() - 类中的方法org.apache.shardingsphere.data.pipeline.core.job.AbstractPipelineJobId
getKeyPattern() - 类中的方法org.apache.shardingsphere.data.pipeline.core.metadata.node.event.handler.impl.BarrierMetaDataChangedEventHandler
getKeyPattern() - 类中的方法org.apache.shardingsphere.data.pipeline.core.metadata.node.event.handler.impl.ChangedJobConfigurationDispatcher
getKeyPattern() - 接口中的方法org.apache.shardingsphere.data.pipeline.core.metadata.node.event.handler.PipelineMetaDataChangedEventHandler: Get key pattern.
getLatestDataConsistencyCheckResult(String) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobAPIImpl
getMetaDataDataSources(JobType) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.api.GovernanceRepositoryAPI: Get meta data data sources.
getMetaDataDataSources(JobType) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.GovernanceRepositoryAPIImpl
getMetaDataDataSourcesPath(JobType) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.metadata.node.PipelineMetaDataNode: Get metadata data sources path.
getMetaDataProcessConfigPath(JobType) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.metadata.node.PipelineMetaDataNode: Get metadata process configuration path.
getMetaDataProcessConfiguration(JobType) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.api.GovernanceRepositoryAPI: Get meta data process configuration.
getMetaDataProcessConfiguration(JobType) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.GovernanceRepositoryAPIImpl
getModeConfig() - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.context.PipelineContext: Get mode configuration.
getPipelineChannelCreator() - 接口中的方法org.apache.shardingsphere.data.pipeline.core.context.InventoryIncrementalProcessContext: Get pipeline channel creator.
getPipelineJobAPI(JobType) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.api.PipelineAPIFactory: Get pipeline job API.
getProcessedRecordsCount() - 接口中的方法org.apache.shardingsphere.data.pipeline.core.context.InventoryIncrementalJobItemContext: Get processed record count.
getProcessedRecordsCount() - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobItemContext
getQualifiedTableName(String, String) - 类中的方法org.apache.shardingsphere.data.pipeline.core.sqlbuilder.AbstractPipelineSQLBuilder
getReadRateLimitAlgorithm() - 接口中的方法org.apache.shardingsphere.data.pipeline.core.context.InventoryIncrementalProcessContext: Get job read rate limit algorithm.
getRegistryCenter() - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.api.PipelineAPIFactory: Get registry center.
getShardingItems(String) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.api.GovernanceRepositoryAPI: Get sharding items of job.
getShardingItems(String) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.GovernanceRepositoryAPIImpl
getSourceDataSource() - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobItemContext: Get source data source.
getSourceMetaDataLoader() - 接口中的方法org.apache.shardingsphere.data.pipeline.core.context.InventoryIncrementalJobItemContext: Get source meta data loader.
getSourceMetaDataLoader() - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobItemContext
getSQLParserEngine(String) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.prepare.PipelineJobPreparerUtils: Get SQL parser engine.
getSupportedDatabaseTypes() - 类中的方法org.apache.shardingsphere.data.pipeline.core.check.consistency.algorithm.CRC32MatchDataConsistencyCalculateAlgorithm
getSupportedDatabaseTypes() - 类中的方法org.apache.shardingsphere.data.pipeline.core.check.consistency.algorithm.DataMatchDataConsistencyCalculateAlgorithm
getTableMetaData(String, String) - 类中的方法org.apache.shardingsphere.data.pipeline.core.metadata.loader.StandardPipelineTableMetaDataLoader
getTargetDatabaseName() - 类中的方法org.apache.shardingsphere.data.pipeline.yaml.job.YamlConsistencyCheckJobConfiguration
getTargetDatabaseType(PipelineJobConfiguration) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractInventoryIncrementalJobAPIImpl
getTargetDatabaseType(PipelineJobConfiguration) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPIImpl
getTaskId() - 接口中的方法org.apache.shardingsphere.data.pipeline.core.task.PipelineTask: Get task id.
getTaskProgress() - 类中的方法org.apache.shardingsphere.data.pipeline.core.task.InventoryTask
getTaskProgress() - 接口中的方法org.apache.shardingsphere.data.pipeline.core.task.PipelineTask: Get task progress.
getTasksRunner(int) - 类中的方法org.apache.shardingsphere.data.pipeline.core.job.AbstractPipelineJob
getType() - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractPipelineJobAPIImpl
getType() - 类中的方法org.apache.shardingsphere.data.pipeline.core.check.consistency.algorithm.CRC32MatchDataConsistencyCalculateAlgorithm
getType() - 类中的方法org.apache.shardingsphere.data.pipeline.core.check.consistency.algorithm.DataMatchDataConsistencyCalculateAlgorithm
getType() - 类中的方法org.apache.shardingsphere.data.pipeline.core.check.datasource.AbstractDataSourceChecker
getType() - 类中的方法org.apache.shardingsphere.data.pipeline.core.datasource.creator.impl.StandardPipelineDataSourceCreator
getType() - 类中的方法org.apache.shardingsphere.data.pipeline.core.importer.DefaultImporterCreator
getType() - 类中的方法org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory.MemoryPipelineChannelCreator
getType() - 类中的方法org.apache.shardingsphere.data.pipeline.core.ratelimit.QPSJobRateLimitAlgorithm
getType() - 类中的方法org.apache.shardingsphere.data.pipeline.core.ratelimit.TPSJobRateLimitAlgorithm
getType() - 类中的方法org.apache.shardingsphere.data.pipeline.core.sqlbuilder.OraclePipelineSQLBuilder
getType() - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckChangedJobConfigurationProcessor
getType() - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationChangedJobConfigurationProcessor
getTypeAliases() - 类中的方法org.apache.shardingsphere.data.pipeline.core.importer.DefaultImporterCreator
getUniqueKeyColumn(String, String, PipelineTableMetaDataLoader) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.metadata.loader.PipelineTableMetaDataUtil: Get unique key column.
getWriteRateLimitAlgorithm() - 接口中的方法org.apache.shardingsphere.data.pipeline.core.context.InventoryIncrementalProcessContext: Get job write rate limit algorithm.
GovernanceRepositoryAPI - org.apache.shardingsphere.data.pipeline.core.api中的接口: Governance repository API.
GovernanceRepositoryAPIImpl - org.apache.shardingsphere.data.pipeline.core.api.impl中的类: Governance repository API impl.
GovernanceRepositoryAPIImpl() - 类的构造器org.apache.shardingsphere.data.pipeline.core.api.impl.GovernanceRepositoryAPIImpl
group(List<DataRecord>) - 类中的方法org.apache.shardingsphere.data.pipeline.core.importer.DataRecordMerger: Group by table and type.

H

handle(DataChangedEvent) - 类中的方法org.apache.shardingsphere.data.pipeline.core.metadata.node.event.handler.impl.BarrierMetaDataChangedEventHandler
handle(DataChangedEvent) - 类中的方法org.apache.shardingsphere.data.pipeline.core.metadata.node.event.handler.impl.ChangedJobConfigurationDispatcher
handle(DataChangedEvent) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.metadata.node.event.handler.PipelineMetaDataChangedEventHandler: Handle meta data changed event.

I

IncrementalTask - org.apache.shardingsphere.data.pipeline.core.task中的类: Incremental task.
IncrementalTask(int, DumperConfiguration, ImporterConfiguration, PipelineChannelCreator, PipelineDataSourceManager, PipelineTableMetaDataLoader, ExecuteEngine, PipelineJobProgressListener) - 类的构造器org.apache.shardingsphere.data.pipeline.core.task.IncrementalTask
IngestDataChangeType - org.apache.shardingsphere.data.pipeline.core.ingest中的类: Ingest data change type.
IngestDataChangeType() - 类的构造器org.apache.shardingsphere.data.pipeline.core.ingest.IngestDataChangeType
IngestException - org.apache.shardingsphere.data.pipeline.core.ingest.exception中的异常错误: Ingest exception.
IngestException(String) - 异常错误的构造器org.apache.shardingsphere.data.pipeline.core.ingest.exception.IngestException
IngestException(Throwable) - 异常错误的构造器org.apache.shardingsphere.data.pipeline.core.ingest.exception.IngestException
IngestException(String, Throwable) - 异常错误的构造器org.apache.shardingsphere.data.pipeline.core.ingest.exception.IngestException
init(Properties) - 类中的方法org.apache.shardingsphere.data.pipeline.core.check.consistency.algorithm.CRC32MatchDataConsistencyCalculateAlgorithm
init(Properties) - 类中的方法org.apache.shardingsphere.data.pipeline.core.check.consistency.algorithm.DataMatchDataConsistencyCalculateAlgorithm
init(Properties) - 类中的方法org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory.MemoryPipelineChannelCreator
init(DataSource, String) - 类中的方法org.apache.shardingsphere.data.pipeline.core.ingest.position.DefaultPositionInitializer
init(String) - 类中的方法org.apache.shardingsphere.data.pipeline.core.ingest.position.DefaultPositionInitializer
init(Properties) - 类中的方法org.apache.shardingsphere.data.pipeline.core.ratelimit.QPSJobRateLimitAlgorithm
init(Properties) - 类中的方法org.apache.shardingsphere.data.pipeline.core.ratelimit.TPSJobRateLimitAlgorithm
initContextManager(ContextManager) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.context.PipelineContext: Initialize context manager.
initialize() - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.execute.PipelineJobWorker: Initialize job worker.
initialize(ContextManager) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.execute.ShardingSphereDataJobWorker: Initialize job worker.
initModeConfig(ModeConfiguration) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.context.PipelineContext: Initialize mode configuration.
INSERT - 类中的静态变量org.apache.shardingsphere.data.pipeline.core.ingest.IngestDataChangeType: Insert flag.
intercept(JobOperationType, Number) - 类中的方法org.apache.shardingsphere.data.pipeline.core.ratelimit.QPSJobRateLimitAlgorithm
intercept(JobOperationType, Number) - 类中的方法org.apache.shardingsphere.data.pipeline.core.ratelimit.TPSJobRateLimitAlgorithm
InventoryDumper - org.apache.shardingsphere.data.pipeline.core.ingest.dumper中的类: Inventory dumper.
InventoryDumper(InventoryDumperConfiguration, PipelineChannel, DataSource, PipelineTableMetaDataLoader) - 类的构造器org.apache.shardingsphere.data.pipeline.core.ingest.dumper.InventoryDumper
InventoryIncrementalJobAPI - org.apache.shardingsphere.data.pipeline.core.api中的接口: Inventory incremental job API.
InventoryIncrementalJobItemAPIImpl - org.apache.shardingsphere.data.pipeline.core.api.impl中的类: Inventory incremental job item API implementation.
InventoryIncrementalJobItemAPIImpl() - 类的构造器org.apache.shardingsphere.data.pipeline.core.api.impl.InventoryIncrementalJobItemAPIImpl
InventoryIncrementalJobItemContext - org.apache.shardingsphere.data.pipeline.core.context中的接口: Inventory incremental job item context.
InventoryIncrementalProcessContext - org.apache.shardingsphere.data.pipeline.core.context中的接口: Inventory incremental process context.
InventoryIncrementalTasksRunner - org.apache.shardingsphere.data.pipeline.core.task中的类: Inventory incremental tasks' runner.
InventoryIncrementalTasksRunner() - 类的构造器org.apache.shardingsphere.data.pipeline.core.task.InventoryIncrementalTasksRunner
InventoryTask - org.apache.shardingsphere.data.pipeline.core.task中的类: Inventory task.
InventoryTask(InventoryDumperConfiguration, ImporterConfiguration, PipelineChannelCreator, PipelineDataSourceManager, DataSource, PipelineTableMetaDataLoader, ExecuteEngine, ExecuteEngine, PipelineJobProgressListener) - 类的构造器org.apache.shardingsphere.data.pipeline.core.task.InventoryTask
InventoryTaskSplitter - org.apache.shardingsphere.data.pipeline.core.prepare中的类: Inventory data task splitter.
InventoryTaskSplitter() - 类的构造器org.apache.shardingsphere.data.pipeline.core.prepare.InventoryTaskSplitter
invokeMethod(Object, String, Class<?>[], Object[]) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.util.ReflectionUtil: Invoke method.
isAllFieldsNull() - 类中的方法org.apache.shardingsphere.data.pipeline.yaml.process.YamlPipelineProcessConfiguration: Check all fields is null.
isBigDecimalEquals(BigDecimal, BigDecimal) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.check.consistency.DataConsistencyCheckUtils: Check two BigDecimal whether equals or not.
isDefault() - 类中的方法org.apache.shardingsphere.data.pipeline.core.ingest.position.DefaultPositionInitializer
isDefault() - 类中的方法org.apache.shardingsphere.data.pipeline.core.sqlbuilder.DefaultPipelineSQLBuilder
isExisted(String) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.api.GovernanceRepositoryAPI: Whether key existing or not.
isExisted(String) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.GovernanceRepositoryAPIImpl
isIncrementalSupported(String) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.prepare.PipelineJobPreparerUtils: Is incremental supported.
isIntegerColumn(int) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.util.PipelineJdbcUtils: Whether column is integer type.
isJobCompleted(int, Collection<? extends PipelineJobItemProgress>) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.job.progress.PipelineJobProgressDetector: Whether job is completed (successful or failed).
isJobExisting(String) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.job.PipelineJobCenter: Is job existing.
isJobSuccessful(int, Collection<? extends PipelineJobItemProgress>) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.job.progress.PipelineJobProgressDetector: Whether job is successful.
isShardingColumn(Map<LogicTableName, Set<String>>, String, String) - 类中的方法org.apache.shardingsphere.data.pipeline.core.sqlbuilder.AbstractPipelineSQLBuilder
isSourceTargetDatabaseTheSame() - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobItemContext: Is source and target database the same or not.
isStringColumn(int) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.util.PipelineJdbcUtils: Whether column is string column.

L

list() - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractPipelineJobAPIImpl
listCheckJobIds(String) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.api.GovernanceRepositoryAPI: List check job ids.
listCheckJobIds(String) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.GovernanceRepositoryAPIImpl
listDataConsistencyCheckAlgorithms() - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractInventoryIncrementalJobAPIImpl
listMigrationSourceResources() - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPIImpl
load(JobType) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.PipelineDataSourcePersistService
load(JobType) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.PipelineProcessConfigurationPersistService
load(JobType) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.api.PipelineMetaDataPersistService: Load meta data.

M

ManualBitSet - org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory中的类: Manual BitSet.
ManualBitSet() - 类的构造器org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory.ManualBitSet
marshalJobId(PipelineJobId) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractPipelineJobAPIImpl
marshalJobId(PipelineJobId) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.api.PipelineJobAPI: Marshal pipeline job id.
marshalJobIdCommonPrefix(PipelineJobId) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.job.PipelineJobIdUtils: Marshal job id common prefix.
marshalJobIdLeftPart(PipelineJobId) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractPipelineJobAPIImpl
marshalJobIdLeftPart(PipelineJobId) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobAPIImpl
marshalJobIdLeftPart(PipelineJobId) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPIImpl
MemoryPipelineChannelCreator - org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory中的类: Memory implementation of pipeline channel creator.
MemoryPipelineChannelCreator() - 类的构造器org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory.MemoryPipelineChannelCreator
merge(List<DataRecord>) - 类中的方法org.apache.shardingsphere.data.pipeline.core.importer.DataRecordMerger: Merge data record.
MigrationChangedJobConfigurationProcessor - org.apache.shardingsphere.data.pipeline.scenario.migration中的类: Migration job configuration changed processor.
MigrationChangedJobConfigurationProcessor() - 类的构造器org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationChangedJobConfigurationProcessor
MigrationDataConsistencyChecker - org.apache.shardingsphere.data.pipeline.scenario.migration中的类: Data consistency checker for migration job.
MigrationDataConsistencyChecker(MigrationJobConfiguration, InventoryIncrementalProcessContext, ConsistencyCheckJobItemContext) - 类的构造器org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationDataConsistencyChecker
MigrationJob - org.apache.shardingsphere.data.pipeline.scenario.migration中的类: Migration job.
MigrationJob() - 类的构造器org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJob
MigrationJobAPI - org.apache.shardingsphere.data.pipeline.scenario.migration中的接口: Migration job API.
MigrationJobAPIFactory - org.apache.shardingsphere.data.pipeline.scenario.migration中的类: Migration job API factory.
MigrationJobAPIFactory() - 类的构造器org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPIFactory
MigrationJobAPIImpl - org.apache.shardingsphere.data.pipeline.scenario.migration中的类: Migration job API impl.
MigrationJobAPIImpl() - 类的构造器org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPIImpl
MigrationJobId - org.apache.shardingsphere.data.pipeline.scenario.migration中的类: Migration job id.
MigrationJobId(String, String, String, String, String) - 类的构造器org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobId
MigrationJobItemContext - org.apache.shardingsphere.data.pipeline.scenario.migration中的类: Migration job item context.
MigrationJobItemContext(MigrationJobConfiguration, int, InventoryIncrementalJobItemProgress, MigrationProcessContext, MigrationTaskConfiguration, PipelineDataSourceManager) - 类的构造器org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobItemContext
MigrationJobPreparer - org.apache.shardingsphere.data.pipeline.scenario.migration中的类: Migration job preparer.
MigrationJobPreparer() - 类的构造器org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobPreparer
MigrationProcessContext - org.apache.shardingsphere.data.pipeline.scenario.migration中的类: Migration process context.
MigrationProcessContext(String, PipelineProcessConfiguration) - 类的构造器org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationProcessContext: Constructor.
MigrationTaskConfiguration - org.apache.shardingsphere.data.pipeline.scenario.migration中的类: Migration task configuration.
MigrationTaskConfiguration() - 类的构造器org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationTaskConfiguration
MIN_SEQUENCE - 类中的静态变量org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobId
MultiplexMemoryPipelineChannel - org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory中的类: Multiplex memory pipeline channel.
MultiplexMemoryPipelineChannel() - 类的构造器org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory.MultiplexMemoryPipelineChannel
MultiplexMemoryPipelineChannel(AckCallback) - 类的构造器org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory.MultiplexMemoryPipelineChannel
MultiplexMemoryPipelineChannel(int, AckCallback) - 类的构造器org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory.MultiplexMemoryPipelineChannel
MultiplexMemoryPipelineChannel(int, int, AckCallback) - 类的构造器org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory.MultiplexMemoryPipelineChannel

N

newCachedThreadInstance(String) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.execute.ExecuteEngine: Create task execute engine instance with cached thread pool.
newFixedThreadInstance(int, String) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.execute.ExecuteEngine: Create task execute engine instance with fixed thread pool.
newInstance(PipelineDataSourceConfiguration) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.datasource.PipelineDataSourceFactory: New instance data source wrapper.
notifyPersist(String, int) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.job.progress.persist.PipelineJobProgressPersistService: Notify persist.

O

onAck(List<Record>) - 类中的方法org.apache.shardingsphere.data.pipeline.core.ingest.channel.EmptyAckCallback
onFailure(Throwable) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.execute.ExecuteCallback: Callback when execute failure.
onInitialized(ModeConfiguration, ContextManager) - 类中的方法org.apache.shardingsphere.data.pipeline.core.listener.PipelineContextManagerLifecycleListener
onInitialized(ModeConfiguration, ContextManager) - 类中的方法org.apache.shardingsphere.data.pipeline.core.listener.ShardingSphereDataContextManagerLifecycleListener
onProgressUpdated(PipelineJobProgressUpdatedParameter) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobItemContext
onProgressUpdated(PipelineJobProgressUpdatedParameter) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobItemContext
onSuccess() - 接口中的方法org.apache.shardingsphere.data.pipeline.core.execute.ExecuteCallback: Callback when execute success.
OraclePipelineSQLBuilder - org.apache.shardingsphere.data.pipeline.core.sqlbuilder中的类: Oracle pipeline SQL builder.
OraclePipelineSQLBuilder() - 类的构造器org.apache.shardingsphere.data.pipeline.core.sqlbuilder.OraclePipelineSQLBuilder
org.apache.shardingsphere.data.pipeline.core.api - 程序包 org.apache.shardingsphere.data.pipeline.core.api
org.apache.shardingsphere.data.pipeline.core.api.impl - 程序包 org.apache.shardingsphere.data.pipeline.core.api.impl
org.apache.shardingsphere.data.pipeline.core.check.consistency - 程序包 org.apache.shardingsphere.data.pipeline.core.check.consistency
org.apache.shardingsphere.data.pipeline.core.check.consistency.algorithm - 程序包 org.apache.shardingsphere.data.pipeline.core.check.consistency.algorithm
org.apache.shardingsphere.data.pipeline.core.check.datasource - 程序包 org.apache.shardingsphere.data.pipeline.core.check.datasource
org.apache.shardingsphere.data.pipeline.core.config.process - 程序包 org.apache.shardingsphere.data.pipeline.core.config.process
org.apache.shardingsphere.data.pipeline.core.constant - 程序包 org.apache.shardingsphere.data.pipeline.core.constant
org.apache.shardingsphere.data.pipeline.core.context - 程序包 org.apache.shardingsphere.data.pipeline.core.context
org.apache.shardingsphere.data.pipeline.core.datasource - 程序包 org.apache.shardingsphere.data.pipeline.core.datasource
org.apache.shardingsphere.data.pipeline.core.datasource.creator - 程序包 org.apache.shardingsphere.data.pipeline.core.datasource.creator
org.apache.shardingsphere.data.pipeline.core.datasource.creator.impl - 程序包 org.apache.shardingsphere.data.pipeline.core.datasource.creator.impl
org.apache.shardingsphere.data.pipeline.core.exception - 程序包 org.apache.shardingsphere.data.pipeline.core.exception
org.apache.shardingsphere.data.pipeline.core.exception.connection - 程序包 org.apache.shardingsphere.data.pipeline.core.exception.connection
org.apache.shardingsphere.data.pipeline.core.exception.data - 程序包 org.apache.shardingsphere.data.pipeline.core.exception.data
org.apache.shardingsphere.data.pipeline.core.exception.job - 程序包 org.apache.shardingsphere.data.pipeline.core.exception.job
org.apache.shardingsphere.data.pipeline.core.exception.metadata - 程序包 org.apache.shardingsphere.data.pipeline.core.exception.metadata
org.apache.shardingsphere.data.pipeline.core.exception.syntax - 程序包 org.apache.shardingsphere.data.pipeline.core.exception.syntax
org.apache.shardingsphere.data.pipeline.core.execute - 程序包 org.apache.shardingsphere.data.pipeline.core.execute
org.apache.shardingsphere.data.pipeline.core.importer - 程序包 org.apache.shardingsphere.data.pipeline.core.importer
org.apache.shardingsphere.data.pipeline.core.ingest - 程序包 org.apache.shardingsphere.data.pipeline.core.ingest
org.apache.shardingsphere.data.pipeline.core.ingest.channel - 程序包 org.apache.shardingsphere.data.pipeline.core.ingest.channel
org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory - 程序包 org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory
org.apache.shardingsphere.data.pipeline.core.ingest.dumper - 程序包 org.apache.shardingsphere.data.pipeline.core.ingest.dumper
org.apache.shardingsphere.data.pipeline.core.ingest.exception - 程序包 org.apache.shardingsphere.data.pipeline.core.ingest.exception
org.apache.shardingsphere.data.pipeline.core.ingest.position - 程序包 org.apache.shardingsphere.data.pipeline.core.ingest.position
org.apache.shardingsphere.data.pipeline.core.job - 程序包 org.apache.shardingsphere.data.pipeline.core.job
org.apache.shardingsphere.data.pipeline.core.job.progress - 程序包 org.apache.shardingsphere.data.pipeline.core.job.progress
org.apache.shardingsphere.data.pipeline.core.job.progress.persist - 程序包 org.apache.shardingsphere.data.pipeline.core.job.progress.persist
org.apache.shardingsphere.data.pipeline.core.job.progress.yaml - 程序包 org.apache.shardingsphere.data.pipeline.core.job.progress.yaml
org.apache.shardingsphere.data.pipeline.core.listener - 程序包 org.apache.shardingsphere.data.pipeline.core.listener
org.apache.shardingsphere.data.pipeline.core.metadata.generator - 程序包 org.apache.shardingsphere.data.pipeline.core.metadata.generator
org.apache.shardingsphere.data.pipeline.core.metadata.loader - 程序包 org.apache.shardingsphere.data.pipeline.core.metadata.loader
org.apache.shardingsphere.data.pipeline.core.metadata.node - 程序包 org.apache.shardingsphere.data.pipeline.core.metadata.node
org.apache.shardingsphere.data.pipeline.core.metadata.node.event.handler - 程序包 org.apache.shardingsphere.data.pipeline.core.metadata.node.event.handler
org.apache.shardingsphere.data.pipeline.core.metadata.node.event.handler.impl - 程序包 org.apache.shardingsphere.data.pipeline.core.metadata.node.event.handler.impl
org.apache.shardingsphere.data.pipeline.core.prepare - 程序包 org.apache.shardingsphere.data.pipeline.core.prepare
org.apache.shardingsphere.data.pipeline.core.prepare.datasource - 程序包 org.apache.shardingsphere.data.pipeline.core.prepare.datasource
org.apache.shardingsphere.data.pipeline.core.ratelimit - 程序包 org.apache.shardingsphere.data.pipeline.core.ratelimit
org.apache.shardingsphere.data.pipeline.core.record - 程序包 org.apache.shardingsphere.data.pipeline.core.record
org.apache.shardingsphere.data.pipeline.core.registry - 程序包 org.apache.shardingsphere.data.pipeline.core.registry
org.apache.shardingsphere.data.pipeline.core.sqlbuilder - 程序包 org.apache.shardingsphere.data.pipeline.core.sqlbuilder
org.apache.shardingsphere.data.pipeline.core.task - 程序包 org.apache.shardingsphere.data.pipeline.core.task
org.apache.shardingsphere.data.pipeline.core.util - 程序包 org.apache.shardingsphere.data.pipeline.core.util
org.apache.shardingsphere.data.pipeline.scenario.consistencycheck - 程序包 org.apache.shardingsphere.data.pipeline.scenario.consistencycheck
org.apache.shardingsphere.data.pipeline.scenario.migration - 程序包 org.apache.shardingsphere.data.pipeline.scenario.migration
org.apache.shardingsphere.data.pipeline.yaml.consistency - 程序包 org.apache.shardingsphere.data.pipeline.yaml.consistency
org.apache.shardingsphere.data.pipeline.yaml.job - 程序包 org.apache.shardingsphere.data.pipeline.yaml.job
org.apache.shardingsphere.data.pipeline.yaml.metadata - 程序包 org.apache.shardingsphere.data.pipeline.yaml.metadata
org.apache.shardingsphere.data.pipeline.yaml.process - 程序包 org.apache.shardingsphere.data.pipeline.yaml.process

P

parseJobType(String) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.job.PipelineJobIdUtils: Parse job type.
parseSequence(String) - 类中的静态方法org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobId: Parse consistency check sequence.
persist(String, String) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.api.GovernanceRepositoryAPI: Persist data.
persist(String, String) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.GovernanceRepositoryAPIImpl
persist(JobType, Map<String, DataSourceProperties>) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.PipelineDataSourcePersistService
persist(JobType, PipelineProcessConfiguration) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.PipelineProcessConfigurationPersistService
persist(JobType, T) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.api.PipelineMetaDataPersistService: Persist meta data.
persistCheckJobResult(String, String, Map<String, DataConsistencyCheckResult>) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.api.GovernanceRepositoryAPI: Persist check job result.
persistCheckJobResult(String, String, Map<String, DataConsistencyCheckResult>) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.GovernanceRepositoryAPIImpl
persistCheckLatestJobId(String, String) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.api.GovernanceRepositoryAPI: Persist check latest job id.
persistCheckLatestJobId(String, String) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.GovernanceRepositoryAPIImpl
persistEphemeralChildrenNode(String, int) - 类中的方法org.apache.shardingsphere.data.pipeline.core.util.PipelineDistributedBarrier: Persist ephemeral children node.
persistJobItemErrorMessage(String, int, Object) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractPipelineJobAPIImpl
persistJobItemErrorMessage(String, int, Object) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.api.PipelineJobAPI: Persist job item error message.
persistJobItemProgress(String, int, String) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.api.GovernanceRepositoryAPI: Persist job item progress.
persistJobItemProgress(PipelineJobItemContext) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractInventoryIncrementalJobAPIImpl
persistJobItemProgress(String, int, String) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.GovernanceRepositoryAPIImpl
persistJobItemProgress(PipelineJobItemContext) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.InventoryIncrementalJobItemAPIImpl
persistJobItemProgress(PipelineJobItemContext) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.api.PipelineJobItemAPI: Persist job item progress.
persistJobItemProgress(PipelineJobItemContext) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobAPIImpl
persistMetaDataDataSources(JobType, String) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.api.GovernanceRepositoryAPI: Persist meta data data sources.
persistMetaDataDataSources(JobType, String) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.GovernanceRepositoryAPIImpl
persistMetaDataProcessConfiguration(JobType, String) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.api.GovernanceRepositoryAPI: Persist meta data process configuration.
persistMetaDataProcessConfiguration(JobType, String) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.GovernanceRepositoryAPIImpl
PipelineAPIFactory - org.apache.shardingsphere.data.pipeline.core.api中的类: Pipeline API factory.
PipelineAPIFactory() - 类的构造器org.apache.shardingsphere.data.pipeline.core.api.PipelineAPIFactory
PipelineChangedJobConfigurationProcessor - org.apache.shardingsphere.data.pipeline.core.metadata.node.event.handler中的接口: Pipeline changed job configuration processor.
PipelineChangedJobConfigurationProcessorFactory - org.apache.shardingsphere.data.pipeline.core.metadata.node.event.handler中的类: Pipeline changed job configuration processor factory.
PipelineChangedJobConfigurationProcessorFactory() - 类的构造器org.apache.shardingsphere.data.pipeline.core.metadata.node.event.handler.PipelineChangedJobConfigurationProcessorFactory
PipelineContext - org.apache.shardingsphere.data.pipeline.core.context中的类: Pipeline context.
PipelineContext() - 类的构造器org.apache.shardingsphere.data.pipeline.core.context.PipelineContext
PipelineContextManagerLifecycleListener - org.apache.shardingsphere.data.pipeline.core.listener中的类: Pipeline context manager lifecycle listener.
PipelineContextManagerLifecycleListener() - 类的构造器org.apache.shardingsphere.data.pipeline.core.listener.PipelineContextManagerLifecycleListener
PipelineDataSourceCreator - org.apache.shardingsphere.data.pipeline.core.datasource.creator中的接口: Pipeline data source creator.
PipelineDataSourceCreatorFactory - org.apache.shardingsphere.data.pipeline.core.datasource.creator中的类: Pipeline data source creator factory.
PipelineDataSourceCreatorFactory() - 类的构造器org.apache.shardingsphere.data.pipeline.core.datasource.creator.PipelineDataSourceCreatorFactory
PipelineDataSourceFactory - org.apache.shardingsphere.data.pipeline.core.datasource中的类: Pipeline data source factory.
PipelineDataSourceFactory() - 类的构造器org.apache.shardingsphere.data.pipeline.core.datasource.PipelineDataSourceFactory
PipelineDataSourcePersistService - org.apache.shardingsphere.data.pipeline.core.api.impl中的类: Pipeline data source persist service.
PipelineDataSourcePersistService() - 类的构造器org.apache.shardingsphere.data.pipeline.core.api.impl.PipelineDataSourcePersistService
PipelineDDLGenerator - org.apache.shardingsphere.data.pipeline.core.metadata.generator中的类: Pipeline DDL generator.
PipelineDDLGenerator() - 类的构造器org.apache.shardingsphere.data.pipeline.core.metadata.generator.PipelineDDLGenerator
PipelineDistributedBarrier - org.apache.shardingsphere.data.pipeline.core.util中的类: Pipeline distributed barrier.
PipelineDistributedBarrier() - 类的构造器org.apache.shardingsphere.data.pipeline.core.util.PipelineDistributedBarrier
PipelineImporterJobWriteException - org.apache.shardingsphere.data.pipeline.core.exception.job中的异常错误: Pipeline importer job write exception.
PipelineImporterJobWriteException() - 异常错误的构造器org.apache.shardingsphere.data.pipeline.core.exception.job.PipelineImporterJobWriteException
PipelineJdbcUtils - org.apache.shardingsphere.data.pipeline.core.util中的类: Pipeline JDBC utils.
PipelineJdbcUtils() - 类的构造器org.apache.shardingsphere.data.pipeline.core.util.PipelineJdbcUtils
PipelineJobAPI - org.apache.shardingsphere.data.pipeline.core.api中的接口: Pipeline job API.
PipelineJobCenter - org.apache.shardingsphere.data.pipeline.core.job中的类: Pipeline job center.
PipelineJobCenter() - 类的构造器org.apache.shardingsphere.data.pipeline.core.job.PipelineJobCenter
PipelineJobCreationWithInvalidShardingCountException - org.apache.shardingsphere.data.pipeline.core.exception.job中的异常错误: Pipeline job creation with invalid sharding count exception.
PipelineJobCreationWithInvalidShardingCountException(String) - 异常错误的构造器org.apache.shardingsphere.data.pipeline.core.exception.job.PipelineJobCreationWithInvalidShardingCountException
PipelineJobExecutionException - org.apache.shardingsphere.data.pipeline.core.exception.job中的异常错误: Pipeline job execution exception.
PipelineJobExecutionException(String, Throwable) - 异常错误的构造器org.apache.shardingsphere.data.pipeline.core.exception.job.PipelineJobExecutionException
PipelineJobHasAlreadyFinishedException - org.apache.shardingsphere.data.pipeline.core.exception.job中的异常错误: Pipeline job has already finished exception.
PipelineJobHasAlreadyFinishedException(String) - 异常错误的构造器org.apache.shardingsphere.data.pipeline.core.exception.job.PipelineJobHasAlreadyFinishedException
PipelineJobHasAlreadyStartedException - org.apache.shardingsphere.data.pipeline.core.exception.job中的异常错误: Pipeline job has already started exception.
PipelineJobHasAlreadyStartedException(String) - 异常错误的构造器org.apache.shardingsphere.data.pipeline.core.exception.job.PipelineJobHasAlreadyStartedException
PipelineJobIdUtils - org.apache.shardingsphere.data.pipeline.core.job中的类: Pipeline job id utils.
PipelineJobIdUtils() - 类的构造器org.apache.shardingsphere.data.pipeline.core.job.PipelineJobIdUtils
PipelineJobItemAPI - org.apache.shardingsphere.data.pipeline.core.api中的接口: Pipeline job item API.
PipelineJobNotFoundException - org.apache.shardingsphere.data.pipeline.core.exception.job中的异常错误: Pipeline job not found exception.
PipelineJobNotFoundException(String) - 异常错误的构造器org.apache.shardingsphere.data.pipeline.core.exception.job.PipelineJobNotFoundException
PipelineJobPreparerUtils - org.apache.shardingsphere.data.pipeline.core.prepare中的类: Pipeline job preparer utils.
PipelineJobPreparerUtils() - 类的构造器org.apache.shardingsphere.data.pipeline.core.prepare.PipelineJobPreparerUtils
PipelineJobProgressDetector - org.apache.shardingsphere.data.pipeline.core.job.progress中的类: Pipeline job progress detector.
PipelineJobProgressDetector() - 类的构造器org.apache.shardingsphere.data.pipeline.core.job.progress.PipelineJobProgressDetector
PipelineJobProgressPersistContext - org.apache.shardingsphere.data.pipeline.core.job.progress.persist中的类: Pipeline job progress persist context.
PipelineJobProgressPersistContext() - 类的构造器org.apache.shardingsphere.data.pipeline.core.job.progress.persist.PipelineJobProgressPersistContext
PipelineJobProgressPersistService - org.apache.shardingsphere.data.pipeline.core.job.progress.persist中的类: Pipeline job progress persist service.
PipelineJobProgressPersistService() - 类的构造器org.apache.shardingsphere.data.pipeline.core.job.progress.persist.PipelineJobProgressPersistService
PipelineJobWorker - org.apache.shardingsphere.data.pipeline.core.execute中的类: Pipeline job worker.
PipelineJobWorker() - 类的构造器org.apache.shardingsphere.data.pipeline.core.execute.PipelineJobWorker
PipelineMetaDataChangedEventHandler - org.apache.shardingsphere.data.pipeline.core.metadata.node.event.handler中的接口: Pipeline meta data changed event handler.
PipelineMetaDataChangedEventHandlerFactory - org.apache.shardingsphere.data.pipeline.core.metadata.node.event.handler中的类: Pipeline meta data changed event handler factory.
PipelineMetaDataChangedEventHandlerFactory() - 类的构造器org.apache.shardingsphere.data.pipeline.core.metadata.node.event.handler.PipelineMetaDataChangedEventHandlerFactory
PipelineMetaDataNode - org.apache.shardingsphere.data.pipeline.core.metadata.node中的类: Pipeline meta data node.
PipelineMetaDataNode() - 类的构造器org.apache.shardingsphere.data.pipeline.core.metadata.node.PipelineMetaDataNode
PipelineMetaDataNodeWatcher - org.apache.shardingsphere.data.pipeline.core.metadata.node中的类: Pipeline meta data node watcher.
PipelineMetaDataPersistService<T> - org.apache.shardingsphere.data.pipeline.core.api中的接口: Pipeline meta data persist service.
PipelineProcessConfigurationPersistService - org.apache.shardingsphere.data.pipeline.core.api.impl中的类: Pipeline process configuration persist service.
PipelineProcessConfigurationPersistService() - 类的构造器org.apache.shardingsphere.data.pipeline.core.api.impl.PipelineProcessConfigurationPersistService
PipelineProcessConfigurationUtil - org.apache.shardingsphere.data.pipeline.core.config.process中的类: Pipeline process configuration util.
PipelineProcessConfigurationUtil() - 类的构造器org.apache.shardingsphere.data.pipeline.core.config.process.PipelineProcessConfigurationUtil
PipelineSchemaUtil - org.apache.shardingsphere.data.pipeline.core.metadata.loader中的类: Pipeline schema util.
PipelineSchemaUtil() - 类的构造器org.apache.shardingsphere.data.pipeline.core.metadata.loader.PipelineSchemaUtil
PipelineSQLBuilderFactory - org.apache.shardingsphere.data.pipeline.core.sqlbuilder中的类: Pipeline SQL builder factory.
PipelineSQLBuilderFactory() - 类的构造器org.apache.shardingsphere.data.pipeline.core.sqlbuilder.PipelineSQLBuilderFactory
PipelineSQLException - org.apache.shardingsphere.data.pipeline.core.exception中的异常错误: Pipeline SQL exception.
PipelineSQLException(SQLState, int, String, Object...) - 异常错误的构造器org.apache.shardingsphere.data.pipeline.core.exception.PipelineSQLException
PipelineTableDataConsistencyCheckLoadingFailedException - org.apache.shardingsphere.data.pipeline.core.exception.data中的异常错误: Pipeline table data consistency check loading failed exception.
PipelineTableDataConsistencyCheckLoadingFailedException(String) - 异常错误的构造器org.apache.shardingsphere.data.pipeline.core.exception.data.PipelineTableDataConsistencyCheckLoadingFailedException
PipelineTableMetaDataUtil - org.apache.shardingsphere.data.pipeline.core.metadata.loader中的类: Pipeline table meta data util.
PipelineTableMetaDataUtil() - 类的构造器org.apache.shardingsphere.data.pipeline.core.metadata.loader.PipelineTableMetaDataUtil
PipelineTask - org.apache.shardingsphere.data.pipeline.core.task中的接口: Pipeline task interface.
PipelineUnexpectedDataRecordOrderException - org.apache.shardingsphere.data.pipeline.core.exception.data中的异常错误: Pipeline unexpected data record order exception.
PipelineUnexpectedDataRecordOrderException(DataRecord, DataRecord) - 异常错误的构造器org.apache.shardingsphere.data.pipeline.core.exception.data.PipelineUnexpectedDataRecordOrderException
prepare(MigrationJobItemContext) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobPreparer: Do prepare work.
PrepareJobWithCheckPrivilegeFailedException - org.apache.shardingsphere.data.pipeline.core.exception.job中的异常错误: Prepare job with check privilege failed exception.
PrepareJobWithCheckPrivilegeFailedException(SQLException) - 异常错误的构造器org.apache.shardingsphere.data.pipeline.core.exception.job.PrepareJobWithCheckPrivilegeFailedException
PrepareJobWithGetBinlogPositionException - org.apache.shardingsphere.data.pipeline.core.exception.job中的异常错误: Prepare job with get binlog position.
PrepareJobWithGetBinlogPositionException(String, SQLException) - 异常错误的构造器org.apache.shardingsphere.data.pipeline.core.exception.job.PrepareJobWithGetBinlogPositionException
PrepareJobWithInvalidConnectionException - org.apache.shardingsphere.data.pipeline.core.exception.job中的异常错误: Prepare job with invalid connection exception.
PrepareJobWithInvalidConnectionException(SQLException) - 异常错误的构造器org.apache.shardingsphere.data.pipeline.core.exception.job.PrepareJobWithInvalidConnectionException
PrepareJobWithInvalidSourceDataSourceException - org.apache.shardingsphere.data.pipeline.core.exception.job中的异常错误: Prepare job with invalid source data source exception.
PrepareJobWithInvalidSourceDataSourceException(String, String, String) - 异常错误的构造器org.apache.shardingsphere.data.pipeline.core.exception.job.PrepareJobWithInvalidSourceDataSourceException
PrepareJobWithoutEnoughPrivilegeException - org.apache.shardingsphere.data.pipeline.core.exception.job中的异常错误: Prepare job without enough privilege exception.
PrepareJobWithoutEnoughPrivilegeException(Collection<String>) - 异常错误的构造器org.apache.shardingsphere.data.pipeline.core.exception.job.PrepareJobWithoutEnoughPrivilegeException
PrepareJobWithoutUserException - org.apache.shardingsphere.data.pipeline.core.exception.job中的异常错误: Prepare job without user exception.
PrepareJobWithoutUserException(String) - 异常错误的构造器org.apache.shardingsphere.data.pipeline.core.exception.job.PrepareJobWithoutUserException
PrepareJobWithTargetTableNotEmptyException - org.apache.shardingsphere.data.pipeline.core.exception.job中的异常错误: Prepare job with target table not empty exception.
PrepareJobWithTargetTableNotEmptyException(String) - 异常错误的构造器org.apache.shardingsphere.data.pipeline.core.exception.job.PrepareJobWithTargetTableNotEmptyException
prepareTargetSchema(String, PrepareTargetSchemasParameter) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.prepare.PipelineJobPreparerUtils: Prepare target schema.
prepareTargetSchemas(PrepareTargetSchemasParameter) - 类中的方法org.apache.shardingsphere.data.pipeline.core.prepare.datasource.AbstractDataSourcePreparer
prepareTargetSchemas(PrepareTargetSchemasParameter) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.prepare.datasource.DataSourcePreparer: Prepare target schemas.
PrepareTargetSchemasParameter - org.apache.shardingsphere.data.pipeline.core.prepare.datasource中的类: Prepare target schemas parameter.
PrepareTargetSchemasParameter() - 类的构造器org.apache.shardingsphere.data.pipeline.core.prepare.datasource.PrepareTargetSchemasParameter
prepareTargetTables(PrepareTargetTablesParameter) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.prepare.datasource.DataSourcePreparer: Prepare target tables.
prepareTargetTables(String, PrepareTargetTablesParameter) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.prepare.PipelineJobPreparerUtils: Prepare target tables.
PrepareTargetTablesParameter - org.apache.shardingsphere.data.pipeline.core.prepare.datasource中的类: Prepare target tables parameter.
PrepareTargetTablesParameter() - 类的构造器org.apache.shardingsphere.data.pipeline.core.prepare.datasource.PrepareTargetTablesParameter
process(DataChangedEvent.Type, JobConfigurationPOJO) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.metadata.node.event.handler.PipelineChangedJobConfigurationProcessor: Process changed job configuration.
process(DataChangedEvent.Type, JobConfigurationPOJO) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckChangedJobConfigurationProcessor
process(DataChangedEvent.Type, JobConfigurationPOJO) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationChangedJobConfigurationProcessor
pushRecord(Record) - 类中的方法org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory.MultiplexMemoryPipelineChannel
pushRecord(Record) - 类中的方法org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory.SimpleMemoryPipelineChannel

Q

QPSJobRateLimitAlgorithm - org.apache.shardingsphere.data.pipeline.core.ratelimit中的类: QPS job rate limit algorithm for SPI.
QPSJobRateLimitAlgorithm() - 类的构造器org.apache.shardingsphere.data.pipeline.core.ratelimit.QPSJobRateLimitAlgorithm
quote(String) - 类中的方法org.apache.shardingsphere.data.pipeline.core.sqlbuilder.AbstractPipelineSQLBuilder: Add left and right identifier quote string.

R

readValue(ResultSet, ResultSetMetaData, int) - 类中的方法org.apache.shardingsphere.data.pipeline.core.ingest.dumper.BasicColumnValueReader
RecordUtil - org.apache.shardingsphere.data.pipeline.core.record中的类: Record utility.
RecordUtil() - 类的构造器org.apache.shardingsphere.data.pipeline.core.record.RecordUtil
ReflectionUtil - org.apache.shardingsphere.data.pipeline.core.util中的类: Reflection utils.
ReflectionUtil() - 类的构造器org.apache.shardingsphere.data.pipeline.core.util.ReflectionUtil
register(String, int) - 类中的方法org.apache.shardingsphere.data.pipeline.core.util.PipelineDistributedBarrier: Register count down latch.
removeJobProgressPersistContext(String) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.job.progress.persist.PipelineJobProgressPersistService: Remove job progress persist context.
removeParentNode(String) - 类中的方法org.apache.shardingsphere.data.pipeline.core.util.PipelineDistributedBarrier: Persist ephemeral children node.
rollback(String) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPIImpl
runBlocking() - 类中的方法org.apache.shardingsphere.data.pipeline.core.importer.DefaultImporter
runBlocking() - 类中的方法org.apache.shardingsphere.data.pipeline.core.ingest.dumper.InventoryDumper
runInBackground(Runnable) - 类中的方法org.apache.shardingsphere.data.pipeline.core.job.AbstractPipelineJob

S

set(long) - 类中的方法org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory.ManualBitSet: Sets the bit at the specified index to true.
setAllFieldsNull() - 类中的方法org.apache.shardingsphere.data.pipeline.yaml.process.YamlPipelineProcessConfiguration: Set all fields null.
setCurrentStatement(T) - 类中的方法org.apache.shardingsphere.data.pipeline.core.check.consistency.algorithm.AbstractDataConsistencyCalculateAlgorithm
setFieldNull(String) - 类中的方法org.apache.shardingsphere.data.pipeline.yaml.process.YamlPipelineProcessConfiguration: Set field to null.
setFieldNull(String) - 类中的方法org.apache.shardingsphere.data.pipeline.yaml.process.YamlPipelineReadConfiguration: Set field to null.
setFieldNull(String) - 类中的方法org.apache.shardingsphere.data.pipeline.yaml.process.YamlPipelineWriteConfiguration: Set field to null.
setFieldsNullByConfPath(YamlPipelineProcessConfiguration, String) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.config.process.PipelineProcessConfigurationUtil: Set fields to null by configuration path.
setFieldValue(Object, String, Object) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.util.ReflectionUtil: Set value into target object field.
setSource(YamlPipelineDataSourceConfiguration) - 类中的方法org.apache.shardingsphere.data.pipeline.yaml.job.YamlMigrationJobConfiguration: Set source.
setTarget(YamlPipelineDataSourceConfiguration) - 类中的方法org.apache.shardingsphere.data.pipeline.yaml.job.YamlMigrationJobConfiguration: Set target.
ShardingSphereDataContextManagerLifecycleListener - org.apache.shardingsphere.data.pipeline.core.listener中的类: ShardingSphere data context manager lifecycle listener.
ShardingSphereDataContextManagerLifecycleListener() - 类的构造器org.apache.shardingsphere.data.pipeline.core.listener.ShardingSphereDataContextManagerLifecycleListener
ShardingSphereDataJobWorker - org.apache.shardingsphere.data.pipeline.core.execute中的类: ShardingSphere data job worker.
ShardingSphereDataJobWorker() - 类的构造器org.apache.shardingsphere.data.pipeline.core.execute.ShardingSphereDataJobWorker
ShardingSphereDataScheduleCollector - org.apache.shardingsphere.data.pipeline.core.execute中的类: ShardingSphere data schedule collector.
ShardingSphereDataScheduleCollector() - 类的构造器org.apache.shardingsphere.data.pipeline.core.execute.ShardingSphereDataScheduleCollector
showProcessConfiguration() - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractInventoryIncrementalJobAPIImpl
SimpleMemoryPipelineChannel - org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory中的类: Simple memory pipeline channel.
SimpleMemoryPipelineChannel(int) - 类的构造器org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory.SimpleMemoryPipelineChannel
SimpleMemoryPipelineChannel(int, AckCallback) - 类的构造器org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory.SimpleMemoryPipelineChannel
SingleTableInventoryDataConsistencyChecker - org.apache.shardingsphere.data.pipeline.core.check.consistency中的类: Single table inventory data consistency checker.
SingleTableInventoryDataConsistencyChecker() - 类的构造器org.apache.shardingsphere.data.pipeline.core.check.consistency.SingleTableInventoryDataConsistencyChecker
sleep(long) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.util.ThreadUtil: Sleep ignored InterruptedException.
sleep(int, TimeUnit) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.util.ThreadUtil: Sleep ignored InterruptedException.
splitInventoryData(InventoryIncrementalJobItemContext) - 类中的方法org.apache.shardingsphere.data.pipeline.core.prepare.InventoryTaskSplitter: Split inventory data to multi-tasks.
SplitPipelineJobByRangeException - org.apache.shardingsphere.data.pipeline.core.exception.job中的异常错误: Split pipeline job by range exception.
SplitPipelineJobByRangeException(String, String) - 异常错误的构造器org.apache.shardingsphere.data.pipeline.core.exception.job.SplitPipelineJobByRangeException
SplitPipelineJobByUniqueKeyException - org.apache.shardingsphere.data.pipeline.core.exception.job中的异常错误: Split pipeline job by unique key exception.
SplitPipelineJobByUniqueKeyException(String, String, SQLException) - 异常错误的构造器org.apache.shardingsphere.data.pipeline.core.exception.job.SplitPipelineJobByUniqueKeyException
StandardPipelineDataSourceCreator - org.apache.shardingsphere.data.pipeline.core.datasource.creator.impl中的类: Standard pipeline data source creator.
StandardPipelineDataSourceCreator() - 类的构造器org.apache.shardingsphere.data.pipeline.core.datasource.creator.impl.StandardPipelineDataSourceCreator
StandardPipelineTableMetaDataLoader - org.apache.shardingsphere.data.pipeline.core.metadata.loader中的类: Standard pipeline table metadata loader.
StandardPipelineTableMetaDataLoader() - 类的构造器org.apache.shardingsphere.data.pipeline.core.metadata.loader.StandardPipelineTableMetaDataLoader
start(PipelineJobConfiguration) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractPipelineJobAPIImpl
start(PipelineJobConfiguration) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.api.PipelineJobAPI: Start job.
start() - 类中的方法org.apache.shardingsphere.data.pipeline.core.execute.ShardingSphereDataScheduleCollector: Start.
start() - 类中的方法org.apache.shardingsphere.data.pipeline.core.task.IncrementalTask
start() - 类中的方法org.apache.shardingsphere.data.pipeline.core.task.InventoryIncrementalTasksRunner
start() - 类中的方法org.apache.shardingsphere.data.pipeline.core.task.InventoryTask
start() - 接口中的方法org.apache.shardingsphere.data.pipeline.core.task.PipelineTask: Start task.
start() - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckTasksRunner
startByParentJobId(String) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobAPIImpl
startDisabledJob(String) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractPipelineJobAPIImpl
startDisabledJob(String) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobAPIImpl
startDisabledJob(String) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPIImpl
stop(String) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractPipelineJobAPIImpl
stop(String) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.job.PipelineJobCenter: Stop job.
stop() - 类中的方法org.apache.shardingsphere.data.pipeline.core.task.IncrementalTask
stop() - 类中的方法org.apache.shardingsphere.data.pipeline.core.task.InventoryIncrementalTasksRunner
stop() - 类中的方法org.apache.shardingsphere.data.pipeline.core.task.InventoryTask
stop() - 接口中的方法org.apache.shardingsphere.data.pipeline.core.task.PipelineTask: Stop task.
stop() - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJob
stop() - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckTasksRunner
stop() - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJob: Stop job.
stop(String) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPIImpl
stopByParentJobId(String) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobAPIImpl
submit(LifecycleExecutor, ExecuteCallback) - 类中的方法org.apache.shardingsphere.data.pipeline.core.execute.ExecuteEngine: Submit a LifecycleExecutor with callback ExecuteCallback to execute.
submitAll(Collection<? extends LifecycleExecutor>, ExecuteCallback) - 类中的方法org.apache.shardingsphere.data.pipeline.core.execute.ExecuteEngine: Submit a collection of LifecycleExecutor with callback ExecuteCallback to execute.
swapToObject(YamlConsistencyCheckJobProgress) - 类中的方法org.apache.shardingsphere.data.pipeline.core.job.progress.yaml.YamlConsistencyCheckJobProgressSwapper
swapToObject(YamlInventoryIncrementalJobItemProgress) - 类中的方法org.apache.shardingsphere.data.pipeline.core.job.progress.yaml.YamlInventoryIncrementalJobItemProgressSwapper
swapToObject(String, YamlJobItemIncrementalTasksProgress) - 类中的方法org.apache.shardingsphere.data.pipeline.core.job.progress.yaml.YamlJobItemIncrementalTasksProgressSwapper: Swap to object.
swapToObject(YamlJobItemInventoryTasksProgress) - 类中的方法org.apache.shardingsphere.data.pipeline.core.job.progress.yaml.YamlJobItemInventoryTasksProgressSwapper: Swap to object.
swapToObject(YamlDataConsistencyCheckResult) - 类中的方法org.apache.shardingsphere.data.pipeline.yaml.consistency.YamlDataConsistencyCheckResultSwapper
swapToObject(String) - 类中的方法org.apache.shardingsphere.data.pipeline.yaml.consistency.YamlDataConsistencyCheckResultSwapper: Swap string to data consistency check result.
swapToObject(YamlConsistencyCheckJobConfiguration) - 类中的方法org.apache.shardingsphere.data.pipeline.yaml.job.YamlConsistencyCheckJobConfigurationSwapper
swapToObject(String) - 类中的方法org.apache.shardingsphere.data.pipeline.yaml.job.YamlConsistencyCheckJobConfigurationSwapper: Swap to job configuration from text.
swapToObject(YamlMigrationJobConfiguration) - 类中的方法org.apache.shardingsphere.data.pipeline.yaml.job.YamlMigrationJobConfigurationSwapper
swapToObject(String) - 类中的方法org.apache.shardingsphere.data.pipeline.yaml.job.YamlMigrationJobConfigurationSwapper: Swap to migration job configuration from YAML text.
swapToObject(YamlPipelineColumnMetaData) - 类中的方法org.apache.shardingsphere.data.pipeline.yaml.metadata.YamlPipelineColumnMetaDataSwapper
swapToObject(YamlPipelineProcessConfiguration) - 类中的方法org.apache.shardingsphere.data.pipeline.yaml.process.YamlPipelineProcessConfigurationSwapper
swapToObject(YamlPipelineReadConfiguration) - 类中的方法org.apache.shardingsphere.data.pipeline.yaml.process.YamlPipelineReadConfigurationSwapper
swapToObject(YamlPipelineWriteConfiguration) - 类中的方法org.apache.shardingsphere.data.pipeline.yaml.process.YamlPipelineWriteConfigurationSwapper
swapToYaml(JobItemIncrementalTasksProgress) - 类中的方法org.apache.shardingsphere.data.pipeline.core.job.progress.yaml.YamlJobItemIncrementalTasksProgressSwapper: Swap to YAML.
swapToYaml(JobItemInventoryTasksProgress) - 类中的方法org.apache.shardingsphere.data.pipeline.core.job.progress.yaml.YamlJobItemInventoryTasksProgressSwapper: Swap to YAML.
swapToYamlConfiguration(ConsistencyCheckJobProgress) - 类中的方法org.apache.shardingsphere.data.pipeline.core.job.progress.yaml.YamlConsistencyCheckJobProgressSwapper
swapToYamlConfiguration(InventoryIncrementalJobItemProgress) - 类中的方法org.apache.shardingsphere.data.pipeline.core.job.progress.yaml.YamlInventoryIncrementalJobItemProgressSwapper
swapToYamlConfiguration(DataConsistencyCheckResult) - 类中的方法org.apache.shardingsphere.data.pipeline.yaml.consistency.YamlDataConsistencyCheckResultSwapper
swapToYamlConfiguration(ConsistencyCheckJobConfiguration) - 类中的方法org.apache.shardingsphere.data.pipeline.yaml.job.YamlConsistencyCheckJobConfigurationSwapper
swapToYamlConfiguration(MigrationJobConfiguration) - 类中的方法org.apache.shardingsphere.data.pipeline.yaml.job.YamlMigrationJobConfigurationSwapper
swapToYamlConfiguration(PipelineColumnMetaData) - 类中的方法org.apache.shardingsphere.data.pipeline.yaml.metadata.YamlPipelineColumnMetaDataSwapper
swapToYamlConfiguration(PipelineProcessConfiguration) - 类中的方法org.apache.shardingsphere.data.pipeline.yaml.process.YamlPipelineProcessConfigurationSwapper
swapToYamlConfiguration(PipelineReadConfiguration) - 类中的方法org.apache.shardingsphere.data.pipeline.yaml.process.YamlPipelineReadConfigurationSwapper
swapToYamlConfiguration(PipelineWriteConfiguration) - 类中的方法org.apache.shardingsphere.data.pipeline.yaml.process.YamlPipelineWriteConfigurationSwapper
swapToYamlJobConfiguration(PipelineJobConfiguration) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractPipelineJobAPIImpl
swapToYamlJobConfiguration(PipelineJobConfiguration) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobAPIImpl
swapToYamlJobConfiguration(PipelineJobConfiguration) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPIImpl

T

ThreadUtil - org.apache.shardingsphere.data.pipeline.core.util中的类: Thread util.
ThreadUtil() - 类的构造器org.apache.shardingsphere.data.pipeline.core.util.ThreadUtil
toString() - 类中的方法org.apache.shardingsphere.data.pipeline.core.ratelimit.QPSJobRateLimitAlgorithm
toString() - 类中的方法org.apache.shardingsphere.data.pipeline.core.ratelimit.TPSJobRateLimitAlgorithm
TPSJobRateLimitAlgorithm - org.apache.shardingsphere.data.pipeline.core.ratelimit中的类: TPS job rate limit algorithm for SPI.
TPSJobRateLimitAlgorithm() - 类的构造器org.apache.shardingsphere.data.pipeline.core.ratelimit.TPSJobRateLimitAlgorithm
TYPE - 类中的静态变量org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory.MemoryPipelineChannelCreator

U

UncompletedConsistencyCheckJobExistsException - org.apache.shardingsphere.data.pipeline.core.exception.job中的异常错误: Uncompleted consistency check job exists exception.
UncompletedConsistencyCheckJobExistsException(String) - 异常错误的构造器org.apache.shardingsphere.data.pipeline.core.exception.job.UncompletedConsistencyCheckJobExistsException
UnsupportedCRC32DataConsistencyCalculateAlgorithmException - org.apache.shardingsphere.data.pipeline.core.exception.data中的异常错误: Unsupported CRC32 data consistency calculate algorithm exception.
UnsupportedCRC32DataConsistencyCalculateAlgorithmException(String) - 异常错误的构造器org.apache.shardingsphere.data.pipeline.core.exception.data.UnsupportedCRC32DataConsistencyCalculateAlgorithmException
UnsupportedPipelineDatabaseTypeException - org.apache.shardingsphere.data.pipeline.core.exception.data中的异常错误: Unsupported pipeline database type exception.
UnsupportedPipelineDatabaseTypeException(DatabaseType) - 异常错误的构造器org.apache.shardingsphere.data.pipeline.core.exception.data.UnsupportedPipelineDatabaseTypeException
UnsupportedPipelineJobUniqueKeyDataTypeException - org.apache.shardingsphere.data.pipeline.core.exception.data中的异常错误: Unsupported pipeline job unique key data type exception.
UnsupportedPipelineJobUniqueKeyDataTypeException(int) - 异常错误的构造器org.apache.shardingsphere.data.pipeline.core.exception.data.UnsupportedPipelineJobUniqueKeyDataTypeException
UPDATE - 类中的静态变量org.apache.shardingsphere.data.pipeline.core.ingest.IngestDataChangeType: Update flag.
updateJobItemStatus(String, int, JobStatus) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractInventoryIncrementalJobAPIImpl
updateJobItemStatus(String, int, JobStatus) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.InventoryIncrementalJobItemAPIImpl
updateJobItemStatus(String, int, JobStatus) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.api.PipelineJobItemAPI: Update job item status.
updateJobItemStatus(String, int, JobStatus) - 类中的方法org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobAPIImpl

V

verifyConfPath(String) - 类中的静态方法org.apache.shardingsphere.data.pipeline.core.config.process.PipelineProcessConfigurationUtil: Verify configuration path valid or not.

W

watch(String, DataChangedEventListener) - 接口中的方法org.apache.shardingsphere.data.pipeline.core.api.GovernanceRepositoryAPI: Watch key or path of governance server.
watch(String, DataChangedEventListener) - 类中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.GovernanceRepositoryAPIImpl

Y

YamlConsistencyCheckJobConfiguration - org.apache.shardingsphere.data.pipeline.yaml.job中的类: Consistency check job configuration for YAML.
YamlConsistencyCheckJobConfiguration() - 类的构造器org.apache.shardingsphere.data.pipeline.yaml.job.YamlConsistencyCheckJobConfiguration
YamlConsistencyCheckJobConfigurationSwapper - org.apache.shardingsphere.data.pipeline.yaml.job中的类: YAML consistency check job configuration swapper.
YamlConsistencyCheckJobConfigurationSwapper() - 类的构造器org.apache.shardingsphere.data.pipeline.yaml.job.YamlConsistencyCheckJobConfigurationSwapper
YamlConsistencyCheckJobProgress - org.apache.shardingsphere.data.pipeline.core.job.progress.yaml中的类: Yaml data consistency check job progress.
YamlConsistencyCheckJobProgress() - 类的构造器org.apache.shardingsphere.data.pipeline.core.job.progress.yaml.YamlConsistencyCheckJobProgress
YamlConsistencyCheckJobProgressSwapper - org.apache.shardingsphere.data.pipeline.core.job.progress.yaml中的类: YAML data check job progress swapper.
YamlConsistencyCheckJobProgressSwapper() - 类的构造器org.apache.shardingsphere.data.pipeline.core.job.progress.yaml.YamlConsistencyCheckJobProgressSwapper
YamlDataConsistencyCheckResult - org.apache.shardingsphere.data.pipeline.yaml.consistency中的类: Yaml data consistency check result config.
YamlDataConsistencyCheckResult() - 类的构造器org.apache.shardingsphere.data.pipeline.yaml.consistency.YamlDataConsistencyCheckResult
YamlDataConsistencyCheckResult.YamlDataConsistencyContentCheckResult - org.apache.shardingsphere.data.pipeline.yaml.consistency中的类: YAML data consistency content result.
YamlDataConsistencyCheckResult.YamlDataConsistencyCountCheckResult - org.apache.shardingsphere.data.pipeline.yaml.consistency中的类: YAML data consistency count result.
YamlDataConsistencyCheckResultSwapper - org.apache.shardingsphere.data.pipeline.yaml.consistency中的类: Yaml data consistency check result swapper.
YamlDataConsistencyCheckResultSwapper() - 类的构造器org.apache.shardingsphere.data.pipeline.yaml.consistency.YamlDataConsistencyCheckResultSwapper
YamlDataConsistencyContentCheckResult() - 类的构造器org.apache.shardingsphere.data.pipeline.yaml.consistency.YamlDataConsistencyCheckResult.YamlDataConsistencyContentCheckResult
YamlDataConsistencyCountCheckResult() - 类的构造器org.apache.shardingsphere.data.pipeline.yaml.consistency.YamlDataConsistencyCheckResult.YamlDataConsistencyCountCheckResult
YamlInventoryIncrementalJobItemProgress - org.apache.shardingsphere.data.pipeline.core.job.progress.yaml中的类: YAML inventory incremental job item progress.
YamlInventoryIncrementalJobItemProgress() - 类的构造器org.apache.shardingsphere.data.pipeline.core.job.progress.yaml.YamlInventoryIncrementalJobItemProgress
YamlInventoryIncrementalJobItemProgressSwapper - org.apache.shardingsphere.data.pipeline.core.job.progress.yaml中的类: YAML inventory incremental job item progress swapper.
YamlInventoryIncrementalJobItemProgressSwapper() - 类的构造器org.apache.shardingsphere.data.pipeline.core.job.progress.yaml.YamlInventoryIncrementalJobItemProgressSwapper
YamlJobItemIncrementalTasksProgress - org.apache.shardingsphere.data.pipeline.core.job.progress.yaml中的类: YAML job item incremental tasks progress.
YamlJobItemIncrementalTasksProgress() - 类的构造器org.apache.shardingsphere.data.pipeline.core.job.progress.yaml.YamlJobItemIncrementalTasksProgress
YamlJobItemIncrementalTasksProgressSwapper - org.apache.shardingsphere.data.pipeline.core.job.progress.yaml中的类: YAML job item incremental tasks progress swapper.
YamlJobItemIncrementalTasksProgressSwapper() - 类的构造器org.apache.shardingsphere.data.pipeline.core.job.progress.yaml.YamlJobItemIncrementalTasksProgressSwapper
YamlJobItemInventoryTasksProgress - org.apache.shardingsphere.data.pipeline.core.job.progress.yaml中的类: YAML job item inventory tasks progress.
YamlJobItemInventoryTasksProgress() - 类的构造器org.apache.shardingsphere.data.pipeline.core.job.progress.yaml.YamlJobItemInventoryTasksProgress
YamlJobItemInventoryTasksProgressSwapper - org.apache.shardingsphere.data.pipeline.core.job.progress.yaml中的类: YAML job item inventory tasks progress swapper.
YamlJobItemInventoryTasksProgressSwapper() - 类的构造器org.apache.shardingsphere.data.pipeline.core.job.progress.yaml.YamlJobItemInventoryTasksProgressSwapper
YamlMigrationJobConfiguration - org.apache.shardingsphere.data.pipeline.yaml.job中的类: Migration job configuration for YAML.
YamlMigrationJobConfiguration() - 类的构造器org.apache.shardingsphere.data.pipeline.yaml.job.YamlMigrationJobConfiguration
YamlMigrationJobConfigurationSwapper - org.apache.shardingsphere.data.pipeline.yaml.job中的类: YAML migration job configuration swapper.
YamlMigrationJobConfigurationSwapper() - 类的构造器org.apache.shardingsphere.data.pipeline.yaml.job.YamlMigrationJobConfigurationSwapper
YamlPipelineColumnMetaData - org.apache.shardingsphere.data.pipeline.yaml.metadata中的类: Yaml pipeline column meta data.
YamlPipelineColumnMetaData() - 类的构造器org.apache.shardingsphere.data.pipeline.yaml.metadata.YamlPipelineColumnMetaData
YamlPipelineColumnMetaDataSwapper - org.apache.shardingsphere.data.pipeline.yaml.metadata中的类: Yaml pipeline column meta data swapper.
YamlPipelineColumnMetaDataSwapper() - 类的构造器org.apache.shardingsphere.data.pipeline.yaml.metadata.YamlPipelineColumnMetaDataSwapper
YamlPipelineProcessConfiguration - org.apache.shardingsphere.data.pipeline.yaml.process中的类: YAML pipeline process configuration.
YamlPipelineProcessConfiguration() - 类的构造器org.apache.shardingsphere.data.pipeline.yaml.process.YamlPipelineProcessConfiguration
YamlPipelineProcessConfigurationSwapper - org.apache.shardingsphere.data.pipeline.yaml.process中的类: YAML pipeline process configuration swapper.
YamlPipelineProcessConfigurationSwapper() - 类的构造器org.apache.shardingsphere.data.pipeline.yaml.process.YamlPipelineProcessConfigurationSwapper
YamlPipelineReadConfiguration - org.apache.shardingsphere.data.pipeline.yaml.process中的类: YAML pipeline read configuration.
YamlPipelineReadConfiguration() - 类的构造器org.apache.shardingsphere.data.pipeline.yaml.process.YamlPipelineReadConfiguration
YamlPipelineReadConfigurationSwapper - org.apache.shardingsphere.data.pipeline.yaml.process中的类: YAML pipeline read configuration swapper.
YamlPipelineReadConfigurationSwapper() - 类的构造器org.apache.shardingsphere.data.pipeline.yaml.process.YamlPipelineReadConfigurationSwapper
YamlPipelineWriteConfiguration - org.apache.shardingsphere.data.pipeline.yaml.process中的类: YAML pipeline write configuration.
YamlPipelineWriteConfiguration() - 类的构造器org.apache.shardingsphere.data.pipeline.yaml.process.YamlPipelineWriteConfiguration
YamlPipelineWriteConfigurationSwapper - org.apache.shardingsphere.data.pipeline.yaml.process中的类: YAML pipeline write configuration swapper.
YamlPipelineWriteConfigurationSwapper() - 类的构造器org.apache.shardingsphere.data.pipeline.yaml.process.YamlPipelineWriteConfigurationSwapper

A B C D E F G H I L M N O P Q R S T U V W Y