所有程序包的分层结构

程序包分层结构:

• org.apache.shardingsphere.data.pipeline.core.api,
• org.apache.shardingsphere.data.pipeline.core.api.impl,
• org.apache.shardingsphere.data.pipeline.core.check.consistency,
• org.apache.shardingsphere.data.pipeline.core.check.consistency.algorithm,
• org.apache.shardingsphere.data.pipeline.core.check.datasource,
• org.apache.shardingsphere.data.pipeline.core.config.process,
• org.apache.shardingsphere.data.pipeline.core.constant,
• org.apache.shardingsphere.data.pipeline.core.context,
• org.apache.shardingsphere.data.pipeline.core.datasource,
• org.apache.shardingsphere.data.pipeline.core.datasource.creator,
• org.apache.shardingsphere.data.pipeline.core.datasource.creator.impl,
• org.apache.shardingsphere.data.pipeline.core.exception,
• org.apache.shardingsphere.data.pipeline.core.exception.connection,
• org.apache.shardingsphere.data.pipeline.core.exception.data,
• org.apache.shardingsphere.data.pipeline.core.exception.job,
• org.apache.shardingsphere.data.pipeline.core.exception.metadata,
• org.apache.shardingsphere.data.pipeline.core.exception.syntax,
• org.apache.shardingsphere.data.pipeline.core.execute,
• org.apache.shardingsphere.data.pipeline.core.importer,
• org.apache.shardingsphere.data.pipeline.core.ingest,
• org.apache.shardingsphere.data.pipeline.core.ingest.channel,
• org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory,
• org.apache.shardingsphere.data.pipeline.core.ingest.dumper,
• org.apache.shardingsphere.data.pipeline.core.ingest.exception,
• org.apache.shardingsphere.data.pipeline.core.ingest.position,
• org.apache.shardingsphere.data.pipeline.core.job,
• 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.yaml,
• org.apache.shardingsphere.data.pipeline.core.listener,
• org.apache.shardingsphere.data.pipeline.core.metadata.generator,
• org.apache.shardingsphere.data.pipeline.core.metadata.loader,
• 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.impl,
• org.apache.shardingsphere.data.pipeline.core.prepare,
• org.apache.shardingsphere.data.pipeline.core.prepare.datasource,
• org.apache.shardingsphere.data.pipeline.core.ratelimit,
• org.apache.shardingsphere.data.pipeline.core.record,
• org.apache.shardingsphere.data.pipeline.core.registry,
• org.apache.shardingsphere.data.pipeline.core.sqlbuilder,
• org.apache.shardingsphere.data.pipeline.core.task,
• org.apache.shardingsphere.data.pipeline.core.util,
• org.apache.shardingsphere.data.pipeline.scenario.consistencycheck,
• org.apache.shardingsphere.data.pipeline.scenario.migration,
• org.apache.shardingsphere.data.pipeline.yaml.consistency,
• org.apache.shardingsphere.data.pipeline.yaml.job,
• org.apache.shardingsphere.data.pipeline.yaml.metadata,
• org.apache.shardingsphere.data.pipeline.yaml.process

类分层结构

