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

A

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

AbstractIncrementalDumper<P> - org.apache.shardingsphere.data.pipeline.core.ingest.dumper中的类

Abstract incremental dumper.

AbstractIncrementalDumper(DumperConfiguration, IngestPosition<P>, PipelineChannel, PipelineTableMetaDataLoader) - 类 的构造器org.apache.shardingsphere.data.pipeline.core.ingest.dumper.AbstractIncrementalDumper

AbstractInventoryDumper - org.apache.shardingsphere.data.pipeline.core.ingest.dumper中的类

Abstract JDBC dumper implement.

AbstractInventoryDumper(InventoryDumperConfiguration, PipelineChannel, DataSource, PipelineTableMetaDataLoader) - 类 的构造器org.apache.shardingsphere.data.pipeline.core.ingest.dumper.AbstractInventoryDumper

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

AbstractPipelineProcessContext - org.apache.shardingsphere.data.pipeline.core.context中的类

Abstract pipeline process context.

AbstractPipelineProcessContext(String, PipelineProcessConfiguration) - 类 的构造器org.apache.shardingsphere.data.pipeline.core.context.AbstractPipelineProcessContext

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中的异常错误

Add migration source resource exception.

AddMigrationSourceResourceException(String) - 异常错误 的构造器org.apache.shardingsphere.data.pipeline.core.exception.AddMigrationSourceResourceException

AddMigrationSourceResourceException(Throwable) - 异常错误 的构造器org.apache.shardingsphere.data.pipeline.core.exception.AddMigrationSourceResourceException

addMigrationSourceResources(Map<String, DataSourceProperties>) - 类 中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPIImpl

aggregateDataConsistencyCheckResults(String, Map<String, DataConsistencyCheckResult>) - 接口 中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPI

Aggregate data consistency check results.

aggregateDataConsistencyCheckResults(String, Map<String, DataConsistencyCheckResult>) - 类 中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPIImpl

allInventoryTasksFinished(Collection<InventoryTask>) - 类 中的静态方法org.apache.shardingsphere.data.pipeline.core.job.progress.PipelineJobProgressDetector

All inventory tasks is finished.

alterProcessConfiguration(PipelineProcessConfiguration) - 类 中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractPipelineJobAPIImpl

await(String, long, TimeUnit) - 类 中的方法org.apache.shardingsphere.data.pipeline.core.util.PipelineDistributedBarrier

Await unitl all children node is ready.

B

BARRIER_PATTERN - 类 中的静态变量org.apache.shardingsphere.data.pipeline.core.metadata.node.PipelineMetaDataNode

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

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

buildCreateSchemaSQL(String) - 类 中的方法org.apache.shardingsphere.data.pipeline.core.sqlbuilder.OraclePipelineSQLBuilder

buildDeleteSQL(String, DataRecord, Collection<Column>) - 类 中的方法org.apache.shardingsphere.data.pipeline.core.sqlbuilder.AbstractPipelineSQLBuilder

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

buildInventoryDumpSQL(String, String, String, int, boolean) - 类 中的方法org.apache.shardingsphere.data.pipeline.core.sqlbuilder.AbstractPipelineSQLBuilder

buildInventoryDumpSQL(String, String, String, int, boolean) - 类 中的方法org.apache.shardingsphere.data.pipeline.core.sqlbuilder.OraclePipelineSQLBuilder

buildPipelineProcessContext(PipelineJobConfiguration) - 接口 中的方法org.apache.shardingsphere.data.pipeline.core.api.PipelineJobAPI

Build pipeline process context.

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.migration.MigrationJobAPIImpl

buildTruncateSQL(String, String) - 类 中的方法org.apache.shardingsphere.data.pipeline.core.sqlbuilder.AbstractPipelineSQLBuilder

buildUpdateSQL(String, DataRecord, Collection<Column>, Map<LogicTableName, Set<String>>) - 类 中的方法org.apache.shardingsphere.data.pipeline.core.sqlbuilder.AbstractPipelineSQLBuilder

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

check(DataConsistencyCalculateAlgorithm) - 类 中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationDataConsistencyChecker

