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

↓ 34 callersMethodtoByteArray

()

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

↓ 34 callersMethodtoString

()

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java:135

↓ 33 callersMethodassertIndexIsValid

(int index)

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

↓ 33 callersMethodfrom

Returns a {@link ServerIdRange} from a server id range string which likes '5400-5408' or a single server id likes '5400'.

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

↓ 33 callersMethodgetArity

Returns the number of fields in this record.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/RecordData.java:86

↓ 33 callersMethodpartitionKeys

Returns the partition keys of the table or data collection.

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

↓ 33 callersMethodport

Integer port number of 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:81

↓ 33 callersMethodtest

(final Row row)

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

↓ 32 callersMethodcollect

(RowData record)

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

↓ 32 callersMethodequals

(Object o)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/offset/LsnOffset.java:84

↓ 32 callersMethodfromEpochDay

(int epochOfDay)

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/DateData.java:35

↓ 32 callersMethodgetData

()

flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/serializer/SerializerTestBase.java:513

↓ 32 callersMethodgetDataType

()

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

↓ 32 callersMethodgetParallelism

()

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2/compaction/CompactionOptions.java:49

↓ 32 callersMethodgetTableFilters

()

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

↓ 32 callersMethodgetValueToOrdinal

()

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

↓ 31 callersMethodanyMatch

(List<Pattern> patterns)

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

↓ 31 callersMethodget

(PostgreSQLTableSource postgreSQLTableSource, String name)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/test/java/org/apache/flink/cdc/connectors/postgres/table/MockPostgreSQLTableSource.java:107

↓ 31 callersMethodgetConfig

( UniqueDatabase database, String[] captureTables, int splitSize)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/debezium/reader/SnapshotSplitReaderTest.java:714

↓ 31 callersMethodgetNamespace

()

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java:99

↓ 31 callersMethodgetTable

(Identifier tableId)

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

↓ 31 callersMethodnow

(long epochTime)

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/functions/impl/TemporalFunctions.java:52

↓ 31 callersMethodquery