• java.lang.Object
  • org.apache.shardingsphere.data.pipeline.core.check.consistency.algorithm.AbstractDataConsistencyCalculateAlgorithm (implements org.apache.shardingsphere.data.pipeline.spi.check.consistency.DataConsistencyCalculateAlgorithm)
    • org.apache.shardingsphere.data.pipeline.core.check.consistency.algorithm.AbstractStreamingDataConsistencyCalculateAlgorithm
      • org.apache.shardingsphere.data.pipeline.core.check.consistency.algorithm.DataMatchDataConsistencyCalculateAlgorithm
    • org.apache.shardingsphere.data.pipeline.core.check.consistency.algorithm.CRC32MatchDataConsistencyCalculateAlgorithm
  • org.apache.shardingsphere.data.pipeline.core.check.datasource.AbstractDataSourceChecker (implements org.apache.shardingsphere.data.pipeline.spi.check.datasource.DataSourceChecker)
    • org.apache.shardingsphere.data.pipeline.core.check.datasource.BasicDataSourceChecker
  • org.apache.shardingsphere.data.pipeline.core.prepare.datasource.AbstractDataSourcePreparer (implements org.apache.shardingsphere.data.pipeline.core.prepare.datasource.DataSourcePreparer)
  • org.apache.shardingsphere.data.pipeline.core.context.AbstractInventoryIncrementalProcessContext (implements org.apache.shardingsphere.data.pipeline.core.context.InventoryIncrementalProcessContext)
    • org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationProcessContext
  • org.apache.shardingsphere.data.pipeline.api.executor.AbstractLifecycleExecutor (implements org.apache.shardingsphere.data.pipeline.api.executor.LifecycleExecutor)
    • org.apache.shardingsphere.data.pipeline.core.importer.DefaultImporter (implements org.apache.shardingsphere.data.pipeline.api.importer.Importer)
    • org.apache.shardingsphere.data.pipeline.core.ingest.dumper.InventoryDumper (implements org.apache.shardingsphere.data.pipeline.api.ingest.dumper.Dumper)
  • org.apache.shardingsphere.data.pipeline.core.job.AbstractPipelineJob (implements org.apache.shardingsphere.data.pipeline.api.job.PipelineJob)
    • org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJob (implements org.apache.shardingsphere.data.pipeline.api.job.PipelineJob, org.apache.shardingsphere.elasticjob.simple.job.SimpleJob)
    • org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJob (implements org.apache.shardingsphere.data.pipeline.api.job.PipelineJob, org.apache.shardingsphere.elasticjob.simple.job.SimpleJob)
  • org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractPipelineJobAPIImpl (implements org.apache.shardingsphere.data.pipeline.core.api.PipelineJobAPI)
    • org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractInventoryIncrementalJobAPIImpl (implements org.apache.shardingsphere.data.pipeline.core.api.InventoryIncrementalJobAPI, org.apache.shardingsphere.data.pipeline.api.InventoryIncrementalJobPublicAPI)
      • org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPIImpl (implements org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPI)
    • org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobAPIImpl (implements org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobAPI)
  • org.apache.shardingsphere.data.pipeline.core.job.AbstractPipelineJobId (implements org.apache.shardingsphere.data.pipeline.api.job.PipelineJobId)
    • org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobId
    • org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobId
  • org.apache.shardingsphere.data.pipeline.core.sqlbuilder.AbstractPipelineSQLBuilder (implements org.apache.shardingsphere.data.pipeline.spi.sqlbuilder.PipelineSQLBuilder)
    • org.apache.shardingsphere.data.pipeline.core.sqlbuilder.DefaultPipelineSQLBuilder
    • org.apache.shardingsphere.data.pipeline.core.sqlbuilder.OraclePipelineSQLBuilder
  • org.apache.shardingsphere.data.pipeline.core.metadata.node.event.handler.impl.BarrierMetaDataChangedEventHandler (implements org.apache.shardingsphere.data.pipeline.core.metadata.node.event.handler.PipelineMetaDataChangedEventHandler)
  • org.apache.shardingsphere.data.pipeline.core.ingest.dumper.BasicColumnValueReader (implements org.apache.shardingsphere.data.pipeline.spi.ingest.dumper.ColumnValueReader)
  • org.apache.shardingsphere.data.pipeline.core.metadata.node.event.handler.impl.ChangedJobConfigurationDispatcher (implements org.apache.shardingsphere.data.pipeline.core.metadata.node.event.handler.PipelineMetaDataChangedEventHandler)
  • org.apache.shardingsphere.data.pipeline.core.ingest.dumper.ColumnValueReaderFactory
  • org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckChangedJobConfigurationProcessor (implements org.apache.shardingsphere.data.pipeline.core.metadata.node.event.handler.PipelineChangedJobConfigurationProcessor)
  • org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobAPIFactory
  • org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobItemContext (implements org.apache.shardingsphere.data.pipeline.api.context.PipelineJobItemContext, org.apache.shardingsphere.data.pipeline.api.job.progress.listener.PipelineJobProgressListener)
  • org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckTasksRunner (implements org.apache.shardingsphere.data.pipeline.api.task.PipelineTasksRunner)
  • org.apache.shardingsphere.data.pipeline.core.registry.CoordinatorRegistryCenterInitializer
  • org.apache.shardingsphere.data.pipeline.core.check.consistency.DataConsistencyCalculateAlgorithmChooser
  • org.apache.shardingsphere.data.pipeline.core.check.consistency.DataConsistencyCheckUtils
  • org.apache.shardingsphere.data.pipeline.core.constant.DataPipelineConstants
  • org.apache.shardingsphere.data.pipeline.core.importer.DataRecordMerger
  • org.apache.shardingsphere.data.pipeline.core.check.datasource.DataSourceCheckerFactory
  • org.apache.shardingsphere.data.pipeline.core.prepare.datasource.DataSourcePreparerFactory
  • org.apache.shardingsphere.data.pipeline.core.importer.DefaultImporterCreator (implements org.apache.shardingsphere.data.pipeline.spi.importer.ImporterCreator)
  • org.apache.shardingsphere.data.pipeline.core.datasource.DefaultPipelineDataSourceManager (implements org.apache.shardingsphere.data.pipeline.api.datasource.PipelineDataSourceManager)
  • org.apache.shardingsphere.data.pipeline.core.ingest.position.DefaultPositionInitializer (implements org.apache.shardingsphere.data.pipeline.spi.ingest.position.PositionInitializer)
  • org.apache.shardingsphere.data.pipeline.core.ingest.channel.EmptyAckCallback (implements org.apache.shardingsphere.data.pipeline.api.ingest.channel.AckCallback)
  • org.apache.shardingsphere.data.pipeline.core.execute.ExecuteEngine
  • org.apache.shardingsphere.data.pipeline.core.api.impl.GovernanceRepositoryAPIImpl (implements org.apache.shardingsphere.data.pipeline.core.api.GovernanceRepositoryAPI)
  • org.apache.shardingsphere.data.pipeline.core.task.IncrementalTask (implements java.lang.AutoCloseable, org.apache.shardingsphere.data.pipeline.core.task.PipelineTask)
  • org.apache.shardingsphere.data.pipeline.core.ingest.IngestDataChangeType
  • org.apache.shardingsphere.data.pipeline.core.api.impl.InventoryIncrementalJobItemAPIImpl (implements org.apache.shardingsphere.data.pipeline.core.api.PipelineJobItemAPI)
  • org.apache.shardingsphere.data.pipeline.core.task.InventoryIncrementalTasksRunner (implements org.apache.shardingsphere.data.pipeline.api.task.PipelineTasksRunner)
  • org.apache.shardingsphere.data.pipeline.core.task.InventoryTask (implements java.lang.AutoCloseable, org.apache.shardingsphere.data.pipeline.core.task.PipelineTask)
  • org.apache.shardingsphere.data.pipeline.core.prepare.InventoryTaskSplitter
  • org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory.ManualBitSet
  • org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory.MemoryPipelineChannelCreator (implements org.apache.shardingsphere.data.pipeline.spi.ingest.channel.PipelineChannelCreator)
  • org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationChangedJobConfigurationProcessor (implements org.apache.shardingsphere.data.pipeline.core.metadata.node.event.handler.PipelineChangedJobConfigurationProcessor)
  • org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationDataConsistencyChecker (implements org.apache.shardingsphere.data.pipeline.api.check.consistency.PipelineDataConsistencyChecker)
  • org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPIFactory
  • org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobItemContext (implements org.apache.shardingsphere.data.pipeline.core.context.InventoryIncrementalJobItemContext)
  • org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobPreparer
  • org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationTaskConfiguration (implements org.apache.shardingsphere.data.pipeline.api.config.PipelineTaskConfiguration)
  • org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory.MultiplexMemoryPipelineChannel (implements org.apache.shardingsphere.data.pipeline.api.ingest.channel.PipelineChannel)
  • org.apache.shardingsphere.data.pipeline.core.api.PipelineAPIFactory
  • org.apache.shardingsphere.data.pipeline.core.metadata.node.event.handler.PipelineChangedJobConfigurationProcessorFactory
  • org.apache.shardingsphere.data.pipeline.core.context.PipelineContext
  • org.apache.shardingsphere.data.pipeline.core.listener.PipelineContextManagerLifecycleListener (implements org.apache.shardingsphere.mode.manager.listener.ContextManagerLifecycleListener)
  • org.apache.shardingsphere.data.pipeline.core.datasource.creator.PipelineDataSourceCreatorFactory
  • org.apache.shardingsphere.data.pipeline.core.datasource.PipelineDataSourceFactory
  • org.apache.shardingsphere.data.pipeline.core.api.impl.PipelineDataSourcePersistService (implements org.apache.shardingsphere.data.pipeline.core.api.PipelineMetaDataPersistService<T>)
  • org.apache.shardingsphere.data.pipeline.core.metadata.generator.PipelineDDLGenerator
  • org.apache.shardingsphere.data.pipeline.core.util.PipelineDistributedBarrier
  • org.apache.shardingsphere.data.pipeline.core.util.PipelineJdbcUtils
  • org.apache.shardingsphere.data.pipeline.core.job.PipelineJobCenter
  • org.apache.shardingsphere.data.pipeline.core.job.PipelineJobIdUtils
  • org.apache.shardingsphere.data.pipeline.core.prepare.PipelineJobPreparerUtils
  • org.apache.shardingsphere.data.pipeline.core.job.progress.PipelineJobProgressDetector
  • org.apache.shardingsphere.data.pipeline.core.job.progress.persist.PipelineJobProgressPersistContext
  • org.apache.shardingsphere.data.pipeline.core.job.progress.persist.PipelineJobProgressPersistService
  • org.apache.shardingsphere.data.pipeline.core.execute.PipelineJobWorker
  • org.apache.shardingsphere.data.pipeline.core.metadata.node.event.handler.PipelineMetaDataChangedEventHandlerFactory
  • org.apache.shardingsphere.data.pipeline.core.metadata.node.PipelineMetaDataNode
  • org.apache.shardingsphere.data.pipeline.core.metadata.node.PipelineMetaDataNodeWatcher
  • org.apache.shardingsphere.data.pipeline.core.api.impl.PipelineProcessConfigurationPersistService (implements org.apache.shardingsphere.data.pipeline.core.api.PipelineMetaDataPersistService<T>)
  • org.apache.shardingsphere.data.pipeline.core.config.process.PipelineProcessConfigurationUtil
  • org.apache.shardingsphere.data.pipeline.core.metadata.loader.PipelineSchemaUtil
  • org.apache.shardingsphere.data.pipeline.core.sqlbuilder.PipelineSQLBuilderFactory
  • org.apache.shardingsphere.data.pipeline.core.metadata.loader.PipelineTableMetaDataUtil
  • org.apache.shardingsphere.data.pipeline.core.prepare.datasource.PrepareTargetSchemasParameter
  • org.apache.shardingsphere.data.pipeline.core.prepare.datasource.PrepareTargetTablesParameter
  • org.apache.shardingsphere.data.pipeline.core.ratelimit.QPSJobRateLimitAlgorithm (implements org.apache.shardingsphere.data.pipeline.spi.ratelimit.JobRateLimitAlgorithm)
  • org.apache.shardingsphere.data.pipeline.core.record.RecordUtil
  • org.apache.shardingsphere.data.pipeline.core.util.ReflectionUtil
  • org.apache.shardingsphere.data.pipeline.core.listener.ShardingSphereDataContextManagerLifecycleListener (implements org.apache.shardingsphere.mode.manager.listener.ContextManagerLifecycleListener)
  • org.apache.shardingsphere.data.pipeline.core.execute.ShardingSphereDataJobWorker
  • org.apache.shardingsphere.data.pipeline.core.execute.ShardingSphereDataScheduleCollector
  • org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory.SimpleMemoryPipelineChannel (implements org.apache.shardingsphere.data.pipeline.api.ingest.channel.PipelineChannel)
  • org.apache.shardingsphere.data.pipeline.core.check.consistency.SingleTableInventoryDataConsistencyChecker
  • org.apache.shardingsphere.data.pipeline.core.datasource.creator.impl.StandardPipelineDataSourceCreator (implements org.apache.shardingsphere.data.pipeline.core.datasource.creator.PipelineDataSourceCreator)
  • org.apache.shardingsphere.data.pipeline.core.metadata.loader.StandardPipelineTableMetaDataLoader (implements org.apache.shardingsphere.data.pipeline.api.metadata.loader.PipelineTableMetaDataLoader)
  • org.apache.shardingsphere.data.pipeline.core.util.ThreadUtil
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • java.lang.RuntimeException
        • org.apache.shardingsphere.data.pipeline.core.ingest.exception.IngestException
        • org.apache.shardingsphere.infra.util.exception.external.ShardingSphereExternalException
          • org.apache.shardingsphere.infra.util.exception.external.sql.ShardingSphereSQLException
            • org.apache.shardingsphere.infra.util.exception.external.sql.type.kernel.KernelSQLException
              • org.apache.shardingsphere.data.pipeline.core.exception.PipelineSQLException
                • org.apache.shardingsphere.data.pipeline.core.exception.connection.AddMigrationSourceResourceException
                • org.apache.shardingsphere.data.pipeline.core.exception.metadata.AlterNotExistProcessConfigurationException
                • org.apache.shardingsphere.data.pipeline.core.exception.job.BinlogSyncChannelAlreadyClosedException
                • org.apache.shardingsphere.data.pipeline.core.exception.metadata.CreateExistsProcessConfigurationException
                • org.apache.shardingsphere.data.pipeline.core.exception.syntax.CreateTableSQLGenerateException
                • org.apache.shardingsphere.data.pipeline.core.exception.connection.DropMigrationSourceResourceException
                • org.apache.shardingsphere.data.pipeline.core.exception.job.PipelineImporterJobWriteException
                • org.apache.shardingsphere.data.pipeline.core.exception.job.PipelineJobCreationWithInvalidShardingCountException
                • org.apache.shardingsphere.data.pipeline.core.exception.job.PipelineJobExecutionException
                • org.apache.shardingsphere.data.pipeline.core.exception.job.PipelineJobHasAlreadyFinishedException
                • org.apache.shardingsphere.data.pipeline.core.exception.job.PipelineJobHasAlreadyStartedException
                • org.apache.shardingsphere.data.pipeline.core.exception.job.PipelineJobNotFoundException
                • org.apache.shardingsphere.data.pipeline.core.exception.data.PipelineTableDataConsistencyCheckLoadingFailedException
                • org.apache.shardingsphere.data.pipeline.core.exception.data.PipelineUnexpectedDataRecordOrderException
                • org.apache.shardingsphere.data.pipeline.core.exception.job.PrepareJobWithCheckPrivilegeFailedException
                • org.apache.shardingsphere.data.pipeline.core.exception.job.PrepareJobWithGetBinlogPositionException
                • org.apache.shardingsphere.data.pipeline.core.exception.job.PrepareJobWithInvalidConnectionException
                • org.apache.shardingsphere.data.pipeline.core.exception.job.PrepareJobWithInvalidSourceDataSourceException
                • org.apache.shardingsphere.data.pipeline.core.exception.job.PrepareJobWithoutEnoughPrivilegeException
                • org.apache.shardingsphere.data.pipeline.core.exception.job.PrepareJobWithoutUserException
                • org.apache.shardingsphere.data.pipeline.core.exception.job.PrepareJobWithTargetTableNotEmptyException
                • org.apache.shardingsphere.data.pipeline.core.exception.job.SplitPipelineJobByRangeException
                • org.apache.shardingsphere.data.pipeline.core.exception.job.SplitPipelineJobByUniqueKeyException
                • org.apache.shardingsphere.data.pipeline.core.exception.job.UncompletedConsistencyCheckJobExistsException
                • org.apache.shardingsphere.data.pipeline.core.exception.data.UnsupportedCRC32DataConsistencyCalculateAlgorithmException
                • org.apache.shardingsphere.data.pipeline.core.exception.data.UnsupportedPipelineDatabaseTypeException
                • org.apache.shardingsphere.data.pipeline.core.exception.data.UnsupportedPipelineJobUniqueKeyDataTypeException
  • org.apache.shardingsphere.data.pipeline.core.ratelimit.TPSJobRateLimitAlgorithm (implements org.apache.shardingsphere.data.pipeline.spi.ratelimit.JobRateLimitAlgorithm)
  • org.apache.shardingsphere.data.pipeline.yaml.job.YamlConsistencyCheckJobConfiguration (implements org.apache.shardingsphere.data.pipeline.api.config.job.yaml.YamlPipelineJobConfiguration)
  • org.apache.shardingsphere.data.pipeline.yaml.job.YamlConsistencyCheckJobConfigurationSwapper (implements org.apache.shardingsphere.infra.util.yaml.swapper.YamlConfigurationSwapper<Y,T>)
  • org.apache.shardingsphere.data.pipeline.core.job.progress.yaml.YamlConsistencyCheckJobProgress (implements org.apache.shardingsphere.infra.util.yaml.YamlConfiguration)
  • org.apache.shardingsphere.data.pipeline.core.job.progress.yaml.YamlConsistencyCheckJobProgressSwapper (implements org.apache.shardingsphere.infra.util.yaml.swapper.YamlConfigurationSwapper<Y,T>)
  • org.apache.shardingsphere.data.pipeline.yaml.consistency.YamlDataConsistencyCheckResult (implements org.apache.shardingsphere.infra.util.yaml.YamlConfiguration)
  • org.apache.shardingsphere.data.pipeline.yaml.consistency.YamlDataConsistencyCheckResult.YamlDataConsistencyContentCheckResult (implements org.apache.shardingsphere.infra.util.yaml.YamlConfiguration)
  • org.apache.shardingsphere.data.pipeline.yaml.consistency.YamlDataConsistencyCheckResult.YamlDataConsistencyCountCheckResult (implements org.apache.shardingsphere.infra.util.yaml.YamlConfiguration)
  • org.apache.shardingsphere.data.pipeline.yaml.consistency.YamlDataConsistencyCheckResultSwapper (implements org.apache.shardingsphere.infra.util.yaml.swapper.YamlConfigurationSwapper<Y,T>)
  • org.apache.shardingsphere.data.pipeline.core.job.progress.yaml.YamlInventoryIncrementalJobItemProgress (implements org.apache.shardingsphere.infra.util.yaml.YamlConfiguration)
  • org.apache.shardingsphere.data.pipeline.core.job.progress.yaml.YamlInventoryIncrementalJobItemProgressSwapper (implements org.apache.shardingsphere.infra.util.yaml.swapper.YamlConfigurationSwapper<Y,T>)
  • org.apache.shardingsphere.data.pipeline.core.job.progress.yaml.YamlJobItemIncrementalTasksProgress
  • org.apache.shardingsphere.data.pipeline.core.job.progress.yaml.YamlJobItemIncrementalTasksProgressSwapper
  • org.apache.shardingsphere.data.pipeline.core.job.progress.yaml.YamlJobItemInventoryTasksProgress
  • org.apache.shardingsphere.data.pipeline.core.job.progress.yaml.YamlJobItemInventoryTasksProgressSwapper
  • org.apache.shardingsphere.data.pipeline.yaml.job.YamlMigrationJobConfiguration (implements org.apache.shardingsphere.data.pipeline.api.config.job.yaml.YamlPipelineJobConfiguration)
  • org.apache.shardingsphere.data.pipeline.yaml.job.YamlMigrationJobConfigurationSwapper (implements org.apache.shardingsphere.infra.util.yaml.swapper.YamlConfigurationSwapper<Y,T>)
  • org.apache.shardingsphere.data.pipeline.yaml.metadata.YamlPipelineColumnMetaData (implements org.apache.shardingsphere.infra.util.yaml.YamlConfiguration)
  • org.apache.shardingsphere.data.pipeline.yaml.metadata.YamlPipelineColumnMetaDataSwapper (implements org.apache.shardingsphere.infra.util.yaml.swapper.YamlConfigurationSwapper<Y,T>)
  • org.apache.shardingsphere.data.pipeline.yaml.process.YamlPipelineProcessConfiguration (implements org.apache.shardingsphere.infra.util.yaml.YamlConfiguration)
  • org.apache.shardingsphere.data.pipeline.yaml.process.YamlPipelineProcessConfigurationSwapper (implements org.apache.shardingsphere.infra.util.yaml.swapper.YamlConfigurationSwapper<Y,T>)
  • org.apache.shardingsphere.data.pipeline.yaml.process.YamlPipelineReadConfiguration (implements org.apache.shardingsphere.infra.util.yaml.YamlConfiguration)
  • org.apache.shardingsphere.data.pipeline.yaml.process.YamlPipelineReadConfigurationSwapper (implements org.apache.shardingsphere.infra.util.yaml.swapper.YamlConfigurationSwapper<Y,T>)
  • org.apache.shardingsphere.data.pipeline.yaml.process.YamlPipelineWriteConfiguration (implements org.apache.shardingsphere.infra.util.yaml.YamlConfiguration)
  • org.apache.shardingsphere.data.pipeline.yaml.process.YamlPipelineWriteConfigurationSwapper (implements org.apache.shardingsphere.infra.util.yaml.swapper.YamlConfigurationSwapper<Y,T>)