Check data consistency.

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.

cleanTempTableOnRollback(String) - 类 中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractPipelineJobAPIImpl

cleanTempTableOnRollback(String) - 类 中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPIImpl

cleanup(MigrationJobConfiguration) - 类 中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobPreparer

Do cleanup work for scaling job.

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.core.api.impl.AbstractPipelineJobAPIImpl

CONFIG_PATTERN - 类 中的静态变量org.apache.shardingsphere.data.pipeline.core.metadata.node.PipelineMetaDataNode

convertWithDefaultValue(PipelineProcessConfiguration) - 类 中的静态方法org.apache.shardingsphere.data.pipeline.core.util.PipelineProcessConfigurationUtils

Convert with default value.

CoordinatorRegistryCenterInitializer - org.apache.shardingsphere.data.pipeline.core.registry中的类

CoordinatorRegistryCenter initializer.

CoordinatorRegistryCenterInitializer() - 类 的构造器org.apache.shardingsphere.data.pipeline.core.registry.CoordinatorRegistryCenterInitializer

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

createImporter(ImporterConfiguration, PipelineDataSourceManager, PipelineChannel, PipelineJobProgressListener) - 类 中的方法org.apache.shardingsphere.data.pipeline.core.importer.DefaultImporterCreator

createIncrementalDumper(DumperConfiguration, IngestPosition<P>, PipelineChannel, PipelineTableMetaDataLoader) - 接口 中的方法org.apache.shardingsphere.data.pipeline.core.ingest.dumper.IncrementalDumperCreator

Create incremental dumper.

createInventoryDumper(InventoryDumperConfiguration, PipelineChannel, DataSource, PipelineTableMetaDataLoader) - 类 中的方法org.apache.shardingsphere.data.pipeline.core.ingest.dumper.DefaultInventoryDumperCreator

createInventoryDumper(InventoryDumperConfiguration, PipelineChannel, DataSource, PipelineTableMetaDataLoader) - 接口 中的方法org.apache.shardingsphere.data.pipeline.core.ingest.dumper.InventoryDumperCreator

Create Inventory Dumper.

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.

createPreparedStatement(Connection, String) - 类 中的方法org.apache.shardingsphere.data.pipeline.core.ingest.dumper.AbstractInventoryDumper

createPreparedStatement(Connection, String) - 类 中的方法org.apache.shardingsphere.data.pipeline.core.ingest.dumper.DefaultInventoryDumper

createProcessConfiguration(PipelineProcessConfiguration) - 类 中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractPipelineJobAPIImpl

createRegistryCenter(ModeConfiguration, String) - 类 中的方法org.apache.shardingsphere.data.pipeline.core.registry.CoordinatorRegistryCenterInitializer

Create registry center instance.

CreateTableSQLGenerateException - org.apache.shardingsphere.data.pipeline.core.exception中的异常错误

Create table SQL generate exception.

CreateTableSQLGenerateException(String) - 异常错误 的构造器org.apache.shardingsphere.data.pipeline.core.exception.CreateTableSQLGenerateException

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

DataConsistencyCalculateAlgorithmFactory - org.apache.shardingsphere.data.pipeline.core.check.consistency中的类

Data consistency calculate algorithm factory.

DataConsistencyCalculateAlgorithmFactory() - 类 的构造器org.apache.shardingsphere.data.pipeline.core.check.consistency.DataConsistencyCalculateAlgorithmFactory

dataConsistencyCheck(MigrationJobConfiguration) - 接口 中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPI

Do data consistency check.

dataConsistencyCheck(String) - 类 中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPIImpl

dataConsistencyCheck(MigrationJobConfiguration) - 类 中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPIImpl

dataConsistencyCheck(String, String, Properties) - 类 中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPIImpl

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

decorate(String, String) - 类 中的方法org.apache.shardingsphere.data.pipeline.core.sqlbuilder.AbstractPipelineSQLBuilder

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

DefaultInventoryDumper - org.apache.shardingsphere.data.pipeline.core.ingest.dumper中的类

Default inventory dumper.

