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/schema/Column.java:84

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

↓ 24 callersMethodnewBuilder

Returns a builder to build {@link RowDataDebeziumDeserializeSchema}.

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/table/RowDataDebeziumDeserializeSchema.java:98

↓ 24 callersMethodroute

(TableIdRouter router, String tableId)

flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/operators/schema/common/TableIdRouterMatchModeTest.java:115

↓ 24 callersMethodsetGtidSet

(String gtidSet)

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

↓ 24 callersMethodsetPhysicalRowType

(RowType physicalRowType)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/table/RowDataDebeziumDeserializeSchema.java:199

↓ 24 callersMethodsetResultTypeInfo

(TypeInformation<RowData> resultTypeInfo)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/table/RowDataDebeziumDeserializeSchema.java:209

↓ 24 callersMethodwaitForSinkSize

(String sinkName, int expectedSize)

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

↓ 24 callersMethodwrite

( BinaryWriter writer, int pos, Object o, DataType type, TypeSerializer<?> serializer)

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

↓ 23 callersMethodassertInsert

Verify that the given {@link SourceRecord} is a {@link Envelope.Operation#CREATE INSERT/CREATE} record. @param record the source record; may not be n

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

↓ 23 callersMethodassertKeyRangeContains

( Object[] key, Object[] splitKeyStart, Object[] splitKeyEnd)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/utils/RecordUtilsTest.java:104

↓ 23 callersMethodcolumns

()

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

↓ 23 callersMethodconvertValue

Tries to convert the raw value into the provided type. @param rawValue rawValue to convert into the provided type clazz @param clazz clazz specifying

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/ConfigurationUtils.java:46

↓ 23 callersMethoddatabase

The name of the PostgreSQL database from which to stream the changes.

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

↓ 23 callersMethoddecodingPluginName

The name of the Postgres logical decoding plug-in installed on the server. Supported values are decoderbufs and pgoutput.

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

↓ 23 callersMethodensureMaterialized

()

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

↓ 23 callersMethodevolveFromSource

(SchemaChangeEvent event)

flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/operators/transform/TransformOperatorWithSchemaEvolveTest.java:110

↓ 23 callersMethodgetOperator

()

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

↓ 23 callersMethodgetOptions

()

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/UdfDef.java:58

↓ 23 callersMethodgetSchema

()

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/TableSchemaInfo.java:95

↓ 23 callersMethodgetSourceConfig

()

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

↓ 23 callersMethodincludeSchemaChanges

Whether the {@link Db2IncrementalSource} should output the schema changes or not.

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

↓ 23 callersMethodisRunning

Returns current task is running or not.

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

↓ 23 callersMethodmeta

()

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

↓ 23 callersMethodobject

Get the builder of a variant object.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/variant/VariantBuilder.java:80

↓ 23 callersMethodtoInstant

Converts this {@link ZonedTimestampData} object to a {@link Instant}.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/ZonedTimestampData.java:77

↓ 22 callersMethodapplyEvolvedSchemaChange

Apply schema change to a table.

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaManager.java:168

↓ 22 callersMethodcollect

(SourceRecord record)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/reader/MySqlSourceReaderTest.java:669

↓ 22 callersMethodcollect

(T record)

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

↓ 22 callersMethodcompare

Compares two comparable objects. @return The value {@code 0} if {@code num1} is equal to the {@code num2}; a value less than {@code 0} if the {@c

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

↓ 22 callersMethodcomplete

Finally, complete write to set real size to row.

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/writer/BinaryArrayWriter.java:211

↓ 22 callersMethodcomplete

Finally, complete write to set real size to binary.

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

↓ 22 callersMethoddropDatabase

(Connection connection, String database)

flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/OceanBaseE2eITCase.java:334

↓ 22 callersMethodevaluate

(Object[] rowData, TransformContext context)

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/ProjectionColumnProcessor.java:84

↓ 22 callersMethodexecuteStatements

(String... statements)

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

↓ 22 callersMethodexpectInPreTransformed

(SchemaChangeEvent event)

flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/operators/transform/TransformOperatorWithSchemaEvolveTest.java:130

↓ 22 callersMethodgetHostAndPort

()

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

↓ 22 callersMethodgetJdbcConnection

()

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

↓ 22 callersMethodgetSchema

Returns the table schema.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/CreateTableEvent.java:45

↓ 22 callersMethodinFirstSegment

Is it just in first MemorySegment, we use quick way to do something.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySegmentUtils.java:409

↓ 22 callersMethodisOptional

(int i)

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/parser/metadata/TransformNumericExceptFirstOperandChecker.java:87

↓ 22 callersMethoditerator

()

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

↓ 22 callersMethodkey

Gets the configuration key. @return The configuration key

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/ConfigOption.java:186

↓ 22 callersMethodslotName

The name of the PostgreSQL logical decoding slot that was created for streaming changes from a particular plug-in for a particular database/schema. Th

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

↓ 22 callersMethodtoJson

Parses the variant to json.

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

↓ 21 callersMethodassertEqualsInAnyOrder

(List<String> expected, List<String> actual)

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

↓ 21 callersMethodavailable

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/com/github/shyiko/mysql/binlog/io/BufferedSocketInputStream.java:47

↓ 21 callersMethodclear

()

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

↓ 21 callersMethodcreate

Creates a new {@link PostgresSourceConfig} for the given subtask {@code subtaskId}.

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

↓ 21 callersMethoddeserializer

The deserializer used to convert from consumed {@link org.apache.kafka.connect.source.SourceRecord}.

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

↓ 21 callersMethodequals

Equals two memory segments regions. @param segments1 Segments 1 @param offset1 Offset of segments1 to start equaling @param segments2 Segments 2 @par

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySegmentUtils.java:312

↓ 21 callersMethodgenerate

(Schema schema, Object... fields)

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

↓ 21 callersMethodgenerate

(Schema schema, Object... fields)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/table/MySqlOnLineSchemaMigrationTableITCase.java:545

↓ 21 callersMethodgetComment

()

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

↓ 21 callersMethodgetDouble

Returns the double value at the given position.

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

↓ 21 callersMethodgetEventType

(Event event)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/reader/BinlogSplitReader.java:430

↓ 21 callersMethodgetFloat

Returns the float value at the given position.

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

↓ 21 callersMethodgetOraclePort

()

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

↓ 21 callersMethodgetPrecision

Returns the precision of all types that define a precision implicitly or explicitly.

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

↓ 21 callersMethodgetPrecision

()

flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/serializer/data/TimestampDataSerializerTest.java:60

↓ 21 callersMethodgetProject

()

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/SessionIdentifier.java:64

↓ 21 callersMethodgetSplitId

()

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

↓ 21 callersMethodindex

Get the index for the last character returned from {@link #next()}. @return the index of the last character returned

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

↓ 21 callersMethodisSnapshotSplit

Checks whether this split is a snapshot split.

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

↓ 21 callersMethodquote

(String dbOrTableName)

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

↓ 21 callersMethodreadUnsigned

(byte[] bytes, int pos, int numBytes)

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

↓ 21 callersMethodtestPostgresParallelSource

( PostgresTestUtils.FailoverType failoverType, PostgresTestUtils.FailoverPhase failove

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

↓ 21 callersMethodvisit

(CharType charType)

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypeVisitor.java:31

↓ 20 callersMethodassertTypeMergingVector

(DataType incomingType, List<DataType> resultTypes)

flink-cdc-common/src/test/java/org/apache/flink/cdc/common/utils/SchemaMergingUtilsTest.java:1161

↓ 20 callersMethodcreateFieldGetters

create a list of {@link RecordData.FieldGetter} from given {@link Schema} to get Object from RecordData.

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

↓ 20 callersMethoddebeziumProperties

(Properties debeziumProperties)

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

↓ 20 callersMethoddefaultMethod

(DataType dataType)

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypeDefaultVisitor.java:128

↓ 20 callersMethodequals

(Object o)

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:53

↓ 20 callersMethodequals

(Object o)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSource.java:271

↓ 20 callersMethodfetchResults

(Iterator<T> iter, int size)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/test/java/org/apache/flink/cdc/connectors/mysql/testutils/MySqSourceTestUtils.java:37

↓ 20 callersMethodgetExistedColumnName

()

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

↓ 20 callersMethodgetFieldValue

( RowDataAvroQueryContexts.RowDataQueryContext queryContext, RowData rowData,

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-hudi/src/test/java/org/apache/flink/cdc/connectors/hudi/sink/HudiSinkITCase.java:473

↓ 20 callersMethodgetServerId

(boolean incrementalSnapshot)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/table/MySqlConnectorITCase.java:2194

↓ 20 callersMethodgetShort

Returns the short value at the given position.

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

↓ 20 callersMethodgetSlotName

()

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

↓ 20 callersMethodof

Create a variant from a byte.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/variant/VariantBuilder.java:38

↓ 20 callersMethodopen

Called to open the assigner to acquire any resources, like threads or network connections.

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

↓ 20 callersMethodparseDefaultValue

Parse a CDC default value expression string into an Iceberg {@link Literal}. @return the parsed Literal, or null if the expression is null or cannot

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/utils/IcebergTypeUtils.java:69

↓ 19 callersMethodaddAll

(List<T> values)

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

↓ 19 callersMethodaddTimezone

(String timezone)

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PostTransformOperatorBuilder.java:99

↓ 19 callersMethodassertIndexIsValid

(int index)

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

↓ 19 callersMethodcompareTo

(Offset offset)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/meta/offset/RedoLogOffset.java:70

↓ 19 callersMethodconfigureFixedDelayRestartStrategy

Sets a fixed-delay restart strategy for the given StreamExecutionEnvironment. @param env the StreamExecutionEnvironment to configure @param restartAt

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

↓ 19 callersMethodconnection

Return an unwrapped PgConnection instead of HikariProxyConnection

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/PostgresConnection.java:216

↓ 19 callersMethodcreateFactoryHelper

(Factory factory, Factory.Context context)

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/factories/FactoryHelper.java:50

↓ 19 callersMethodflush

()

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

↓ 19 callersMethodfromBytes

Creates a {@link BinaryStringData} instance from the given UTF-8 bytes.

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

↓ 19 callersMethodgenerate

()

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-hudi/src/main/java/org/apache/flink/cdc/connectors/hudi/sink/v2/OperatorIDGenerator.java:35

↓ 19 callersMethodgetBinlogPosition

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

↓ 19 callersMethodgetElement

Access value of the specified element of an array variant. If index is out of range, null is returned. <p>NOTE: if the element value has been explici

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

↓ 19 callersMethodgetElementType

()

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java:51

↓ 19 callersMethodgetOraclePort

()

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

↓ 19 callersMethodposition

Get the position of this token, which includes the line number and column number of the first character in the token. @return the position; never nul

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

↓ 19 callersMethodrepeatedCheck

Fetch with a ({@code timeout}, {@code interval}) duration.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/TestCaseUtils.java:35

↓ 19 callersMethodsetupSource

(DebeziumSourceFunction<T> source)

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

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