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-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/config/ElasticsearchSinkOptions.java:126

↓ 4 callersMethodgetMaxBufferedRequests

@return the maximum number of buffered requests

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

↓ 4 callersMethodgetMaxInFlightRequests

@return the maximum number of in-flight requests

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

↓ 4 callersMethodgetMaxRecordSizeInBytes

@return the maximum record size in bytes

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

↓ 4 callersMethodgetMessageTimestamp

Return the timestamp when the change event is produced in MongoDB.

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

↓ 4 callersMethodgetMetadataKey

(byte[] metadata, int id)

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

↓ 4 callersMethodgetMongoDatabase

(String dbName)

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

↓ 4 callersMethodgetNamespace

()

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

↓ 4 callersMethodgetNext

()

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

↓ 4 callersMethodgetNext

()

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

↓ 4 callersMethodgetOffset

()

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

↓ 4 callersMethodgetOffset

()

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

↓ 4 callersMethodgetOffsetContext

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/source/reader/fetch/SqlServerSourceFetchTaskContext.java:246

↓ 4 callersMethodgetOffsetContext

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/fetch/Db2SourceFetchTaskContext.java:233

↓ 4 callersMethodgetOperatorStateStore

()

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

↓ 4 callersMethodgetPaimonSchemaInfo

()

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketAssignOperator.java:376

↓ 4 callersMethodgetPartition

()

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/external/JdbcSourceFetchTaskContext.java:194

↓ 4 callersMethodgetPayload

()

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PartitioningEvent.java:57

↓ 4 callersMethodgetPendingOffsetsToCommit

()

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

↓ 4 callersMethodgetPostgresDialect

(PostgresSourceConfig sourceConfig)

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

↓ 4 callersMethodgetPrimaryKeys

()

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/TransformDef.java:113

↓ 4 callersMethodgetProperties

()

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/TableCreateConfig.java:56

↓ 4 callersMethodgetProperties

()

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

↓ 4 callersMethodgetReplicationConnection

()

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

↓ 4 callersMethodgetRestartSkipRows

()

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

↓ 4 callersMethodgetReturnTypeHint

()

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/UserDefinedFunctionDescriptor.java:107

↓ 4 callersMethodgetSchemaName

()

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

↓ 4 callersMethodgetScheme

()

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

↓ 4 callersMethodgetSegments

()

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

↓ 4 callersMethodgetSelectors

()

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PreTransformer.java:42

↓ 4 callersMethodgetServerId

()

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

↓ 4 callersMethodgetServerId

()

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

↓ 4 callersMethodgetServerId

()

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

↓ 4 callersMethodgetSnapshotExpected

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

↓ 4 callersMethodgetSnapshotSplits

( SqlServerSourceConfig sourceConfig, JdbcDataSourceDialect sourceDialect)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/test/java/org/apache/flink/cdc/connectors/sqlserver/source/reader/fetch/SqlServerScanFetchTaskTest.java:335

↓ 4 callersMethodgetSourceBuilder

()

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

↓ 4 callersMethodgetSourceConfig

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/reader/fetch/OracleSourceFetchTaskContext.java:166

↓ 4 callersMethodgetSplitEnd

()

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

↓ 4 callersMethodgetSplitEnd

()

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

↓ 4 callersMethodgetSplitId

()

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

↓ 4 callersMethodgetSplitKey

( RowType splitBoundaryType, SchemaNameAdjuster nameAdjuster, Struct target)

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

↓ 4 callersMethodgetSplitStart

()

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

↓ 4 callersMethodgetSplitStart

()

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

↓ 4 callersMethodgetStatusCode

()

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

↓ 4 callersMethodgetStatusCode

()

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

↓ 4 callersMethodgetStreamExecutionEnvironmentFromSavePoint

( String finishedSavePointPath, int parallelism)

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

↓ 4 callersMethodgetStreamExecutionEnvironmentFromSavePoint

( String finishedSavePointPath, int parallelism)

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

↓ 4 callersMethodgetString

(int pos)

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

↓ 4 callersMethodgetSupportedMetadataColumns

()

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

↓ 4 callersMethodgetTableId

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/testutils/TestTable.java:56

↓ 4 callersMethodgetTableId

()

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

↓ 4 callersMethodgetTableNameRegex

(String[] captureCustomerTables)

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

↓ 4 callersMethodgetTablePath

(TableId tableId)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/FlussEventSerializationSchema.java:146

↓ 4 callersMethodgetTableSchemas

()

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

↓ 4 callersMethodgetTaskContext

()

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

↓ 4 callersMethodgetTiConfiguration

( final String pdAddrsStr, final String hostMapping, final Map<String, String> options)

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

↓ 4 callersMethodgetTimestampResult