接口分层结构

• org.apache.shardingsphere.data.pipeline.core.execute.ExecuteCallback
• org.apache.shardingsphere.data.pipeline.core.api.GovernanceRepositoryAPI
• org.apache.shardingsphere.data.pipeline.core.api.PipelineJobItemAPI
  • org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobAPI (并 extends org.apache.shardingsphere.data.pipeline.api.ConsistencyCheckJobPublicAPI, org.apache.shardingsphere.data.pipeline.core.api.PipelineJobAPI)
  • org.apache.shardingsphere.data.pipeline.core.api.InventoryIncrementalJobAPI
    • org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPI (并 extends org.apache.shardingsphere.data.pipeline.api.MigrationJobPublicAPI, org.apache.shardingsphere.infra.util.spi.type.required.RequiredSPI)
  • org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPI (并 extends org.apache.shardingsphere.data.pipeline.core.api.InventoryIncrementalJobAPI, org.apache.shardingsphere.data.pipeline.api.MigrationJobPublicAPI, org.apache.shardingsphere.infra.util.spi.type.required.RequiredSPI)
  • org.apache.shardingsphere.data.pipeline.core.api.PipelineJobAPI (并 extends org.apache.shardingsphere.data.pipeline.api.PipelineJobPublicAPI, org.apache.shardingsphere.infra.util.spi.type.typed.TypedSPI)
    • org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobAPI (并 extends org.apache.shardingsphere.data.pipeline.api.ConsistencyCheckJobPublicAPI, org.apache.shardingsphere.data.pipeline.core.api.PipelineJobItemAPI)
    • org.apache.shardingsphere.data.pipeline.core.api.InventoryIncrementalJobAPI
      • org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPI (并 extends org.apache.shardingsphere.data.pipeline.api.MigrationJobPublicAPI, org.apache.shardingsphere.infra.util.spi.type.required.RequiredSPI)
    • org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPI (并 extends org.apache.shardingsphere.data.pipeline.core.api.InventoryIncrementalJobAPI, org.apache.shardingsphere.data.pipeline.api.MigrationJobPublicAPI, org.apache.shardingsphere.infra.util.spi.type.required.RequiredSPI)
