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
↓ 2 callersMethodbefore
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/test/java/org/apache/flink/cdc/connectors/vitess/VitessSourceTest.java:61
↓ 2 callersMethodbitGet
read bit. @param segment target segment. @param baseOffset bits base offset. @param index bit index from base offset.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySegmentUtils.java:458
↓ 2 callersMethodbroadcastEvent
(Event toBroadcast)
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/RegularPrePartitionOperator.java:114
↓ 2 callersMethodbsonListToJson
(List<Bson> bsonList)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/utils/CollectionDiscoveryUtils.java:217
↓ 2 callersMethodbucketBounds
(BsonDocument bucket)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/assigners/splitters/SampleBucketSplitStrategy.java:171
↓ 2 callersMethodbuild
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/offset/BinlogOffsetBuilder.java:86
↓ 2 callersMethodbuildAlterAddColumnsSql
( String databaseName, String tableName, List<OceanBaseColumn> addColumns)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseMySQLCatalog.java:542
↓ 2 callersMethodbuildColumnsDDL
( String columnPrefix, int start, int end, String dataType)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/table/MySqlConnectorITCase.java:2218
↓ 2 callersMethodbuildDataDictionary
Requests Oracle to build the data dictionary. <p>During the build step, Oracle will perform an additional series of redo log switches. Additionally,
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/io/debezium/connector/oracle/logminer/LogMinerStreamingChangeEventSource.java:510
↓ 2 callersMethodbuildDescription
Build a simple description for the write result.
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2/WriteResultWrapper.java:77
↓ 2 callersMethodbuildDistributeKeys
(Schema schema)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink/DorisMetadataApplier.java:218
↓ 2 callersMethodbuildPipelineDefinitionFromConfiguration
(Configuration pipelineConfig)
flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/FlinkPipelineComposerTest.java:217
↓ 2 callersMethodbuildPrimaryKeyStr
(RecordData recordData)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/src/main/java/org/apache/flink/cdc/connectors/values/ValuesDatabase.java:422
↓ 2 callersMethodbuildSchemaFromTable
(Table table)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/reader/MySqlPipelineRecordEmitter.java:263
↓ 2 callersMethodbuildSplitScanQuery
( TableId tableId, RowType pkRowType, boolean isFirstSplit, bo
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/utils/PostgresQueryUtils.java:152
↓ 2 callersMethodbuildTypeString
(DataType dataType)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink/DorisMetadataApplier.java:228
↓ 2 callersMethodbuilder
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/SqlServerSource.java:39
↓ 2 callersMethodbuilder
Get a MySqlParallelSourceBuilder to build a {@link MySqlSource}. @return a MySql parallel source builder.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlSource.java:117
↓ 2 callersMethodbuilder
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/Db2Source.java:35
↓ 2 callersMethodbuilder
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/OracleSourceBuilder.java:286
↓ 2 callersMethodbuilder
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/VitessSource.java:38
↓ 2 callersMethodbuilder
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/TiDBSource.java:28
↓ 2 callersMethodcachePreTransformProcessor
(TableId tableId, Schema tableSchema)
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PreTransformOperator.java:310
↓ 2 callersMethodcalculateBitSetWidthInBytes
(int arity)
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryRecordData.java:68
↓ 2 callersMethodcanBePrefixMap
Maps can be represented in two ways. <p>With constant key space: <pre> avro-confluent.properties = schema: 1, other-prop: 2 </pre> <p>Or with v
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/ConfigurationUtils.java:288
↓ 2 callersMethodchannel
(CommittableMessage<MultiTableCommittable> committableMessage)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/MultiTableCommittableChannelComputer.java:44
↓ 2 callersMethodcheckAdvance
(int segSize)
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryStringData.java:815
↓ 2 callersMethodcheckIfResumeTokenExpires
(final MongoCommandException e)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/utils/MongoUtils.java:460
↓ 2 callersMethodcheckIndex
(int index, int size)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/serializer/ElasticsearchEventSerializer.java:249
↓ 2 callersMethodcheckResult
(List<String> expectedResult, String table, String[] fields)
flink-cdc-e2e-tests/flink-cdc-e2e-utils/src/test/java/org/apache/flink/cdc/common/test/utils/JdbcProxy.java:47
↓ 2 callersMethodcheckSlot
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:189
↓ 2 callersMethodcheckTableColumnNameLengths
Examines the table and column names and logs a warning if any name exceeds {@link #MAXIMUM_NAME_LENGTH}. @param table the table, should not be {@code
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/io/debezium/connector/oracle/logminer/LogMinerStreamingChangeEventSource.java:924
↓ 2 callersMethodchunkKeyColumn
The chunk key of table snapshot, captured tables are split into multiple chunks by the chunk key column when read the snapshot of table.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/Db2SourceBuilder.java:183
↓ 2 callersMethodclearOperator
()
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PreTransformOperator.java:408
↓ 2 callersMethodclose
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/PostgresReplicationConnection.java:624
↓ 2 callersMethodclose
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlHybridSplitAssigner.java:200
↓ 2 callersMethodclose
()
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/external/IncrementalSourceStreamFetcher.java:154
↓ 2 callersMethodclose
()
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/external/IncrementalSourceScanFetcher.java:225
↓ 2 callersMethodclose
()
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/SnapshotSplitAssigner.java:576
↓ 2 callersMethodclose
Closes the handover. Both the {@link #produce(List)} method and the {@link #pollNext()} will throw a {@link ClosedException} on any currently blocking
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/internal/Handover.java:188
↓ 2 callersMethodcloseExecutorService
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlSnapshotSplitAssigner.java:527
↓ 2 callersMethodcloseExecutorService
()
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/SnapshotSplitAssigner.java:589
↓ 2 callersMethodcloseIdleReaders
scan.incremental.close-idle-reader.enabled <p>Whether to close idle readers at the end of the snapshot phase. This feature depends on FLIP-147: Suppo
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/MongoDBSourceBuilder.java:213
↓ 2 callersMethodcoerceToBytes
(Object originalField)
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/SchemaMergingUtils.java:615
↓ 2 callersMethodcoerceToString
(Object originalField, DataType originalType)
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/SchemaMergingUtils.java:591
↓ 2 callersMethodcollect
(RowData record)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/test/java/org/apache/flink/cdc/connectors/db2/testutils/RecordsFormatter.java:87
↓ 2 callersMethodcolumnMatchCost
Computes the min cost of matching a before column to an after column (0, 1, or 2). if column name is same and type is same, cost = 0; if column name i
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-postgres/src/main/java/org/apache/flink/cdc/connectors/postgres/utils/SchemaChangeUtil.java:213
↓ 2 callersMethodcolumnParseForTableEditor
()
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oracle/src/main/java/org/apache/flink/cdc/connectors/oracle/source/parser/OracleAlterTableParserListener.java:249
↓ 2 callersMethodcommit
( PaimonWriter<Event> writer, Committer<MultiTableCommittable> committer)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/test/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonSinkITCase.java:759
↓ 2 callersMethodcommitInterval
(int commitInterval)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2/compaction/CompactionOptions.java:66
↓ 2 callersMethodcommitOperation
( SnapshotUpdate<?> operation, String newFlinkJobId, String operatorId,
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2/IcebergCommitter.java:183
↓ 2 callersMethodcommitSuccess
(String sessionId, boolean success)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/utils/SessionCommitCoordinateHelper.java:150
↓ 2 callersMethodcommitUpToCheckpoint
(long checkpointId)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PreCommitOperator.java:130
↓ 2 callersMethodcommitted
Never to perform snapshot on the monitored database tables upon first startup, just read from the previous committed posistion of the change log which
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupOptions.java:76
↓ 2 callersMethodcompact
(TableId tableId)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2/compaction/CompactionOperator.java:112
↓ 2 callersMethodcompare
(Object obj1, Object obj2, Column splitColumn)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/source/utils/SqlServerUtils.java:408
↓ 2 callersMethodcompareBsonDocument
(BsonDocument d1, BsonDocument d2)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/utils/BsonUtils.java:108
↓ 2 callersMethodcompileExpression
Compiles an expression code to a janino {@link ExpressionEvaluator}.
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionCompiler.java:55
↓ 2 callersMethodcompletionPattern
(String pattern)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/utils/CollectionDiscoveryUtils.java:210
↓ 2 callersMethodconfig
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlConnection.java:668
↓ 2 callersMethodconnectMaxRetries
The max retry times to get connection.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlSourceBuilder.java:184
↓ 2 callersMethodconnectionPoolSize
The connection pool size.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlSourceBuilder.java:190
↓ 2 callersMethodconnectorJarUrl
(String name)
flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/utils/TarballFetcher.java:179
↓ 2 callersMethodconstructTableId
()
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/test/java/org/apache/flink/cdc/connectors/base/source/assigner/state/PendingSplitsStateSerializerTest.java:185
↓ 2 callersMethodconsume
Return the value of this token and move to the next token. @return the value of the current token @throws ParsingException if there is no such token
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/text/TokenStream.java:189
↓ 2 callersMethodconsumeBinlogRecords
( MySqlSourceReader<SourceRecord> sourceReader, DataType recordType)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/reader/MySqlSourceReaderTest.java:651
↓ 2 callersMethodconsumeInQuotes
( String string, char quote, int cursor, StringBuilder builder)
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/StructuredOptionsSplitter.java:145
↓ 2 callersMethodconsumeRecords
( IncrementalSourceReaderWithCommit sourceReader, DataType recordType)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/test/java/org/apache/flink/cdc/connectors/sqlserver/source/reader/SqlserverSourceReaderTest.java:186
↓ 2 callersMethodconsumeSnapshotRecords
( MySqlSourceReader<SourceRecord> sourceReader, DataType recordType)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/reader/MySqlSourceReaderTest.java:638
↓ 2 callersMethodconvert
(Object dbzObj, Schema schema)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/table/DeserializationRuntimeConverter.java:30
↓ 2 callersMethodconvertBigInt
(Column column, Field fieldDefn, Object data)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlValueConverters.java:475
↓ 2 callersMethodconvertDataChangeEvent
(DataChangeEvent dataChangeEvent)
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:252
↓ 2 callersMethodconvertDataChangeEventToRowData
Convert {@link DataChangeEvent} to {@link RowData}.
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-hudi/src/main/java/org/apache/flink/cdc/connectors/hudi/sink/util/RowDataUtils.java:69
↓ 2 callersMethodconvertField
( DeserializationRuntimeConverter fieldConverter, BsonValue fieldValue)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBConnectorDeserializationSchema.java:773
↓ 2 callersMethodconvertInstantToLocalDate
(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:462
↓ 2 callersMethodconvertInstantToLocalTime
(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:466
↓ 2 callersMethodconvertInstantToZonedDateTime
(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:474
↓ 2 callersMethodconvertInteger
(Column column, Field fieldDefn, Object data)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlValueConverters.java:465
↓ 2 callersMethodconvertInvalidTimestampDefaultValue
(String defaultValue, DataType dataType)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink/DorisMetadataApplier.java:329
↓ 2 callersMethodconvertInvalidTimestampDefaultValue
( String defaultValue, DataType dataType)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/SchemaChangeProvider.java:154
↓ 2 callersMethodconvertJsonNodeToModelDef
(JsonNode modelNode)
flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/parser/YamlPipelineDefinitionParser.java:434
↓ 2 callersMethodconvertString
Convert the {@link String} or {@code byte[]} value to a string value used in a {@link SourceRecord}. @param column the column in which the value appe
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlValueConverters.java:516
↓ 2 callersMethodconvertToDate
(String columnType, Object date)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/converters/MysqlDebeziumTimeConverter.java:291
↓ 2 callersMethodconvertToDecimal
Converts a string object for an expected JDBC type of {@link Types#DECIMAL}. @param column the column definition describing the {@code data} value; n
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlDefaultValueConverter.java:330
↓ 2 callersMethodconvertToJavaMap
Converts a {@link MapData} into Java {@link Map}, the keys and values of the Java map still holds objects of internal data structures.
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/util/MapDataUtil.java:35
↓ 2 callersMethodconvertToTime
(String columnType, Object time)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/converters/MysqlDebeziumTimeConverter.java:250
↓ 2 callersMethodconvertToVariant
(Object obj, VariantType variantType)
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/converter/CommonConverter.java:127
↓ 2 callersMethodcreate
Creates a new {@link OracleSourceConfig} for the given subtask {@code subtaskId}.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/config/OracleSourceConfigFactory.java:63
↓ 2 callersMethodcreateConfiguration
(List<String> tableNames)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlSnapshotSplitAssignerTest.java:598
↓ 2 callersMethodcreateConverter
Creates a runtime converter which is null safe.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/event/DebeziumEventDeserializationSchema.java:170
↓ 2 callersMethodcreateConverter
Creates a runtime converter which is null safe.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/RowDataTiKVEventDeserializationSchemaBase.java:115
↓ 2 callersMethodcreateDataSource
(Context context)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oracle/src/main/java/org/apache/flink/cdc/connectors/oracle/factory/OracleDataSourceFactory.java:67
↓ 2 callersMethodcreateDorisDataSink
(Configuration factoryConfiguration)
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:138
↓ 2 callersMethodcreateDorisDatabase
(String databaseName)
flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/MySqlToDorisE2eITCase.java:947
↓ 2 callersMethodcreateExecutor
(CommandLine commandLine)
flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/CliFrontend.java:86
↓ 2 callersMethodcreateFetchTask
(SourceSplitBase sourceSplitBase)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/PostgresDialect.java:227
↓ 2 callersMethodcreateFetchTaskContext
The task context used for fetch task to fetch data from external systems.
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/dialect/DataSourceDialect.java:82
↓ 2 callersMethodcreateFieldGetters
(Schema schema, ZoneId zoneId)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-hudi/src/main/java/org/apache/flink/cdc/connectors/hudi/sink/util/RowDataUtils.java:106
↓ 2 callersMethodcreateInitialOffset
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/offset/PostgresOffsetFactory.java:49
↓ 2 callersMethodcreateInitialOffset
()
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/offset/OffsetFactory.java:37
← previousnext →2,501–2,600 of 12,620, ranked by callers