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-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/utils/TemporalConversions.java:46

↓ 19 callersMethodvalidateExcept

Validates the options of the factory. It checks for unconsumed option keys while ignoring the options with given prefixes. <p>The option keys that ha

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

↓ 19 callersMethodwithStartupTimeout

(Duration timeout)

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

↓ 18 callersMethodaddSplits

Adds a set of splits to this assigner. This happens for example when some split processing failed and the splits need to be re-added.

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

↓ 18 callersMethodafter

()

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

↓ 18 callersMethodafter

( Column addColumn, String existedColumnName)

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

↓ 18 callersMethodasBinlogSplit

Casts this split into a {@link MySqlBinlogSplit}.

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

↓ 18 callersMethodbefore

( Column addColumn, String existedColumnName)

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

↓ 18 callersMethodcollect

(SourceRecord record)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/test/java/org/apache/flink/cdc/connectors/postgres/source/reader/PostgresSourceReaderTest.java:360

↓ 18 callersMethodcopyToBytes

Copy segments to a new byte[]. @param segments Source segments. @param offset Source segments offset. @param numBytes the number bytes to copy.

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

↓ 18 callersMethodcreateAndInitialize

(String sqlFile)

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

↓ 18 callersMethodequals

(Object o)

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

↓ 18 callersMethodexecuteSql

(String... statements)

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

↓ 18 callersMethodexecuteSql

(String sql)

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

↓ 18 callersMethodexpectInPostTransformed

(SchemaChangeEvent event)

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

↓ 18 callersMethodfromMillisOfDay

(int millisOfDay)

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

↓ 18 callersMethodfromZonedDateTime