• org.apache.shardingsphere.data.pipeline.api.context.PipelineJobItemContext
  • org.apache.shardingsphere.data.pipeline.core.context.InventoryIncrementalJobItemContext (并 extends org.apache.shardingsphere.data.pipeline.api.job.progress.listener.PipelineJobProgressListener)
• org.apache.shardingsphere.data.pipeline.api.job.progress.listener.PipelineJobProgressListener
  • org.apache.shardingsphere.data.pipeline.core.context.InventoryIncrementalJobItemContext (并 extends org.apache.shardingsphere.data.pipeline.api.context.PipelineJobItemContext)
• org.apache.shardingsphere.data.pipeline.api.PipelineJobPublicAPI
  • org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobAPI (并 extends org.apache.shardingsphere.data.pipeline.api.ConsistencyCheckJobPublicAPI, org.apache.shardingsphere.data.pipeline.core.api.PipelineJobAPI, org.apache.shardingsphere.data.pipeline.core.api.PipelineJobItemAPI)
  • org.apache.shardingsphere.data.pipeline.api.ConsistencyCheckJobPublicAPI (并 extends org.apache.shardingsphere.infra.util.spi.type.required.RequiredSPI)
    • org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobAPI (并 extends org.apache.shardingsphere.data.pipeline.core.api.PipelineJobAPI, org.apache.shardingsphere.data.pipeline.core.api.PipelineJobItemAPI)
  • org.apache.shardingsphere.data.pipeline.core.api.InventoryIncrementalJobAPI
    • org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPI (并 extends org.apache.shardingsphere.data.pipeline.api.MigrationJobPublicAPI, org.apache.shardingsphere.infra.util.spi.type.required.RequiredSPI)
  • org.apache.shardingsphere.data.pipeline.api.InventoryIncrementalJobPublicAPI (并 extends org.apache.shardingsphere.infra.util.spi.type.typed.TypedSPI)
    • org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPI (并 extends org.apache.shardingsphere.data.pipeline.core.api.InventoryIncrementalJobAPI, org.apache.shardingsphere.data.pipeline.api.MigrationJobPublicAPI, org.apache.shardingsphere.infra.util.spi.type.required.RequiredSPI)
    • org.apache.shardingsphere.data.pipeline.api.MigrationJobPublicAPI (并 extends org.apache.shardingsphere.infra.util.spi.type.required.RequiredSPI)
      • org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPI (并 extends org.apache.shardingsphere.data.pipeline.core.api.InventoryIncrementalJobAPI, org.apache.shardingsphere.infra.util.spi.type.required.RequiredSPI)
  • org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPI (并 extends org.apache.shardingsphere.data.pipeline.core.api.InventoryIncrementalJobAPI, org.apache.shardingsphere.data.pipeline.api.MigrationJobPublicAPI, org.apache.shardingsphere.infra.util.spi.type.required.RequiredSPI)
  • org.apache.shardingsphere.data.pipeline.api.MigrationJobPublicAPI (并 extends org.apache.shardingsphere.data.pipeline.api.InventoryIncrementalJobPublicAPI, org.apache.shardingsphere.infra.util.spi.type.required.RequiredSPI)
    • org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPI (并 extends org.apache.shardingsphere.data.pipeline.core.api.InventoryIncrementalJobAPI, org.apache.shardingsphere.infra.util.spi.type.required.RequiredSPI)
  • org.apache.shardingsphere.data.pipeline.core.api.PipelineJobAPI (并 extends org.apache.shardingsphere.data.pipeline.core.api.PipelineJobItemAPI, org.apache.shardingsphere.infra.util.spi.type.typed.TypedSPI)
    • org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobAPI (并 extends org.apache.shardingsphere.data.pipeline.api.ConsistencyCheckJobPublicAPI, org.apache.shardingsphere.data.pipeline.core.api.PipelineJobItemAPI)
    • org.apache.shardingsphere.data.pipeline.core.api.InventoryIncrementalJobAPI
      • org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPI (并 extends org.apache.shardingsphere.data.pipeline.api.MigrationJobPublicAPI, org.apache.shardingsphere.infra.util.spi.type.required.RequiredSPI)
    • org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPI (并 extends org.apache.shardingsphere.data.pipeline.core.api.InventoryIncrementalJobAPI, org.apache.shardingsphere.data.pipeline.api.MigrationJobPublicAPI, org.apache.shardingsphere.infra.util.spi.type.required.RequiredSPI)
