Functions — github.com/apache/flink-cdc

hub / github.com/apache/flink-cdc / functions

Functions12,620 in github.com/apache/flink-cdc

⨍ Functions 12,620◇ Types & classes 1,927

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/history/FlinkJsonTableChangeSerializer.java:137

↓ 7 callersMethodfromPrimitiveArray

(boolean[] arr)

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryArrayData.java:572

↓ 7 callersMethodgenerate

(List<Tuple2<DataType, Object>> elements)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/test/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonSinkITCase.java:819

↓ 7 callersMethodgenerateBinaryOperation

( Context context, SqlBasicCall sqlBasicCall, Java.Rvalue[] atoms, String operator)

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/parser/JaninoCompiler.java:332

↓ 7 callersMethodgenerateIncrementalChanges

()

flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/RouteE2eITCase.java:66

↓ 7 callersMethodgetAllRequiredOptionsWithHost

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/test/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSourceFactoryTest.java:464

↓ 7 callersMethodgetConfig

()

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SinkDef.java:77

↓ 7 callersMethodgetConfirmedFlushLsn

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/test/java/org/apache/flink/cdc/connectors/postgres/PostgreSQLSourceTest.java:647

↓ 7 callersMethodgetConnection

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/test/java/org/apache/flink/cdc/connectors/oceanbase/OceanBaseSourceTestBase.java:250

↓ 7 callersMethodgetConnection

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/task/context/StatefulTaskContext.java:387

↓ 7 callersMethodgetDbzConnectorConfig

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/source/reader/fetch/SqlServerSourceFetchTaskContext.java:222

↓ 7 callersMethodgetDbzConnectorConfig

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/fetch/Db2SourceFetchTaskContext.java:209

↓ 7 callersMethodgetFamilies

()

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypeRoot.java:117

↓ 7 callersMethodgetJdbcUrl

()

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oracle/src/test/java/org/testcontainers/containers/OracleContainer.java:130

↓ 7 callersMethodgetKafkaClientConfiguration

()

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/test/java/org/apache/flink/cdc/connectors/kafka/sink/KafkaDataSinkITCase.java:684

↓ 7 callersMethodgetLatestOriginalSchema

Get the latest original schema of the specified table.

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaManager.java:115

↓ 7 callersMethodgetLength

(DataType dataType)

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypes.java:430

↓ 7 callersMethodgetLsn

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/offset/PostgresOffset.java:78

↓ 7 callersMethodgetMySqlSourceConfig

(Long timestamp, String serverId)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/SpecificStartingOffsetITCase.java:466

↓ 7 callersMethodgetNumBuckets

()

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/TableCreateConfig.java:52

↓ 7 callersMethodgetOffsetKind

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/offset/BinlogOffset.java:138

↓ 7 callersMethodgetPosition

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/io/debezium/connector/mysql/MySqlStreamingChangeEventSource.java:156

↓ 7 callersMethodgetPosition

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlStreamingChangeEventSource.java:154

↓ 7 callersMethodgetServerId

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/test/java/org/apache/flink/cdc/connectors/oceanbase/OceanBaseSourceTestBase.java:160

↓ 7 callersMethodgetShort

(int pos)

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryArrayData.java:353

↓ 7 callersMethodgetSrid

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/converters/OracleGeometry.java:53

↓ 7 callersMethodgetTableList

( @Nullable List<TableId> tableIdList, Selectors selectors)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/factory/MySqlDataSourceFactory.java:377

↓ 7 callersMethodgetTableOrColumnName

Resolves a table or column name from the provided string. <p>Oracle table and column names are inherently stored in upper-case; however, if the objec

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oracle/src/main/java/org/apache/flink/cdc/connectors/oracle/source/parser/BaseParserListener.java:80

↓ 7 callersMethodgetTableSchema

Get the {@link Schema} of the given table. @param tableId The {@link TableId} of the given table. @return The {@link Schema} of the table.

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlMetadataAccessor.java:84

↓ 7 callersMethodgetTestSchemalessSnapshotSplit

( TableId tableId, int splitNo)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/PendingSplitsStateSerializerTest.java:210

↓ 7 callersMethodinFirstSegment

()

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryStringData.java:720

↓ 7 callersMethodinitialize

(String metastore)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/test/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonMetadataApplierTest.java:80

↓ 7 callersMethodinitialize

(String metastore)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/test/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonSinkITCase.java:153

↓ 7 callersMethodinitializeHarness

()

flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/operators/transform/TransformOperatorWithSchemaEvolveTest.java:197

↓ 7 callersMethodinitializeTidbTable

Executes a JDBC statement using the default jdbc config without autocommitting the connection.

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/test/java/org/apache/flink/cdc/connectors/tidb/TiDBTestBase.java:187

↓ 7 callersMethodinspectTableSchema

(TableId tableId)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/org/apache/flink/cdc/connectors/starrocks/sink/utils/StarRocksSinkTestBase.java:189

↓ 7 callersMethodisSuspended

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlBinlogSplit.java:130

↓ 7 callersMethodisTransactionMetadataEvent

