Uses of Class
org.apache.flink.cdc.common.annotation.VisibleForTesting

Packages that use VisibleForTesting

Package	Description
org.apache.flink.cdc.cli
org.apache.flink.cdc.common.utils
org.apache.flink.cdc.composer.flink
org.apache.flink.cdc.composer.flink.translator
org.apache.flink.cdc.connectors.base.relational.connection
org.apache.flink.cdc.connectors.base.source
org.apache.flink.cdc.connectors.base.source.reader
org.apache.flink.cdc.connectors.base.source.reader.external
org.apache.flink.cdc.connectors.fluss.sink.row
org.apache.flink.cdc.connectors.mysql.debezium.reader
org.apache.flink.cdc.connectors.mysql.debezium.task
org.apache.flink.cdc.connectors.mysql.source
org.apache.flink.cdc.connectors.mysql.source.assigners
org.apache.flink.cdc.connectors.mysql.source.offset
org.apache.flink.cdc.connectors.mysql.source.reader
org.apache.flink.cdc.connectors.oracle.source
org.apache.flink.cdc.connectors.paimon.sink.v2.bucket
org.apache.flink.cdc.connectors.postgres.source
org.apache.flink.cdc.connectors.sqlserver.source
org.apache.flink.cdc.connectors.starrocks.sink
org.apache.flink.cdc.debezium
org.apache.flink.cdc.debezium.internal
org.apache.flink.cdc.runtime.operators.schema.common
org.apache.flink.cdc.runtime.operators.schema.distributed
org.apache.flink.cdc.runtime.operators.schema.regular
org.apache.flink.cdc.runtime.operators.transform.exceptions
org.apache.flink.cdc.runtime.parser
org.apache.flink.cdc.runtime.serializer.data

Uses of VisibleForTesting in org.apache.flink.cdc.cli

Methods in org.apache.flink.cdc.cli with annotations of type VisibleForTesting

Modifier and Type	Method	Description
PipelineExecution.ExecutionInfo	CliExecutor.deployWithNoOpComposer()
List<org.apache.flink.core.fs.Path>	CliExecutor.getAdditionalJars()
org.apache.flink.configuration.Configuration	CliExecutor.getFlinkConfig()
Configuration	CliExecutor.getGlobalPipelineConfig()

Uses of VisibleForTesting in org.apache.flink.cdc.common.utils

Methods in org.apache.flink.cdc.common.utils with annotations of type VisibleForTesting

Modifier and Type	Method	Description
static Object	SchemaMergingUtils.coerceObject(String timezone, Object originalField, DataType originalType, DataType destinationType)
static int	SchemaMergingUtils.getNumericPrecision(DataType dataType)
static int	SchemaUtils.getNumericPrecision(DataType dataType)	Deprecated.
static Column	SchemaUtils.inferWiderColumn(Column lColumn, Column rColumn)	Deprecated. Use getLeastCommonType in SchemaMergingUtils instead.
static Schema	SchemaUtils.inferWiderSchema(Schema lSchema, Schema rSchema)	Deprecated. Use getLeastCommonSchema in SchemaMergingUtils instead.
static DataType	SchemaUtils.inferWiderType(DataType lType, DataType rType)	Deprecated. Use getLeastCommonType in SchemaMergingUtils instead.
static List<SchemaChangeEventType>	ChangeEventUtils.resolveSchemaEvolutionTag(String tag)

Uses of VisibleForTesting in org.apache.flink.cdc.composer.flink

Methods in org.apache.flink.cdc.composer.flink with annotations of type VisibleForTesting

Modifier and Type	Method	Description
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment	FlinkPipelineComposer.getEnv()
static FlinkPipelineComposer	FlinkPipelineComposer.ofMiniCluster()

Uses of VisibleForTesting in org.apache.flink.cdc.composer.flink.translator

Methods in org.apache.flink.cdc.composer.flink.translator with annotations of type VisibleForTesting

Modifier and Type	Method	Description
org.apache.flink.streaming.api.datastream.DataStream<Event>	SchemaOperatorTranslator.translateRegular(org.apache.flink.streaming.api.datastream.DataStream<Event> input, int parallelism, boolean isBatchMode, MetadataApplier metadataApplier, List<RouteDef> routes)
org.apache.flink.streaming.api.datastream.DataStream<Event>	SchemaOperatorTranslator.translateRegular(org.apache.flink.streaming.api.datastream.DataStream<Event> input, int parallelism, MetadataApplier metadataApplier, List<RouteDef> routes)

Uses of VisibleForTesting in org.apache.flink.cdc.connectors.base.relational.connection

Methods in org.apache.flink.cdc.connectors.base.relational.connection with annotations of type VisibleForTesting

Modifier and Type	Method	Description
String	JdbcConnectionPools.getJdbcUrl(JdbcSourceConfig sourceConfig, String dataSourcePoolFactoryIdentifier)	this method is only supported for test.