• org.apache.shardingsphere.data.pipeline.core.metadata.node.event.handler.PipelineMetaDataChangedEventHandler
• org.apache.shardingsphere.data.pipeline.core.api.PipelineMetaDataPersistService<T>
• org.apache.shardingsphere.data.pipeline.api.context.PipelineProcessContext
  • org.apache.shardingsphere.data.pipeline.core.context.InventoryIncrementalProcessContext
• org.apache.shardingsphere.data.pipeline.core.task.PipelineTask
• org.apache.shardingsphere.infra.util.spi.type.required.RequiredSPI
  • org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobAPI (并 extends org.apache.shardingsphere.data.pipeline.api.ConsistencyCheckJobPublicAPI, org.apache.shardingsphere.data.pipeline.core.api.PipelineJobAPI, org.apache.shardingsphere.data.pipeline.core.api.PipelineJobItemAPI)
  • org.apache.shardingsphere.data.pipeline.api.ConsistencyCheckJobPublicAPI (并 extends org.apache.shardingsphere.data.pipeline.api.PipelineJobPublicAPI)
    • org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobAPI (并 extends org.apache.shardingsphere.data.pipeline.core.api.PipelineJobAPI, org.apache.shardingsphere.data.pipeline.core.api.PipelineJobItemAPI)
  • org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPI (并 extends org.apache.shardingsphere.data.pipeline.core.api.InventoryIncrementalJobAPI, org.apache.shardingsphere.data.pipeline.api.MigrationJobPublicAPI)
  • org.apache.shardingsphere.data.pipeline.api.MigrationJobPublicAPI (并 extends org.apache.shardingsphere.data.pipeline.api.InventoryIncrementalJobPublicAPI)
    • org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPI (并 extends org.apache.shardingsphere.data.pipeline.core.api.InventoryIncrementalJobAPI, org.apache.shardingsphere.infra.util.spi.type.required.RequiredSPI)
