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/event/DataChangeEvent.java:78

Declares a partition key constraint for a set of given columns. Partition key uniquely identify a row in a table. Neither of columns in a partition ca

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

↓ 50 callersMethodtableList

(String... tableList)

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

↓ 49 callersMethodMAP

Data type of an associative array that maps keys (including {@code NULL}) to values (including {@code NULL}). A map cannot contain duplicate keys; eac

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypes.java:376

↓ 49 callersMethodgetEventSourceProvider

Get the {@link EventSourceProvider} for reading events from external systems.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/source/DataSource.java:31

↓ 49 callersMethodhostname

(String hostname)

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

↓ 49 callersMethodpassword

(String password)

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

↓ 49 callersMethodport

(int port)

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

↓ 49 callersMethodusername

(String username)

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

↓ 48 callersMethodcreateAndInitialize

(String sqlFile)

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

↓ 48 callersMethodinferWiderType

Try to combine given data types to a compatible wider data type. @deprecated Use {@code getLeastCommonType} in {@link SchemaMergingUtils} instead.

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

↓ 48 callersMethoditemAccess

Accesses an element from an ARRAY by index (1-based, SQL standard). array[1] returns the first element. @param <T> the element type of the array

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/functions/impl/StructFunctions.java:43

↓ 48 callersMethodname

(String name)

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

↓ 48 callersMethodsnapshotState

Creates a snapshot of the state of this split assigner, to be stored in a checkpoint. The snapshot should contain the latest state of the assigner

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

↓ 48 callersMethodstartupOptions

Specifies the startup options.

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

↓ 47 callersMethodgetFactoryConfiguration

Returns the factory options used to create the object instances. @return options of the current session.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/factories/Factory.java:71

↓ 47 callersMethodgetText

()

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description/LinkElement.java:53

↓ 47 callersMethodinitial

Performs an initial snapshot on the monitored database tables upon first startup, and continue to read the latest binlog.

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

↓ 47 callersMethodtype

Get the type of the token. @return the token's type

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/text/TokenStream.java:509

↓ 46 callersMethodcompareBsonValue

(BsonValue o1, BsonValue o2)

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

↓ 46 callersMethodempty

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/hooks/SnapshotPhaseHooks.java:78

↓ 46 callersMethodfromLocalDateTime

Creates an instance of {@link TimestampData} from an instance of {@link LocalDateTime}. @param dateTime an instance of {@link LocalDateTime}

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/TimestampData.java:125

↓ 46 callersMethodgetUsername

()

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

↓ 45 callersMethodcreateMySqlConnection

Creates a new {@link MySqlConnection}, but not open the connection.

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

↓ 45 callersMethodgetCheckpointLock

()

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

↓ 45 callersMethodgetTimestamp

Returns the timestamp value at the given position. The precision is required to determine whether the timestamp value was stored in a compact repr

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

↓ 45 callersMethoditerator

()

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

↓ 45 callersMethodscale

Returns the scale of this {@link DecimalData}.

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

↓ 45 callersMethodwriteBoolean

(int pos, boolean value)

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

↓ 44 callersMethodaddTransform

( String tableInclusions, @Nullable String projection, @Nullable String filter)

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PreTransformOperatorBuilder.java:36

↓ 44 callersMethodclearOutputRecords

()

flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/testutils/operators/RegularEventOperatorTestHarness.java:221

↓ 44 callersMethodempty

()

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/utils/hooks/SnapshotPhaseHooks.java:78

↓ 44 callersMethodgetAddColumn

()

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/AddColumnEvent.java:104

↓ 44 callersMethodgetJdbcConnection

()

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

↓ 44 callersMethodgetResults

(TableId tableId)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/src/main/java/org/apache/flink/cdc/connectors/values/ValuesDatabase.java:282

↓ 43 callersMethodaddAll

(Configuration other)

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/Configuration.java:70

↓ 43 callersMethodbuilder

()

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchSink.java:83

↓ 43 callersMethodcomment

()

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

↓ 43 callersMethodfromLocalTime

(LocalTime localTime)

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

↓ 43 callersMethodgenerate

(Schema schema, Object... fields)

flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/FlinkPipelineTransformITCase.java:3463

↓ 43 callersMethodquote

(String dbOrTableName)

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

↓ 42 callersMethodcollect

(RowData record)

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

↓ 42 callersMethodconfigureNoRestartStrategy

Disables the restart strategy for the given StreamExecutionEnvironment. @param env the StreamExecutionEnvironment to configure

flink-cdc-flink1-compat/src/main/java/org/apache/flink/streaming/util/RestartStrategyUtils.java:39

↓ 42 callersMethodequals

(Object o)

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

↓ 42 callersMethodgetPassword

()

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

↓ 42 callersMethodindexOf

Returns the index within this string of the first occurrence of the specified substring, starting at the specified index. @param str the substring to

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

↓ 42 callersMethodisNullAt

(int pos)

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

↓ 42 callersMethods

(Object wrappedString)

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

↓ 42 callersMethodsetField