( String localTimeZone, String serverTimeZone, String jvmTimeZone,

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/test/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTimezoneITCase.java:117

↓ 4 callersMethodgetTransactionEventCount

Returns the number of events associated with the specified transaction. @param transaction the transaction, must not be {@code null} @return the numb

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/io/debezium/connector/oracle/logminer/processor/AbstractLogMinerEventProcessor.java:173

↓ 4 callersMethodgetTransactionId

( DataCollectionId source, OffsetContext offset, Object key, Struct value)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/fetch/Db2SourceFetchTaskContext.java:304

↓ 4 callersMethodgetType

()

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java:67

↓ 4 callersMethodgetUpstreamSchemaInfo

()

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketAssignOperator.java:372

↓ 4 callersMethodgetUserCodeClassLoader

()

flink-cdc-flink2-compat/src/main/java/org/apache/flink/api/connector/sink2/Sink.java:58

↓ 4 callersMethodgetUserName

()

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

↓ 4 callersMethodgetUsername

()

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

↓ 4 callersMethodgetWatermarkKind

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

↓ 4 callersMethodgetWatermarkKind

(SourceRecord record)

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/wartermark/WatermarkEvent.java:94

↓ 4 callersMethodhandleIntervalWithIntervalHandlingMode

( PostgresConnectorConfig.IntervalHandlingMode 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:253

↓ 4 callersMethodhandleMoneyWithDecimalMode

( int moneyFractionDigits, JdbcValueConverters.DecimalMode 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:239

↓ 4 callersMethodhandleObject

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

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

↓ 4 callersMethodhasNextData

(final CloseableIterator<?> iterator)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/test/java/org/apache/flink/cdc/connectors/postgres/testutils/PostgresTestUtils.java:138

↓ 4 callersMethodhasValidKey

Verify that the given {@link SourceRecord} has a valid non-null integer key that matches the expected integer value. @param record the source record;

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-test-util/src/main/java/org/apache/flink/cdc/connectors/utils/AssertUtils.java:140

↓ 4 callersMethodhashCode

()

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperFlushEvent.java:70

↓ 4 callersMethodhashcode

(T event)

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/function/HashFunction.java:30

↓ 4 callersMethodhostname

()

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

↓ 4 callersMethodhostname

(String hostname)

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

↓ 4 callersMethodinfer

(Object value, Schema schema)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/event/DebeziumSchemaDataTypeInference.java:55

↓ 4 callersMethodinfer

Infer {@link DataType} from {@link Schema}. @param value the value corresponding value to SCHEMA @param schema the kafka connect schema @return the i

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/event/SchemaDataTypeInference.java:36

↓ 4 callersMethodinsertRecordsPhase1

(UniqueDatabase database, int startIndex, int count)

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

↓ 4 callersMethodinvoke

(Class<?> clazz, Object object, String methodName)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-test-util/src/main/java/org/apache/flink/cdc/connectors/utils/ExternalResourceProxy.java:53

↓ 4 callersMethodisBefore

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

↓ 4 callersMethodisBinlogSplitAssigned

()

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

↓ 4 callersMethodisBinlogSplitState

Checks whether this split state is a binlog split state.

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

↓ 4 callersMethodisCommitOffset

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/reader/PostgresSourceReader.java:173

↓ 4 callersMethodisDataCollectionIdCaseSensitive

Check if the CollectionId is case-sensitive or not.

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/dialect/DataSourceDialect.java:70

↓ 4 callersMethodisHeartbeatEvent

Check the sourceRecord is heartbeat 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:60

↓ 4 callersMethodisHighWatermarkEvent

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

↓ 4 callersMethodisInPreSnapshotCatchUpStreaming

Returns whether the current streaming phase is running a catch up streaming phase that runs before a snapshot. This is useful for transaction manageme

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

↓ 4 callersMethodisIncludeDatabaseInTableId

Returns whether to include database in the generated Table ID.

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

↓ 4 callersMethodisLowWatermarkEvent

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

↓ 4 callersMethodisMatch

Match the {@link TableId} against the {@link Selector}s.

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

↓ 4 callersMethodisNoOpRequest

()

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

↓ 4 callersMethodisRestored

()

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

↓ 4 callersMethodisSnapshotSplitState

Checks whether this split state is a snapshot split state.

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

↓ 4 callersMethodisStreamOnly

()

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

↓ 4 callersMethodisStreamSplitAssigned

()

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

↓ 4 callersMethodisStreamSplitState

Checks whether this split state is a stream split state.

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

↓ 4 callersMethodjdbcProperties

Custom properties that will overwrite the default JDBC connection URL.

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

↓ 4 callersMethodlistTables

( JdbcConnection jdbc, Predicate<String> databaseFilter, Predicate<TableId> tableFilter)

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

↓ 4 callersMethodm

(K k1, V v1, K k2, V v2, K k3, V v3)

flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/specs/TransformSpecsITCase.java:317

↓ 4 callersMethodmaybeWarnAboutGrowingWalBacklog

If we receive change events but all of them get filtered out, we cannot commit any new offset with Apache Kafka. This in turn means no LSN is ever ack

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

← previous next →1,701–1,800 of 12,620, ranked by callers