• org.apache.shardingsphere.infra.util.spi.type.typed.TypedSPI
  • org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobAPI (并 extends org.apache.shardingsphere.data.pipeline.api.ConsistencyCheckJobPublicAPI, org.apache.shardingsphere.data.pipeline.core.api.PipelineJobAPI, org.apache.shardingsphere.data.pipeline.core.api.PipelineJobItemAPI)
  • org.apache.shardingsphere.data.pipeline.core.prepare.datasource.DataSourcePreparer
  • org.apache.shardingsphere.data.pipeline.core.api.InventoryIncrementalJobAPI
    • org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPI (并 extends org.apache.shardingsphere.data.pipeline.api.MigrationJobPublicAPI, org.apache.shardingsphere.infra.util.spi.type.required.RequiredSPI)
  • org.apache.shardingsphere.data.pipeline.api.InventoryIncrementalJobPublicAPI (并 extends org.apache.shardingsphere.data.pipeline.api.PipelineJobPublicAPI)
    • org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPI (并 extends org.apache.shardingsphere.data.pipeline.core.api.InventoryIncrementalJobAPI, org.apache.shardingsphere.data.pipeline.api.MigrationJobPublicAPI, org.apache.shardingsphere.infra.util.spi.type.required.RequiredSPI)
    • org.apache.shardingsphere.data.pipeline.api.MigrationJobPublicAPI (并 extends org.apache.shardingsphere.infra.util.spi.type.required.RequiredSPI)
      • org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPI (并 extends org.apache.shardingsphere.data.pipeline.core.api.InventoryIncrementalJobAPI, org.apache.shardingsphere.infra.util.spi.type.required.RequiredSPI)
  • org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPI (并 extends org.apache.shardingsphere.data.pipeline.core.api.InventoryIncrementalJobAPI, org.apache.shardingsphere.data.pipeline.api.MigrationJobPublicAPI, org.apache.shardingsphere.infra.util.spi.type.required.RequiredSPI)
  • org.apache.shardingsphere.data.pipeline.api.MigrationJobPublicAPI (并 extends org.apache.shardingsphere.data.pipeline.api.InventoryIncrementalJobPublicAPI, org.apache.shardingsphere.infra.util.spi.type.required.RequiredSPI)
    • org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPI (并 extends org.apache.shardingsphere.data.pipeline.core.api.InventoryIncrementalJobAPI, org.apache.shardingsphere.infra.util.spi.type.required.RequiredSPI)
  • org.apache.shardingsphere.data.pipeline.core.metadata.node.event.handler.PipelineChangedJobConfigurationProcessor
  • org.apache.shardingsphere.data.pipeline.core.datasource.creator.PipelineDataSourceCreator
  • org.apache.shardingsphere.data.pipeline.core.api.PipelineJobAPI (并 extends org.apache.shardingsphere.data.pipeline.core.api.PipelineJobItemAPI, org.apache.shardingsphere.data.pipeline.api.PipelineJobPublicAPI)
    • org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobAPI (并 extends org.apache.shardingsphere.data.pipeline.api.ConsistencyCheckJobPublicAPI, org.apache.shardingsphere.data.pipeline.core.api.PipelineJobItemAPI)
    • org.apache.shardingsphere.data.pipeline.core.api.InventoryIncrementalJobAPI
      • org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPI (并 extends org.apache.shardingsphere.data.pipeline.api.MigrationJobPublicAPI, org.apache.shardingsphere.infra.util.spi.type.required.RequiredSPI)
    • org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPI (并 extends org.apache.shardingsphere.data.pipeline.core.api.InventoryIncrementalJobAPI, org.apache.shardingsphere.data.pipeline.api.MigrationJobPublicAPI, org.apache.shardingsphere.infra.util.spi.type.required.RequiredSPI)