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

↓ 13 callersMethodtestNewlyAddedTableOneByOne

( int parallelism, FailoverType failoverType, FailoverPhase failoverPhase,

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

↓ 13 callersMethodtestNewlyAddedTableOneByOne

( int parallelism, FailoverType failoverType, FailoverPhase failoverPhase,

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

↓ 13 callersMethodtoLocalDateTime

Converts this {@link TimestampData} object to a {@link LocalDateTime}.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/TimestampData.java:74

↓ 13 callersMethodupdatePreTransformed

()

flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/operators/transform/UnifiedTransformOperatorTest.java:142

↓ 13 callersMethodupdateSource

(Object[] beforeRecord, Object[] afterRecord)

flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/operators/transform/UnifiedTransformOperatorTest.java:133

↓ 13 callersMethodvalidateSinkSchema

(String databaseName, String tableName, List<String> expected)

flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/MySqlToDorisE2eITCase.java:997

↓ 13 callersMethodverifySerializeResult

( TableId expectTable, String expectRow, StarRocksRowData actualRowData)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/org/apache/flink/cdc/connectors/starrocks/sink/EventRecordSerializationSchemaTest.java:561

↓ 13 callersMethodwaitForSinkSize

(String sinkName, int expectedSize)

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

↓ 13 callersMethodwaitForSinkSize

(String sinkName, int expectedSize)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/table/MySqlConnectorITCase.java:2242

↓ 13 callersMethodwaitForSinkSize

(String sinkName, int expectedSize)

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

↓ 13 callersMethodwriteString

(int pos, StringData value)

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/writer/BinaryWriter.java:71

↓ 12 callersMethodassertUpdate

Verify that the given {@link SourceRecord} is a {@link Envelope.Operation#UPDATE UPDATE} record. @param record the source record; may not be null

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-test-util/src/main/java/org/apache/flink/cdc/connectors/utils/AssertUtils.java:80

↓ 12 callersMethodcollect

(T record)

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/IncrementalSourceRecordEmitter.java:188

↓ 12 callersMethodcommit

(int subtaskId, String sessionId)

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

↓ 12 callersMethodcompare

Compares two comparable objects. @return The value {@code 0} if {@code num1} is equal to the {@code num2}; a value less than {@code 0} if the {@c

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/utils/ObjectUtils.java:101

↓ 12 callersMethodconvertToCamelCase

Convert underline and space case to camel case. @param str The string to convert @return String which is camel case.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/StringUtils.java:49

↓ 12 callersMethodcreateSplit

( TableId tableId, String splitId, Object[] splitStart, Object[] splitEnd)

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/test/java/org/apache/flink/cdc/connectors/base/utils/SplitKeyUtilsTest.java:125

↓ 12 callersMethodcurrentBinlogOffset

Fetch current binlog offsets in MySql Server.

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/DebeziumUtils.java:120

↓ 12 callersMethoddelete

(ArrayRecord record)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/writer/MaxComputeWriter.java:51

↓ 12 callersMethodfind

Find equal segments2 in segments1. @param segments1 segs to find. @param segments2 sub segs. @return Return the found offset, return -1 if not find.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySegmentUtils.java:1135

↓ 12 callersMethodflinkHome

()

flink-cdc-cli/src/test/java/org/apache/flink/cdc/cli/CliFrontendTest.java:234

↓ 12 callersMethodgetConnection

()

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

↓ 12 callersMethodgetDbzConnectorConfig

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/source/config/SqlServerSourceConfig.java:90

↓ 12 callersMethodgetFields

( List<DataType> dataTypes, List<RecordData.FieldGetter> fieldGetters, Rec

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/src/main/java/org/apache/flink/cdc/connectors/values/sink/ValuesDataSinkHelper.java:59

↓ 12 callersMethodgetJdbcUrl

(String databaseName)

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

↓ 12 callersMethodgetKey

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiKVReadableMetadata.java:43

↓ 12 callersMethodgetLong

get long from segments. @param segments target segments. @param offset value offset.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySegmentUtils.java:721

↓ 12 callersMethodgetMap

Returns the map value at the given position.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/ArrayData.java:117

↓ 12 callersMethodgetMySqlSplitEnumeratorContext

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/testutils/MetricsUtils.java:24

↓ 12 callersMethodgetMySqlSplits

(MySqlSourceConfig sourceConfig)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/debezium/reader/SnapshotSplitReaderTest.java:683

↓ 12 callersMethodgetOperatorCoordinatorEventGateway

()

flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/testutils/operators/RegularEventOperatorTestHarness.java:379

↓ 12 callersMethodgetPort

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/polardbx/PolardbxSourceTestBase.java:83

↓ 12 callersMethodgetRealWorldMatchedTables

( String tables, @Nullable String tablesExclude, boolean scanBinlogNewlyAd

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/test/java/org/apache/flink/cdc/connectors/mysql/source/MySqlTablePatternMatchingTest.java:413

↓ 12 callersMethodgetRowDataFromRecordData

convert to {@link RowData}, which will be pass to serializationSchema.

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/TableSchemaInfo.java:70

↓ 12 callersMethodgetSchema

()

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/TableSchemaInfo.java:41

↓ 12 callersMethodgetTableFilter

()

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/external/FetchTask.java:63

↓ 12 callersMethodincludeTables

(String tableInclusions)

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/schema/Selectors.java:113

↓ 12 callersMethodincludeTables

Current {@link TableId} used in mysql cdc connector will map database name to catalog. @param tableInclusions @return

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

↓ 12 callersMethodinterruptableSleep

(long millis)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/test/java/org/apache/flink/cdc/connectors/maxcompute/utils/SessionCommitCoordinateHelperTest.java:108

↓ 12 callersMethodisCompact

Returns whether the decimal value is small enough to be stored in a long.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/DecimalData.java:133

↓ 12 callersMethodisIncludeSchemaChanges

()

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/config/SourceConfig.java:35

↓ 12 callersMethodmergeAndDiff

( @Nullable Schema currentSchema, Schema upcomingSchema)

flink-cdc-common/src/test/java/org/apache/flink/cdc/common/utils/SchemaMergingUtilsTest.java:1172

↓ 12 callersMethodnewBuilder

()

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PreTransformOperator.java:78

↓ 12 callersMethodnumBytesForFirstByte

Returns the number of bytes for a code point with the first byte as `b`. @param b The first byte of a code point

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

↓ 12 callersMethodofEarliest

Create offset which represents the earliest accessible binlog offset.

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

↓ 12 callersMethodoption

Declares an option.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/schema/Schema.java:463

↓ 12 callersMethodqualifiedTableName

@return Fully qualified table name <code><databaseName>.<tableName></code>

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/testutils/UniqueDatabase.java:105

↓ 12 callersMethodreadTableSnapshotSplits

( List<MySqlSplit> mySqlSplits, StatefulTaskContext statefulTaskContext, i

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/debezium/reader/SnapshotSplitReaderTest.java:631

↓ 12 callersMethodrunNumericCastingWith

(String expression)

flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/FlinkPipelineTransformITCase.java:2182

↓ 12 callersMethodserializeObject

(Object o)

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/InstantiationUtil.java:130

↓ 12 callersMethodsetDatabaseName

(String databaseName)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java:191

↓ 12 callersMethodsetPostLowWatermarkAction

(SnapshotPhaseHook postLowWatermarkAction)

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:54

↓ 12 callersMethodsetPreHighWatermarkAction

(SnapshotPhaseHook preHighWatermarkAction)

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:42

↓ 12 callersMethodsetTableKeys

(List<String> tableKeys)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java:211

↓ 12 callersMethodsetTableName

(String tableName)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java:196

↓ 12 callersMethodsetTableType

(TableType tableType)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java:201

↓ 12 callersMethodstart

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/enumerator/PostgresSourceEnumerator.java:64

↓ 12 callersMethodstringify

(Object... objects)

flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/operators/transform/UnifiedTransformOperatorTest.java:96

↓ 12 callersMethodtestFilterExpressionWithColumns

( String expression, String expressionExpect, List<Column> columns)

flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/parser/TransformParserTest.java:878

↓ 12 callersMethodtestSchemaEvolutionTypesParsing

( String behavior, String included, String excluded, Set<SchemaChangeEventType> expected)

flink-cdc-cli/src/test/java/org/apache/flink/cdc/cli/parser/YamlPipelineDefinitionParserTest.java:330

↓ 12 callersMethodtoTimestamp

Converts this {@link TimestampData} object to a {@link Timestamp}.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/TimestampData.java:69

↓ 12 callersMethodvalidateSinkResult

( String warehouse, String database, String table, List<String> expected)

flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/MySqlToHudiE2eITCase.java:488

↓ 12 callersMethodwaitForSinkSize

(String sinkName, int expectedSize)

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

↓ 11 callersMethodafter

()

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/test/java/org/apache/flink/cdc/connectors/mysql/source/MySqlAncientDateAndTimeITCase.java:101

↓ 11 callersMethodalterTable

(String schemaName, String tableName, String comment)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseCatalog.java:111

↓ 11 callersMethodclear

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/connection/JdbcConnectionPools.java:56

↓ 11 callersMethodcopyToUnsafe

Copy segments to target unsafe pointer. @param segments Source segments. @param offset The position where the bytes are started to be read from these

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySegmentUtils.java:171

↓ 11 callersMethodcreateDataSource

(Context context)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-postgres/src/main/java/org/apache/flink/cdc/connectors/postgres/factory/PostgresDataSourceFactory.java:99

↓ 11 callersMethodcreateFieldGetter

Creates an accessor for getting elements in an internal RecordData structure at the given position. @param fieldType the element type of the RecordDa

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

↓ 11 callersMethodcreateSqlServerConnection

( RelationalDatabaseConnectorConfig connectorConfig)

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

↓ 11 callersMethodcreateTableSource

(Map<String, String> options)

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

↓ 11 callersMethoddeletePreTransformed

()

flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/operators/transform/UnifiedTransformOperatorTest.java:179

↓ 11 callersMethoddeleteSource

(Object... record)

flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/operators/transform/UnifiedTransformOperatorTest.java:172

↓ 11 callersMethoddeserializeObject

(byte[] bytes, ClassLoader cl)

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/InstantiationUtil.java:202

↓ 11 callersMethoddoubleCompare

Compares two Double numeric object. @return -1, 0, or 1 as this {@code arg1} is numerically less than, equal to, or greater than {@code arg2}.

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/utils/ObjectUtils.java:114

↓ 11 callersMethoddrain

(TestSourceContext<T> sourceContext, int expectedRecordCount)

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

↓ 11 callersMethoddropDatabase

(String databaseName)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/test/java/org/apache/flink/cdc/connectors/doris/sink/utils/DorisSinkTestBase.java:212

↓ 11 callersMethodenumType

Defines that the value of the option should be of {@link Enum} type. @param enumClass Concrete type of the expected enum.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/ConfigOptions.java:148

↓ 11 callersMethodexecInContainer

(Container<?> container, String prompt, String... commands)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/table/MySqlOnLineSchemaMigrationTableITCase.java:496

↓ 11 callersMethodexpectNothingInPostTransformed

()

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

↓ 11 callersMethodextractRowData

(BsonDocument document)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBConnectorDeserializationSchema.java:172

↓ 11 callersMethodgenerateCastTo

(String type)

flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/FlinkPipelineTransformITCase.java:2240

↓ 11 callersMethodgenerateUid

(String suffix)

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/translator/OperatorUidGenerator.java:44

↓ 11 callersMethodgetColumn

(String columnName)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java:121

↓ 11 callersMethodgetDatabaseName

()

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java:89

↓ 11 callersMethodgetFlinkWriterOperator

()

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/sink/DataSinkWriterOperator.java:327

↓ 11 callersMethodgetHighWatermark

()

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

↓ 11 callersMethodgetInt

(int pos)

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

↓ 11 callersMethodgetLocalZonedTimestampData

Returns the local zoned timestamp value at the given position. <p>The precision is required to determine whether the local zoned timestamp value was

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/RecordData.java:152

↓ 11 callersMethodgetLong

(byte[] value, int pos)

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/variant/BinaryVariantUtil.java:399

↓ 11 callersMethodgetNumberOfParallelSubtasks

()

flink-cdc-flink2-compat/src/main/java/org/apache/flink/api/connector/sink2/Sink.java:81

↓ 11 callersMethodgetOperation

(ResultSet resultSet)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/io/debezium/connector/db2/Db2StreamingChangeEventSource.java:483

↓ 11 callersMethodgetPhysicalSchema

Return {@link ResolvedSchema} which consists of all physical columns.

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/utils/ResolvedSchemaUtils.java:32

↓ 11 callersMethodgetPreTransformedSchema

()

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PreTransformChangeInfo.java:92

↓ 11 callersMethodgetSchemaChangeEventType

()

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/FlushEvent.java:54

↓ 11 callersMethodgetSourceInfo

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/io/debezium/connector/sqlserver/SqlServerOffsetContext.java:110

↓ 11 callersMethodgetSplitId

()

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/events/StreamSplitMetaEvent.java:62

↓ 11 callersMethodgetStartingOffset

()

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

↓ 11 callersMethodgetTableIds

()

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/FlushEvent.java:46

↓ 11 callersMethodgetTaskInfo

()

flink-cdc-flink1-compat/src/main/java/org/apache/flink/api/connector/sink2/InitContextAdapter.java:77

← previous next →701–800 of 12,620, ranked by callers