DefaultInventoryDumper(InventoryDumperConfiguration, PipelineChannel, DataSource, PipelineTableMetaDataLoader) - 类 的构造器org.apache.shardingsphere.data.pipeline.core.ingest.dumper.DefaultInventoryDumper

DefaultInventoryDumperCreator - org.apache.shardingsphere.data.pipeline.core.ingest.dumper中的类

Default inventory dumper creator.

DefaultInventoryDumperCreator() - 类 的构造器org.apache.shardingsphere.data.pipeline.core.ingest.dumper.DefaultInventoryDumperCreator

DefaultPipelineDataSourceManager - org.apache.shardingsphere.data.pipeline.core.datasource中的类

Default pipeline data source manager.

DefaultPipelineDataSourceManager() - 类 的构造器org.apache.shardingsphere.data.pipeline.core.datasource.DefaultPipelineDataSourceManager

DefaultPipelineJobProgressListener - org.apache.shardingsphere.data.pipeline.core.job.progress.listener中的类

Default pipeline job progress listener implementation.

DefaultPipelineJobProgressListener() - 类 的构造器org.apache.shardingsphere.data.pipeline.core.job.progress.listener.DefaultPipelineJobProgressListener

DefaultPipelineSQLBuilder - org.apache.shardingsphere.data.pipeline.core.sqlbuilder中的类

Default pipeline SQL builder.

DefaultPipelineSQLBuilder() - 类 的构造器org.apache.shardingsphere.data.pipeline.core.sqlbuilder.DefaultPipelineSQLBuilder

DELETE - 类 中的静态变量org.apache.shardingsphere.data.pipeline.core.ingest.IngestDataChangeType

Delete flag.

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.

doStart() - 类 中的方法org.apache.shardingsphere.data.pipeline.core.execute.PipelineJobExecutor

doStart() - 类 中的方法org.apache.shardingsphere.data.pipeline.core.importer.DefaultImporter

doStart() - 类 中的方法org.apache.shardingsphere.data.pipeline.core.ingest.dumper.AbstractInventoryDumper

doStart() - 类 中的方法org.apache.shardingsphere.data.pipeline.core.task.IncrementalTask

doStart() - 类 中的方法org.apache.shardingsphere.data.pipeline.core.task.InventoryTask

doStop() - 类 中的方法org.apache.shardingsphere.data.pipeline.core.execute.PipelineJobExecutor

doStop() - 类 中的方法org.apache.shardingsphere.data.pipeline.core.importer.DefaultImporter

doStop() - 类 中的方法org.apache.shardingsphere.data.pipeline.core.ingest.dumper.AbstractInventoryDumper

doStop() - 类 中的方法org.apache.shardingsphere.data.pipeline.core.task.IncrementalTask

doStop() - 类 中的方法org.apache.shardingsphere.data.pipeline.core.task.InventoryTask

DropMigrationSourceResourceException - org.apache.shardingsphere.data.pipeline.core.exception中的异常错误

Drop migration source resource exception.

DropMigrationSourceResourceException(String) - 异常错误 的构造器org.apache.shardingsphere.data.pipeline.core.exception.DropMigrationSourceResourceException

DropMigrationSourceResourceException(Throwable) - 异常错误 的构造器org.apache.shardingsphere.data.pipeline.core.exception.DropMigrationSourceResourceException

dropMigrationSourceResources(Collection<String>) - 类 中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPIImpl

dropProcessConfiguration(String) - 类 中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractPipelineJobAPIImpl

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

equals(Object) - 类 中的方法org.apache.shardingsphere.data.pipeline.core.metadata.model.PipelineTableMetaData

execute(ShardingContext) - 类 中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJob

ExecuteCallback - org.apache.shardingsphere.data.pipeline.core.execute中的接口

Scaling task execute callback.

ExecuteEngine - org.apache.shardingsphere.data.pipeline.core.execute中的类

Scaling 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.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.util.PipelineProcessConfigurationUtils

Fill in default value.

fillJobInfo(PipelineJobInfo, JobConfigurationPOJO) - 类 中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractPipelineJobAPIImpl

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.

