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-runtime/src/test/java/org/apache/flink/cdc/runtime/serializer/data/ArrayDataSerializerTest.java:95

Creates a runtime converter which is null safe.

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

↓ 4 callersMethodcreateDataSink

(DataSinkFactory sinkFactory, Configuration conf)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/test/java/org/apache/flink/cdc/connectors/elasticsearch/sink/ElasticsearchDataSinkFactoryTest.java:202

↓ 4 callersMethodcreateDb2Connection

( RelationalDatabaseConnectorConfig connectorConfig)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/utils/Db2ConnectionUtils.java:41

↓ 4 callersMethodcreateDb2Source

(String tableName)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/test/java/org/apache/flink/cdc/connectors/db2/Db2SourceTest.java:323

↓ 4 callersMethodcreateFetchTask

The fetch task used to fetch data of a snapshot split or stream split.

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/dialect/DataSourceDialect.java:79

↓ 4 callersMethodcreateFieldGetters

create a list of {@link RecordData.FieldGetter} from given {@link Schema} to get Object from RecordData. <p>This method is a modified version of {@li

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

↓ 4 callersMethodcreateMongoDBSource

(String database)

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

↓ 4 callersMethodcreateMySqlContainer

(String timezone)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/debezium/converters/MysqlDebeziumTimeConverterITCase.java:253

↓ 4 callersMethodcreateOffsetContext

(String gtidSetStr)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/io/debezium/connector/mysql/FilterGtidSetTest.java:120

↓ 4 callersMethodcreateSnapshotSplit

Generates all snapshot splits (chunks) from chunk ranges.

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/JdbcSourceChunkSplitter.java:534

↓ 4 callersMethodcreateSourceWithConfig

( GtidNewChannelPosition channelPosition, Predicate<String> gtidSourceFilter)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/io/debezium/connector/mysql/FilterGtidSetTest.java:102

↓ 4 callersMethodcreateTableSource

(Map<String, String> options)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/test/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableFactoryTest.java:265

↓ 4 callersMethodcreateUpdatedCatalogTable

( ResolvedCatalogTable existingTable, ResolvedSchema newSchema)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-hudi/src/main/java/org/apache/flink/cdc/connectors/hudi/sink/HudiMetadataApplier.java:487

↓ 4 callersMethodcreateWatermarkPartitionMap

(String partition)

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

↓ 4 callersMethodcustomerDocOf

(Long cid, String name, String address, String phoneNumber)

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

↓ 4 callersMethodcustomerDocOf

(Long cid, String name, String address, String phoneNumber)

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

↓ 4 callersMethoddatabaseList

A required list of regular expressions that match database names to be monitored; any database name not included in the whitelist will be excluded fro

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/source/SqlServerSourceBuilder.java:65

↓ 4 callersMethoddatabaseList

An required 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-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/OracleSourceBuilder.java:71

↓ 4 callersMethoddatabaseNames

( MongoClient mongoClient, Predicate<String> databaseFilter)

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

↓ 4 callersMethoddecodingPluginName

The name of the Postgres logical decoding plug-in installed on the server. Supported values are decoderbufs, wal2json, wal2json_rds, wal2json_streamin

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

↓ 4 callersMethoddeployment

(Pattern databaseRegex)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/offset/ChangeStreamDescriptor.java:88

↓ 4 callersMethoddescribeMeta

Creates a string to describe the information of meta.

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

↓ 4 callersMethoddeserialize

(DataInputView source)

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/schema/SchemaSerializer.java:94

↓ 4 callersMethoddeserializeBinlogOffset

(byte[] serialized)

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

↓ 4 callersMethoddeserializer

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

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/PostgreSQLSource.java:146

↓ 4 callersMethoddistributionFactorLower

The lower bound of split key evenly distribution factor, the factor is used to determine whether the table is evenly distribution 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:135

↓ 4 callersMethoddistributionFactorUpper

The upper bound of split key evenly distribution factor, the factor is used to determine whether the table is evenly distribution 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:126

↓ 4 callersMethoddoValidate

( MySqlVersion version, String configPath, String exceptionMessage,

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

↓ 4 callersMethodemit

(SourceRecord inRecord, RowData physicalRow, Collector<RowData> collector)

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

↓ 4 callersMethodemit

(SourceRecord inRecord, RowData physicalRow, Collector<RowData> collector)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBConnectorDeserializationSchema.java:197

↓ 4 callersMethodemitElement

(SourceRecord element, SourceOutput<T> output)

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

↓ 4 callersMethodequals

(Object o)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/offset/PostgresOffset.java:112

↓ 4 callersMethodequals

(Object o)

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableSource.java:314

↓ 4 callersMethodequals

(Object o)

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/offset/Offset.java:88

↓ 4 callersMethodequals

(Object o)

flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/serializer/data/util/DataFormatTestUtil.java:113

↓ 4 callersMethodequals

(Object o)

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/MapDataSerializer.java:214

↓ 4 callersMethodescapeWithSingleQuote

Escapes the given string with single quotes, if the input string contains a double quote or any of the given {@code charsToEscape}. Any single quotes

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/StructuredOptionsSplitter.java:75

↓ 4 callersMethodexecuteAlterAndProvideExpected

The final schema of table products is as follows. <pre> CREATE TABLE products ( id INTEGER NOT NULL AUTO_INCREMENT PRIMARY KEY, name VARCHAR(255)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oracle/src/test/java/org/apache/flink/cdc/connectors/oracle/source/OraclePipelineITCase.java:1711

↓ 4 callersMethodexecuteDataStreamJob

read Events from {@link org.apache.flink.cdc.connectors.values.source.ValuesDataSource} and apply the events to ValuesDatabase.

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/src/test/java/org/apache/flink/cdc/connectors/values/source/ValuesDataSourceITCase.java:69

↓ 4 callersMethodexecuteUpdateStatement

(String sql)

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksEnrichedCatalog.java:161

↓ 4 callersMethodexitStreamReading

()

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/metrics/SourceEnumeratorMetrics.java:87

↓ 4 callersMethodextractRecord

Converts a binary record data with specific schema to Java objects.

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/typeutils/BinaryRecordDataExtractor.java:45

↓ 4 callersMethodfetchRowData

( Iterator<RowData> iter, int size, Function<RowData, String> stringifier)

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

↓ 4 callersMethodfmix

(int h1, int length)

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/MurmurHashUtils.java:157

↓ 4 callersMethodformat

(List<SourceRecord> records)

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

↓ 4 callersMethodfromDbzColumn

Returns a corresponding Flink data type from a debezium {@link Column}.

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oracle/src/main/java/org/apache/flink/cdc/connectors/oracle/utils/OracleTypeUtils.java:32

↓ 4 callersMethodfromStatusCode

Gets the {@link AssignerStatus} from status code.

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

↓ 4 callersMethodfromStatusCode

Gets the {@link AssignerStatus} from status code.

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/AssignerStatus.java:154

↓ 4 callersMethodgenerate

(Schema schema, Object... fields)

flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/FlinkPipelineBatchComposerITCase.java:1475

↓ 4 callersMethodgetAllOptions

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/test/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableFactoryTest.java:254

↓ 4 callersMethodgetAssignerStatus

Gets the split assigner status, see {@code AssignerStatus}.

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/SplitAssigner.java:110

↓ 4 callersMethodgetBatchSize

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java:140

↓ 4 callersMethodgetBoolean

(int pos)

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

↓ 4 callersMethodgetBoundedness

()

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

↓ 4 callersMethodgetByte

(int pos)

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

↓ 4 callersMethodgetCheckpointId

()

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

↓ 4 callersMethodgetCollectionId

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/assigners/splitters/SplitContext.java:76

↓ 4 callersMethodgetCollectionList

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java:135

↓ 4 callersMethodgetColumnNames

()

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformFilter.java:58

↓ 4 callersMethodgetConfig

( UniqueDatabase database, int splitSize, double distributionFactorUpper,

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

↓ 4 callersMethodgetConfigFactory

( MySqlContainer container, UniqueDatabase database, String[] captureTable

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

↓ 4 callersMethodgetConnection

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/fetch/Db2SourceFetchTaskContext.java:243

↓ 4 callersMethodgetConnectionString

()

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

↓ 4 callersMethodgetCount

()

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

↓ 4 callersMethodgetCreateTableStatement

( Map<String, String> otherOptions, String... captureTableNames)

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

↓ 4 callersMethodgetCreateTableStatement

( Map<String, String> otherOptions, String... captureTableNames)

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

↓ 4 callersMethodgetCreateTableStatement

( Map<String, String> otherOptions, String... captureTableNames)

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

↓ 4 callersMethodgetDatabaseFilter

()

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

↓ 4 callersMethodgetDatabaseSchema

()

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

↓ 4 callersMethodgetDecimal

(int pos, int precision, int scale)

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

↓ 4 callersMethodgetDefaultValueConverter

()

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

↓ 4 callersMethodgetDeploymentFromName

(final String deploymentTargetStr)

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/deployment/ComposeDeployment.java:43

↓ 4 callersMethodgetDispatcher

()

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

↓ 4 callersMethodgetDouble

(int pos)

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

↓ 4 callersMethodgetElemInfo

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/converters/OracleGeometry.java:77

↓ 4 callersMethodgetEpochMillisecond

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

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

↓ 4 callersMethodgetEpochNanoOfMillisecond

Returns the number of epoch nanoseconds (the nanoseconds within the milliseconds). <p>The value range is from 0 to 999,999.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/LocalZonedTimestampData.java:66

↓ 4 callersMethodgetEventSourceProvider

()

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlDataSource.java:61

↓ 4 callersMethodgetExecutorService

()

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

↓ 4 callersMethodgetExecutorService

()

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

↓ 4 callersMethodgetFieldCount

Returns the field count of row and structured types. Other types return 1.

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

↓ 4 callersMethodgetFinishedSplitInfos

Gets the finished splits' information. This is useful metadata to generate a stream split that considering finished snapshot splits.

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/SplitAssigner.java:67

↓ 4 callersMethodgetFlinkConfig

()

flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/CliExecutor.java:124

↓ 4 callersMethodgetFlinkSourceProvider

( List<String> tables, int parallelism, Map<String, String> additionalOpti

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

↓ 4 callersMethodgetFlinkSourceProvider

( String[] captureTables, UniqueDatabase database, Boolean useLegacyJsonFormat)

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

↓ 4 callersMethodgetFloat

(int pos)

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

↓ 4 callersMethodgetGeometryType

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/converters/OracleGeometry.java:61

↓ 4 callersMethodgetHashFunction

Gets a hash function based on the given table ID and schema, to help {@code PrePartitionOperator} to shuffle {@link DataChangeEvent} to designated sub

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/function/HashFunctionProvider.java:48

↓ 4 callersMethodgetHosts

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java:112

↓ 4 callersMethodgetInt

Get the scalar value of variant as int, if the variant type is {@link Type#INT}. @throws VariantTypeException if this variant is not a scalar value o

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

↓ 4 callersMethodgetInt

get int from segments. @param segments target segments. @param offset value offset.

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

↓ 4 callersMethodgetIntegerSeqString

(int start, int end)

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

↓ 4 callersMethodgetIntegerSize

(int value)

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

↓ 4 callersMethodgetJdbcConnection

()

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

↓ 4 callersMethodgetKey

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLReadableMetadata.java:136

↓ 4 callersMethodgetKey

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBReadableMetadata.java:122

↓ 4 callersMethodgetLength

()

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/schema/DataTypeSerializer.java:96

↓ 4 callersMethodgetList

()

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/test/java/org/apache/flink/cdc/connectors/db2/Db2SourceTest.java:563

↓ 4 callersMethodgetMap

(int pos)

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

← previous next →1,601–1,700 of 12,620, ranked by callers