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

↓ 4 callersMethodmicrosToInstant

(long timestamp)

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/variant/BinaryVariant.java:378

↓ 4 callersMethodmixH1

(int h1, int k1)

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/MurmurHashUtils.java:149

↓ 4 callersMethodmixK1

(int k1)

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/MurmurHashUtils.java:142

↓ 4 callersMethodnewBuilder

( List<String> firstRoundListenTables, Integer firstRoundFetchSize,

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

↓ 4 callersMethodnewOffset

(Map<String, String> offset)

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

↓ 4 callersMethodnewPostgresValueConverterBuilder

Create a new PostgresVauleConverterBuilder instance and offer type registry for JDBC connection. It is created in this package because some method

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

↓ 4 callersMethodnotifyCheckpointComplete

Notifies the listener that the checkpoint with the given {@code checkpointId} completed and was committed. @see CheckpointListener#notifyCheckpointCo

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

↓ 4 callersMethodnotifyFlushSuccess

send {@link FlushSuccessEvent} to Schema Registry.

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/sink/SchemaEvolutionClient.java:62

↓ 4 callersMethodof

(Function<K, V> creator)

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/ThreadLocalCache.java:79

↓ 4 callersMethodof

Create a {@link FlinkSourceProvider} from a {@link Source}.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/source/FlinkSourceProvider.java:35

↓ 4 callersMethodof

(SourceRecord dataRecord)

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

↓ 4 callersMethodof

Returns a {@link ChunkRange} with the given chunk start and chunk end.

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

↓ 4 callersMethodof

( TableId tableId, Schema sourceSchema, Schema preTransformedSchema)

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

↓ 4 callersMethodofStart

(final Cdcpb.Event.Row row)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/TiKVRichParallelSourceFunction.java:381

↓ 4 callersMethodopenJdbcConnection

(JdbcSourceConfig sourceConfig)

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

↓ 4 callersMethodparseColumnNameList

(SqlNode sqlNode)

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

↓ 4 callersMethodparseProjectionExpression

(String projection)

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

↓ 4 callersMethodpassword

Password to use when connecting to the MySQL database server.

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlSourceBuilder.java:94

↓ 4 callersMethodpassword

Password to use when connecting to the Oracle database server.

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

↓ 4 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-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/ObjectUtils.java:30

↓ 4 callersMethodplus

(byte lhs, byte rhs)

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/functions/impl/ArithmeticFunctions.java:27

↓ 4 callersMethodpollAwaitTimeMillis

poll.await.time.ms The amount of time to wait before checking for new results on the change stream. Default: 1000

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/MongoDBSource.java:169

↓ 4 callersMethodport

()

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

↓ 4 callersMethodport

Integer port number of the MySQL database server.

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlSourceBuilder.java:63

↓ 4 callersMethodprintUnknownDateClassLogs

(String type, Object value)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/converters/MysqlDebeziumTimeConverter.java:338

↓ 4 callersMethodprocessDataChangeEvent

( DataSinkOperatorAdapter dataSinkWriterOperator, DataChangeEvent event)

flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/operators/sink/DataSinkOperatorWithSchemaEvolveTest.java:110

↓ 4 callersMethodprocessElement

(StreamRecord<Event> element)

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/RegularPrePartitionOperator.java:85

↓ 4 callersMethodprocessSchemaChangeEvent

( DataSinkOperatorAdapter dataSinkWriterOperator, RegularEventOperatorTestHarness<Data

flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/operators/sink/DataSinkOperatorWithSchemaEvolveTest.java:81

↓ 4 callersMethodproject

(Object[] rowData, TransformContext context)

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformProjectionProcessor.java:80

↓ 4 callersMethodquote

(String dbOrTableName)

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

↓ 4 callersMethodquoteForMinMax

(Column column)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/utils/PostgresQueryUtils.java:241

↓ 4 callersMethodquotedColumnIdString

(String columnName)

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

↓ 4 callersMethodread

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/com/github/shyiko/mysql/binlog/io/BufferedSocketInputStream.java:52

↓ 4 callersMethodreadIntegers

(ByteArrayInputStream inputStream)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/TableMapEventMetadataDeserializer.java:146

↓ 4 callersMethodregisterHistory

(String engineName, Collection<TableChange> engineHistory)

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

↓ 4 callersMethodremoveQuotes

Removes leading and trailing double quote characters from the provided string. Oracle table and column names are inherently stored in upper-case;

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oracle/src/main/java/org/apache/flink/cdc/connectors/oracle/utils/OracleSchemaUtils.java:61

↓ 4 callersMethodrequestBinlogSplitUpdateIfNeed

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/enumerator/MySqlSourceEnumerator.java:280

↓ 4 callersMethodrunGenericAncientDateAndTimeTest

( MySqlContainer container, UniqueDatabase database, boolean enableTimeAdj

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

↓ 4 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/ElasticsearchDataSinkITCaseTest.java:191

↓ 4 callersMethodschemaChangeEvent

(SchemaChangeEvent event)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/dispatcher/EventDispatcherImpl.java:312

↓ 4 callersMethodserialize

(PendingSplitsState state)

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

↓ 4 callersMethodserialize

(TableId record, DataOutputView target)

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/TableIdSerializer.java:67

↓ 4 callersMethodserialize

(Schema record, DataOutputView target)

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/schema/SchemaSerializer.java:83

↓ 4 callersMethodserializeAndDeserializeSplit

(MySqlSplit split)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplitSerializerTest.java:139

↓ 4 callersMethodserializeBinlogOffset

(BinlogOffset binlogOffset)

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

↓ 4 callersMethodsetColumns

Set new columns.

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

↓ 4 callersMethodsetFirstRoundInitTables

(List<String> firstRoundInitTables)

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

↓ 4 callersMethodsetFloat

(int pos, float value)

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

↓ 4 callersMethodsetHighWatermark

(@Nullable BinlogOffset highWatermark)

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

↓ 4 callersMethodsetLsnCommitCheckpointsDelay

The lsn commit checkpoints delay for Postgres.

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/config/PostgresSourceConfigFactory.java:188

↓ 4 callersMethodsetNullAt

Set null to this field.

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

↓ 4 callersMethodsetTimestamp

(int pos, TimestampData value, int precision)

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

↓ 4 callersMethodsetup

(boolean incrementalSnapshot)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/test/java/org/apache/flink/cdc/connectors/db2/table/Db2ConnectorITCase.java:79

↓ 4 callersMethodsetup

(boolean parallelismSnapshot)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/test/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBConnectorITCase.java:67

↓ 4 callersMethodsetupHarness

( DataSinkOperatorAdapter dataSinkWriterOperator)

flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/operators/sink/DataSinkOperatorWithSchemaEvolveTest.java:67

↓ 4 callersMethodsetupSource

(DebeziumSourceFunction<T> source)

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

↓ 4 callersMethodsetupSource

(DebeziumSourceFunction<T> source)

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

↓ 4 callersMethodshardKeysToRowType

(BsonDocument shardKeys)

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

↓ 4 callersMethodshoppingCartDoc

(long productNo)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/test/java/org/apache/flink/cdc/connectors/mongodb/source/reader/MongoDBStreamSplitReaderTest.java:200

↓ 4 callersMethodshouldUseCatalogBeforeSchema

Check whether the catalog should be used before the schema. @param tableId the table id @return false if catalog is not defined but the schema is def

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

↓ 4 callersMethodskipSnapshotBackfill

Whether to skip backfill in snapshot reading phase. If backfill is skipped, changes on captured tables during snapshot phase will be consumed late

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

↓ 4 callersMethodsleepMs

(long millis)

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

↓ 4 callersMethodsleepMs

(long millis)

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

↓ 4 callersMethodsleepMs

(long millis)

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

↓ 4 callersMethodsmallestValueOfArray

(BsonArray bsonArray)

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

↓ 4 callersMethodsnapshotConfiguration

()

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/MapSerializer.java:202

↓ 4 callersMethodsortFinishedSplitInfos

Sorts the list of FinishedSnapshotSplitInfo by splitStart in ascending order. This is required for binary search to work correctly. Handles specia

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

↓ 4 callersMethodsplitMetaGroupSize

The group size of split meta, if the meta size exceeds the group size, the meta will be will be divided into multiple groups.

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/Db2SourceBuilder.java:117

↓ 4 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-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/PostgresSourceBuilder.java:157

↓ 4 callersMethodsplitSizeMB

scan.incremental.snapshot.chunk.size.mb The chunk size mb of incremental snapshot. Default: 64mb.

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/MongoDBSourceBuilder.java:177

↓ 4 callersMethodstart

(Map<String, String> props)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/internal/MongoDBConnectorSourceTask.java:111

↓ 4 callersMethodstart

()

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaRegistry.java:125

↓ 4 callersMethodstopChangeEventSource

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/reader/StoppableChangeEventSourceContext.java:35

↓ 4 callersMethodstopCurrentTask

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/reader/SnapshotSplitReader.java:440

↓ 4 callersMethodstoreOnlyCapturedTables

()

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

↓ 4 callersMethodstringOption

(String key, Description description)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-hudi/src/main/java/org/apache/flink/cdc/connectors/hudi/sink/HudiConfig.java:35

↓ 4 callersMethodsubstitute

(String key, String value)

flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/specs/SubmitStep.java:33

↓ 4 callersMethodsubstring

(String str, int beginIndex)

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/functions/impl/StringFunctions.java:84

↓ 4 callersMethodtestAccessCommonTypesSchema

(UniqueDatabase database, boolean tinyint1IsBit)

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

↓ 4 callersMethodtestAddNewTable

(TestParam testParam, int parallelism)

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

↓ 4 callersMethodtestBackfillWhenWritingEvents

( boolean skipSnapshotBackfill, int fetchSize, int hookType)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/test/java/org/apache/flink/cdc/connectors/sqlserver/source/SqlServerSourceITCase.java:326

↓ 4 callersMethodtestFromUnixTimeTransformWithTimeZone

( String timeZone, Long seconds, String unixTimeStr)

flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/operators/transform/PostTransformOperatorTest.java:1043

↓ 4 callersMethodtestJsonDataType

(UniqueDatabase database, Boolean useLegacyJsonFormat)

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

↓ 4 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/MongoDBSnapshotSplitReaderTest.java:115

↓ 4 callersMethodtimestampDiff

( String timeIntervalUnit, Instant fromTimestamp, String fromTimezone,

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/DateTimeUtils.java:205

↓ 4 callersMethodtimestampDiff

( String timeIntervalUnit, LocalDateTime fromTimestamp, LocalDateTime toTi

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

↓ 4 callersMethodtoBinaryMap

(MapData from)

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/MapDataSerializer.java:132

↓ 4 callersMethodtoBytes

Converts this {@link StringData} object to a UTF-8 byte array. Note: The returned byte array may be reused.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/StringData.java:33

↓ 4 callersMethodtoCdcTableId

(TableId dbzTableId)

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

↓ 4 callersMethodtoDbzTableId

(TableId tableId)

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

↓ 4 callersMethodtoDocument

()

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

↓ 4 callersMethodtoFlussType

( org.apache.flink.cdc.common.types.DataType flinkDataType)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/utils/FlussConversions.java:109

↓ 4 callersMethodtoInstant

(String ts)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-postgres/src/test/java/org/apache/flink/cdc/connectors/postgres/source/PostgresFullTypesITCase.java:1125

↓ 4 callersMethodtoJavaString

(BsonValue bsonValue)

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

↓ 4 callersMethodtoPaimonDataType

Convert Flink CDC DataType to Paimon DataType. @param dataType Flink CDC DataType @return Paimon DataType

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/utils/TypeUtils.java:37

↓ 4 callersMethodtoUnscaledLong

Returns a long describing the unscaled value of this {@link DecimalData}. @throws ArithmeticException if this {@link DecimalData} does not exa

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

↓ 4 callersMethodtransformSchemaChangeEvent

This function determines if the given schema change event {@code event} should be sent to downstream based on if the given transform rule has asterisk

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/SchemaUtils.java:234

↓ 4 callersMethodtranslate

( SinkDef sinkDef, DataStream<Event> input, DataSink dataSink,

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/translator/DataSinkTranslator.java:82

↓ 4 callersMethodtranslateRegular

( DataStream<Event> input, int parallelism, MetadataApplier metadataApplie

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/translator/SchemaOperatorTranslator.java:60

↓ 4 callersMethodtreatTinyInt1AsBoolean

(boolean treatTinyInt1AsBoolean)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/config/MySqlSourceConfigFactory.java:330

← previous next →1,801–1,900 of 12,620, ranked by callers