Creates an instance of {@link ZonedTimestampData} from an instance of {@link LocalDateTime}. @param zonedDateTime an instance of {@link ZonedDateTime

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

↓ 18 callersMethodgetColumnSize

()

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

↓ 18 callersMethodgetOptions

()

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

↓ 18 callersMethodgetRecord

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

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

↓ 18 callersMethodgetSizeInBytes

Gets the size in bytes of this binary data.

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

↓ 18 callersMethodgetTableSchema

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

↓ 18 callersMethodgetTransactionId

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

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

↓ 18 callersMethodgetType

()

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/variant/BinaryVariant.java:116

↓ 18 callersMethodparse

Parse the specified pipeline definition file.

flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/parser/YamlPipelineDefinitionParser.java:114

↓ 18 callersMethodsetColumns

(List<OceanBaseColumn> columns)

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

↓ 18 callersMethodstart

(final long startTs)

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

↓ 18 callersMethodtestRoute

(String tableId)

flink-cdc-runtime/src/test/java/org/apache/flink/cdc/common/route/TableIdRouterTest.java:38

↓ 18 callersMethodtoEpochDay

()

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

↓ 18 callersMethodvalidateSinkResult

( String databaseName, String tableName, int columnCount, List<String> expected)

flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/MySqlToDorisE2eITCase.java:985

↓ 18 callersMethodwriteAndCommit

( PaimonWriter<Event> writer, Committer<MultiTableCommittable> committer, Event... events)

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

↓ 17 callersMethodVARIANT

()

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

↓ 17 callersMethodaddAll

(List<T> values)

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

↓ 17 callersMethodaddAll

(List<T> values)

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

↓ 17 callersMethodarray

Get the builder for a variant array.

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

↓ 17 callersMethodassertInsert

(SourceRecord record, boolean keyExpected)

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

↓ 17 callersMethodcheckCapacity

(int additional)

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

↓ 17 callersMethodcollect

(RowData record)

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

↓ 17 callersMethodconcat

(String... str)

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/functions/impl/StringFunctions.java:64

↓ 17 callersMethodconvert

(Object object, TiTableInfo tableInfo, DataType dataType)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiKVDeserializationRuntimeConverter.java:31

↓ 17 callersMethoddoubleCompare

Compares two Double numeric object. @return -1, 0, or 1 as this {@code arg1} is numerically less than, equal to, or greater than {@code arg2}.

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

↓ 17 callersMethodfetchResultsAndCreateTableEvent

( Iterator<T> iter, int size)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-postgres/src/test/java/org/apache/flink/cdc/connectors/postgres/source/PostgresFullTypesITCase.java:1092

↓ 17 callersMethodfetchRows

(Iterator<Row> iter, int size)

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

↓ 17 callersMethodfindSplitByKeyBinary

Uses binary search to find the split containing the specified key in a sorted split list. <p>IMPORTANT: The splits list MUST be sorted by splitStart

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

↓ 17 callersMethodgetConnection

()

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

↓ 17 callersMethodgetKeyType

()

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java:55

↓ 17 callersMethodgetLeastCommonSchema

Try to merge {@code upcomingSchema} into {@code currentSchema} by performing lenient schema changes. Returns a wider schema that could both of them.

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

↓ 17 callersMethodgetMillisecond

Returns the number of milliseconds since {@code 1970-01-01 00:00:00}.

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

↓ 17 callersMethodgetOdps

(MaxComputeOptions maxComputeOptions)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/utils/MaxComputeUtils.java:51

↓ 17 callersMethodgetSerializer

()

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

↓ 17 callersMethodgetServerId

(int parallelism)

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

↓ 17 callersMethodgetSplitSize

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

↓ 17 callersMethodgetStartupOptions

()

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

↓ 17 callersMethodgetTableInfo

(TableId tableId)

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

↓ 17 callersMethodgetTableSchemas

()

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

↓ 17 callersMethodgetValueType

()

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java:59

↓ 17 callersMethodlongType

Defines that the value of the option should be of {@link Long} type.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/ConfigOptions.java:119

↓ 17 callersMethodmetricGroup

()

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

↓ 17 callersMethodsetProducerThrowable

(Throwable producerThrowable)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/task/context/MySqlErrorHandler.java:62

↓ 17 callersMethodsinkTo

( DataStream<Event> input, Sink<Event> sink, String sinkName,

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/translator/DataSinkTranslator.java:121

↓ 17 callersMethodwithPassword

(String password)

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

↓ 17 callersMethodwrap

(R response)

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

↓ 17 callersMethodwrite

(Event event, Context context)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2/IcebergWriter.java:149

↓ 16 callersMethodapplyOriginalSchemaChange

Apply schema change to a table.

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

↓ 16 callersMethodcreateAndInitialize

Creates the database and populates it with initialization SQL script.

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

↓ 16 callersMethodcreateConnection

(Map<String, String> properties)

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

↓ 16 callersMethodcreateDataSource

(Context context)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/factory/MySqlDataSourceFactory.java:116

↓ 16 callersMethodcreateMySqlBinlogSource

( String offsetFile, int offsetPos, boolean useLegacyImplementation)

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

↓ 16 callersMethodcreateSplit

( TableId tableId, String splitId, Object[] splitStart, Object[] splitEnd)

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

↓ 16 callersMethoddestroyHarness

()

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

↓ 16 callersMethodequals

(Object o)

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

↓ 16 callersMethodfromUnscaledLong

Creates an instance of {@link DecimalData} from an unscaled long value and the given precision and scale.

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

↓ 16 callersMethodgetAddedColumns

Returns the added columns.

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

↓ 16 callersMethodgetCause

()

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

↓ 16 callersMethodgetCollectedOutputs

()

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

↓ 16 callersMethodgetDroppedColumnNames

()

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/DropColumnEvent.java:43

↓ 16 callersMethodgetElementOffset

(int pos, int elementSize)

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

↓ 16 callersMethodgetElementOrNull

(ArrayData array, int pos)

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

↓ 16 callersMethodgetKey

()

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/FallbackKey.java:41

↓ 16 callersMethodgetLatestEvolvedSchema

Get the latest evolved schema of the specified table.

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

↓ 16 callersMethodgetPipelineConfiguration

Returns the configuration of current pipeline.

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

↓ 16 callersMethodgetSink

Get the {@link Sink} for writing events to external systems.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/FlinkSinkProvider.java:32

↓ 16 callersMethodgetSplitKeyType

()

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

↓ 16 callersMethodgetTypeMapping

Returns the type mapping.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/AlterColumnTypeEvent.java:81

↓ 16 callersMethodinitializeHarness

()

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

↓ 16 callersMethodisArray

Returns true if this variant is an Array, false otherwise.

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

↓ 16 callersMethodof

Creates an instance of {@link ZonedTimestampData} from milliseconds and nanos-of-millisecond with the given zoneId. @param millisecond the number of

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

↓ 16 callersMethodof

( TableId tableId, String projectionExpression, String filterE

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

↓ 16 callersMethodprimitiveHeader

(int type)

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

↓ 16 callersMethodprocessElement

(StreamRecord<Event> element)

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PreTransformOperator.java:162

↓ 16 callersMethodresolveSchemaEvolutionTag

(String tag)

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/ChangeEventUtils.java:75

↓ 16 callersMethodreverseLookupSchema

(String tableId)

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

↓ 16 callersMethodreverseLookupTable

(String tableId)

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

↓ 16 callersMethodrunInContainerAsRoot

(GenericContainer<?> container, String... command)

flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/utils/PipelineTestEnvironment.java:442

↓ 16 callersMethodrunTests

()

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

↓ 16 callersMethodsubmitSplit

(MySqlSplit mySqlSplit)

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

↓ 16 callersMethodtestGenericTableMatching

( String tablesConfig, @Nullable String tablesExclude, boolean scanBinlogN

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

↓ 16 callersMethodtoBigDecimal

(Object numericObj)

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

↓ 16 callersMethodtoFlinkDataType

Convert CDC's {@link DataType} to Flink's internal {@link org.apache.flink.table.types.DataType}.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/utils/DataTypeUtils.java:99

↓ 16 callersMethodtoLocalDateTime

(Object obj, ZoneId serverTimeZone)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/utils/TemporalConversions.java:134

← previous next →501–600 of 12,620, ranked by callers