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-common/src/main/java/org/apache/flink/cdc/common/configuration/StructuredOptionsSplitter.java:198

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/options/MaxComputeOptions.java:58

↓ 3 callersMethodgetType

(byte[] value, int pos)

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

↓ 3 callersMethodgetType

The data type of this column in Flink CDC.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/source/SupportedMetadataColumn.java:34

↓ 3 callersMethodgetUnionListState

( org.apache.flink.api.common.state.v2.ListStateDescriptor<S> var1)

flink-cdc-flink2-compat/src/test/java/org/apache/flink/cdc/runtime/compat/OperatorStateStoreAdapter.java:54

↓ 3 callersMethodgetVersion

()

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

↓ 3 callersMethodgetVersion

()

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitSerializer.java:60

↓ 3 callersMethodgetWaterMarkDispatcher

()

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

↓ 3 callersMethodgetYarnClient

()

flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/utils/PipelineTestOnYarnEnvironment.java:299

↓ 3 callersMethodgetZoneId

Returns the {@code ZoneId} string of this zoned date-time.

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

↓ 3 callersMethodglobalPipelineConfig

()

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

↓ 3 callersMethodhandleBatch

(List<ChangeEvent<SourceRecord, SourceRecord>> changeEvents)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/internal/DebeziumChangeFetcher.java:223

↓ 3 callersMethodhandleChange