getAllInstances() - 类 中的静态方法org.apache.shardingsphere.data.pipeline.core.check.consistency.DataConsistencyCalculateAlgorithmFactory

Get all data consistency calculate algorithm instances.

getCachedDataSource(PipelineDataSourceConfiguration, PipelineDataSourceManager) - 类 中的方法org.apache.shardingsphere.data.pipeline.core.prepare.datasource.AbstractDataSourcePreparer

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

getColumnMetaData(int) - 类 中的方法org.apache.shardingsphere.data.pipeline.core.metadata.model.PipelineTableMetaData

Get column metadata.

getColumnMetaData(String) - 类 中的方法org.apache.shardingsphere.data.pipeline.core.metadata.model.PipelineTableMetaData

Get column metadata.

getContextManager() - 类 中的静态方法org.apache.shardingsphere.data.pipeline.core.context.PipelineContext

Get context manager.

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.

getDefaultSchema(PipelineDataSourceConfiguration) - 类 中的静态方法org.apache.shardingsphere.data.pipeline.core.util.PipelineSchemaTableUtil

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.

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.

getImporterExecuteEngine() - 类 中的方法org.apache.shardingsphere.data.pipeline.core.context.AbstractPipelineProcessContext

Get importer execute engine.

getIncrementalDumperExecuteEngine() - 类 中的方法org.apache.shardingsphere.data.pipeline.core.context.AbstractPipelineProcessContext

Get incremental dumper 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.

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(String) - 类 中的静态方法org.apache.shardingsphere.data.pipeline.core.ingest.dumper.IncrementalDumperCreatorFactory

Incremental dumper creator.

getInstance(String) - 类 中的静态方法org.apache.shardingsphere.data.pipeline.core.ingest.dumper.InventoryDumperCreatorFactory

Get inventoryDumper creator instance.

getInstance(String) - 类 中的静态方法org.apache.shardingsphere.data.pipeline.core.ingest.position.PositionInitializerFactory

Get instance of position initializer.

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.migration.MigrationJobAPIFactory

Get instance of migration job API.

getInventoryDumperExecuteEngine() - 类 中的方法org.apache.shardingsphere.data.pipeline.core.context.AbstractPipelineProcessContext

Get inventory dumper 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.

getJobCheckResult(String) - 接口 中的方法org.apache.shardingsphere.data.pipeline.core.api.GovernanceRepositoryAPI

Get job check result.

getJobCheckResult(String) - 类 中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.GovernanceRepositoryAPIImpl

getJobCheckResultPath(String) - 类 中的静态方法org.apache.shardingsphere.data.pipeline.core.metadata.node.PipelineMetaDataNode

Get job check result path.

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.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.migration.MigrationJobAPIImpl

getJobItemContext(String, int) - 类 中的静态方法org.apache.shardingsphere.data.pipeline.core.job.PipelineJobCenter

Get job item context.

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.GovernanceRepositoryAPIImpl

getJobItemProgress(String, int) - 类 中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.InventoryIncrementalJobItemAPIImpl

getJobItemProgress(String, int) - 接口 中的方法org.apache.shardingsphere.data.pipeline.core.api.PipelineJobItemAPI

Get job item progress.

getJobItemProgress(String, int) - 接口 中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPI

getJobItemProgress(String, int) - 类 中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPIImpl

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.

getJobProgress(MigrationJobConfiguration) - 接口 中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPI

Get job progress.

getJobProgress(String) - 类 中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPIImpl

getJobProgress(MigrationJobConfiguration) - 类 中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPIImpl

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.core.api.impl.AbstractPipelineJobAPIImpl

getJobType() - 类 中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPIImpl

getJobTypeCode() - 类 中的方法org.apache.shardingsphere.data.pipeline.core.job.AbstractPipelineJobId

getLeftIdentifierQuoteString() - 类 中的方法org.apache.shardingsphere.data.pipeline.core.sqlbuilder.AbstractPipelineSQLBuilder

Get left identifier quote string.

getLeftIdentifierQuoteString() - 类 中的方法org.apache.shardingsphere.data.pipeline.core.sqlbuilder.DefaultPipelineSQLBuilder