Uses of VisibleForTesting in org.apache.flink.cdc.connectors.base.source

Methods in org.apache.flink.cdc.connectors.base.source with annotations of type VisibleForTesting

Modifier and Type	Method	Description
void	IncrementalSource.setSnapshotHooks(SnapshotPhaseHooks snapshotHooks)	Set snapshot hooks only for test.

Uses of VisibleForTesting in org.apache.flink.cdc.connectors.base.source.reader

Methods in org.apache.flink.cdc.connectors.base.source.reader with annotations of type VisibleForTesting

Modifier and Type	Method	Description
boolean	IncrementalSourceSplitReader.canAssignNextSplit()
Map<String,SnapshotSplit>	IncrementalSourceReader.getFinishedUnackedSplits()

Uses of VisibleForTesting in org.apache.flink.cdc.connectors.base.source.reader.external

Methods in org.apache.flink.cdc.connectors.base.source.reader.external with annotations of type VisibleForTesting

Modifier and Type	Method	Description
ExecutorService	IncrementalSourceScanFetcher.getExecutorService()
void	AbstractScanFetchTask.setSnapshotPhaseHooks(SnapshotPhaseHooks snapshotPhaseHooks)

Uses of VisibleForTesting in org.apache.flink.cdc.connectors.fluss.sink.row

Methods in org.apache.flink.cdc.connectors.fluss.sink.row with annotations of type VisibleForTesting

Modifier and Type	Method	Description
RecordData	CdcAsFlussRow.getCdcRecord()
Map<Integer,Integer>	CdcAsFlussRow.getIndexMapping()

Uses of VisibleForTesting in org.apache.flink.cdc.connectors.mysql.debezium.reader

Methods in org.apache.flink.cdc.connectors.mysql.debezium.reader with annotations of type VisibleForTesting

Modifier and Type	Method	Description
StoppableChangeEventSourceContext	BinlogSplitReader.getChangeEventSourceContext()
ExecutorService	BinlogSplitReader.getExecutorService()
ExecutorService	SnapshotSplitReader.getExecutorService()

Uses of VisibleForTesting in org.apache.flink.cdc.connectors.mysql.debezium.task

Methods in org.apache.flink.cdc.connectors.mysql.debezium.task with annotations of type VisibleForTesting

Modifier and Type	Method	Description
java.util.function.Predicate<com.github.shyiko.mysql.binlog.event.Event>	MySqlBinlogSplitReadTask.getEventFilter()

Uses of VisibleForTesting in org.apache.flink.cdc.connectors.mysql.source

Methods in org.apache.flink.cdc.connectors.mysql.source with annotations of type VisibleForTesting

Modifier and Type	Method	Description
MySqlSourceConfig	MySqlDataSource.getSourceConfig()
void	MySqlSource.setSnapshotHooks(SnapshotPhaseHooks snapshotHooks)

Uses of VisibleForTesting in org.apache.flink.cdc.connectors.mysql.source.assigners

Methods in org.apache.flink.cdc.connectors.mysql.source.assigners with annotations of type VisibleForTesting

Modifier and Type	Method	Description
List<org.apache.flink.cdc.connectors.mysql.source.assigners.ChunkRange>	MySqlChunkSplitter.splitEvenlySizedChunks(io.debezium.relational.TableId tableId, Object min, Object max, long approximateRowCnt, int chunkSize, int dynamicChunkSize)	Split table into evenly sized chunks based on the numeric min and max value of split column, and tumble chunks in step size.

Uses of VisibleForTesting in org.apache.flink.cdc.connectors.mysql.source.offset

Constructors in org.apache.flink.cdc.connectors.mysql.source.offset with annotations of type VisibleForTesting

Constructor	Description
BinlogOffset(Map<String,String> offset)

Uses of VisibleForTesting in org.apache.flink.cdc.connectors.mysql.source.reader

Methods in org.apache.flink.cdc.connectors.mysql.source.reader with annotations of type VisibleForTesting

Modifier and Type	Method	Description
Map<String,MySqlSnapshotSplit>	MySqlSourceReader.getFinishedUnackedSplits()

Uses of VisibleForTesting in org.apache.flink.cdc.connectors.oracle.source

Methods in org.apache.flink.cdc.connectors.oracle.source with annotations of type VisibleForTesting

Modifier and Type	Method	Description
OracleSourceConfig	OracleDataSource.getSourceConfig()

Uses of VisibleForTesting in org.apache.flink.cdc.connectors.paimon.sink.v2.bucket

Methods in org.apache.flink.cdc.connectors.paimon.sink.v2.bucket with annotations of type VisibleForTesting

