Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/apache/flink-cdc
/ functions
Functions
12,620 in github.com/apache/flink-cdc
⨍
Functions
12,620
◇
Types & classes
1,927
↓ 5 callers
Method
open
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlSnapshotSplitAssigner.java:186
↓ 5 callers
Method
parseSelect
(String statement)
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/parser/TransformParser.java:189
↓ 5 callers
Method
physicalColumn
Declares a physical column that is appended to this schema. @param columnName column name @param type data type of the column
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/schema/Schema.java:343
↓ 5 callers
Method
pointTo
(MemorySegment[] segments, int offset, int sizeInBytes)
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryArrayData.java:178
↓ 5 callers
Method
productDocOf
(String id, String name, String description, Double weight)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/test/java/org/apache/flink/cdc/connectors/mongodb/LegacyMongoDBSourceTest.java:641
↓ 5 callers
Method
purgeBinaryLogs
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/SpecificStartingOffsetITCase.java:484
↓ 5 callers
Method
queryTable
(String tableName, boolean isMySQL)
flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/OceanBaseE2eITCase.java:270
↓ 5 callers
Method
quote
(String dbOrTableName)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/utils/Db2Utils.java:359
↓ 5 callers
Method
read
Read the metadata from the {@link DataChangeEvent#meta()}. @param metadata the metadata returned from {@link DataChangeEvent#meta()} @return the valu
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/source/SupportedMetadataColumn.java:45
↓ 5 callers
Method
readBinlogSplitsFromSnapshotSplits
( List<MySqlSnapshotSplit> sqlSplits, DataType dataType, MySqlSourceConfig
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/debezium/reader/BinlogSplitReaderTest.java:1327
↓ 5 callers
Method
readLines
(String resource)
flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/utils/PipelineTestEnvironment.java:459
↓ 5 callers
Method
readObject
(ObjectInputStream in)
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/EnumSerializer.java:154
↓ 5 callers
Method
readOffsetPosition
(int offsetVersion, DataInputDeserializer in)
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/offset/OffsetDeserializerSerializer.java:41
↓ 5 callers
Method
registerNewSchema
( final Map<TableId, SortedMap<Integer, Schema>> schemaMap, TableId tableId,
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaManager.java:224
↓ 5 callers
Method
removeSlot
Drop slot from database.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/test/java/org/apache/flink/cdc/connectors/postgres/testutils/UniqueDatabase.java:177
↓ 5 callers
Method
replaceFirstNonNumericSubstring
Replace the first non-numeric substring. @param s the original string @param startIndex the beginning index, inclusive @param c the new character @re
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlDefaultValueConverter.java:514
↓ 5 callers
Method
requestStreamSplitUpdateIfNeed
()
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/enumerator/IncrementalSourceEnumerator.java:278
↓ 5 callers
Method
retrieveHistory
Retrieves history of schema safely, this method firstly checks the history status of specific engine, and then return the history of schema if the his
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/utils/DatabaseHistoryUtil.java:73
↓ 5 callers
Method
reverseLookupDependingUpstreamTables
For an evolved table ID, reverse lookup all upstream tables that it depends on.
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaDerivator.java:108
↓ 5 callers
Method
rowToArray
Converts a {@link ResultSet} row to an array of Objects.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/RecordUtils.java:76
↓ 5 callers
Method
scanNewlyAddedTableEnabled
Whether the {@link MySqlSource} should scan the newly added tables or not.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlSourceBuilder.java:209
↓ 5 callers
Method
sendRequestToCoordinator
( OperatorID operator, SerializedValue<CoordinationRequest> request)
flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/testutils/schema/TestingSchemaRegistryGateway.java:62
↓ 5 callers
Method
serializedStringToRow
(String serialized)
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/utils/SerializerUtils.java:57
↓ 5 callers
Method
setAcceptedSchemaEvolutionTypes
Sets enabled schema evolution event types of current metadata applier.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/MetadataApplier.java:39
↓ 5 callers
Method
setOffsetKind
(BinlogOffsetKind offsetKind)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/offset/BinlogOffsetBuilder.java:70
↓ 5 callers
Method
setTableId
( SourceRecord dataRecord, TableId originalTableId, TableId tableId)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/RecordUtils.java:399
↓ 5 callers
Method
skipSnapshotBackfill
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-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlSourceBuilder.java:271
↓ 5 callers
Method
skipSnapshotBackfill
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-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/Db2SourceBuilder.java:230
↓ 5 callers
Method
sleepMs
(long millis)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/test/java/org/apache/flink/cdc/connectors/oracle/source/NewlyAddedTableITCase.java:824
↓ 5 callers
Method
slotName
The name of the PostgreSQL logical decoding slot that was created for streaming changes from a particular plug-in for a particular database/schema. Th
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/PostgreSQLSource.java:131
↓ 5 callers
Method
sslMode
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlConnection.java:696
↓ 5 callers
Method
start
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/internal/FlinkOffsetBackingStore.java:149
↓ 5 callers
Method
startupOptions
Specifies the startup options.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/PostgresSourceBuilder.java:217
↓ 5 callers
Method
stopJobWithSavepoint
(JobID jobID)
flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/utils/PipelineTestEnvironment.java:321
↓ 5 callers
Method
string
(DataType dataType)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/utils/SchemaEvolutionUtils.java:297
↓ 5 callers
Method
submitRequestToOperator
(CoordinationRequest request)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/coordinator/SessionManageOperator.java:293
↓ 5 callers
Method
submitSplit
Add to split to read, this should call only the when reader is idle. @param splitToRead
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/reader/DebeziumReader.java:35
↓ 5 callers
Method
tableList
An optional list of regular expressions that match fully-qualified table identifiers for tables to be monitored; any table not included in the list wi
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/OracleSource.java:91
↓ 5 callers
Method
toCdcTableId
(TableId dbzTableId)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/parser/CustomAlterTableParserListener.java:520
↓ 5 callers
Method
toJavaClass
(DataType dataType)
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/converter/JavaClassConverter.java:62
↓ 5 callers
Method
triggerSavepointWithRetry
(JobClient jobClient, String savepointDirectory)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/NewlyAddedTableITCase.java:956
↓ 5 callers
Method
triggerSavepointWithRetry
(JobClient jobClient, String savepointDirectory)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/test/java/org/apache/flink/cdc/connectors/mongodb/source/NewlyAddedTableITCase.java:928
↓ 5 callers
Method
validateIntegerOption
Checks the value of given integer option is valid.
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/factory/MySqlDataSourceFactory.java:483
↓ 5 callers
Method
validateIntegerOption
Checks the value of given integer option is valid.
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-postgres/src/main/java/org/apache/flink/cdc/connectors/postgres/factory/PostgresDataSourceFactory.java:286
↓ 5 callers
Method
validateIntegerOption
Checks the value of given integer option is valid.
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oracle/src/main/java/org/apache/flink/cdc/connectors/oracle/factory/OracleDataSourceFactory.java:223
↓ 5 callers
Method
validateIntegerOption
Checks the value of given integer option is valid.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableFactory.java:255
↓ 5 callers
Method
validateIntegerOption
Checks the value of given integer option is valid.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableFactory.java:247
↓ 5 callers
Method
validateIntegerOption
Checks the value of given integer option is valid.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/MySqlTableSourceFactory.java:327
↓ 5 callers
Method
validateIntegerOption
Checks the value of given integer option is valid.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/Db2TableSourceFactory.java:246
↓ 5 callers
Method
validateIntegerOption
Checks the value of given integer option is valid.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSourceFactory.java:249
↓ 5 callers
Method
validateSinkResult
( 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/MySqlToPaimonE2eITCase.java:467
↓ 5 callers
Method
waitForAvailableRecords
Wait for a maximum amount of time until the first record is available. @param timeout the maximum amount of time to wait; must not be negative @retur
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/test/java/org/apache/flink/cdc/connectors/postgres/PostgreSQLSourceTest.java:703
↓ 5 callers
Method
waitForAvailableRecords
Wait for a maximum amount of time until the first record is available. @param timeout the maximum amount of time to wait; must not be negative @retur
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/LegacyMySqlSourceTest.java:1291
↓ 5 callers
Method
waitForAvailableRecords
Wait for a maximum amount of time until the first record is available. @param timeout the maximum amount of time to wait; must not be negative @retur
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/test/java/org/apache/flink/cdc/connectors/oracle/OracleSourceTest.java:625
↓ 5 callers
Method
waitForSinkSize
(String sinkName, int expectedSize)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/test/java/org/apache/flink/cdc/connectors/sqlserver/source/SqlServerSourceTestBase.java:197
↓ 5 callers
Method
waitForSnapshotStarted
(String sinkName)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/test/java/org/apache/flink/cdc/connectors/postgres/PostgresTestBase.java:176
↓ 5 callers
Method
writeOffsetPosition
(Offset offset, DataOutputSerializer out)
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/offset/OffsetDeserializerSerializer.java:73
↓ 4 callers
Method
add
Creates a SchemaChange object for adding a column without specifying its position. @param columnWithPosition The ColumnWithPosition object containing
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/SchemaChangeProvider.java:51
↓ 4 callers
Method
addCollector
( StreamExecutionEnvironment env, DataStreamSource<T> source, AbstractColl
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/test/java/org/apache/flink/cdc/connectors/mysql/source/MysqlPipelineNewlyAddedTableITCase.java:574
↓ 4 callers
Method
addCollector
( StreamExecutionEnvironment env, DataStreamSource<T> source, AbstractColl
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-postgres/src/test/java/org/apache/flink/cdc/connectors/postgres/source/PostgresPipelineITCase.java:351
↓ 4 callers
Method
addColumns
equals to run a sql like: 'alter table table_name add columns (col_name1 type1 comment [, col_name2 type2 ...]);'.
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/utils/SchemaEvolutionUtils.java:109
↓ 4 callers
Method
addToken
Create a single-character token at the supplied index in the character stream. The token type is set to 0, meaning this is equivalent to calling <code
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/text/TokenStream.java:414
↓ 4 callers
Method
allSnapshotSplitsFinished
Returns whether all splits are finished which means no more splits and all assigned splits are finished.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlSnapshotSplitAssigner.java:580
↓ 4 callers
Method
allSnapshotSplitsFinished
Returns whether all splits are finished which means no more splits and all assigned splits are finished.
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/SnapshotSplitAssigner.java:653
↓ 4 callers
Method
allowsPrecScale
Returns whether this type can be specified with a given combination of precision and scale. For example, <ul> <li><code>Varchar.allowsPrecScale(tru
flink-cdc-runtime/src/main/java/org/apache/calcite/sql/type/SqlTypeName.java:415
↓ 4 callers
Method
appendQuoted
(StringBuilder sb, String str)
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/variant/BinaryVariant.java:471
↓ 4 callers
Method
apply
(Event event, SinkWriter.Context context)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/serializer/ElasticsearchEventSerializer.java:90
↓ 4 callers
Method
asStreamSplitState
Casts this split state into a {@link StreamSplitState}.
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitState.java:45
↓ 4 callers
Method
assertRead
Verify that the given {@link SourceRecord} is a {@link Envelope.Operation#READ READ} 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:62
↓ 4 callers
Method
assignUnboundedChunkFirst
Whether the {@link MySqlSource} should assign the unbounded chunks first or not during snapshot reading phase.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlSourceBuilder.java:310
↓ 4 callers
Method
basicSourceBuilder
( UniqueDatabase database, String serverTimezone, boolean useLegacyImplementation)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/MySqlTestUtils.java:58
↓ 4 callers
Method
builder
( String accessId, String accessKey, String endpoint, String project)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/options/MaxComputeOptions.java:53
↓ 4 callers
Method
cancelJob
(JobID jobID)
flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/utils/PipelineTestEnvironment.java:340
↓ 4 callers
Method
cancelJobIfRunning
(TableResult result)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/test/java/org/apache/flink/cdc/connectors/db2/table/Db2ConnectorITCase.java:90
↓ 4 callers
Method
castObjectIntoString
(Object object)
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/functions/impl/CastingFunctions.java:310
↓ 4 callers
Method
checkTableArgument
(String databaseName, String tableName)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksEnrichedCatalog.java:174
↓ 4 callers
Method
close
Called to close the assigner, in case it holds on to 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:125
↓ 4 callers
Method
closeBinlogReader
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/reader/MySqlSplitReader.java:252
↓ 4 callers
Method
closeIdleReaders
Whether to close idle readers at the end of the snapshot phase. This feature depends on FLIP-147: Support Checkpoints After Tasks Finished. The flink
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/Db2SourceBuilder.java:214
↓ 4 callers
Method
closeScanFetcher
()
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/IncrementalSourceSplitReader.java:277
↓ 4 callers
Method
closeSnapshotReader
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/reader/MySqlSplitReader.java:240
↓ 4 callers
Method
closeStreamFetcher
()
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/IncrementalSourceSplitReader.java:288
↓ 4 callers
Method
code
Creates a block of text formatted as code. @param text a block of text that will be formatted as code @return block of text formatted as code
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description/TextElement.java:71
↓ 4 callers
Method
coerceDataRecord
Coerce a {@link DataChangeEvent} from upstream to expected downstream schema.
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaDerivator.java:299
↓ 4 callers
Method
collect
(RowData record)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/test/java/org/apache/flink/cdc/connectors/oracle/testutils/RecordsFormatter.java:91
↓ 4 callers
Method
collectionFor
( MongoClient mongoClient, TableId collectionId, Class<T> documentClass)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/utils/MongoUtils.java:410
↓ 4 callers
Method
collectionsFilter
(List<String> collectionList)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/utils/CollectionDiscoveryUtils.java:110
↓ 4 callers
Method
compareKeyWithRange
Compares {@code key} against the half-open interval {@code [splitStart, splitEnd)} and returns where the key lies relative to that interval.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/SplitKeyUtils.java:194
↓ 4 callers
Method
compareKeyWithRange
Compares {@code key} against the half-open interval {@code [splitStart, splitEnd)} and returns where the key lies relative to that interval.
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/utils/SplitKeyUtils.java:186
↓ 4 callers
Method
configuration
()
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/udf/UserDefinedFunctionContext.java:25
↓ 4 callers
Method
connectMaxRetries
The max retry times to get connection.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/Db2SourceBuilder.java:156
↓ 4 callers
Method
connectTimeout
The maximum time that the connector should wait after trying to connect to the Db2 database server before timing out.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/Db2SourceBuilder.java:150
↓ 4 callers
Method
connectionPoolSize
The connection pool size.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/Db2SourceBuilder.java:162
↓ 4 callers
Method
convertInstantToLocalDateTime
(Instant instant)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBConnectorDeserializationSchema.java:470
↓ 4 callers
Method
convertRecordDataToGenericRow
( RecordData recordData, List<RecordData.FieldGetter> fieldGetters, RowKind rowKind)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonWriterHelper.java:305
↓ 4 callers
Method
convertSchemaChangeEvent
(SchemaChangeEvent schemaChangeEvent)
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:213
↓ 4 callers
Method
copy
Returns a deep copy of this type with possibly different nullability. @param isNullable the intended nullability of the copied type @return a deep co
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java:96
↓ 4 callers
Method
copyMultiSegmentsToBytes
( MemorySegment[] segments, int offset, byte[] bytes, int bytesOffset, int numBytes)
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySegmentUtils.java:140
↓ 4 callers
Method
create
(int subtask)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/source/config/SqlServerSourceConfigFactory.java:38
↓ 4 callers
Method
createArray
(int... vs)
flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/serializer/data/MapDataSerializerTest.java:116
← previous
next →
1,501–1,600 of 12,620, ranked by callers