Check whether the given source record is a transaction metadata event (BEGIN or END). <p>Transaction events are emitted by Debezium to mark transacti

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/RecordUtils.java:345

↓ 7 callersMethodisTreatTinyInt1AsBoolean

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/config/MySqlSourceConfig.java:299

↓ 7 callersMethodminus

Returns the difference {@code BigDecimal} whose value is {@code (minuend - subtrahend)}.

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/ObjectUtils.java:48

↓ 7 callersMethodnotifyCheckpointComplete

(long checkpointId)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/reader/PostgresSourceReader.java:131

↓ 7 callersMethodof

Creates a CatalogTable using the Flink 1.x API. @param schema the table schema @param comment the table comment @param partitionKeys the partition ke

flink-cdc-flink1-compat/src/main/java/org/apache/flink/table/catalog/CatalogTableAdapter.java:44

↓ 7 callersMethodof

Returns a {@link ChunkRange} with the given chunk start and chunk end.

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/ChunkRange.java:43

↓ 7 callersMethodof

( TableId tableId, String projectionExpression, String filterE

flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/operators/transform/TransformOperatorWithSchemaEvolveTest.java:88

↓ 7 callersMethodopenJdbcConnection

(JdbcSourceConfig sourceConfig)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/PostgresDialect.java:78

↓ 7 callersMethodparseLength

(String lengthStr)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/parser/CustomColumnDefinitionParserListener.java:312

↓ 7 callersMethodprepareCommit

()

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2/IcebergWriter.java:123

↓ 7 callersMethodquote

(String dbOrTableName)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlSnapshotChangeEventSource.java:588

↓ 7 callersMethodreadBinlogPosition

(int offsetVersion, DataInputDeserializer in)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/SerializerUtils.java:51

↓ 7 callersMethodrequiredOptions

Returns a set of {@link ConfigOption} that an implementation of this factory requires in addition to {@link #optionalOptions()}.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/factories/Factory.java:54

↓ 7 callersMethodrowToSerializedString

(Object[] splitBoundary)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/SerializerUtils.java:95

↓ 7 callersMethodsameSchemaIgnoreCommentAndDefaultValue

( org.apache.flink.cdc.common.schema.Schema oldSchema, org.apache.flink.cdc.common.sch

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/utils/FlussConversions.java:114

↓ 7 callersMethodserializedStringToRow

(String serialized)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/SerializerUtils.java:106

↓ 7 callersMethodsetLong

(int pos, long value)

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryArrayData.java:211

↓ 7 callersMethodsetMetadataConverters

(MetadataConverter[] metadataConverters)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/table/RowDataDebeziumDeserializeSchema.java:204

↓ 7 callersMethodsetNotNullAt

(int pos)

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryArrayData.java:200

↓ 7 callersMethodsetNullBit

(int ordinal)

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/writer/BinaryArrayWriter.java:59

↓ 7 callersMethodsetPostHighWatermarkAction

(SnapshotPhaseHook postHighWatermarkAction)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/hooks/SnapshotPhaseHooks.java:46

↓ 7 callersMethodsetSchema

Set schema for a table. Used to initialize table-specific serializers with schema. @param tableId The table identifier @param schema The schema to se

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-hudi/src/main/java/org/apache/flink/cdc/connectors/hudi/sink/event/HudiRecordEventSerializer.java:143

↓ 7 callersMethodsetServerTimeZone

(ZoneId serverTimeZone)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/table/RowDataDebeziumDeserializeSchema.java:219

↓ 7 callersMethodsetSnapshotHooks

(SnapshotPhaseHooks snapshotHooks)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlSource.java:285

↓ 7 callersMethodsetStartingOffset

(@Nullable BinlogOffset startingOffset)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlBinlogSplitState.java:48

↓ 7 callersMethodsleepMs

(long millis)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/test/java/org/apache/flink/cdc/connectors/postgres/source/PostgresSourceITCase.java:1249

↓ 7 callersMethodsplitSize

The split size (number of rows) of table snapshot, captured tables are split into multiple splits when read the snapshot of table.

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/Db2SourceBuilder.java:108

↓ 7 callersMethodtableId

()

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/CreateTableEvent.java:71

↓ 7 callersMethodtableName

TableName name to be monitored.

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/TiDBSource.java:49

↓ 7 callersMethodtestBackfillWhenWritingEvents

( boolean skipSnapshotBackfill, int fetchSize, int hookType, S

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/test/java/org/apache/flink/cdc/connectors/oracle/source/OracleSourceITCase.java:491

↓ 7 callersMethodtestBackfillWhenWritingEvents

( boolean skipBackFill, int fetchSize, int hookType, StartupOptions startupOptions)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/test/java/org/apache/flink/cdc/connectors/mongodb/source/MongoDBFullChangelogITCase.java:457

↓ 7 callersMethodtestBackfillWhenWritingEvents

( boolean skipBackFill, int fetchSize, int hookType, StartupOptions startupOptions)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/test/java/org/apache/flink/cdc/connectors/mongodb/source/MongoDBParallelSourceITCase.java:408

↓ 7 callersMethodtoFlussSchema

( org.apache.flink.cdc.common.schema.Schema cdcSchema)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/utils/FlussConversions.java:89

↓ 7 callersMethodtoLocalTime

()

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/TimeData.java:68

↓ 7 callersMethodtoMySqlSplit

Use the current split state to create a new MySqlSplit.

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplitState.java:50

↓ 7 callersMethodtoObjectArray

Converts this {@link GenericArrayData} into an array of Java {@link Object}. <p>The method will convert a primitive array into an object array. But i

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java:120

↓ 7 callersMethodtriggerFailover

( FailoverType type, JobID jobId, MiniCluster miniCluster, Runnable afterFailAction)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/MySqlSourceTestBase.java:136

↓ 7 callersMethodunwrapData

(Event event)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/io/debezium/connector/mysql/MySqlStreamingChangeEventSource.java:459

↓ 7 callersMethodunwrapData

(Event event)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlStreamingChangeEventSource.java:454

↓ 7 callersMethodusername

Name of the PostgreSQL database to use when connecting to the PostgreSQL database server.

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/PostgreSQLSource.java:110

↓ 7 callersMethodusername

Name of the Oracle database to use when connecting to the Oracle database server.

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/OracleSource.java:107

↓ 7 callersMethodverifyDataChangeEvent

(TableId tableId, FlussRowWithOp row, FlussEvent flussEvent)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/test/java/org/apache/flink/cdc/connectors/fluss/sink/FlussEventSerializationSchemaTest.java:307

↓ 7 callersMethodwriteBinlogPosition

(BinlogOffset offset, DataOutputSerializer out)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/SerializerUtils.java:41

↓ 7 callersMethodwriteInt

(int pos, int value)

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/writer/BinaryArrayWriter.java:179

↓ 6 callersMethodaddJar

Add the specified JAR to {@link StreamExecutionEnvironment} so that the JAR will be uploaded together with the job graph.

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/FlinkEnvironmentUtils.java:48

↓ 6 callersMethodaddPrimaryKeyColumnsToCondition

( RowType pkRowType, StringBuilder sql, String predicate, List<String> uuidFields)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/utils/PostgresQueryUtils.java:279

↓ 6 callersMethodaddPrimaryKeyColumnsToCondition

( RowType pkRowType, StringBuilder sql, String predicate)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/source/utils/SqlServerUtils.java:376

↓ 6 callersMethodaddPrimaryKeyColumnsToCondition

( RowType pkRowType, StringBuilder sql, String predicate)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/StatementUtils.java:263

↓ 6 callersMethodaddPrimaryKeyColumnsToCondition

( RowType pkRowType, StringBuilder sql, String predicate)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/utils/Db2Utils.java:367

↓ 6 callersMethodaddPrimaryKeyColumnsToCondition

( RowType pkRowType, StringBuilder sql, String predicate)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/utils/OracleUtils.java:258

↓ 6 callersMethodaddSchemaEvent

( RelationalSnapshotContext<MySqlPartition, MySqlOffsetContext> snapshotContext, Strin

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlSnapshotChangeEventSource.java:374

↓ 6 callersMethodaddressDocOf

(Long cid, String country, String city, String detailAddress)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/test/java/org/apache/flink/cdc/connectors/mongodb/source/NewlyAddedTableITCase.java:1040

↓ 6 callersMethodafter

()

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-postgres/src/test/java/org/apache/flink/cdc/connectors/postgres/source/PostgresPipelineITCase.java:113

↓ 6 callersMethodasBinlogSplitState

Casts this split state into a {@link MySqlBinlogSplitState}.

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplitState.java:45

↓ 6 callersMethodassertEqualsInAnyOrder

(List<String> expected, List<String> actual)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/test/java/org/apache/flink/cdc/connectors/tidb/table/TiDBConnectorITCase.java:639

↓ 6 callersMethodassertHistoryState

( TestingListState<String> historyState, boolean useLegacyImplementation)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/LegacyMySqlSourceTest.java:1220

↓ 6 callersMethodassertObjectIdEquals

(String expect, SourceRecord actual)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/test/java/org/apache/flink/cdc/connectors/mongodb/utils/MongoDBAssertUtils.java:31

↓ 6 callersMethodbuildConnectionString

( @Nullable String username, @Nullable String password, String scheme,

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/utils/MongoUtils.java:430

↓ 6 callersMethodcastToString

(Object object)

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/functions/impl/CastingFunctions.java:37

↓ 6 callersMethodcheckProducerLeak

()

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/test/java/org/apache/flink/cdc/connectors/kafka/sink/KafkaDataSinkITCase.java:639

↓ 6 callersMethodcheckSupportCheckpointsAfterTasksFinished

(boolean closeIdleReaders)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/EnvironmentUtils.java:37

↓ 6 callersMethodclear

()

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/utils/SessionCommitCoordinateHelper.java:104

↓ 6 callersMethodclear

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/test/java/org/apache/flink/cdc/connectors/db2/Db2SourceTest.java:546

← previous next →1,101–1,200 of 12,620, ranked by callers