MCPcopy Index your code

hub / github.com/apache/flink-cdc / functions

Functions12,620 in github.com/apache/flink-cdc

⨍ Functions 12,620◇ Types & classes 1,927
↓ 106 callersMethodARRAY
Data type of an array of elements with same subtype. <p>Compared to the SQL standard, the maximum cardinality of an array cannot be specified but is
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypes.java:360
↓ 106 callersMethodvalidateResult
(String... expectedEvents)
flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/utils/PipelineTestEnvironment.java:466
↓ 103 callersMethodexecuteSql
(String sql)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/test/java/org/apache/flink/cdc/connectors/db2/Db2TestBase.java:273
↓ 101 callersMethodcreateAndInitialize
Creates the database and populates it with initialization SQL script.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/testutils/UniqueDatabase.java:110
↓ 100 callersMethodcommit
()
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/writer/MaxComputeWriter.java:55
↓ 99 callersMethodgetTableName
()
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java:93
↓ 99 callersMethodof
(DataType... types)
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java:162
↓ 99 callersMethodprocessElement
(StreamRecord<Event> element)
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PostTransformOperator.java:141
↓ 98 callersMethoddeserialize
Deserialize given record to {@link Event}s.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/EventDeserializer.java:30
↓ 98 callersMethodget
(ConfigOption<T> option)
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/Configuration.java:107
↓ 95 callersMethodstartsWith
Tests if this BinaryStringData starts with the specified prefix. @param prefix the prefix. @return {@code true} if the bytes represented by the argum
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryStringData.java:482
↓ 93 callersMethodupdateEvent
Creates a {@link DataChangeEvent} instance that describes the update event.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/DataChangeEvent.java:128
↓ 90 callersMethodcheckState
Checks the given boolean condition, and throws an {@code IllegalStateException} if the condition is not met (evaluates to {@code false}). @param cond
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/Preconditions.java:144
↓ 89 callersMethodgetColumnDataTypes
Returns all column data types. It does not distinguish between different kinds of columns.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/schema/Schema.java:125
↓ 89 callersMethodisNullable
()
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java:94
↓ 86 callersMethodconvertToInternal
(Object obj, DataType dataType)
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/converter/InternalObjectConverter.java:170
↓ 85 callersMethodDATE
Data type of a date consisting of {@code year-month-day} with values ranging from {@code 0000-01-01} to {@code 9999-12-31}. <p>Compared to the SQL st
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypes.java:184
↓ 85 callersMethodgetTableName
()
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java:109
↓ 85 callersMethodwith
(OP operator, int numOutputs)
flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/testutils/operators/RegularEventOperatorTestHarness.java:134
↓ 84 callersMethodCHAR
Data type of a fixed-length character string {@code CHAR(n)} where {@code n} is the number of code points. {@code n} must have a value between 1 and {
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypes.java:138
↓ 84 callersMethodcompose
(PipelineDef pipelineDef)
flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/FlinkPipelineComposer.java:99
↓ 84 callersMethodconvertToJava
(Object obj, DataType dataType)
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/converter/JavaObjectConverter.java:166
↓ 84 callersMethodofMiniCluster
()
flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/FlinkPipelineComposer.java:89
↓ 84 callersMethodsubmitPipelineJob
Submits a YAML job to the running cluster with latest CDC version, without from previous savepoint states.
flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/utils/PipelineTestEnvironment.java:238
↓ 82 callersMethodBINARY
Data type of a fixed-length binary string (=a sequence of bytes) {@code BINARY(n)} where {@code n} is the number of bytes. {@code n} must have a value
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypes.java:41
↓ 81 callersMethoddatabaseList
An optional list of regular expressions that match database names to be monitored; any database name not included in the whitelist will be excluded fr
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/MySqlSource.java:91
↓ 81 callersMethodfromMillis
Creates an instance of {@link TimestampData} from milliseconds and a nanos-of-millisecond. @param milliseconds the number of milliseconds since {@cod
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/TimestampData.java:142
↓ 79 callersMethodfromInstant
Creates an instance of {@link LocalZonedTimestampData} from an instance of {@link Instant}. @param instant an instance of {@link Instant}
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/LocalZonedTimestampData.java:167
↓ 79 callersMethodgetFieldOrNull
(RecordData recordData)
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/RecordData.java:273
↓ 79 callersMethodgetPrecision
()
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java:70
↓ 79 callersMethodsetDataType
(String dataType)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java:181
↓ 78 callersMethodgetBytes
Get the scalar value of variant as byte array, if the variant type is {@link Type#BYTES}. @throws VariantTypeException If this variant is not a scala
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/variant/Variant.java:154
↓ 77 callersMethodgetColumns
()
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java:101
↓ 76 callersMethodcollect
( org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext<Event>
flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/testsource/source/DistributedSourceFunction.java:271
↓ 76 callersMethodgetKey
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/Db2ReadableMetaData.java:113
↓ 76 callersMethodintType
Defines that the value of the option should be of {@link Integer} type.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/ConfigOptions.java:114
↓ 76 callersMethodsetNullable
(boolean isNullable)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java:186
↓ 75 callersMethodTIMESTAMP_TZ
Data type of a timestamp WITH time zone {@code TIMESTAMP WITH TIME ZONE} with 6 digits of fractional seconds by default. <p>An instance consists of {
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypes.java:275
↓ 74 callersMethodassertEqualsInAnyOrder
(List<T> expected, List<T> actual)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/MySqlSourceTestBase.java:110
↓ 74 callersMethodopen
This will be invoked every time when a UDF got created. <p>this method is {@link Deprecated}, please use {@link #open(UserDefinedFunctionContext)} in
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/udf/UserDefinedFunction.java:39
↓ 73 callersMethodidentifier
Returns a unique identifier among same factory interfaces.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/factories/Factory.java:48
↓ 73 callersMethodsplitId
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplit.java:58
↓ 72 callersMethodapplySchemaChange
Apply the given {@link SchemaChangeEvent} to external systems.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/MetadataApplier.java:36
↓ 72 callersMethodisNullable
Returns whether a value of this type can be {@code null}.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java:42
↓ 71 callersMethoddeleteEvent
Creates a {@link DataChangeEvent} instance that describes the delete event.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/DataChangeEvent.java:114
↓ 71 callersMethodgetClassLoader
Returns the class loader of the current session. <p>The class loader is in particular useful for discovering factories.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/factories/Factory.java:81
↓ 71 callersMethodgetInt
Returns the integer value at the given position.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/ArrayData.java:64
↓ 71 callersMethodid
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/LegacyMySqlSourceTest.java:1340
↓ 71 callersMethodrun
Called by Flink runtime to run the source. This implementation delegates to the new SourceContext version.
flink-cdc-flink2-compat/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java:34
↓ 71 callersMethodtestExpressionConditionTransform
(String expression)
flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/operators/transform/PostTransformOperatorTest.java:2924
↓ 71 callersMethodwaitUntilSpecificEvent
(String event)
flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/utils/PipelineTestEnvironment.java:489
↓ 70 callersMethodfromEpochMillis
Creates an instance of {@link LocalZonedTimestampData} from epoch milliseconds. <p>The nanos-of-millisecond field will be set to zero. @param millis
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/LocalZonedTimestampData.java:144
↓ 70 callersMethodgetTypeRoot
Returns the root of this type. It is an essential description without additional parameters.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java:49
↓ 69 callersMethodgetOptional
(ConfigOption<T> option)
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/Configuration.java:111
↓ 69 callersMethodreplace
( RecordData cdcRecord, Integer rowFieldCount, Map<Integer, Integer> indexMapping)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/row/row/CdcAsFlussRow.java:59
↓ 69 callersMethodsubstring
Returns a binary string that is a substring of this binary string. The substring begins at the specified {@code beginIndex} and extends to the charact
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryStringData.java:388
↓ 68 callersMethodserverTimeZone
The session time zone in database server, e.g. "America/Los_Angeles". It controls how the TIMESTAMP type in MYSQL converted to STRING. See more https:
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/MySqlSource.java:124
↓ 68 callersMethodtoRowDataType
Converts all columns of this schema into a (possibly nested) row data type. @see DataTypes#ROW(DataField...)
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/schema/Schema.java:178
↓ 67 callersMethodBYTES
Data type of a variable-length binary string (=a sequence of bytes) with defined maximum length. This is a shortcut for {@code VARBINARY(2147483647)}
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypes.java:63
↓ 67 callersMethodgetJdbcConnection
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/testutils/UniqueDatabase.java:163
↓ 67 callersMethodprimaryKeys
Returns the primary keys of the table or data collection.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/schema/Schema.java:135
↓ 66 callersMethodfield
(String name, DataType type)
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java:205
↓ 66 callersMethodgetOffset
Gets the start offset of this binary data in the {@link MemorySegment}s.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryFormat.java:60
↓ 66 callersMethodmatches
Determine if the token matches the supplied string. @param expected the expected value @return true if the token's value matches the supplied value,
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/text/TokenStream.java:473
↓ 65 callersMethodkeySet
Returns the keys of all key/value pairs stored inside this configuration object. @return the keys of all key/value pairs stored inside this configura
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/Configuration.java:141
↓ 65 callersMethodwithLogConsumer
(Consumer<OutputFrame> consumer)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/test/java/org/apache/flink/cdc/connectors/mongodb/utils/MongoDBContainer.java:100
↓ 64 callersMethodsetColumnName
(String columnName)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java:171
↓ 63 callersMethodclose
Closes the metadata applier and its underlying resources.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/MetadataApplier.java:55
↓ 62 callersMethodaddAll
(List<T> values)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/test/java/org/apache/flink/cdc/connectors/db2/Db2SourceTest.java:578
↓ 62 callersMethodsetOrdinalPosition
(int ordinalPosition)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java:176
↓ 62 callersMethodwrap
(Event payload)
flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaTestBase.java:124
↓ 61 callersMethodfromString
(String kindString)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/dispatcher/SignalEventDispatcher.java:116
↓ 61 callersMethodisNullOrWhitespaceOnly
Checks if the string is null, empty, or contains only whitespace characters. A whitespace character is defined via {@link Character#isWhitespace(char)
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/StringUtils.java:29
↓ 61 callersMethodtoUpperCase
Converts all of the characters in this {@code BinaryStringData} to upper case. @return the {@code BinaryStringData}, converted to uppercase.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryStringData.java:643
↓ 60 callersMethodbooleanType
Defines that the value of the option should be of {@link Boolean} type.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/ConfigOptions.java:109
↓ 59 callersMethodVARBINARY
Data type of a variable-length binary string (=a sequence of bytes) {@code VARBINARY(n)} where {@code n} is the maximum number of bytes. {@code n} mus
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypes.java:52
↓ 59 callersMethodgetConnection
(boolean isMySQL)
flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/OceanBaseE2eITCase.java:298
↓ 59 callersMethodgetId
()
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/writer/MaxComputeWriter.java:57
↓ 59 callersMethodmatches
Determine if the uppercase form of a column's type exactly matches or begins with the specified prefix. Note that this logic works when the column's {
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlValueConverters.java:672
↓ 59 callersMethodwaitUntilJobRunning
(JobID jobId, Duration timeout)
flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/MySqlToHudiE2eITCase.java:762
↓ 56 callersMethodclose
Close the client and releases all resources.
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/external/Fetcher.java:49
↓ 56 callersMethodgetDatabase
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/offset/ChangeStreamDescriptor.java:52
↓ 56 callersMethodgetHost
()
flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/utils/factory/DataSinkFactory1.java:62
↓ 56 callersMethodgetLong
Returns the long value at the given position.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/ArrayData.java:67
↓ 56 callersMethodgetPassword
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/testutils/UniqueDatabase.java:98
↓ 56 callersMethodgetUsername
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/testutils/UniqueDatabase.java:94
↓ 55 callersMethodgetColumns
Returns all {@link Column}s of this schema.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/schema/Schema.java:108
↓ 55 callersMethodtoMap
()
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/Configuration.java:147
↓ 54 callersMethodexecuteSql
(String sql)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/test/java/org/apache/flink/cdc/connectors/oracle/source/OracleSourceITCase.java:795
↓ 52 callersMethodbuilder
()
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java:186
↓ 52 callersMethodfromTimestamp
Creates an instance of {@link TimestampData} from an instance of {@link Timestamp}. @param timestamp an instance of {@link Timestamp}
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/TimestampData.java:163
↓ 52 callersMethodgetCollection
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/offset/ChangeStreamDescriptor.java:57
↓ 52 callersMethodgetValue
()
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/variant/BinaryVariant.java:260
↓ 52 callersMethodtoInstant
(String ts)
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/test/java/org/apache/flink/cdc/connectors/mysql/source/MySqlFullTypesITCase.java:557
↓ 52 callersMethodtoLowerCase
Converts all of the characters in this {@code BinaryStringData} to lower case. @return the {@code BinaryStringData}, converted to lowercase.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryStringData.java:680
↓ 51 callersMethodbuilder
Create a {@link BinlogOffsetBuilder}.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/offset/BinlogOffset.java:62
↓ 51 callersMethodcontains
(RelDataType type)
flink-cdc-runtime/src/main/java/org/apache/calcite/sql/type/SqlTypeFamily.java:284
↓ 51 callersMethodfromString
(String kindString)
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/wartermark/WatermarkKind.java:26
↓ 51 callersMethodgetBoolean
Returns the boolean value at the given position.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/ArrayData.java:55
↓ 50 callersMethodapplySchemaChangeEvent
apply SchemaChangeEvent to the old schema and return the schema after changing.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/SchemaUtils.java:108
← previousnext →101–200 of 12,620, ranked by callers