getLeftIdentifierQuoteString() - 类 中的方法org.apache.shardingsphere.data.pipeline.core.sqlbuilder.OraclePipelineSQLBuilder

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.

getPipelineJobAPI(JobType) - 类 中的静态方法org.apache.shardingsphere.data.pipeline.core.api.PipelineAPIFactory

Get pipeline job API.

getRegistryCenter() - 类 中的静态方法org.apache.shardingsphere.data.pipeline.core.api.PipelineAPIFactory

Get registry center.

getRightIdentifierQuoteString() - 类 中的方法org.apache.shardingsphere.data.pipeline.core.sqlbuilder.AbstractPipelineSQLBuilder

Get right identifier quote string.

getRightIdentifierQuoteString() - 类 中的方法org.apache.shardingsphere.data.pipeline.core.sqlbuilder.DefaultPipelineSQLBuilder

getRightIdentifierQuoteString() - 类 中的方法org.apache.shardingsphere.data.pipeline.core.sqlbuilder.OraclePipelineSQLBuilder

getSchemaTablesMapFromActual(PipelineDataSourceConfiguration, String, String) - 类 中的静态方法org.apache.shardingsphere.data.pipeline.core.util.PipelineSchemaTableUtil

Get schema tables map from actual data source.

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

getSourceCachedDataSource(MigrationJobConfiguration, PipelineDataSourceManager) - 类 中的方法org.apache.shardingsphere.data.pipeline.core.prepare.datasource.AbstractDataSourcePreparer

getSourceDataSource() - 类 中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobItemContext

Get source data source.

getSourceMetaDataLoader() - 类 中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobItemContext

Get source metadata loader.

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.PipelineTableMetaDataLoader

Get table metadata, load if it does not exist.

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.spi.ratelimit.QPSJobRateLimitAlgorithm

getType() - 类 中的方法org.apache.shardingsphere.data.pipeline.core.spi.ratelimit.TPSJobRateLimitAlgorithm

getType() - 类 中的方法org.apache.shardingsphere.data.pipeline.core.sqlbuilder.OraclePipelineSQLBuilder

getTypeAliases() - 类 中的方法org.apache.shardingsphere.data.pipeline.core.importer.DefaultImporterCreator

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

hashCode() - 类 中的方法org.apache.shardingsphere.data.pipeline.core.metadata.model.PipelineTableMetaData

I

IncrementalDumperCreator<P> - org.apache.shardingsphere.data.pipeline.core.ingest.dumper中的接口

Incremental dumper creator.

IncrementalDumperCreatorFactory - org.apache.shardingsphere.data.pipeline.core.ingest.dumper中的类

Incremental dumper creator factory.

IncrementalDumperCreatorFactory() - 类 的构造器org.apache.shardingsphere.data.pipeline.core.ingest.dumper.IncrementalDumperCreatorFactory

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(Properties) - 类 中的方法org.apache.shardingsphere.data.pipeline.core.spi.ratelimit.QPSJobRateLimitAlgorithm

init(Properties) - 类 中的方法org.apache.shardingsphere.data.pipeline.core.spi.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.

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.spi.ratelimit.QPSJobRateLimitAlgorithm

intercept(JobOperationType, Number) - 类 中的方法org.apache.shardingsphere.data.pipeline.core.spi.ratelimit.TPSJobRateLimitAlgorithm

InventoryDumperCreator - org.apache.shardingsphere.data.pipeline.core.ingest.dumper中的接口

Inventory dumper creator.

InventoryDumperCreatorFactory - org.apache.shardingsphere.data.pipeline.core.ingest.dumper中的类

Inventory dumper creator factory.

InventoryDumperCreatorFactory() - 类 的构造器org.apache.shardingsphere.data.pipeline.core.ingest.dumper.InventoryDumperCreatorFactory

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.

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, 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.

isBigDecimalEquals(BigDecimal, BigDecimal) - 类 中的静态方法org.apache.shardingsphere.data.pipeline.core.check.consistency.DataConsistencyCheckUtils

Check two BigDecimal whether equals or not.

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.