Modifier and Type	Method	Description
DataChangeEvent	BucketAssignOperator.convertDataChangeEvent(DataChangeEvent dataChangeEvent)
SchemaChangeEvent	BucketAssignOperator.convertSchemaChangeEvent(SchemaChangeEvent schemaChangeEvent)
void	BucketAssignOperator.open(org.apache.flink.api.common.TaskInfo taskInfo)
void	BucketAssignOperator.setSchemaEvolutionClient(SchemaEvolutionClient schemaEvolutionClient)

Uses of VisibleForTesting in org.apache.flink.cdc.connectors.postgres.source

Methods in org.apache.flink.cdc.connectors.postgres.source with annotations of type VisibleForTesting

Modifier and Type	Method	Description
PostgresSourceConfig	PostgresDataSource.getPostgresSourceConfig()

Uses of VisibleForTesting in org.apache.flink.cdc.connectors.sqlserver.source

Methods in org.apache.flink.cdc.connectors.sqlserver.source with annotations of type VisibleForTesting

Modifier and Type	Method	Description
SqlServerSourceConfig	SqlServerDataSource.getSqlServerSourceConfig()

Uses of VisibleForTesting in org.apache.flink.cdc.connectors.starrocks.sink

Methods in org.apache.flink.cdc.connectors.starrocks.sink with annotations of type VisibleForTesting

Modifier and Type	Method	Description
java.time.ZoneId	StarRocksDataSink.getZoneId()

Uses of VisibleForTesting in org.apache.flink.cdc.debezium

Methods in org.apache.flink.cdc.debezium with annotations of type VisibleForTesting

Modifier and Type	Method	Description
boolean	DebeziumSourceFunction.getDebeziumStarted()
String	DebeziumSourceFunction.getEngineInstanceName()
Handover	DebeziumSourceFunction.getHandover()
org.apache.commons.collections.map.LinkedMap	DebeziumSourceFunction.getPendingOffsetsToCommit()

Uses of VisibleForTesting in org.apache.flink.cdc.debezium.internal

Methods in org.apache.flink.cdc.debezium.internal with annotations of type VisibleForTesting

Modifier and Type	Method	Description
Object	Handover.getLock()

Uses of VisibleForTesting in org.apache.flink.cdc.runtime.operators.schema.common

Methods in org.apache.flink.cdc.runtime.operators.schema.common with annotations of type VisibleForTesting

Modifier and Type	Method	Description
void	SchemaRegistry.emplaceEvolvedSchema(TableId tableId, Schema schema)
void	SchemaRegistry.emplaceOriginalSchema(TableId tableId, Schema schema)
void	SchemaManager.registerNewEvolvedSchema(TableId tableId, Schema newSchema)
void	SchemaManager.registerNewOriginalSchema(TableId tableId, Schema newSchema)

Uses of VisibleForTesting in org.apache.flink.cdc.runtime.operators.schema.distributed

Methods in org.apache.flink.cdc.runtime.operators.schema.distributed with annotations of type VisibleForTesting

Modifier and Type	Method	Description
void	SchemaCoordinator.emplaceOriginalSchema(TableId tableId, Integer subTaskId, Schema schema)

Uses of VisibleForTesting in org.apache.flink.cdc.runtime.operators.schema.regular

Methods in org.apache.flink.cdc.runtime.operators.schema.regular with annotations of type VisibleForTesting

Modifier and Type	Method	Description
void	SchemaOperator.registerInitialSchema(TableId tableId, Schema schema)

Constructors in org.apache.flink.cdc.runtime.operators.schema.regular with annotations of type VisibleForTesting

Constructor	Description
SchemaOperator(List<RouteRule> routingRules)
SchemaOperator(List<RouteRule> routingRules, RouteMode routeMode, java.time.Duration rpcTimeOut)
SchemaOperator(List<RouteRule> routingRules, RouteMode routeMode, java.time.Duration rpcTimeOut, SchemaChangeBehavior schemaChangeBehavior)

Uses of VisibleForTesting in org.apache.flink.cdc.runtime.operators.transform.exceptions

Methods in org.apache.flink.cdc.runtime.operators.transform.exceptions with annotations of type VisibleForTesting

Modifier and Type	Method	Description
static String	TransformException.prettyPrintEvent(Event event, Schema schema)

Uses of VisibleForTesting in org.apache.flink.cdc.runtime.parser

Fields in org.apache.flink.cdc.runtime.parser with annotations of type VisibleForTesting

Modifier and Type	Field	Description
static String	JaninoCompiler.LOAD_MODULES_EXPRESSION

Uses of VisibleForTesting in org.apache.flink.cdc.runtime.serializer.data

Methods in org.apache.flink.cdc.runtime.serializer.data with annotations of type VisibleForTesting

Modifier and Type	Method	Description
org.apache.flink.api.common.typeutils.TypeSerializer	ArrayDataSerializer.getEleSer()
org.apache.flink.api.common.typeutils.TypeSerializer	MapDataSerializer.getKeySerializer()
org.apache.flink.api.common.typeutils.TypeSerializer	MapDataSerializer.getValueSerializer()