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

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/TimeData.java:39

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/test/java/org/apache/flink/cdc/connectors/vitess/table/VitessTableFactoryTest.java:165

↓ 5 callersMethodgetAllRequiredOptions

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/test/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSourceFactoryTest.java:451

↓ 5 callersMethodgetByteOneSegment

(int i)

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryStringData.java:716

↓ 5 callersMethodgetColumn

()

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/parser/CustomColumnDefinitionParserListener.java:78

↓ 5 callersMethodgetConfig

()

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/PipelineDef.java:121

↓ 5 callersMethodgetConfigFactory

( String databaseName, String[] captureTables, int splitSize)

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

↓ 5 callersMethodgetConnection

(String databaseName)

flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/specs/FlinkPipelineSpecsITCase.java:74

↓ 5 callersMethodgetConnection

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/fetch/PostgresSourceFetchTaskContext.java:352

↓ 5 callersMethodgetCreateTableStatement

( Map<String, String> otherOptions, String... captureTableNames)

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

↓ 5 callersMethodgetDataInSnapshotScan

( String[] changingDataSql, String schemaName, String tableName,

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/test/java/org/apache/flink/cdc/connectors/postgres/source/fetch/PostgresScanFetchTaskTest.java:286

↓ 5 callersMethodgetDatabaseList

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java:130

↓ 5 callersMethodgetDebeziumStarted

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/DebeziumSourceFunction.java:567

↓ 5 callersMethodgetElasticsearchDataSinkFactory

()

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/test/java/org/apache/flink/cdc/connectors/elasticsearch/sink/ElasticsearchDataSinkFactoryTest.java:173

↓ 5 callersMethodgetFilter

()

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformRule.java:71

↓ 5 callersMethodgetFinishedSplitInfos

Gets the finished splits' information. This is useful metadata to generate a binlog split that considering finished snapshot splits.

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlSplitAssigner.java:64

↓ 5 callersMethodgetFinishedUnackedSplits

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/reader/MySqlSourceReader.java:529

↓ 5 callersMethodgetHost

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/polardbx/PolardbxSourceTestBase.java:79

↓ 5 callersMethodgetHostMapping

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/utils/UriHostMapping.java:60

↓ 5 callersMethodgetJdbcConnection

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/test/java/org/apache/flink/cdc/connectors/oceanbase/OceanBaseSourceTestBase.java:89

↓ 5 callersMethodgetJdbcConnection

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/polardbx/PolardbxSourceTestBase.java:108

↓ 5 callersMethodgetJdbcConnectionAsDBA

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/test/java/org/apache/flink/cdc/connectors/oracle/source/OracleSourceTestBase.java:126

↓ 5 callersMethodgetJdbcUrl

(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:94

↓ 5 callersMethodgetLong

(int pos)

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryRecordData.java:129

↓ 5 callersMethodgetMaxTimeInBufferMS

@return the maximum time in buffer in milliseconds

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/config/ElasticsearchSinkOptions.java:133

↓ 5 callersMethodgetMetricGroup

()

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/test/java/org/apache/flink/cdc/connectors/kafka/json/MockInitializationContext.java:29

↓ 5 callersMethodgetNext

Gets the next split. <p>When this method returns an empty {@code Optional}, then the set of splits is assumed to be done and the source will finish o

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlSplitAssigner.java:52

↓ 5 callersMethodgetNextStatus

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/AssignerStatus.java:50

↓ 5 callersMethodgetNextStatus

()

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

↓ 5 callersMethodgetNumericLimit

( int radix, int exponent, boolean sign, Limit limit, boolean beyond)

flink-cdc-runtime/src/main/java/org/apache/calcite/sql/type/SqlTypeName.java:959

↓ 5 callersMethodgetOrCreateConverters

( TableId tableId, Schema schema)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/serializer/ElasticsearchEventSerializer.java:233

↓ 5 callersMethodgetPartitionKeys

()

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java:109

↓ 5 callersMethodgetPassword

()

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oracle/src/test/java/org/testcontainers/containers/OracleContainer.java:150

↓ 5 callersMethodgetPort

()

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/config/JdbcSourceConfig.java:117

↓ 5 callersMethodgetPosition

()

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/text/ParsingException.java:54

↓ 5 callersMethodgetPostTransformedSchema

()

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PostTransformChangeInfo.java:124

↓ 5 callersMethodgetProductsCreateTableEvent

(TableId tableId)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oracle/src/test/java/org/apache/flink/cdc/connectors/oracle/source/OraclePipelineITCase.java:1577

↓ 5 callersMethodgetRegion

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/tikv/cdc/RegionCDCClient.java:147

↓ 5 callersMethodgetResolvedCatalogTable

Gets a table from the catalog and ensures it's returned as a ResolvedCatalogTable. If the catalog returns a DefaultCatalogTable, it will be converted

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

↓ 5 callersMethodgetResumeToken

Return the resumeToken from heartbeat event or change stream event.

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

↓ 5 callersMethodgetRowType

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/test/java/org/apache/flink/cdc/connectors/mongodb/utils/TestTable.java:58

↓ 5 callersMethodgetSchema

( JdbcConnection jdbcConnection, io.debezium.relational.TableId tableId)

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

↓ 5 callersMethodgetSchema

Get cached schema for a table. @param tableId The table identifier @return Schema or null if not cached

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-hudi/src/main/java/org/apache/flink/cdc/connectors/hudi/sink/event/HudiRecordEventSerializer.java:123

↓ 5 callersMethodgetSinkSubTaskId

()

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/distributed/event/SchemaChangeRequest.java:59

↓ 5 callersMethodgetSnapshotExpected

(TableId tableId)

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

↓ 5 callersMethodgetSourceSubTaskId

()

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/event/FlushSuccessEvent.java:47

↓ 5 callersMethodgetSourceTable

()

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/RouteDef.java:53

↓ 5 callersMethodgetSplitId

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/events/BinlogSplitMetaEvent.java:62

↓ 5 callersMethodgetSplitKeyType

()

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SnapshotSplit.java:160

↓ 5 callersMethodgetStreamExecutionEnvironment

( String finishedSavePointPath, int parallelism)

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

↓ 5 callersMethodgetStreamExecutionEnvironmentFromSavePoint

( String finishedSavePointPath, int parallelism)

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

↓ 5 callersMethodgetTableId

(SourceRecord dataRecord)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/RecordUtils.java:391

↓ 5 callersMethodgetTableKeys

()

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java:105

↓ 5 callersMethodgetTableSchemaFromTable

(Db2ChangeTable changeTable)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/io/debezium/connector/db2/Db2Connection.java:362

↓ 5 callersMethodgetTableSchemas

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/SnapshotPendingSplitsState.java:111

↓ 5 callersMethodgetTableSchemas

()

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

↓ 5 callersMethodgetTestSplitInfo

(TableId tableId, int splitNo)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/PendingSplitsStateSerializerTest.java:225

↓ 5 callersMethodgetTimestampSec

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/offset/BinlogOffset.java:130

↓ 5 callersMethodgetUsername

()

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oracle/src/test/java/org/testcontainers/containers/OracleContainer.java:143

↓ 5 callersMethodgetValues

()

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/EnumSerializer.java:279

↓ 5 callersMethodgetZonedTimestamp

Returns the zoned timestamp value at the given position. <p>The precision is required to determine whether the timestamp value was stored in a compac

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/ArrayData.java:108

↓ 5 callersMethodgroupSourceTablesByRouteRule

Group the source tables that conform to the same routing rule together. The total number of groups is less than or equal to the number of routing rule

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/route/TableIdRouter.java:194

↓ 5 callersMethodhandleArray

(byte[] value, int pos, ArrayHandler<T> handler)

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/variant/BinaryVariantUtil.java:585

↓ 5 callersMethodhandleBinaryWithBinaryMode

( CommonConnectorConfig.BinaryHandlingMode mode)

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

↓ 5 callersMethodhandleCoordinationRequest

( CoordinationRequest request)

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

↓ 5 callersMethodhandleDateWithTemporalMode

(TemporalPrecisionMode mode)

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

↓ 5 callersMethodhasPrimaryKey

()

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/TableSchemaInfo.java:49

↓ 5 callersMethodheartbeatInterval

The interval of heartbeat event.

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

↓ 5 callersMethodignoreIfNull

(String configName, String configValue)

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

↓ 5 callersMethodincludeListAsPatterns

(List<String> includeList)

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

↓ 5 callersMethodincludes

(String regexPatterns, Function<T, String> conversion)

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/Predicates.java:39

↓ 5 callersMethodinferWiderColumn

Try to combine two columns with potential incompatible type. @deprecated Use {@code getLeastCommonType} in {@link SchemaMergingUtils} instead.

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

↓ 5 callersMethodinferWiderSchema

Merge compatible schemas. @deprecated Use {@code getCommonSchema} in {@link SchemaMergingUtils} instead.

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

↓ 5 callersMethodinitialAddressTables

(JdbcConnection connection, List<String> addressTables)

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

↓ 5 callersMethodinstance

( Configuration conf, AbstractWriteOperator<IN> writeOperator)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-hudi/src/main/java/org/apache/flink/cdc/connectors/hudi/sink/operator/MultiTableWriteOperatorFactory.java:69

↓ 5 callersMethodisAfter

(BinlogOffset that)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/offset/BinlogOffset.java:277

↓ 5 callersMethodisAfter

(Offset that)

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

↓ 5 callersMethodisDataTypeCompatible

(@Nullable DataType currentType, DataType upcomingType)

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/SchemaMergingUtils.java:326

↓ 5 callersMethodisGloballyLocked

()

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

↓ 5 callersMethodisNewlyAddedAssigningSnapshotFinished

Returns whether the split assigner has finished its newly added snapshot splits assignment.

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/AssignerStatus.java:211

↓ 5 callersMethodisSchemaChangeEvent

(SourceRecord sourceRecord)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/RecordUtils.java:325

↓ 5 callersMethodisSchemaChangeEvent

(SourceRecord sourceRecord)

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

↓ 5 callersMethodisSchemaChangeEventRedundant

This function checks if the given schema change event has been applied already. If so, it will be ignored to avoid sending duplicate evolved schema ch

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

↓ 5 callersMethodisSnapshotOnly

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupOptions.java:117

↓ 5 callersMethodisSnapshotSplit

Checks whether this split is a snapshot split.

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitBase.java:40

↓ 5 callersMethodisStreamSplit

Checks whether this split is a stream split.

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitBase.java:45

↓ 5 callersMethodisSuspended

()

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/StreamSplit.java:120

↓ 5 callersMethodisTableIdCaseSensitive

(JdbcConnection connection)

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

↓ 5 callersMethodisWatermarkEvent

(SourceRecord record)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/RecordUtils.java:256

↓ 5 callersMethodlinebreak

Creates a line break in the description.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description/LineBreakElement.java:27

↓ 5 callersMethodloadConfigFile

(Path configPath)

flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/utils/ConfigurationUtils.java:33

↓ 5 callersMethodlogBinaryDataContents

( String prefix, Event event, List<RecordData.FieldGetter> fieldGetters)

flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/operators/transform/UnifiedTransformOperatorTest.java:270

↓ 5 callersMethodlogStreamingSourceState

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/io/debezium/connector/mysql/MySqlStreamingChangeEventSource.java:1358

↓ 5 callersMethodlogStreamingSourceState

()

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

↓ 5 callersMethodlongOffsetValue

(Map<String, ?> values, String key)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/offset/BinlogOffset.java:146

↓ 5 callersMethodmakeFirstPartStreamEvents

Make some changes on the specified customer table. Changelog in string could be accessed by {@link #firstPartStreamEvents}.

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

↓ 5 callersMethodmakeSecondPartStreamEvents

Make some other changes on the specified customer table. Changelog in string could be accessed by {@link #secondPartStreamEvents}.

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

↓ 5 callersMethodmergeGtidSetInto

This method merges one GTID set (toMerge) into another (base), without overwriting the existing elements in the base GTID set.

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

↓ 5 callersMethodneedToDiscoveryTables

Indicates current assigner need to discovery tables or not.

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlSnapshotSplitAssigner.java:556

↓ 5 callersMethodof

(byte b)

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/variant/BinaryVariantBuilder.java:41

← previous next →1,401–1,500 of 12,620, ranked by callers