isUniqueKey(int) - 类 中的方法org.apache.shardingsphere.data.pipeline.core.metadata.model.PipelineTableMetaData

Judge whether column is unique key or not.

L

list() - 类 中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractPipelineJobAPIImpl

list() - 类 中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPIImpl

listCreateLogicalTableSQL(PrepareTargetTablesParameter) - 类 中的方法org.apache.shardingsphere.data.pipeline.core.prepare.datasource.AbstractDataSourcePreparer

listDataConsistencyCheckAlgorithms() - 类 中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobAPIImpl

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.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.

MigrationDataConsistencyChecker - org.apache.shardingsphere.data.pipeline.scenario.migration中的类

Data consistency checker for migration job.

MigrationDataConsistencyChecker(MigrationJobConfiguration, JobRateLimitAlgorithm) - 类 的构造器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, TaskConfiguration, 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

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(String, Properties) - 类 中的静态方法org.apache.shardingsphere.data.pipeline.core.check.consistency.DataConsistencyCalculateAlgorithmFactory

Create new instance of data consistency calculate algorithm.

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

onProgressUpdated() - 类 中的方法org.apache.shardingsphere.data.pipeline.core.job.progress.listener.DefaultPipelineJobProgressListener

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.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.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.listener - 程序包 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.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.model - 程序包 org.apache.shardingsphere.data.pipeline.core.metadata.model

org.apache.shardingsphere.data.pipeline.core.metadata.node - 程序包 org.apache.shardingsphere.data.pipeline.core.metadata.node

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.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.spi.ratelimit - 程序包 org.apache.shardingsphere.data.pipeline.core.spi.ratelimit

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.migration - 程序包 org.apache.shardingsphere.data.pipeline.scenario.migration

P

parseJobType(String) - 类 中的静态方法org.apache.shardingsphere.data.pipeline.core.job.PipelineJobIdUtils

Parse job type.

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.

persistEphemeralChildrenNode(String, int) - 类 中的方法org.apache.shardingsphere.data.pipeline.core.util.PipelineDistributedBarrier

Persist ephemeral children node.

persistJobCheckResult(String, boolean) - 接口 中的方法org.apache.shardingsphere.data.pipeline.core.api.GovernanceRepositoryAPI

Persist job check result.

persistJobCheckResult(String, boolean) - 类 中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.GovernanceRepositoryAPIImpl

persistJobItemProgress(String, int, String) - 接口 中的方法org.apache.shardingsphere.data.pipeline.core.api.GovernanceRepositoryAPI

Persist job item progress.

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.migration.MigrationJobAPIImpl

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

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

PipelineDataConsistencyCheckFailedException - org.apache.shardingsphere.data.pipeline.core.exception中的异常错误

Pipeline data consistency check failed exception.

PipelineDataConsistencyCheckFailedException(String) - 异常错误 的构造器org.apache.shardingsphere.data.pipeline.core.exception.PipelineDataConsistencyCheckFailedException

PipelineDataConsistencyCheckFailedException(String, Throwable) - 异常错误 的构造器org.apache.shardingsphere.data.pipeline.core.exception.PipelineDataConsistencyCheckFailedException

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

PipelineIgnoredException - org.apache.shardingsphere.data.pipeline.core.exception中的异常错误

Pipeline job ignored exception.

PipelineIgnoredException(String) - 异常错误 的构造器org.apache.shardingsphere.data.pipeline.core.exception.PipelineIgnoredException

PipelineIgnoredException(String, Throwable) - 异常错误 的构造器org.apache.shardingsphere.data.pipeline.core.exception.PipelineIgnoredException

PipelineIndexMetaData - org.apache.shardingsphere.data.pipeline.core.metadata.model中的类

Pipeline meta data of index.

PipelineIndexMetaData() - 类 的构造器org.apache.shardingsphere.data.pipeline.core.metadata.model.PipelineIndexMetaData

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

PipelineJobCreationException - org.apache.shardingsphere.data.pipeline.core.exception中的异常错误

Pipeline job creation exception.

