所有程序包的分层结构

程序包分层结构:

• 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.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.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.listener,
• 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.model,
• org.apache.shardingsphere.data.pipeline.core.metadata.node,
• org.apache.shardingsphere.data.pipeline.core.prepare,
• org.apache.shardingsphere.data.pipeline.core.prepare.datasource,
• org.apache.shardingsphere.data.pipeline.core.record,
• org.apache.shardingsphere.data.pipeline.core.registry,
• org.apache.shardingsphere.data.pipeline.core.spi.ratelimit,
• 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.migration

类分层结构

• java.lang.Object
  • 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.api.executor.AbstractLifecycleExecutor (implements org.apache.shardingsphere.data.pipeline.api.executor.LifecycleExecutor)
    • org.apache.shardingsphere.data.pipeline.core.ingest.dumper.AbstractIncrementalDumper<P> (implements org.apache.shardingsphere.data.pipeline.spi.ingest.dumper.IncrementalDumper)
    • org.apache.shardingsphere.data.pipeline.core.ingest.dumper.AbstractInventoryDumper (implements org.apache.shardingsphere.data.pipeline.spi.ingest.dumper.InventoryDumper)
      • org.apache.shardingsphere.data.pipeline.core.ingest.dumper.DefaultInventoryDumper
    • org.apache.shardingsphere.data.pipeline.core.importer.DefaultImporter (implements org.apache.shardingsphere.data.pipeline.api.importer.Importer)
    • 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.task.InventoryTask (implements java.lang.AutoCloseable, org.apache.shardingsphere.data.pipeline.core.task.PipelineTask)
    • org.apache.shardingsphere.data.pipeline.core.execute.PipelineJobExecutor
  • org.apache.shardingsphere.data.pipeline.core.job.AbstractPipelineJob (implements org.apache.shardingsphere.data.pipeline.api.job.PipelineJob)
    • 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.scenario.migration.MigrationJobAPIImpl (implements org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPI)
  • org.apache.shardingsphere.data.pipeline.core.job.AbstractPipelineJobId (implements org.apache.shardingsphere.data.pipeline.api.job.PipelineJobId)
    • org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobId
  • org.apache.shardingsphere.data.pipeline.core.context.AbstractPipelineProcessContext (implements org.apache.shardingsphere.data.pipeline.api.context.PipelineProcessContext)
    • org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationProcessContext
  • 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.check.consistency.algorithm.AbstractStreamingDataConsistencyCalculateAlgorithm (implements org.apache.shardingsphere.data.pipeline.spi.check.consistency.DataConsistencyCalculateAlgorithm)
    • org.apache.shardingsphere.data.pipeline.core.check.consistency.algorithm.DataMatchDataConsistencyCalculateAlgorithm
  • 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.ingest.dumper.ColumnValueReaderFactory
  • org.apache.shardingsphere.data.pipeline.core.registry.CoordinatorRegistryCenterInitializer
  • org.apache.shardingsphere.data.pipeline.core.check.consistency.algorithm.CRC32MatchDataConsistencyCalculateAlgorithm (implements org.apache.shardingsphere.data.pipeline.spi.check.consistency.DataConsistencyCalculateAlgorithm)
  • org.apache.shardingsphere.data.pipeline.core.check.consistency.DataConsistencyCalculateAlgorithmChooser
  • org.apache.shardingsphere.data.pipeline.core.check.consistency.DataConsistencyCalculateAlgorithmFactory
  • 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.ingest.dumper.DefaultInventoryDumperCreator (implements org.apache.shardingsphere.data.pipeline.core.ingest.dumper.InventoryDumperCreator)
  • org.apache.shardingsphere.data.pipeline.core.datasource.DefaultPipelineDataSourceManager (implements org.apache.shardingsphere.data.pipeline.api.datasource.PipelineDataSourceManager)
  • org.apache.shardingsphere.data.pipeline.core.job.progress.listener.DefaultPipelineJobProgressListener (implements org.apache.shardingsphere.data.pipeline.api.job.progress.listener.PipelineJobProgressListener)
  • 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.ingest.dumper.IncrementalDumperCreatorFactory
  • org.apache.shardingsphere.data.pipeline.core.ingest.IngestDataChangeType
  • org.apache.shardingsphere.data.pipeline.core.ingest.dumper.InventoryDumperCreatorFactory
  • 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.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.MigrationDataConsistencyChecker
  • 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.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.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.metadata.model.PipelineIndexMetaData
  • 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.PipelineMetaDataNode
  • 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.util.PipelineProcessConfigurationUtils
  • org.apache.shardingsphere.data.pipeline.core.util.PipelineSchemaTableUtil
  • org.apache.shardingsphere.data.pipeline.core.sqlbuilder.PipelineSQLBuilderFactory
  • org.apache.shardingsphere.data.pipeline.core.metadata.model.PipelineTableMetaData
  • org.apache.shardingsphere.data.pipeline.core.metadata.loader.PipelineTableMetaDataLoader
  • org.apache.shardingsphere.data.pipeline.core.ingest.position.PositionInitializerFactory
  • org.apache.shardingsphere.data.pipeline.core.prepare.datasource.PrepareTargetSchemasParameter
  • org.apache.shardingsphere.data.pipeline.core.prepare.datasource.PrepareTargetTablesParameter
  • org.apache.shardingsphere.data.pipeline.core.spi.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.ingest.channel.memory.SimpleMemoryPipelineChannel (implements org.apache.shardingsphere.data.pipeline.api.ingest.channel.PipelineChannel)
  • 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.util.ThreadUtil
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • java.lang.RuntimeException
        • org.apache.shardingsphere.data.pipeline.core.exception.AddMigrationSourceResourceException
        • org.apache.shardingsphere.data.pipeline.core.exception.DropMigrationSourceResourceException
        • org.apache.shardingsphere.data.pipeline.core.ingest.exception.IngestException
        • org.apache.shardingsphere.data.pipeline.core.exception.PipelineDataConsistencyCheckFailedException
        • org.apache.shardingsphere.data.pipeline.core.exception.PipelineIgnoredException
        • org.apache.shardingsphere.data.pipeline.core.exception.PipelineJobCreationException
        • org.apache.shardingsphere.data.pipeline.core.exception.PipelineJobExecutionException
        • org.apache.shardingsphere.data.pipeline.core.exception.PipelineJobPrepareFailedException
        • org.apache.shardingsphere.data.pipeline.core.exception.PipelineMetaDataException
        • org.apache.shardingsphere.data.pipeline.core.exception.PipelineUnexpectedDataRecordOrderException
        • org.apache.shardingsphere.data.pipeline.core.exception.PipelineVerifyFailedException
        • org.apache.shardingsphere.infra.util.exception.ShardingSphereInsideException
          • org.apache.shardingsphere.infra.util.exception.sql.ShardingSphereSQLException
            • org.apache.shardingsphere.data.pipeline.core.exception.CreateTableSQLGenerateException
            • org.apache.shardingsphere.data.pipeline.core.exception.PipelineJobNotFoundException
  • org.apache.shardingsphere.data.pipeline.core.spi.ratelimit.TPSJobRateLimitAlgorithm (implements org.apache.shardingsphere.data.pipeline.spi.ratelimit.JobRateLimitAlgorithm)
  • 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.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.migration.MigrationJobAPI (并 extends org.apache.shardingsphere.data.pipeline.api.MigrationJobPublicAPI, org.apache.shardingsphere.data.pipeline.core.api.PipelineJobAPI, 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.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.context.PipelineJobItemContext
  • org.apache.shardingsphere.data.pipeline.core.context.InventoryIncrementalJobItemContext
• org.apache.shardingsphere.data.pipeline.core.api.PipelineMetaDataPersistService<T>
• org.apache.shardingsphere.infra.util.spi.type.required.RequiredSPI
  • org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPI (并 extends org.apache.shardingsphere.data.pipeline.api.MigrationJobPublicAPI, org.apache.shardingsphere.data.pipeline.core.api.PipelineJobAPI)
  • org.apache.shardingsphere.data.pipeline.api.MigrationJobPublicAPI (并 extends org.apache.shardingsphere.data.pipeline.api.PipelineJobPublicAPI)
    • org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPI (并 extends org.apache.shardingsphere.data.pipeline.core.api.PipelineJobAPI, org.apache.shardingsphere.infra.util.spi.type.required.RequiredSPI)
• java.lang.Runnable
  • org.apache.shardingsphere.data.pipeline.api.executor.LifecycleExecutor
    • org.apache.shardingsphere.data.pipeline.core.task.PipelineTask
  • org.apache.shardingsphere.data.pipeline.core.task.PipelineTask
• org.apache.shardingsphere.infra.util.spi.type.typed.TypedSPI
  • org.apache.shardingsphere.data.pipeline.core.prepare.datasource.DataSourcePreparer
  • org.apache.shardingsphere.data.pipeline.core.ingest.dumper.IncrementalDumperCreator<P>
  • org.apache.shardingsphere.data.pipeline.core.ingest.dumper.InventoryDumperCreator
  • org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPI (并 extends org.apache.shardingsphere.data.pipeline.api.MigrationJobPublicAPI, org.apache.shardingsphere.data.pipeline.core.api.PipelineJobAPI, org.apache.shardingsphere.infra.util.spi.type.required.RequiredSPI)
  • org.apache.shardingsphere.data.pipeline.api.MigrationJobPublicAPI (并 extends org.apache.shardingsphere.data.pipeline.api.PipelineJobPublicAPI, 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.PipelineJobAPI, org.apache.shardingsphere.infra.util.spi.type.required.RequiredSPI)
  • 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.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.PipelineJobPublicAPI
    • org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPI (并 extends org.apache.shardingsphere.data.pipeline.api.MigrationJobPublicAPI, org.apache.shardingsphere.data.pipeline.core.api.PipelineJobAPI, 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.PipelineJobAPI, 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.migration.MigrationJobAPI (并 extends org.apache.shardingsphere.data.pipeline.api.MigrationJobPublicAPI, org.apache.shardingsphere.infra.util.spi.type.required.RequiredSPI)