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
↓ 3,180 callersMethodassertThat
(Event event)
flink-cdc-common/src/test/java/org/apache/flink/cdc/common/testutils/assertions/EventAssertions.java:34
↓ 2,495 callersMethodphysicalColumn
Creates a physical column.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/schema/Column.java:171
↓ 2,062 callersMethodadd
Add a value to the array.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/variant/VariantBuilder.java:104
↓ 1,727 callersMethodget
(MySqlSourceReaderMetrics metrics, MySqlSourceConfig sourceConfig)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlSource.java:295
↓ 1,587 callersMethodformat
Transforms itself into String representation using given format. @param formatter formatter to use.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description/DescriptionElement.java:30
↓ 1,284 callersMethodof
Create a {@link FlinkSinkProvider} from a {@link Sink}.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/FlinkSinkProvider.java:35
↓ 1,274 callersMethodSTRING
Data type of a variable-length character string with defined maximum length. This is a shortcut for {@code VARCHAR(2147483647)} for representing JVM s
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypes.java:159
↓ 936 callersMethodfromString
Creates a {@link BinaryStringData} instance from the given Java string.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryStringData.java:75
↓ 926 callersMethodasList
Defines that the option's type should be a list of previously defined atomic type.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/ConfigOptions.java:176
↓ 923 callersMethodexecute
Execute current task.
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/external/FetchTask.java:43
↓ 834 callersMethodtoString
Converts this {@link StringData} object to a {@link String}.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/StringData.java:36
↓ 760 callersMethodINT
Data type of a 4-byte signed integer with values from -2,147,483,648 to 2,147,483,647. @see IntType
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypes.java:81
↓ 712 callersMethoddefaultValue
Returns the default value, or null, if there is no default value. @return The default value, or null.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/ConfigOption.java:204
↓ 695 callersMethodsize
Returns the number of key-value mappings in this map.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/MapData.java:36
↓ 694 callersMethodbuild
(TypeRegistry registry)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/PostgresConnection.java:882
↓ 634 callersMethodgenerate
Creates an instance of {@link BinaryRecordData} with given field values. <p>Note: All fields of the record must be internal data structures. See {@li
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/typeutils/BinaryRecordDataGenerator.java:75
↓ 594 callersMethodinsertEvent
Creates a {@link DataChangeEvent} instance that describes the insert event.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/DataChangeEvent.java:100
↓ 573 callersMethodmap
(PartitioningEvent value)
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PostPartitionProcessor.java:30
↓ 559 callersMethodget
Get the scalar value of variant. @throws VariantTypeException If this variant is not a scalar value.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/variant/Variant.java:161
↓ 552 callersMethodset
(ConfigOption<T> option, T value)
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/Configuration.java:130
↓ 509 callersMethodnewBuilder
Builder for configuring and creating instances of {@link Schema}.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/schema/Schema.java:254
↓ 479 callersMethodnotNull
()
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java:153
↓ 459 callersMethodprimaryKey
Declares a primary key constraint for a set of given columns. Primary key uniquely identify a row in a table. Neither of columns in a primary can be n
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/schema/Schema.java:441
↓ 450 callersMethodkey
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/io/debezium/embedded/EmbeddedEngineChangeEvent.java:30
↓ 447 callersMethodbuild
Build the variant array.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/variant/VariantBuilder.java:107
↓ 437 callersMethodexecute
Execute the pipeline.
flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/PipelineExecution.java:24
↓ 386 callersMethodvalueOf
@param value numeric represent position in the write-ahead log stream @return not null LSN instance
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/Lsn.java:43
↓ 375 callersMethodtableId
The mapping relationship for external systems. e.g. Oracle (database, schema, table).
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java:62
↓ 367 callersMethodVARCHAR
Data type of a variable-length character string {@code VARCHAR(n)} where {@code n} is the maximum number of code points. {@code n} must have a value b
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypes.java:149
↓ 351 callersMethodgetString
Returns the string value at the given position.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/ArrayData.java:76
↓ 350 callersMethodwithDescription
Creates a new config option, using this option's key and default value, and adding the given description. The given description is used when generatio
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/ConfigOption.java:164
↓ 340 callersMethodkey
Starts building a new {@link ConfigOption}. @param key The key for the config option. @return The builder for the config option with the given key.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/ConfigOptions.java:76
↓ 319 callersMethodBIGINT
Data type of an 8-byte signed integer with values from -9,223,372,036,854,775,808 to 9,223,372,036,854,775,807. @see BigIntType
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypes.java:109
↓ 306 callersMethodgetDatabaseName
()
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oracle/src/test/java/org/testcontainers/containers/OracleContainer.java:155
↓ 293 callersMethodnext
Obtain the next character value, and advance the stream. @return the next character @throws NoSuchElementException if there is no {@link #hasNext() n
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/text/TokenStream.java:382
↓ 275 callersMethodcontains
Checks whether there is an entry for the given config option. @param configOption The configuration option @return <tt>true</tt> if a valid (current
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/Configuration.java:93
↓ 268 callersMethodtableId
Describes the database table corresponding to the occurrence of a change event.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/ChangeEvent.java:30
↓ 266 callersMethodFIELD
Field definition with field name and data type.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypes.java:381
↓ 262 callersMethodDOUBLE
Data type of an 8-byte double precision floating point number. @see DoubleType
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypes.java:127
↓ 246 callersMethoderror
(String message, Exception exception)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlValueConverters.java:63
↓ 244 callersMethodsplit
(SplitContext splitContext)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/assigners/splitters/SplitStrategy.java:36
↓ 242 callersMethodcheckNotNull
Ensures that the given object reference is not null. Upon violation, a {@code NullPointerException} with no message is thrown. @param reference The o
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/Preconditions.java:42
↓ 240 callersMethodDECIMAL
Data type of a decimal number with fixed precision and scale {@code DECIMAL(p, s)} where {@code p} is the number of digits in a number (=precision) an
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypes.java:172
↓ 226 callersMethodTIMESTAMP
Data type of a timestamp WITHOUT time zone {@code TIMESTAMP} with 6 digits of fractional seconds by default. <p>An instance consists of {@code year-m
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypes.java:238
↓ 222 callersMethodgetDatabaseName
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/test/java/org/testcontainers/containers/OracleContainer.java:155
↓ 213 callersMethodserialize
(InputT in)
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:34
↓ 210 callersMethodparse
(String tableId)
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java:77
↓ 205 callersMethodgetHost
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/testutils/UniqueDatabase.java:82
↓ 198 callersMethodcreate
(int subtask)
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/config/SourceConfig.java:49
↓ 189 callersMethodFLOAT
Data type of a 4-byte single precision floating point number. @see FloatType
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypes.java:118
↓ 183 callersMethodparse
Parse the specified pipeline definition file path, merge global configurations, then generate the {@link PipelineDef}.
flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/parser/PipelineDefinitionParser.java:31
↓ 176 callersMethodstringType
()
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java:114
↓ 175 callersMethodlength
Get the length of the token, which is equivalent to <code>endIndex() - startIndex() </code>. @return the length
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/text/TokenStream.java:531
↓ 172 callersMethodcolumn
Get the 1-based column number of the character. @return the column number; always positive
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/text/Position.java:58
↓ 171 callersMethodisNull
Check If this variant is null.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/variant/Variant.java:46
↓ 170 callersMethodgetDatabaseName
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/testutils/UniqueDatabase.java:90
↓ 166 callersMethodget
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/PostgresStreamingChangeEventSource.java:528
↓ 165 callersMethodTIMESTAMP_LTZ
Data type of a timestamp WITH LOCAL time zone {@code TIMESTAMP(p) WITH LOCAL TIME ZONE} where {@code p} is the number of digits of fractional seconds
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypes.java:321
↓ 163 callersMethodname
Unique name for the connector. Attempting to register again with the same name will fail. This property is required by all Kafka Connect connectors. D
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/VitessSource.java:190
↓ 162 callersMethodgetOutputRecords
()
flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/testutils/operators/RegularEventOperatorTestHarness.java:217
↓ 159 callersMethodTIME
Data type of a time WITHOUT time zone {@code TIME} with no fractional seconds by default. <p>An instance consists of {@code hour:minute:second} with
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypes.java:201
↓ 157 callersMethodcollect
(T element)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-test-util/src/main/java/org/apache/flink/cdc/connectors/utils/TestSourceContext.java:33
↓ 157 callersMethodgetDatabasePort
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/testutils/UniqueDatabase.java:86
↓ 154 callersMethodgetResource
Searches for a resource file matching the given regex in the given directory. This method is primarily intended to be used for the initialization of s
flink-cdc-e2e-tests/flink-cdc-e2e-utils/src/test/java/org/apache/flink/cdc/common/test/utils/TestUtils.java:47
↓ 152 callersMethodpoll
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/internal/MongoDBConnectorSourceTask.java:134
↓ 151 callersMethodnoDefaultValue
Creates a ConfigOption without a default value. @return The config option without a default value.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/ConfigOptions.java:232
↓ 149 callersMethodfromMap
Creates a new configuration that is initialized with the options of the given map.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/Configuration.java:64
↓ 146 callersMethodhasNext
Determine if there is another character available in this stream. @return true if there is another character (and {@link #next()} can be called), or
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/text/TokenStream.java:374
↓ 144 callersMethodsetParallelism
(int parallelism)
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:53
↓ 140 callersMethodtestFilterExpression
(String expression, String expressionExpect)
flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/parser/TransformParserTest.java:867
↓ 139 callersMethodgetMessage
()
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/UncheckedOdpsException.java:38
↓ 136 callersMethodBOOLEAN
Data type of a boolean with a (possibly) three-valued logic of {@code TRUE, FALSE, UNKNOWN}. @see BooleanType
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypes.java:72
↓ 135 callersMethodgetName
Get the name of dialect.
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/dialect/DataSourceDialect.java:46
↓ 135 callersMethodof
(Object... args)
flink-cdc-common/src/test/java/org/apache/flink/cdc/common/utils/SchemaMergingUtilsTest.java:1178
↓ 134 callersMethodgetSchemaName
()
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java:104
↓ 133 callersMethodexecuteSql
(MySqlSourceConfig sourceConfig, String[] sqlStatements)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/debezium/reader/SnapshotSplitReaderTest.java:743
↓ 132 callersMethodclose
Close the reader and releases all resources.
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/reader/DebeziumReader.java:38
↓ 130 callersMethodfromBigDecimal
Creates an instance of {@link DecimalData} from a {@link BigDecimal} and the given precision and scale. <p>The returned decimal value may be rounded
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/DecimalData.java:180
↓ 127 callersMethodcancel
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/DebeziumSourceFunction.java:516
↓ 122 callersMethodgetValue
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/ChunkSplitterState.java:116
↓ 119 callersMethodgetTableId
(E data)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlStreamingChangeEventSource.java:1584
↓ 119 callersMethodtrim
Returns a string whose value is this string, with any leading and trailing whitespace removed. @return A string whose value is this string, with any
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryStringData.java:510
↓ 117 callersMethodcheckArgument
Checks the given boolean condition, and throws an {@code IllegalArgumentException} if the condition is not met (evaluates to {@code false}). @param c
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/Preconditions.java:105
↓ 117 callersMethodgetType
Get the type of variant.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/variant/Variant.java:49
↓ 116 callersMethodgetName
Column name.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/source/SupportedMetadataColumn.java:31
↓ 116 callersMethodvalueOf
(BinaryArrayData key, BinaryArrayData value)
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryMapData.java:106
↓ 116 callersMethodwriteInt
(int pos, int value)
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/writer/BinaryWriter.java:63
↓ 115 callersMethodgetExecutionEnvironment
()
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/SpecificStartingOffsetITCase.java:602
↓ 115 callersMethodset
( final Map<ByteBuffer, ByteBuffer> values, final Callback<Void> callback)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/internal/FlinkOffsetBackingStore.java:191
↓ 114 callersMethodcollect
(StreamRecord<E> record)
flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/testutils/operators/RegularEventOperatorTestHarness.java:316
↓ 111 callersMethodTINYINT
Data type of a 1-byte signed integer with values from -128 to 127. @see TinyIntType
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypes.java:90
↓ 111 callersMethodread
(SourceRecord record)
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/table/MetadataConverter.java:31
↓ 111 callersMethodremove
Removes given config option from the configuration. @param configOption config option to remove @param <T> Type of the config option @return true is
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/Configuration.java:164
↓ 111 callersMethodvalue
Get the value of the token, in actual case. @return the value
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/text/TokenStream.java:465
↓ 110 callersMethodcopy
Creates a copy of {@link SchemaChangeEvent} with new {@link TableId}.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/SchemaChangeEvent.java:34
↓ 110 callersMethodgetSource
Get the {@link Source} for reading events from external systems.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/source/FlinkSourceProvider.java:32
↓ 109 callersMethodSMALLINT
Data type of a 2-byte signed integer with values from -32,768 to 32,767. @see SmallIntType
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypes.java:99
↓ 109 callersMethodbuildRecord
(final Object... args)
flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/operators/schema/regular/SchemaEvolveTest.java:2574
↓ 108 callersMethodROW
Data type of a sequence of fields. A field consists of a field name, field type, and an optional description. The most specific type of a row of a tab
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypes.java:406
↓ 107 callersMethodhash
hash segments to int. @param segments Source segments. @param offset Source segments offset. @param numBytes the number bytes to hash.
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySegmentUtils.java:394
next →1–100 of 12,620, ranked by callers