PipelineJobCreationException() - 异常错误 的构造器org.apache.shardingsphere.data.pipeline.core.exception.PipelineJobCreationException

PipelineJobCreationException(String) - 异常错误 的构造器org.apache.shardingsphere.data.pipeline.core.exception.PipelineJobCreationException

PipelineJobCreationException(String, Throwable) - 异常错误 的构造器org.apache.shardingsphere.data.pipeline.core.exception.PipelineJobCreationException

PipelineJobCreationException(Throwable) - 异常错误 的构造器org.apache.shardingsphere.data.pipeline.core.exception.PipelineJobCreationException

PipelineJobCreationException(String, Throwable, boolean, boolean) - 异常错误 的构造器org.apache.shardingsphere.data.pipeline.core.exception.PipelineJobCreationException

PipelineJobExecutionException - org.apache.shardingsphere.data.pipeline.core.exception中的异常错误

Pipeline job execution exception.

PipelineJobExecutionException(String) - 异常错误 的构造器org.apache.shardingsphere.data.pipeline.core.exception.PipelineJobExecutionException

PipelineJobExecutionException(Throwable) - 异常错误 的构造器org.apache.shardingsphere.data.pipeline.core.exception.PipelineJobExecutionException

PipelineJobExecutionException(String, Throwable) - 异常错误 的构造器org.apache.shardingsphere.data.pipeline.core.exception.PipelineJobExecutionException

PipelineJobExecutor - org.apache.shardingsphere.data.pipeline.core.execute中的类

Pipeline job executor.

PipelineJobExecutor() - 类 的构造器org.apache.shardingsphere.data.pipeline.core.execute.PipelineJobExecutor

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中的异常错误

Pipeline job not found exception.

PipelineJobNotFoundException(String) - 异常错误 的构造器org.apache.shardingsphere.data.pipeline.core.exception.PipelineJobNotFoundException

PipelineJobPrepareFailedException - org.apache.shardingsphere.data.pipeline.core.exception中的异常错误

Pipeline job prepare failed exception.

PipelineJobPrepareFailedException(String) - 异常错误 的构造器org.apache.shardingsphere.data.pipeline.core.exception.PipelineJobPrepareFailedException

PipelineJobPrepareFailedException(String, Throwable) - 异常错误 的构造器org.apache.shardingsphere.data.pipeline.core.exception.PipelineJobPrepareFailedException

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

PipelineMetaDataException - org.apache.shardingsphere.data.pipeline.core.exception中的异常错误

Pipeline meta data exception.

PipelineMetaDataException(String) - 异常错误 的构造器org.apache.shardingsphere.data.pipeline.core.exception.PipelineMetaDataException

PipelineMetaDataNode - org.apache.shardingsphere.data.pipeline.core.metadata.node中的类

Pipeline meta data node.

PipelineMetaDataNode() - 类 的构造器org.apache.shardingsphere.data.pipeline.core.metadata.node.PipelineMetaDataNode

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

PipelineProcessConfigurationUtils - org.apache.shardingsphere.data.pipeline.core.util中的类

Pipeline process configuration utils.

PipelineProcessConfigurationUtils() - 类 的构造器org.apache.shardingsphere.data.pipeline.core.util.PipelineProcessConfigurationUtils

PipelineSchemaTableUtil - org.apache.shardingsphere.data.pipeline.core.util中的类

Pipeline schema table util.

PipelineSQLBuilderFactory - org.apache.shardingsphere.data.pipeline.core.sqlbuilder中的类

Pipeline SQL builder factory.

PipelineSQLBuilderFactory() - 类 的构造器org.apache.shardingsphere.data.pipeline.core.sqlbuilder.PipelineSQLBuilderFactory

PipelineTableMetaData - org.apache.shardingsphere.data.pipeline.core.metadata.model中的类

Pipeline table meta data.

PipelineTableMetaData(String, Map<String, PipelineColumnMetaData>, Collection<PipelineIndexMetaData>) - 类 的构造器org.apache.shardingsphere.data.pipeline.core.metadata.model.PipelineTableMetaData

PipelineTableMetaDataLoader - org.apache.shardingsphere.data.pipeline.core.metadata.loader中的类

