MCPcopy Create free account

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

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

⨍ Functions 12,620◇ Types & classes 1,927
↓ 3 callersMethodopenJdbcConnection
(JdbcSourceConfig sourceConfig)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/source/dialect/SqlServerDialect.java:82
↓ 3 callersMethodoptionalOptions
Returns a set of {@link ConfigOption} that an implementation of this factory consumes in addition to {@link #requiredOptions()}.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/factories/Factory.java:60
↓ 3 callersMethodparseFilterExpression
(String filterExpression)
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/parser/TransformParser.java:564
↓ 3 callersMethodparseServerId
(String serverIdValue)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/config/ServerIdRange.java:104
↓ 3 callersMethodpassword
Password to use when connecting to the SQL Server database server.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/SqlServerSource.java:92
↓ 3 callersMethodplus
Returns a number {@code Object} whose value is {@code (number + augend)}, Note: This method will throw {@link ArithmeticException} if number overflows
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/utils/ObjectUtils.java:30
↓ 3 callersMethodpointTo
(MemorySegment[] segments, int offset, int sizeInBytes)
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryMapData.java:50
↓ 3 callersMethodpollSplitRecords
Fetched records from data source. The method should return null when reaching the end of the split, the empty {@link Iterator} will be returned if the
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/external/Fetcher.java:42
↓ 3 callersMethodport
Integer port number of the SQL Server database server.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/SqlServerSource.java:62
↓ 3 callersMethodprepareCommit
()
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonWriter.java:108
↓ 3 callersMethodprettyPrintColumnNameMap
Prints an incrementally-sorted column name map like {@code $0 -> id, $1 -> name, ...}.
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/exceptions/TransformException.java:89
↓ 3 callersMethodprintOptions
(String identifier, Map<String, String> config)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/utils/OptionUtils.java:35
↓ 3 callersMethodprocess
(OraclePartition partition, Scn startScn, Scn endScn)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/io/debezium/connector/oracle/logminer/processor/AbstractLogMinerEventProcessor.java:180
↓ 3 callersMethodprocessNull
(String name)
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/metrics/SourceReaderMetrics.java:224
↓ 3 callersMethodprocessNull
(String name)
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/metrics/SourceEnumeratorMetrics.java:157
↓ 3 callersMethodprocessWarnings
(final boolean forced)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/PostgresReplicationConnection.java:679
↓ 3 callersMethodprojectRecords
Updates the after of a {@link DataChangeEvent} instance that describes the event with meta info.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/DataChangeEvent.java:188
↓ 3 callersMethodpurgedGtidSet
Get the purged GTID values from MySQL (gtid_purged value). @return A GTID set; may be empty if not using GTIDs or none have been purged yet
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlConnection.java:337
↓ 3 callersMethodquerySystemVariables
(String statement)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlConnection.java:158
↓ 3 callersMethodquote
(String dbOrTableName)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/utils/OracleUtils.java:234
↓ 3 callersMethodquotedTableIdString
(TableId tableId)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/io/debezium/connector/db2/Db2Connection.java:472
↓ 3 callersMethodreOrderSnapshotSplits
(List<SnapshotSplit> snapshotSplits)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/test/java/org/apache/flink/cdc/connectors/sqlserver/source/reader/fetch/SqlServerScanFetchTaskTest.java:382
↓ 3 callersMethodreachEndingOffset
( OraclePartition partition, LogMinerEventRow row, StreamSplit redoLogSpli
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/reader/fetch/EventProcessorFactory.java:266
↓ 3 callersMethodreadBooleanList
(ByteArrayInputStream inputStream, int length)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/TableMapEventMetadataDeserializer.java:121
↓ 3 callersMethodreadReplicationSlotInfo
Fetches a replication slot, repeating the query until either the slot is created or until the max number of attempts has been reached <p>To fetch the
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/PostgresConnection.java:370
↓ 3 callersMethodreadTableIds
(DataInputDeserializer in)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/PendingSplitsStateSerializer.java:423
↓ 3 callersMethodreadTableIds
(int version, DataInputDeserializer in)
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/PendingSplitsStateSerializer.java:471
↓ 3 callersMethodreadTableSchemas
(int version, DataInputDeserializer in)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplitSerializer.java:207
↓ 3 callersMethodreadTableSchemas
(int version, DataInputDeserializer in)
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitSerializer.java:223
↓ 3 callersMethodreadTableSnapshotSplits
( List<SnapshotSplit> snapshotSplits, SqlServerSourceFetchTaskContext taskContext,
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/test/java/org/apache/flink/cdc/connectors/sqlserver/source/reader/fetch/SqlServerScanFetchTaskTest.java:294
↓ 3 callersMethodrecordFetchDelay
(long fetchDelay)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/metrics/MySqlSourceReaderMetrics.java:51
↓ 3 callersMethodrecover
( Map<String, ?> source, Map<String, ?> position, Tables schema, DdlParser ddlParser)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/internal/FlinkDatabaseSchemaHistory.java:140
↓ 3 callersMethodregisterHistory
Registers history of schema safely.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/utils/DatabaseHistoryUtil.java:53
↓ 3 callersMethodregisterSubtask
send {@link SinkWriterRegisterEvent} to Schema Registry.
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/sink/SchemaEvolutionClient.java:56
↓ 3 callersMethodregisterTableSchema
(TableId tableId, Schema schema)
flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/testutils/operators/RegularEventOperatorTestHarness.java:229
↓ 3 callersMethodremoveRegions
(final Iterable<Long> regionIds)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/tikv/cdc/CDCClient.java:211
↓ 3 callersMethodremoveSlot
(String slotName)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/PostgresDialect.java:266
↓ 3 callersMethodrenameColumn
( String schemaName, String tableName, String oldColumnName, String newColumnName)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseCatalog.java:104
↓ 3 callersMethodreportError
Reports an exception. The consumer will throw the given exception immediately, if it is currently blocked in the {@link #pollNext()} method, or the ne
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/internal/Handover.java:145
↓ 3 callersMethodreportFinishedSnapshotSplitsIfNeed
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/reader/MySqlSourceReader.java:367
↓ 3 callersMethodreportFinishedSnapshotSplitsIfNeed
()
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/IncrementalSourceReader.java:507
↓ 3 callersMethodreset
First, reset.
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/writer/BinaryArrayWriter.java:50
↓ 3 callersMethodresolveSchemaCompatibility
( TypeSerializer<T> typeSerializer)
flink-cdc-flink2-compat/src/main/java/org/apache/flink/api/common/typeutils/TypeSerializerSnapshotAdapter.java:29
↓ 3 callersMethodrestartFromSavePoint
( Map<String, String> options, OracleSourceConfigFactory configFactory)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oracle/src/test/java/org/apache/flink/cdc/connectors/oracle/source/OraclePipelineITCase.java:1348
↓ 3 callersMethodreverseLookupDependingUpstreamSchemas
For an evolved table ID, reverse lookup all upstream schemas that needs to be fit in.
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaDerivator.java:128
↓ 3 callersMethodround
SQL <code>ROUND</code> operator applied to byte values.
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/functions/impl/ArithmeticFunctions.java:291
↓ 3 callersMethodroundNumberOfBytesToNearestWord
(int numBytes)
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/writer/AbstractBinaryWriter.java:342
↓ 3 callersMethodroute
Updates the {@link TableId} info of current data change event.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/DataChangeEvent.java:201
↓ 3 callersMethodrunInEventLoop
Run a time-consuming task in given {@link ExecutorService}. All overridable functions have been wrapped inside already, so there's no need to call thi
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaRegistry.java:343
↓ 3 callersMethodrunInHarness
( Supplier<OP> opCreator, Function<OP, DistributedEventOperatorTestHar
flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/operators/schema/distributed/SchemaEvolveTest.java:385
↓ 3 callersMethodrunJob
(String databaseName, String tableName)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/test/java/org/apache/flink/cdc/connectors/mysql/source/MySqlOscITCase.java:394
↓ 3 callersMethodrunJobWithEvents
(List<Event> events)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/test/java/org/apache/flink/cdc/connectors/elasticsearch/sink/Elasticsearch6DataSinkITCaseTest.java:156
↓ 3 callersMethodrunJobWithEvents
(List<Event> events)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/test/java/org/apache/flink/cdc/connectors/elasticsearch/sink/Elasticsearch7DataSinkITCaseTest.java:162
↓ 3 callersMethodsamplesPerChunk
scan.incremental.snapshot.chunk.samples <p>The number of samples to take per chunk. Defaults to 20.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/MongoDBSourceBuilder.java:196
↓ 3 callersMethodschemaExists
( Map<TableId, SortedMap<Integer, Schema>> schemaMap, TableId tableId)
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaManager.java:91
↓ 3 callersMethodschemaList
An optional list of regular expressions that match schema names to be monitored; any schema name not included in the whitelist will be excluded from m
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/PostgreSQLSource.java:91
↓ 3 callersMethodschemaList
An optional list of regular expressions that match schema names to be monitored; any schema name not included in the whitelist will be excluded from m
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/OracleSource.java:101
↓ 3 callersMethodsendFromTables
(Consumer<TableId> tableIdConsumer)
flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/testsource/source/DistributedSourceFunction.java:137
↓ 3 callersMethodsendRequestToCoordinator
(REQUEST request)
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/regular/SchemaOperator.java:236
↓ 3 callersMethodsetByte
(int pos, byte value)
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryArrayData.java:341
↓ 3 callersMethodsetDouble
(int pos, double value)
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryArrayData.java:395
↓ 3 callersMethodsetNotifyCheckpointCompleteCallback
(Consumer<Long> callback)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/test/java/org/apache/flink/cdc/connectors/postgres/source/MockPostgresDialect.java:43
↓ 3 callersMethodsetNullBit
(int ordinal)
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/writer/AbstractBinaryWriter.java:81
↓ 3 callersMethodsetNullInt
(int ordinal)
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/writer/BinaryArrayWriter.java:82
↓ 3 callersMethodsetNullLong
(int ordinal)
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/writer/BinaryArrayWriter.java:88
↓ 3 callersMethodsetOf
( String input, Function<String, String[]> splitter, Function<String, T> factory)
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/Predicates.java:67
↓ 3 callersMethodsetOrdinates
(double[] ordinates)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/converters/OracleGeometry.java:89
↓ 3 callersMethodsetPassword
setPassword set the password to authenticate the connection with the Elasticsearch cluster. @param password the auth password @return {@code Elastics
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/v2/Elasticsearch8AsyncSinkBuilder.java:189
↓ 3 callersMethodsetShort
(int pos, short value)
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryArrayData.java:359
↓ 3 callersMethodsetSnapshotPhaseHooks
(SnapshotPhaseHooks snapshotPhaseHooks)
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/external/AbstractScanFetchTask.java:212
↓ 3 callersMethodsetSourceOffset
(Map<String, ?> sourceOffset)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/internal/DebeziumOffset.java:51
↓ 3 callersMethodsetSourcePartition
(Map<String, ?> sourcePartition)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/internal/DebeziumOffset.java:47
↓ 3 callersMethodsetUsername
setUsername set the username to authenticate the connection with the Elasticsearch cluster. @param username the auth username @return {@code Elastics
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/v2/Elasticsearch8AsyncSinkBuilder.java:177
↓ 3 callersMethodsetup
( StreamTask<?, ?> containingTask, StreamConfig config, Output<StreamRecor
flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/operators/sink/DataSinkOperatorAdapter.java:65
↓ 3 callersMethodsetupSavepoint
(StreamExecutionEnvironment env, String savepointPath)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/SpecificStartingOffsetITCase.java:583
↓ 3 callersMethodsinkSize
(String sinkName)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/test/java/org/apache/flink/cdc/connectors/postgres/PostgresTestBase.java:239
↓ 3 callersMethodskipEmptyMessages
Whether empty data messages should be ignored. @return true if empty data messages coming from data source should be ignored. Typical use case ar
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/io/debezium/relational/RelationalChangeRecordEmitter.java:225
↓ 3 callersMethodskipSnapshotBackfill
Whether to skip backfill in snapshot reading phase. <p>If backfill is skipped, changes on captured tables during snapshot phase will be consumed late
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/MongoDBSourceBuilder.java:258
↓ 3 callersMethodsleepMs
(long millis)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/test/java/org/apache/flink/cdc/connectors/oceanbase/OceanBaseFailoverITCase.java:522
↓ 3 callersMethodsleepMs
(long millis)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/MySqlSourceITCase.java:1383
↓ 3 callersMethodsortFinishedSplitInfos
Sorts the list of FinishedSnapshotSplitInfo by splitStart in ascending order. This is required for binary search to work correctly. <p>Handles specia
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/SplitKeyUtils.java:86
↓ 3 callersMethodsplitEscaped
Splits the given string on the given delimiter. It supports quoting parts of the string with either single (') or double quotes ("). Quotes can be esc
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/StructuredOptionsSplitter.java:49
↓ 3 callersMethodsplitEvenlySizedChunks
Split table into evenly sized chunks based on the numeric min and max value of split column, and tumble chunks in step size.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlChunkSplitter.java:287
↓ 3 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-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/OracleSourceBuilder.java:122
↓ 3 callersMethodsslModeEnabled
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlConnection.java:701
↓ 3 callersMethodstartPgReplicationStream
( final Lsn lsn, BiFunction< ChainedLogicalStreamBuilder,
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/PostgresReplicationConnection.java:715
↓ 3 callersMethodstartStreaming
creating a replication connection and starting to stream involves a few steps: 1. we create the connection and ensure that a. the slot exists b. the s
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/PostgresReplicationConnection.java:372
↓ 3 callersMethodstartupOptions
Specifies the startup options.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/OracleSource.java:134
↓ 3 callersMethodstartupOptions
scan.startup.mode <p>Optional startup mode for MongoDB CDC consumer, valid enumerations are initial, latest-offset, timestamp. Default: initial
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/MongoDBSource.java:234
↓ 3 callersMethodstopBinlogReadTask
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/reader/BinlogSplitReader.java:424
↓ 3 callersMethodstopChangeEventSource
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/fetch/StoppableChangeEventSourceContext.java:31
↓ 3 callersMethodstopReadTask
()
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/external/IncrementalSourceStreamFetcher.java:285
↓ 3 callersMethodstringify
(Object... objects)
flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/operators/transform/TransformOperatorWithSchemaEvolveTest.java:104
↓ 3 callersMethodsubmitSnapshotSplit
(SnapshotSplit snapshotSplit)
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/IncrementalSourceSplitReader.java:244
↓ 3 callersMethodsupportCheckpointsAfterTasksFinished
()
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/utils/EnvironmentUtils.java:33
↓ 3 callersMethodtableList
An optional comma-separated list of regular expressions that match fully-qualified table identifiers for tables that you want Debezium to capture; any
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/SqlServerSource.java:80
↓ 3 callersMethodtestConsumingAllEventsWithJsonFormat
( Boolean includeSchema, Map<String, Object> customConverterConfigs, String expectedFile)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/LegacyMySqlSourceITCase.java:78
↓ 3 callersMethodtestConvert
(String input)
flink-cdc-runtime/src/test/java/org/apache/flink/cdc/common/route/TableIdRouterTest.java:44
↓ 3 callersMethodtestMongoDBSnapshotSplitReader
(SplitStrategy splitter)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/test/java/org/apache/flink/cdc/connectors/mongodb/source/reader/MongoDBSnapshotSplitReaderAssignEndingFirstTest.java:92
↓ 3 callersMethodtestReadDateConvertDataStreamSource
(String timezone)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/debezium/converters/MysqlDebeziumTimeConverterITCase.java:123
← previousnext →2,301–2,400 of 12,620, ranked by callers