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
↓ 4 callersMethodtriggerSavepointWithRetry
(JobClient jobClient, String savepointDirectory)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/test/java/org/apache/flink/cdc/connectors/postgres/source/NewlyAddedTableITCase.java:896
↓ 4 callersMethodtriggerSavepointWithRetry
(JobClient jobClient, String savepointDirectory)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/test/java/org/apache/flink/cdc/connectors/oracle/source/NewlyAddedTableITCase.java:831
↓ 4 callersMethodtrim
(String symbol, String target, String str)
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/functions/impl/StringFunctions.java:39
↓ 4 callersMethoduniversalCompares
(Object lhs, Object rhs)
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/functions/impl/ComparisonFunctions.java:30
↓ 4 callersMethodupdateAndVerifyTableChange
( TableId tableId, ObjectPath objectPath, ResolvedSchema newSchema)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-hudi/src/main/java/org/apache/flink/cdc/connectors/hudi/sink/HudiMetadataApplier.java:552
↓ 4 callersMethodusername
Name of the MySQL database 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:88
↓ 4 callersMethodvalidate
(RowData rowData, RowKind rowKind)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/table/RowDataDebeziumDeserializeSchema.java:69
↓ 4 callersMethodvalidateArray
(String contextName, JsonNode jsonNode)
flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/parser/YamlPipelineDefinitionParser.java:493
↓ 4 callersMethodvalidateJsonNodeKeys
( String contextName, JsonNode jsonNode, List<String> requiredKeys,
flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/parser/YamlPipelineDefinitionParser.java:451
↓ 4 callersMethodverifySchemaChangeEvent
(TableId tableId, FlussEvent flussEvent)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/test/java/org/apache/flink/cdc/connectors/fluss/sink/FlussEventSerializationSchemaTest.java:300
↓ 4 callersMethodwaitForSinkSize
(String sinkName, int expectedSize)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/test/java/org/apache/flink/cdc/connectors/db2/table/Db2ConnectorITCase.java:476
↓ 4 callersMethodwaitForSnapshotStarted
(String sinkName)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/test/java/org/apache/flink/cdc/connectors/sqlserver/source/SqlServerSourceTestBase.java:191
↓ 4 callersMethodwithPassword
(String password)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oracle/src/test/java/org/testcontainers/containers/OracleContainer.java:176
↓ 4 callersMethodwrapExceptionToHiddenSensitiveData
This method wraps a MarkedYAMLException to hide sensitive data in its message. Before using this method, an exception message might include sensitive
flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/utils/YamlParserUtils.java:246
↓ 4 callersMethodwriteSegmentsToVarLenPart
( int pos, MemorySegment[] segments, int offset, int size)
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/writer/AbstractBinaryWriter.java:274
↓ 4 callersMethodwriteShort
(int pos, short value)
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/writer/BinaryArrayWriter.java:174
↓ 4 callersMethodwriteValueAsString
(Object object)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/sink/OceanBaseRowConvert.java:171
↓ 3 callersMethodaddCollector
( StreamExecutionEnvironment env, DataStream<T> stream)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/SpecificStartingOffsetITCase.java:490
↓ 3 callersMethodaddColumnComment
(String columnName, @Nullable String comment)
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/AlterColumnTypeEvent.java:74
↓ 3 callersMethodaddDefaultSettings
( JdbcConfiguration configuration, String connectionUsage)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/PostgresConnection.java:226
↓ 3 callersMethodaddFinishedSplit
(String finishedSplitId)
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/metrics/SourceEnumeratorMetrics.java:236
↓ 3 callersMethodaddKey
(String key)
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/variant/BinaryVariantInternalBuilder.java:310
↓ 3 callersMethodaddNewSplit
(String newSplitId)
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/metrics/SourceEnumeratorMetrics.java:165
↓ 3 callersMethodaddSplits
(List<MySqlSplit> splits)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/reader/MySqlSourceReader.java:215
↓ 3 callersMethodaddSplits
(List<SourceSplitBase> splits)
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/IncrementalSourceReader.java:246
↓ 3 callersMethodaddSplits
Adds a set of splits to this assigner. This happens for example when some split processing failed and the splits need to be re-added.
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/SplitAssigner.java:79
↓ 3 callersMethodappendBoolean
(boolean b)
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/variant/BinaryVariantInternalBuilder.java:184
↓ 3 callersMethodapplyWithOption
( ConfigOption<?> option, BiFunction<String, Boolean, Optional<T>> applier)
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/Configuration.java:243
↓ 3 callersMethodasLogSequenceNumber
@return PostgreSQL JDBC driver representation of position in the write-ahead log stream
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/Lsn.java:104
↓ 3 callersMethodasSnapshotSplitState
Casts this split state into a {@link MySqlSnapshotSplitState}.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplitState.java:40
↓ 3 callersMethodassertInfosWithBinaryPrimaryKeyAreEqual
( Function<FinishedSnapshotSplitInfo, R> function)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/split/FinishedSnapshotSplitInfoTest.java:45
↓ 3 callersMethodassertInfosWithBinaryPrimaryKeyAreEqual
( Function<FinishedSnapshotSplitInfo, R> function)
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/test/java/org/apache/flink/cdc/connectors/base/source/meta/split/FinishedSnapshotSplitInfoTest.java:46
↓ 3 callersMethodassertJdbcUrl
(String expected, String actual)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/debezium/DebeziumUtilsTest.java:86
↓ 3 callersMethodassertThatRecordData
( RecordData recordData)
flink-cdc-common/src/test/java/org/apache/flink/cdc/common/testutils/assertions/RecordDataAssert.java:29
↓ 3 callersMethodassignUnboundedChunkFirst
Whether the {@link Db2IncrementalSource} should assign the unbounded chunks first or not during snapshot reading phase.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/Db2SourceBuilder.java:239
↓ 3 callersMethodbefore
()
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-postgres/src/test/java/org/apache/flink/cdc/connectors/postgres/source/PostgresPipelineITCase.java:104
↓ 3 callersMethodbinOf
(String str)
flink-cdc-common/src/test/java/org/apache/flink/cdc/common/utils/SchemaMergingUtilsTest.java:1225
↓ 3 callersMethodbsonTimestampFromEpochMillis
(long epochMillis)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/utils/MongoRecordUtils.java:128
↓ 3 callersMethodbuild
()
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchSink.java:119
↓ 3 callersMethodbuildMySqlConfigFile
(String content)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/MySqlValidatorTest.java:199
↓ 3 callersMethodbuilder
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/OracleSource.java:39
↓ 3 callersMethodbuilder
Get a MongoDBSourceBuilder to build a {@link MongoDBSource}. @return a MongoDB parallel source builder.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/MongoDBSource.java:83
↓ 3 callersMethodbyCode
(int code)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/ColumnType.java:95
↓ 3 callersMethodbyteArrayEquals
(byte[] left, byte[] right, int length)
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/binary/BinaryRecordDataDataUtil.java:42
↓ 3 callersMethodcalculateFixLengthPartSize
It store real value when type is primitive. It store the length and offset of variable-length part when type is string, map, etc.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryArrayData.java:120
↓ 3 callersMethodcalculateHeaderInBytes
Calculates the size of the header in bytes for an array with the specified number of fields. <p>The header consists of: <ul> <li>4 bytes to store
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryArrayData.java:112
↓ 3 callersMethodcanAssignNextSplit
()
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/IncrementalSourceSplitReader.java:213
↓ 3 callersMethodcastParam
(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:246
↓ 3 callersMethodcheckAsyncException
This method should only be invoked in the mailbox thread since the counter is not volatile. Logic needs to be invoked by write AND flush since we supp
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/v2/FlussSinkWriter.java:247
↓ 3 callersMethodcheckDecimal
(BigDecimal d, int maxPrecision)
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/variant/BinaryVariantUtil.java:437
↓ 3 callersMethodcheckReadException
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/reader/SnapshotSplitReader.java:384
↓ 3 callersMethodcheckReadException
()
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/external/IncrementalSourceScanFetcher.java:202
↓ 3 callersMethodclear
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/reader/MySqlSourceReaderTest.java:116
↓ 3 callersMethodclose
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/reader/SnapshotSplitReader.java:415
↓ 3 callersMethodclose
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlSnapshotSplitAssigner.java:513
↓ 3 callersMethodcloseResourcesAndWaitForJobTermination
Properly closes resources and waits for job termination.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/test/java/org/apache/flink/cdc/connectors/postgres/source/SimilarTableNamesITCase.java:326
↓ 3 callersMethodcoerceObject
( String timezone, Object originalField, DataType originalType,
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/SchemaMergingUtils.java:487
↓ 3 callersMethodcoerceToTimestamp
(Object object, String timezone)
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/SchemaMergingUtils.java:796
↓ 3 callersMethodcollectionNames
( MongoClient mongoClient, List<String> databaseNames, Predicate<String> c
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/utils/CollectionDiscoveryUtils.java:70
↓ 3 callersMethodcolumnWithName
(String name)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/LegacyMySqlSourceTest.java:1360
↓ 3 callersMethodcommitMessage
( PostgresPartition partition, PostgresOffsetContext offsetContext, final Lsn lsn)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/PostgresStreamingChangeEventSource.java:421
↓ 3 callersMethodcommitTransaction
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/io/debezium/connector/sqlserver/SqlServerStreamingChangeEventSource.java:465
↓ 3 callersMethodcompareTo
(final RowKeyWithTs that)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/TiKVRichParallelSourceFunction.java:355
↓ 3 callersMethodcompressOptionOf
(String compressAlgo)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/utils/MaxComputeUtils.java:130
↓ 3 callersMethodconnectTimeout
The maximum time that the connector should wait after trying to connect to the MySQL database server before timing out.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlSourceBuilder.java:178
↓ 3 callersMethodconnectionString
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlConnection.java:558
↓ 3 callersMethodconstructInsertEvents
( TableId tableId, String[] fieldNames, String[] pkFieldNames,
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/test/java/org/apache/flink/cdc/connectors/fluss/sink/v2/FlussSinkITCase.java:564
↓ 3 callersMethodconstructSourceSplitSerializer
()
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/test/java/org/apache/flink/cdc/connectors/base/source/assigner/state/PendingSplitsStateSerializerTest.java:110
↓ 3 callersMethodconstructTableSchema
()
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/test/java/org/apache/flink/cdc/connectors/base/source/assigner/state/PendingSplitsStateSerializerTest.java:174
↓ 3 callersMethodconvertArrayData
Converts a CDC {@link ArrayData} to Flink SQL {@link org.apache.flink.table.data.ArrayData}. <p>This method recursively converts each element in the
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/utils/RecordDataConverter.java:171
↓ 3 callersMethodconvertCalciteRelDataTypeToDataType
(RelDataType relDataType)
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/typeutils/CalciteDataTypeConverter.java:297
↓ 3 callersMethodconvertElement
Converts a single element from CDC {@link ArrayData} to Flink SQL format. <p>This method is similar to {@link #convertField} but operates on array el
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/utils/RecordDataConverter.java:234
↓ 3 callersMethodconvertField
( DeserializationRuntimeConverter fieldConverter, Object fieldValue, Schema fieldSchema)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/event/DebeziumEventDeserializationSchema.java:457
↓ 3 callersMethodconvertMapData
Converts a CDC {@link MapData} to Flink SQL {@link org.apache.flink.table.data.MapData}. <p>This method converts both keys and values in the map acco
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/utils/RecordDataConverter.java:198
↓ 3 callersMethodconvertRowData
Converts a CDC {@link RecordData} to Flink SQL {@link RowData}. @param recordData the CDC record data to convert @param rowType the row type schema d
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/utils/RecordDataConverter.java:65
↓ 3 callersMethodconvertSegments
( MemorySegment[] segments, int offset, int sizeInBytes,
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:389
↓ 3 callersMethodconvertTableListToRegExpPattern
Currently, The supported regular syntax is not exactly the same in {@link Selectors}. <p>The main discrepancies are : <p>1) {@link Selectors} use {@
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/route/TableIdRouter.java:78
↓ 3 callersMethodconvertToList
(Object obj, ArrayType arrayType)
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/converter/CommonConverter.java:369
↓ 3 callersMethodconvertToString
(Object o)
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/ConfigurationUtils.java:143
↓ 3 callersMethodconvertToTimestamp
(String columnType, Object timestamp)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/converters/MysqlDebeziumTimeConverter.java:221
↓ 3 callersMethodcopyToView
Copy bytes of segments to output view. <p>Note: It just copies the data in, not include the length. @param segments source segments @param offset of
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySegmentUtils.java:212
↓ 3 callersMethodcreate
Creates a new {@link MongoDBSourceConfig} for the given subtask {@code subtaskId}.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfigFactory.java:284
↓ 3 callersMethodcreate
Creates a {@link TypeSerializer} for internal data structures of the given {@link DataType}.
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/InternalSerializers.java:43
↓ 3 callersMethodcreateAssigner
( List<String> tableNames, @Nullable SnapshotPendingSplitsState state)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlSnapshotSplitAssignerTest.java:578
↓ 3 callersMethodcreateConfigFactory
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/test/java/org/apache/flink/cdc/connectors/postgres/source/reader/PostgresSourceReaderTest.java:341
↓ 3 callersMethodcreateConverter
Creates a runtime converter which is null safe.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBConnectorDeserializationSchema.java:222
↓ 3 callersMethodcreateElementGetter
Creates an accessor for getting elements in an internal array data structure at the given position. <p>This method is a modified version of {@link Ar
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/utils/TypeConvertUtils.java:370
↓ 3 callersMethodcreateEmpty
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/converters/OracleGeometry.java:101
↓ 3 callersMethodcreateFieldGetter
Creates an accessor for getting elements in an internal RecordData structure at the given position. <p>This method is a modified version of {@link Re
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/utils/TypeConvertUtils.java:231
↓ 3 callersMethodcreateNullableExternalConverter
( DataType type, ZoneId pipelineZoneId)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink/DorisRowConverter.java:54
↓ 3 callersMethodcreatePreparedStatementProxy
(Map<String, Object> invocationDetails)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/utils/StatementUtilsTest.java:97
↓ 3 callersMethodcreateReader
(final int lsnCommitCheckpointsDelay)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/test/java/org/apache/flink/cdc/connectors/postgres/source/reader/PostgresSourceReaderTest.java:311
↓ 3 callersMethodcreateReplicationSlot
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/PostgresReplicationConnection.java:429
↓ 3 callersMethodcreateSerializationSchema
Creates a configured instance of {@link SerializationSchema} to convert {@link Event} to byte.
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/sink/KeySerializationFactory.java:45
↓ 3 callersMethodcreateSnapshotSplit
( JdbcConnection jdbc, MySqlPartition partition, TableId tableId,
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlChunkSplitter.java:361
↓ 3 callersMethodcreateSourceDDL
Creates the source DDL for the given table name pattern.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/test/java/org/apache/flink/cdc/connectors/postgres/source/SimilarTableNamesITCase.java:238
↓ 3 callersMethodcreateTableEnv
Creates and configures the StreamTableEnvironment.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/test/java/org/apache/flink/cdc/connectors/postgres/source/SimilarTableNamesITCase.java:230
↓ 3 callersMethodcreateTestEvents
Creates a list of test events that simulate inserting rows into a table. @param tableId the identifier of the table. @return a list of events simulat
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/test/java/org/apache/flink/cdc/connectors/elasticsearch/sink/utils/ElasticsearchTestUtils.java:50
↓ 3 callersMethodcreateTestEventsWithAddColumn
Creates a list of test events that simulate adding a column and then inserting rows into a table. @param tableId the identifier of the table. @return
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/test/java/org/apache/flink/cdc/connectors/elasticsearch/sink/utils/ElasticsearchTestUtils.java:157
↓ 3 callersMethodcreateTestEventsWithDelete
Creates a list of test events that simulate inserting and then deleting a row from a table. @param tableId the identifier of the table. @return a lis
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/test/java/org/apache/flink/cdc/connectors/elasticsearch/sink/utils/ElasticsearchTestUtils.java:120
← previousnext →1,901–2,000 of 12,620, ranked by callers