Pipeline table metadata loader.

PipelineTableMetaDataLoader() - 类 的构造器org.apache.shardingsphere.data.pipeline.core.metadata.loader.PipelineTableMetaDataLoader

PipelineTask - org.apache.shardingsphere.data.pipeline.core.task中的接口

Pipeline task interface.

PipelineUnexpectedDataRecordOrderException - org.apache.shardingsphere.data.pipeline.core.exception中的异常错误

Pipeline unexpected data record order exception.

PipelineUnexpectedDataRecordOrderException(DataRecord, DataRecord) - 异常错误 的构造器org.apache.shardingsphere.data.pipeline.core.exception.PipelineUnexpectedDataRecordOrderException

PipelineVerifyFailedException - org.apache.shardingsphere.data.pipeline.core.exception中的异常错误

Pipeline verify failed exception.

PipelineVerifyFailedException(String) - 异常错误 的构造器org.apache.shardingsphere.data.pipeline.core.exception.PipelineVerifyFailedException

PositionInitializerFactory - org.apache.shardingsphere.data.pipeline.core.ingest.position中的类

Position initializer factory.

PositionInitializerFactory() - 类 的构造器org.apache.shardingsphere.data.pipeline.core.ingest.position.PositionInitializerFactory

prepare(MigrationJobItemContext) - 类 中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobPreparer

Do prepare work for scaling job.

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(String, PipelineDataSourceConfiguration, Map<String, DataSource>, PipelineDataSourceManager, JobDataNodeLine, TableNameSchemaNameMapping, ShardingSphereSQLParserEngine) - 类 的构造器org.apache.shardingsphere.data.pipeline.core.prepare.datasource.PrepareTargetTablesParameter

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.spi.ratelimit中的类

QPS job rate limit algorithm for SPI.

QPSJobRateLimitAlgorithm() - 类 的构造器org.apache.shardingsphere.data.pipeline.core.spi.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.core.api.impl.AbstractPipelineJobAPIImpl

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.

setFieldsNullByConfPath(YamlPipelineProcessConfiguration, String) - 类 中的静态方法org.apache.shardingsphere.data.pipeline.core.util.PipelineProcessConfigurationUtils

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.

showProcessConfiguration() - 类 中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractPipelineJobAPIImpl

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

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(PipelineJobItemContext) - 类 中的方法org.apache.shardingsphere.data.pipeline.core.prepare.InventoryTaskSplitter

Split inventory data to multi-tasks.

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

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.task.InventoryIncrementalTasksRunner

startDisabledJob(String) - 类 中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractPipelineJobAPIImpl

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.InventoryIncrementalTasksRunner

stop() - 类 中的方法org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJob

Stop job.

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(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.

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(InventoryIncrementalJobItemProgress) - 类 中的方法org.apache.shardingsphere.data.pipeline.core.job.progress.yaml.YamlInventoryIncrementalJobItemProgressSwapper

swapToYamlJobConfiguration(PipelineJobConfiguration) - 类 中的方法org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractPipelineJobAPIImpl

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.spi.ratelimit.QPSJobRateLimitAlgorithm

toString() - 类 中的方法org.apache.shardingsphere.data.pipeline.core.spi.ratelimit.TPSJobRateLimitAlgorithm

TPSJobRateLimitAlgorithm - org.apache.shardingsphere.data.pipeline.core.spi.ratelimit中的类

TPS job rate limit algorithm for SPI.

TPSJobRateLimitAlgorithm() - 类 的构造器org.apache.shardingsphere.data.pipeline.core.spi.ratelimit.TPSJobRateLimitAlgorithm

TYPE - 类 中的静态变量org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory.MemoryPipelineChannelCreator

U

UPDATE - 类 中的静态变量org.apache.shardingsphere.data.pipeline.core.ingest.IngestDataChangeType

Update flag.

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.migration.MigrationJobAPIImpl

V

verifyConfPath(String) - 类 中的静态方法org.apache.shardingsphere.data.pipeline.core.util.PipelineProcessConfigurationUtils

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

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

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