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
↓ 6 callersMethodparseOnLineSchemaChanges
Whether to parse gh-ost utility generated schema change events. Defaults to false.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlSourceBuilder.java:301
↓ 6 callersMethodpassword
Password to use when connecting to the PostgreSQL database server.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/PostgreSQLSource.java:116
↓ 6 callersMethodpgConnection
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/PostgresReplicationConnection.java:470
↓ 6 callersMethodpollRecordsFromReader
( BinlogSplitReader reader, Predicate<SourceRecord> filter)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/debezium/reader/BinlogSplitReaderTest.java:1266
↓ 6 callersMethodpollSplitRecords
Reads records from MySQL. The method should return null when reaching the end of the split, the empty {@link Iterator} will be returned if the data of
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/reader/DebeziumReader.java:44
↓ 6 callersMethodport
Integer port number of the PostgreSQL database server.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/PostgreSQLSource.java:75
↓ 6 callersMethodproductDocOf
(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/table/MongoDBConnectorITCase.java:582
↓ 6 callersMethodquote
@link <a href="https://learn.microsoft.com/en-us/sql/t-sql/functions/quotename-transact-sql">QUOTENAME</a>
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/source/utils/SqlServerUtils.java:368
↓ 6 callersMethodquoteSchemaAndTable
(TableId tableId)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/utils/OracleUtils.java:238
↓ 6 callersMethodreplaceEvent
Creates a {@link DataChangeEvent} instance that describes the replace event.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/DataChangeEvent.java:143
↓ 6 callersMethodresolveSchemaEvolutionOptions
( List<String> includedSchemaEvolutionTypes, List<String> excludedSchemaEvolutionTypes)
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/ChangeEventUtils.java:60
↓ 6 callersMethodrestoreOriginalData
Restore original data fields from RecordData structure.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/SchemaUtils.java:94
↓ 6 callersMethodrowToSerializedString
(Object[] splitBoundary)
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/utils/SerializerUtils.java:35
↓ 6 callersMethodrunGenericComplexTypeSerializationTest
( JsonSerializationType serializationType, List<Event> eventsToSerialize,
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/test/java/org/apache/flink/cdc/connectors/kafka/sink/KafkaDataSinkITCase.java:709
↓ 6 callersMethodsameColumnsIgnoreCommentAndDefaultValue
Check if the columns of upstream schema is the same as the physical schema. <p>Note: Default value of column was ignored as it has no influence in {@
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:83
↓ 6 callersMethodsendOperatorEventToCoordinator
( OperatorID operator, SerializedValue<OperatorEvent> event)
flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/testutils/schema/TestingSchemaRegistryGateway.java:51
↓ 6 callersMethodserialize
(Input t)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonRecordSerializer.java:25
↓ 6 callersMethodserialize
(PendingSplitsState state)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/PendingSplitsStateSerializer.java:68
↓ 6 callersMethodsetComment
(String comment)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java:221
↓ 6 callersMethodsetDefaultValue
(String defaultValue)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java:191
↓ 6 callersMethodsetNullAt
(int ordinal)
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/writer/BinaryArrayWriter.java:106
↓ 6 callersMethodsetTimestampSec
(long timestampSec)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/offset/BinlogOffsetBuilder.java:55
↓ 6 callersMethodsetup
(boolean parallelismSnapshot)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/test/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerConnectorITCase.java:57
↓ 6 callersMethodsetup
(boolean parallelismSnapshot)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/test/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBRegexFilterITCase.java:50
↓ 6 callersMethodstart
Begin the token stream, including (if required) the tokenization of the input content. @return this object for easy method chaining; never null @thro
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/text/TokenStream.java:115
↓ 6 callersMethodsubmitJob
(List<Event> events)
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:597
↓ 6 callersMethodsubmitTestCase
( String database, String collection, boolean parallelismSnapshot)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/test/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBRegexFilterITCase.java:322
↓ 6 callersMethodtableExists
(String databaseName, String tableName)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseCatalog.java:85
↓ 6 callersMethodtableList
An optional list of regular expressions that match fully-qualified table identifiers for tables to be monitored; any table not included in the whiteli
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/PostgreSQLSource.java:102
↓ 6 callersMethodtestBackfillWhenWritingEvents
( boolean skipSnapshotBackfill, int fetchSize, int hookType, S
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/test/java/org/apache/flink/cdc/connectors/postgres/source/PostgresSourceITCase.java:684
↓ 6 callersMethodtestBackfillWhenWritingEvents
( boolean skipSnapshotBackfill, int fetchSize, int hookType, S
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/MySqlSourceITCase.java:728
↓ 6 callersMethodtestRemoveCollectionsOneByOne
( int parallelism, MongoDBTestUtils.FailoverType failoverType, MongoDBTest
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/test/java/org/apache/flink/cdc/connectors/mongodb/source/NewlyAddedTableITCase.java:516
↓ 6 callersMethodtestRemoveTablesOneByOne
( int parallelism, PostgresTestUtils.FailoverType failoverType, PostgresTe
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/test/java/org/apache/flink/cdc/connectors/postgres/source/NewlyAddedTableITCase.java:466
↓ 6 callersMethodtestRemoveTablesOneByOne
( int parallelism, FailoverType failoverType, FailoverPhase failoverPhase,
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/NewlyAddedTableITCase.java:583
↓ 6 callersMethodtestRemoveTablesOneByOne
( int parallelism, FailoverType failoverType, FailoverPhase failoverPhase,
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/test/java/org/apache/flink/cdc/connectors/oracle/source/NewlyAddedTableITCase.java:433
↓ 6 callersMethodtoCdcColumn
(Column dbzColumn)
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:510
↓ 6 callersMethodtoSchemalessSnapshotSplit
Casts this split into a {@link MySqlSchemalessSnapshotSplit}.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSnapshotSplit.java:124
↓ 6 callersMethodtoSchemalessSnapshotSplit
Casts this split into a {@link SchemalessSnapshotSplit}.
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SnapshotSplit.java:124
↓ 6 callersMethodtriggerFailover
( FailoverType type, JobID jobId, MiniCluster miniCluster, Runnable afterFailAction)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/test/java/org/apache/flink/cdc/connectors/oracle/testutils/OracleTestUtils.java:48
↓ 6 callersMethodtsOf
(String year, String month, String dayOfMonth)
flink-cdc-common/src/test/java/org/apache/flink/cdc/common/utils/SchemaMergingUtilsTest.java:1198
↓ 6 callersMethodtypeOrder
(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:280
↓ 6 callersMethodverifySerializeResult
(TableId expectTable, String expectRow, Record record)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/test/java/org/apache/flink/cdc/connectors/oceanbase/sink/OceanBaseEventSerializationSchemaTest.java:211
↓ 6 callersMethodversion
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/internal/MongoDBConnectorSourceTask.java:100
↓ 6 callersMethodwaitForLog
(String regex, int count, int timeoutSeconds)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/test/java/org/apache/flink/cdc/connectors/doris/sink/utils/DorisContainer.java:71
↓ 6 callersMethodwaitForSinkResult
(String sinkName, List<String> expected)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/test/java/org/apache/flink/cdc/connectors/postgres/PostgresTestBase.java:192
↓ 6 callersMethodwaitForSinkSize
(String sinkName, int expectedSize)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/test/java/org/apache/flink/cdc/connectors/postgres/PostgresTestBase.java:220
↓ 6 callersMethodwaitUntilSpecificEventCount
( List<ConsumerRecord<byte[], byte[]>> actualEvent, int expectedCount)
flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/MysqlToKafkaE2eITCase.java:350
↓ 6 callersMethodwithDatabaseName
(final String databaseName)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/testutils/MySqlContainer.java:162
↓ 6 callersMethodwithDurationAndBehavior
( OP operator, int numOutputs, Duration evolveDura
flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/testutils/operators/RegularEventOperatorTestHarness.java:159
↓ 6 callersMethodwithPassword
(final String password)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/testutils/MySqlContainer.java:174
↓ 6 callersMethodwithUsername
(final String username)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/testutils/MySqlContainer.java:168
↓ 6 callersMethodzTsOf
(String year, String month, String dayOfMonth)
flink-cdc-common/src/test/java/org/apache/flink/cdc/common/utils/SchemaMergingUtilsTest.java:1209
↓ 5 callersMethodadd
(T value)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/MySqlTestUtils.java:311
↓ 5 callersMethodaddToTransaction
Add a transaction to the transaction map if allowed. @param transactionId the unqiue transaction id @param row the LogMiner event row @param eventSup
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/io/debezium/connector/oracle/logminer/processor/AbstractLogMinerEventProcessor.java:987
↓ 5 callersMethodall
Returns a {@link ChunkRange} which represents a full table scan with unbounded 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:38
↓ 5 callersMethodallocateReuseBytes
Allocate bytes that is only for temporary usage, it should not be stored in somewhere else. Use a {@link ThreadLocal} to reuse bytes to avoid overhead
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySegmentUtils.java:76
↓ 5 callersMethodappendTwoDigitUnsignedInt
(int value)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/json/JsonStringFormatter.java:266
↓ 5 callersMethodasSnapshotSplitState
Casts this split state into a {@link SnapshotSplitState}.
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitState.java:40
↓ 5 callersMethodassertHistoryState
(TestingListState<String> historyState)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/test/java/org/apache/flink/cdc/connectors/oracle/OracleSourceTest.java:540
↓ 5 callersMethodassertRowsEquals
Asserts that actual rows match expected rows (order-insensitive).
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/test/java/org/apache/flink/cdc/connectors/postgres/source/SimilarTableNamesITCase.java:284
↓ 5 callersMethodbefore
()
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-hudi/src/test/java/org/apache/flink/cdc/connectors/hudi/sink/HudiSinkITCase.java:103
↓ 5 callersMethodbuilder
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/PostgreSQLSource.java:40
↓ 5 callersMethodcheckAssignedBinlogOffset
( StartupOptions startupOptions, BinlogOffset expectedOffset)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlBinlogSplitAssignerTest.java:69
↓ 5 callersMethodcheckResult
(TableId tableId, List<String> expectedRows)
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:612
↓ 5 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-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlSourceBuilder.java:127
↓ 5 callersMethodclear
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/test/java/org/apache/flink/cdc/connectors/oracle/OracleSourceTest.java:798
↓ 5 callersMethodcollectRows
Collects specified number of rows from the iterator.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/test/java/org/apache/flink/cdc/connectors/postgres/source/SimilarTableNamesITCase.java:273
↓ 5 callersMethodcollectionSchema
(TableId tableId)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/dialect/MongoDBDialect.java:115
↓ 5 callersMethodcompareSplit
(Object[] leftSplit, Object[] rightSplit)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/SplitKeyUtils.java:225
↓ 5 callersMethodcompareSplit
(Object[] leftSplit, Object[] rightSplit)
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/utils/SplitKeyUtils.java:217
↓ 5 callersMethodcompareTo
This method is inspired by {@link io.debezium.relational.history.HistoryRecordComparator}.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/offset/BinlogOffset.java:171
↓ 5 callersMethodcomposeAndExecute
( List<List<Event>> customSourceEvents, Configuration pipelineConfig)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/test/java/org/apache/flink/cdc/connectors/fluss/FlussPipelineITCase.java:674
↓ 5 callersMethodconvert
( org.apache.paimon.memory.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:410
↓ 5 callersMethodconvert
(BsonValue docObj)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBConnectorDeserializationSchema.java:218
↓ 5 callersMethodconvertCalciteType
( RelDataTypeFactory typeFactory, DataType dataType)
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/typeutils/CalciteDataTypeConverter.java:221
↓ 5 callersMethodcreateFieldGetters
create a list of {@link RecordData.FieldGetter} for {@link PaimonWriter}.
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:68
↓ 5 callersMethodcreateReadOpValue
(SourceRecord binlogRecord, String beforeOrAfter)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/RecordUtils.java:213
↓ 5 callersMethodcreateRecordEmitterWithTransactionConfig
Helper method to create a MySqlRecordEmitter with configurable transaction metadata events.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/reader/MySqlRecordEmitterTest.java:359
↓ 5 callersMethodcreateSourceEvents
()
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/test/java/org/apache/flink/cdc/connectors/kafka/sink/KafkaDataSinkITCase.java:157
↓ 5 callersMethodcreateTableSource
(Map<String, String> options)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/test/java/org/apache/flink/cdc/connectors/vitess/table/VitessTableFactoryTest.java:174
↓ 5 callersMethodcreateTableSpecificConfig
(TableId tableId)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-hudi/src/main/java/org/apache/flink/cdc/connectors/hudi/sink/coordinator/MultiTableStreamWriteOperatorCoordinator.java:954
↓ 5 callersMethoddecodeTimestamp
(BsonDocument resumeToken)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/utils/ResumeTokenUtils.java:37
↓ 5 callersMethoddeserializeValues
(List<ConsumerRecord<byte[], byte[]>> records)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/test/java/org/apache/flink/cdc/connectors/kafka/sink/KafkaDataSinkITCase.java:672
↓ 5 callersMethoddiscoverDataCollections
(JdbcSourceConfig sourceConfig)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/PostgresDialect.java:176
↓ 5 callersMethoddrain
(TestSourceContext<T> sourceContext, int expectedRecordCount)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/test/java/org/apache/flink/cdc/connectors/vitess/VitessSourceTest.java:154
↓ 5 callersMethoddropColumn
equals to run a sql like: 'alter table table_name drop columns col_name1[, col_name2...];'.
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/utils/SchemaEvolutionUtils.java:199
↓ 5 callersMethodenterStreamReading
()
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/metrics/SourceEnumeratorMetrics.java:83
↓ 5 callersMethodequals
(Object o)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonRowDataSerializationSchema.java:134
↓ 5 callersMethodequals
(Object o)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-hudi/src/main/java/org/apache/flink/cdc/connectors/hudi/sink/bucket/BucketWrapperFlushEvent.java:52
↓ 5 callersMethodequals
(Object o)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupOptions.java:121
↓ 5 callersMethodexecuteAlterAndProvideExpected
The final schema of table products is as follows. <pre> CREATE TABLE products ( id INTEGER NOT NULL AUTO_INCREMENT PRIMARY KEY, name VARCHAR(255)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/test/java/org/apache/flink/cdc/connectors/mysql/source/MySqlPipelineITCase.java:1945
↓ 5 callersMethodexecuteCommand
(String command)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/test/java/org/apache/flink/cdc/connectors/mongodb/LegacyMongoDBContainer.java:104
↓ 5 callersMethodexecuteCommandFileInDatabase
Executes a mongo command file, specify a database name.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/test/java/org/apache/flink/cdc/connectors/mongodb/utils/MongoDBContainer.java:157
↓ 5 callersMethodextractBsonDocument
(Struct value, Schema valueSchema, String fieldName)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBConnectorDeserializationSchema.java:177
↓ 5 callersMethodfetchResults
(Iterator<T> iter, int size)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oracle/src/test/java/org/apache/flink/cdc/connectors/oracle/source/OraclePipelineITCase.java:1796
↓ 5 callersMethodfetchResultsExcept
(Iterator<T> iter, int size, T sideEvent)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/test/java/org/apache/flink/cdc/connectors/mysql/source/MySqlPipelineITCase.java:673
↓ 5 callersMethodfilterGtidSet
Apply the include/exclude GTID source filters to the current {@link #source() GTID set} and merge them onto the currently available GTID set from a My
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlStreamingChangeEventSource.java:1401
↓ 5 callersMethodfirstSegmentAndOffset
(int segSize)
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryStringData.java:765
↓ 5 callersMethodformatTime
(LocalTime localTime)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/converters/MysqlDebeziumTimeConverter.java:283
↓ 5 callersMethodfromDbzColumn
Returns a corresponding Flink data type from a debezium {@link Column}.
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/utils/MySqlTypeUtils.java:116
← previousnext →1,301–1,400 of 12,620, ranked by callers