( MySqlPartition partition, MySqlOffsetContext offsetContext, Event event,

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

↓ 3 callersMethodhandleChange

( MySqlPartition partition, MySqlOffsetContext offsetContext, Event event,

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

↓ 3 callersMethodhandleHstoreWithHstoreMode

( PostgresConnectorConfig.HStoreHandlingMode mode)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-postgres/src/main/java/org/apache/flink/cdc/connectors/postgres/utils/PostgresTypeUtils.java:298

↓ 3 callersMethodhasAsterisk

(@Nullable String projection)

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/parser/TransformParser.java:575

↓ 3 callersMethodhasDefaultValue

Checks if this option has a default value. @return True if it has a default value, false if not.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/ConfigOption.java:195

↓ 3 callersMethodhashByWords

hash segments to int, numBytes must be aligned to 4 bytes. @param segments Source segments. @param offset Source segments offset. @param numBytes the

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

↓ 3 callersMethodhostname

(String hostname)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/SqlServerSource.java:56

↓ 3 callersMethodincludeAll

Creates a {@link TableFilter} that includes all tables.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/schema/TableFilter.java:37

↓ 3 callersMethodincludeListAsFlatPattern

(List<String> includeList)

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

↓ 3 callersMethodincludePartitionedTables

Whether the connector should read partitioned tables via partition root or not.

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

↓ 3 callersMethodinit

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlHybridSplitAssignerTest.java:65

↓ 3 callersMethodinit

()

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

↓ 3 callersMethodinitEnumeratorMetrics

This should be invoked after this class's open method.

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/SnapshotSplitAssigner.java:299

↓ 3 callersMethodinitReplicationSlot

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/PostgresReplicationConnection.java:297

↓ 3 callersMethodinitialAddressCollections

( MongoDatabase mongoDatabase, String[] captureCustomerCollections)

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

↓ 3 callersMethodinitialAddressTables

(JdbcConnection connection, String[] addressTables)

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

↓ 3 callersMethodinitialAddressTables

(JdbcConnection connection, String[] addressTables)

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

↓ 3 callersMethodinitialAddressTables

(Connection connection, String[] addressTables)

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

↓ 3 callersMethodinitialize

(SinkWriterMetricGroup metricGroup)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/v2/FlussSinkWriter.java:80

↓ 3 callersMethodinitializeOceanBaseTables

initialize database and tables with ${databaseName}.sql for testing.

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

↓ 3 callersMethodinitializeStorage

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/internal/FlinkDatabaseSchemaHistory.java:184

↓ 3 callersMethodinitializeTable

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

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/test/java/org/apache/flink/cdc/connectors/vitess/VitessTestBase.java:82

↓ 3 callersMethodinstance

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleDeserializationConverterFactory.java:38

↓ 3 callersMethodisAssigningFinished

Returns whether the split assigner has assigned all splits, which indicates it can assign splits for newly added tables or not.

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

↓ 3 callersMethodisAssigningSnapshotSplits

Returns whether the split assigner is assigning snapshot splits.

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

↓ 3 callersMethodisAssigningSnapshotSplits

Returns whether the split assigner is assigning snapshot splits.

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/AssignerStatus.java:194

↓ 3 callersMethodisBefore

(Offset that)

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/offset/Offset.java:71

↓ 3 callersMethodisCdcPipelineUdf

(Class<?> clazz)

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/UserDefinedFunctionDescriptor.java:85

↓ 3 callersMethodisCommitting

()

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

↓ 3 callersMethodisCompact

Returns whether the local zoned timestamp data is small enough to be stored in a long of milliseconds.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/LocalZonedTimestampData.java:181

↓ 3 callersMethodisCompact

Returns whether the date-time part is small enough to be stored in a long of milliseconds.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/ZonedTimestampData.java:205

↓ 3 callersMethodisDataChangeRecord

(SourceRecord record)

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

↓ 3 callersMethodisEndWatermarkEvent

(SourceRecord record)

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

↓ 3 callersMethodisEndWatermarkEvent

(SourceRecord record)

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/wartermark/WatermarkEvent.java:89

↓ 3 callersMethodisHeartbeatEvent

(SourceRecord record)

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

↓ 3 callersMethodisIncludeDataCollection

Check if the tableId is included in SourceConfig.

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/dialect/DataSourceDialect.java:91

↓ 3 callersMethodisMetadataColumn

( String columnName, SupportedMetadataColumn[] supportedMetadataColumns)

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/parser/TransformParser.java:557

↓ 3 callersMethodisNewlyAddedAssigningSnapshotFinished

Returns whether the split assigner has finished its newly added snapshot splits assignment.

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/AssignerStatus.java:211

↓ 3 callersMethodisNumeric

(DataType type)

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/TypeCheckUtils.java:37

↓ 3 callersMethodisPendingTransactionSkip

(OracleConnectorConfig config)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/io/debezium/connector/oracle/logminer/LogMinerAdapter.java:425

↓ 3 callersMethodisPrimitive

Returns true if the variant is a primitive typed value, such as INT, DOUBLE, STRING, etc.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/variant/Variant.java:37

↓ 3 callersMethodisProcessingBacklog

()

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

↓ 3 callersMethodisRecentlyProcessed

Check whether a transaction has been recently processed through either a commit or rollback. @param transactionId the unique transaction id @return t

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/io/debezium/connector/oracle/logminer/processor/AbstractLogMinerEventProcessor.java:122

↓ 3 callersMethodisSameColumnsIgnoringCommentAndDefaultValue

()

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketAssignOperator.java:380

↓ 3 callersMethodisShouldRefreshSchema

()

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/v2/FlussEvent.java:46

↓ 3 callersMethodisSnapshotCompleted

()

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

↓ 3 callersMethodisSnapshotOnly

()

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupOptions.java:151

↓ 3 callersMethodisSnapshotSplitState

Checks whether this split state is a snapshot split state.

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

↓ 3 callersMethodisTableIdCaseSensitive

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/SnapshotPendingSplitsState.java:127

↓ 3 callersMethodisTablesLocked

()

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

↓ 3 callersMethodisValid

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/Lsn.java:142

↓ 3 callersMethodjavaToLowerCase

()

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

↓ 3 callersMethodjavaToUpperCase

()

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

↓ 3 callersMethodkeyArray

()

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericMapData.java:66

↓ 3 callersMethodknownGtidSet

Determine the executed GTID set for MySQL. @return the string representation of MySQL's GTID sets; never null but an empty string if the server d

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

↓ 3 callersMethodlatest

Never to perform snapshot on the monitored database tables upon first startup, just read from the latest CDC events which means only have the changes

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

↓ 3 callersMethodline

Get the 1-based line number of the character. @return the line number; always positive

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/text/Position.java:67

↓ 3 callersMethodlistDatabases

(MySqlSourceConfig sourceConfig)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/utils/MySqlSchemaUtils.java:50

↓ 3 callersMethodloadReferenceFile

(String name)

flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/FlinkParallelizedPipelineITCase.java:99

↓ 3 callersMethodlocaltimestamp

(long epochTime, String timezone)

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/functions/impl/TemporalFunctions.java:56

↓ 3 callersMethodlsnCommitCheckpointsDelay

Set the {@code LSN} checkpoints delay number for Postgres to commit the offsets.

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

↓ 3 callersMethodmain

(String[] args)

flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/CliFrontend.java:65

↓ 3 callersMethodmakeFirstPartBinlogEvents

Make some changes on the specified customer table. Changelog in string could be accessed by {@link #firstPartBinlogEvents}.

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

↓ 3 callersMethodmakeOplogForAddressTableInRound

( MongoDatabase mongoDatabase, String collectionName, int round)

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

↓ 3 callersMethodmatchString

()

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/text/TokenStream.java:617

↓ 3 callersMethodmaxUpperBoundOfId

()

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

↓ 3 callersMethodmaybeSendCreateTableEventFromCache

(TableId tableId, SourceOutput<T> output)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-postgres/src/main/java/org/apache/flink/cdc/connectors/postgres/source/reader/PostgresPipelineRecordEmitter.java:180

↓ 3 callersMethodmiddleOf

(Object obj)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/ChunkSplitterState.java:121

↓ 3 callersMethodmiddleOf

(Object obj)

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/ChunkSplitterState.java:122

↓ 3 callersMethodmoveToNextToken

(List<Token> newTokens)

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/text/TokenStream.java:302

↓ 3 callersMethodnewSchema

Create a new PostgresSchema and initialize the content of the schema.

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/PostgresObjectUtils.java:48

↓ 3 callersMethodnextByte

(int segSize)

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

↓ 3 callersMethodnextChunkEnd

( JdbcConnection jdbc, Object previousChunkEnd, TableId tableId,

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/JdbcSourceChunkSplitter.java:510

↓ 3 callersMethodnoMoreSplits

Indicates there is no more splits available in this assigner.

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

↓ 3 callersMethodnoMoreSplits

Indicates there is no more splits available in this assigner.

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/SplitAssigner.java:61

↓ 3 callersMethodnormalizeSchemaChangeEvents

Rewrite {@link SchemaChangeEvent}s by current {@link SchemaChangeBehavior} and include / exclude them by fine-grained schema change event configuratio

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaDerivator.java:155

↓ 3 callersMethodof

Creates an instance of {@link GenericRecordData} with given field values. <p>Note: All fields of the row must be internal data structures.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericRecordData.java:230

↓ 3 callersMethodof

(MongoDBSourceConfig sourceConfig, TableId collectionId)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/assigners/splitters/SplitContext.java:61

↓ 3 callersMethodofEmptyLiteral

The SQL standard defines that character string literals are allowed to be zero-length strings (i.e., to contain no characters) even though it is not p

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java:82

↓ 3 callersMethodofEmptyLiteral

The SQL standard defines that character string literals are allowed to be zero-length strings (i.e., to contain no characters) even though it is not p

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java:83

↓ 3 callersMethodofGtidSet

Create offset from GTID set.

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

↓ 3 callersMethodofTimestampSec

Create offset specified by a timestamp in second.

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

↓ 3 callersMethodonBinlogSplitUpdated

Callback to handle the binlog split has been updated in the newly added tables process. This is useful to check the newly added tables has been finish

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

↓ 3 callersMethodonError

(final Throwable error)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/tikv/cdc/RegionCDCClient.java:203

↓ 3 callersMethodonFinishedSplits

Callback to handle the finished splits with finished binlog offset. This is useful for determine when to generate binlog split and what binlog split t

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

↓ 3 callersMethodonStreamSplitUpdated

Callback to handle the stream split has been updated in the newly added tables process. This is useful to check the newly added tables has been finish

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/SplitAssigner.java:119

↓ 3 callersMethodopen

Called to open the assigner to acquire any resources, like threads or network connections.

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/SplitAssigner.java:44

↓ 3 callersMethodopenConnection

(Properties properties)

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

← previous next →2,201–2,300 of 12,620, ranked by callers