Sets the field value at the given position. Note: The given field value must be an internal data structures. Otherwise the {@link GenericRecordDat

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericRecordData.java:69

↓ 42 callersMethodstop

()

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

↓ 42 callersMethodwriteLong

(int pos, long value)

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

↓ 41 callersMethodequals

(Object o)

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/schema/Column.java:145

↓ 41 callersMethodgetValue

()

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/v2/metrics/WrappedFlussGauge.java:35

↓ 41 callersMethodoptions

Returns the options of the table or data collection.

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

↓ 40 callersMethodcreateDataSink

Creates a {@link DataSink} instance.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/factories/DataSinkFactory.java:30

↓ 40 callersMethodgetAffected

(String... tables)

flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaDerivatorTest.java:101

↓ 40 callersMethodgetDbzConfiguration

()

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

↓ 40 callersMethodinsertPostTransformed

()

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

↓ 40 callersMethodinsertPreTransformed

()

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

↓ 40 callersMethodinsertSource

(Object... record)

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

↓ 40 callersMethodnewBuilder

()

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/variant/Variant.java:224

↓ 40 callersMethodnewInstance

()

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description/Formatter.java:102

↓ 40 callersMethodwithNetwork

(Network network)

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

↓ 39 callersMethodcollect

(T element)

flink-cdc-flink2-compat/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java:83

↓ 39 callersMethodgetObject

(int pos)

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java:259

↓ 39 callersMethodwrite

(ArrayRecord record)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/writer/MaxComputeWriter.java:49

↓ 38 callersMethodaccept

(LogMinerEvent event, long eventsProcessed)

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

↓ 38 callersMethodclear

()

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/src/main/java/org/apache/flink/cdc/connectors/values/ValuesDatabase.java:288

↓ 38 callersMethodgetJdbcConnection

(PostgreSQLContainer container)

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

↓ 38 callersMethodgetLatestEvolvedSchema

(TableId tableId)

flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/testutils/operators/RegularEventOperatorTestHarness.java:264

↓ 38 callersMethodgetTableId

(SourceRecord record)

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

↓ 38 callersMethodprocessElement

(StreamRecord<Event> element)

flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/operators/sink/DataSinkOperatorAdapter.java:95

↓ 38 callersMethodprocessEvent

(SchemaOperator operator, List<Event> events)

flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/operators/schema/regular/SchemaEvolveTest.java:2591

↓ 37 callersMethodgetFactoryByIdentifier

Returns the {@link Factory} for the given identifier.

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/utils/FactoryDiscoveryUtils.java:47

↓ 37 callersMethodgetSchema

()

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

↓ 37 callersMethodinitial

Performs an initial snapshot on the monitored database tables upon first startup, and continue to read change events from the database's redo logs.

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

↓ 37 callersMethodofBinlogFilePosition

Create offset from binlog filename and position.

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

↓ 37 callersMethodsetBinlogFilePosition

(String filename, long position)

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

↓ 37 callersMethodsetSourceEvents

set sourceEvents using custom events.

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/src/main/java/org/apache/flink/cdc/connectors/values/source/ValuesDataSourceHelper.java:107

↓ 37 callersMethodwithNetworkAliases

(String... aliases)

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

↓ 36 callersMethodaddAll

(List<T> values)

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

↓ 36 callersMethodgetLatestOriginalSchema

(TableId tableId)

flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/testutils/operators/RegularEventOperatorTestHarness.java:250

↓ 36 callersMethodgetSplitStart

()

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

↓ 36 callersMethodgetTaskInfo

()

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/test/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonSinkITCase.java:1125

↓ 36 callersMethodinitial

Performs an initial snapshot on the monitored database tables upon first startup, and continue to read the latest change log.

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupOptions.java:42

↓ 36 callersMethodis

Returns whether the root of the type equals to the {@code typeRoot} or not. @param typeRoot The root type to check against for equality

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java:58

↓ 36 callersMethodnullable

()

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java:157

↓ 36 callersMethodsplitId

()

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

↓ 35 callersMethodassertNotAllowed

( Selectors filter, String nameSpace, String schemaName, String tableName)

flink-cdc-common/src/test/java/org/apache/flink/cdc/common/schema/SelectorsTest.java:143

↓ 35 callersMethodgetDatabaseName

()

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

↓ 35 callersMethodgetPassword

()

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

↓ 35 callersMethodgetScale

(DataType dataType)

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypes.java:434

↓ 35 callersMethodgetUsername

()

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

↓ 35 callersMethodhostname

(String hostname)

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

↓ 35 callersMethodpassword

Password to use when connecting to the MySQL database server.

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

↓ 35 callersMethodtableId

()

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/DataChangeEvent.java:65

↓ 35 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/MySqlSource.java:108

↓ 34 callersMethodfromNanoOfDay

(long nanoOfDay)

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

↓ 34 callersMethodgetFieldNames

()

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java:65

↓ 34 callersMethodtableList

An optional list of regular expressions that match fully-qualified table identifiers for tables to be monitored; any table not included in the list wi

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

← previous next →201–300 of 12,620, ranked by callers