( SupplierWithException<Connection, SQLException> connectionSupplier, String sql,

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

↓ 31 callersMethodserverId

A numeric ID of this database client, which must be unique across all currently-running database processes in the MySQL cluster. This connector joins

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

↓ 31 callersMethodtext

Creates a block of text with placeholders ("%s") that will be replaced with proper string representation of given {@link InlineElement}. For example:

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

↓ 31 callersMethodtoSql

Returns the qualified name to be used in SQL.

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

↓ 30 callersMethodapply

@param size Number of array elements. @param offsetSize The integer size of the offset list. @param offsetStart The starting index of the offset list

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

↓ 30 callersMethodassertAllowed

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

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

↓ 30 callersMethodcreateTableSource

( ResolvedSchema schema, Map<String, String> options)

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

↓ 30 callersMethodfetchResults

(TableId tableId)

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

↓ 30 callersMethodgetElementOffset

(int ordinal, int elementSize)

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

↓ 30 callersMethodgetSplitEnd

()

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

↓ 30 callersMethodnewBuilder

()

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PostTransformOperator.java:94

↓ 30 callersMethodopen

(Connection connection)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/v2/FlussEventSerializer.java:32

↓ 30 callersMethodrunTests

(String comment)

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

↓ 29 callersMethodapplySchemaChange

(SchemaChangeEvent schemaChangeEvent)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonMetadataApplier.java:117

↓ 29 callersMethodassertEqualsInAnyOrder

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

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

↓ 29 callersMethodconfigure

(SourceSplitBase sourceSplitBase)

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

↓ 29 callersMethoddataCollectionFilter

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/io/debezium/relational/RelationalTableFilters.java:124

↓ 29 callersMethodinitializePostgresTable

Executes a JDBC statement using the default jdbc config without autocommitting the connection.

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

↓ 29 callersMethodmetadataColumn

Creates a metadata column.

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

↓ 29 callersMethodparseJson

Parse a JSON string as a Variant value. @throws IOException if any JSON parsing error happens.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/variant/BinaryVariantInternalBuilder.java:105

↓ 29 callersMethodstart

()

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

↓ 29 callersMethodwithNullability

(String format, Object... params)

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

↓ 28 callersMethodassetCompareTo

(BinlogOffset offset1, BinlogOffset offset2, int expected)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/offset/BinlogOffsetTest.java:245

↓ 28 callersMethodbinStrOf

(String str)

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

↓ 28 callersMethodbuilder

()

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

↓ 28 callersMethodexecuteSql

(String sql)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/org/apache/flink/cdc/connectors/starrocks/sink/utils/StarRocksSinkTestBase.java:144

↓ 28 callersMethodexecuteSql

(String sql)

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

↓ 28 callersMethodgenerate

(Schema schema, Object... fields)

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

↓ 28 callersMethodgetColumnCount

Returns the number of columns of this schema.

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

↓ 28 callersMethodgetConfig

(StartupOptions startupOptions, String[] captureTables)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/debezium/reader/BinlogSplitReaderTest.java:1595

↓ 28 callersMethodgetType

Returns the data type of this column.

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

↓ 28 callersMethodisIncluded

Determines whether the given table should be included.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/schema/TableFilter.java:29

↓ 28 callersMethodnormalizeEvent

( SchemaChangeBehavior behavior, SchemaChangeEvent... events)

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

↓ 28 callersMethodsetup

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

↓ 28 callersMethodtestFilterExpressionWithUdf

(String expression, String expressionExpect)

flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/parser/TransformParserTest.java:890

↓ 27 callersMethodasSnapshotSplit

Casts this split into a {@link MySqlSnapshotSplit}.

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

↓ 27 callersMethodassertEqualsInAnyOrder

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

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

↓ 27 callersMethodexecuteCommandFileInSeparateDatabase

Executes a mongo command file in separate database.

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

↓ 27 callersMethodgetArray

Returns the array value at the given position.

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

↓ 27 callersMethodgetColumnName

()

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

↓ 27 callersMethodgetHost

()

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

↓ 27 callersMethodgetRow

Returns the row value at the given position. <p>The number of fields is required to correctly extract the record.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/RecordData.java:165

↓ 27 callersMethodgetTypeAt

(int i)

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

↓ 27 callersMethodinc

()

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

↓ 27 callersMethodreadLong

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

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

↓ 26 callersMethoddrain

(TestSourceContext<T> sourceContext, int expectedRecordCount)

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

↓ 26 callersMethodequals

Indicates whether some other object is "equal to" this one. Two {@code RowWithOp} objects are considered equal if their internal rows and operation ty

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/v2/FlussRowWithOp.java:86

↓ 26 callersMethodexecInContainer

(Container<?> container, String prompt, String... commands)

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

↓ 26 callersMethodgetAllOptions

()

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

↓ 26 callersMethodgetPosition

()

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonStruct.java:35

↓ 26 callersMethodgetScn

()

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

↓ 26 callersMethodgetSegments

Gets the underlying {@link MemorySegment}s this binary format spans.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryFormat.java:57

↓ 26 callersMethodgetTime

Returns the Time data at the given position.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/RecordData.java:171

↓ 26 callersMethodisNullAt

Returns true if the element is null at the given position.

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

↓ 26 callersMethodrunGenericTransformTest

( ValuesDataSink.SinkApi sinkApi, List<TransformDef> transformDefs, List<S

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

↓ 26 callersMethodsetColumnSize

(Integer columnSize)

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

↓ 25 callersMethodasStreamSplit

Casts this split into a {@link StreamSplit}.

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

↓ 25 callersMethodbuilder

()

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2/compaction/CompactionOptions.java:57

↓ 25 callersMethodcreateConfig

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

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

↓ 25 callersMethoddeserialize

Deserialize the Debezium record, it is represented in Kafka {@link SourceRecord}.

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

↓ 25 callersMethodfromLocalDate

(LocalDate date)

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

↓ 25 callersMethodgenInsert

(TableId tableId, String rowType, Object... fields)

flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaTestBase.java:120

↓ 25 callersMethodgetBinary

Returns the binary value at the given position.

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

↓ 25 callersMethodgetByte

Returns the byte value at the given position.

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

↓ 25 callersMethodgetColumnNames

Returns all column names. It does not distinguish between different kinds of columns.

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

↓ 25 callersMethodgetComment

()

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

↓ 25 callersMethodgetField

Access value of the specified field of an object variant. If there is no field with the specified name, null is returned. <p>NOTE: if the property va

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

↓ 25 callersMethodgetStartingOffset

()

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

↓ 25 callersMethodgetTestAssignSnapshotSplits

( int splitSize, double distributionFactorUpper, double distributionFactor

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlSnapshotSplitAssignerTest.java:623

↓ 25 callersMethodstartupOptions

Specifies the startup options.

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

↓ 25 callersMethodunion

(List<T> listA, List<T> listB)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/utils/ListUtils.java:28

↓ 24 callersMethodcheckIndex

(int pos, int length)

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

↓ 24 callersMethodcreateBinaryClient

Creates a new {@link BinaryLogClient} for consuming mysql binlog.

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

↓ 24 callersMethodequals

(Object o)

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

↓ 24 callersMethodgetChangePosition

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/io/debezium/connector/sqlserver/SqlServerOffsetContext.java:115

↓ 24 callersMethodgetDecimal

Returns the decimal value at the given position. <p>The precision and scale are required to determine whether the decimal value was stored in a compa

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

↓ 24 callersMethodgetEndingOffset

()

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

↓ 24 callersMethodgetHost

()

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

← previous next →301–400 of 12,620, ranked by callers