Functions — github.com/apache/rocketmq-connect

hub / github.com/apache/rocketmq-connect / functions

Functions6,037 in github.com/apache/rocketmq-connect

⨍ Functions 6,037◇ Types & classes 1,172

↓ 4 callersMethodbase64Decode

decode @param in @return

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/Base64Util.java:48

↓ 4 callersMethodbaseAuth

(String user, String password)

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/utils/HttpPutBuilder.java:68

↓ 4 callersMethodbindField

(int index, Schema schema, Object value, String fieldName)

connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/binder/AbstractJdbcRecordBinder.java:139

↓ 4 callersMethodbuildTerm

Cassandra datastax driver automatically infer type from literal value, or we can use "typeHints" to tell datastax driver what type should this litera

connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/sink/Updater.java:199

↓ 4 callersMethodcommandName

()

rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command/SubCommand.java:25

↓ 4 callersMethodconfigure

Configure class with the given key-value pairs @param config can be DistributedConfig or StandaloneConfig

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/ConfigManagementService.java:51

↓ 4 callersMethodconnectorLoader

(Connector connector)

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation/DelegatingClassLoader.java:163

↓ 4 callersMethodconnectorTagName

()

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/metrics/ConnectMetricsTemplates.java:145

↓ 4 callersMethodcontainsKey

(String key)

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/common/ConnectKeyValue.java:127

↓ 4 callersMethodconvert

(Schema schema, Object value)

schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/AvroData.java:2205

↓ 4 callersMethodconvertToRecordPartition

convert to rocketmq record partition @param topicPartition @return

connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/context/RocketMQKafkaSinkTaskContext.java:141

↓ 4 callersMethodcreatePreparedStatement

(Connection db, String query, int batchMaxRows)

connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/DatabaseDialect.java:65

↓ 4 callersMethodcreateSubGroup

(WorkerConfig connectConfig, String subGroup)

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/ConnectUtil.java:244

↓ 4 callersMethodcustomCluster

()

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/cfg/DorisOptions.java:322

↓ 4 callersMethoddeleteConnectorConfig

Remove the connector with the specified connector name in the cluster. @param connectorName

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/ConfigManagementService.java:77

↓ 4 callersMethoddeleteFile

(File file)

rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/utils/TestUtils.java:24

↓ 4 callersMethoddlqTopicName

get dlq topic name @return

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/errors/DeadLetterQueueConfig.java:62

↓ 4 callersMethoddoTransforms

(R connectRecord)

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/TransformChain.java:103

↓ 4 callersMethodenable2PC

()

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/cfg/DorisOptions.java:222

↓ 4 callersMethodencode

(K key, V value)

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/datasync/BrokerBasedLog.java:333

↓ 4 callersMethodequals

(Object o)

schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/serde/SchemaPair.java:41

↓ 4 callersMethodequals

(Object o)

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/writer/commit/DorisCommittable.java:74

↓ 4 callersMethodequals

(Object o)

connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/metadata/SchemaPair.java:43

↓ 4 callersMethodequals

(Object o)

connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/offset/TimestampIncrementingOffset.java:84

↓ 4 callersMethodfailed

@return

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/errors/ProcessingContext.java:185

↓ 4 callersMethodfetchAllConsumerGroupList

(WorkerConfig connectConfig)

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/ConnectUtil.java:224

↓ 4 callersMethodfetchMessageQueues

(List<String> topicList)

connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorSourceConnector.java:107

↓ 4 callersMethodfield

(String s)

schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/AvroData.java:2302

↓ 4 callersMethodflush

()

connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/BufferedRecords.java:144

↓ 4 callersMethodforTable

Obtain a {@link ColumnDefinition} that has all the same characteristics as this column except that belongs to the specified table. @param tableId the

connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/ColumnDefinition.java:308

↓ 4 callersMethodformatTimestamp

(Date date, TimeZone timeZone)

connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/DateTimeUtils.java:61

↓ 4 callersMethodfromConnectSchema

(Schema schema)

schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/AvroData.java:1023

↓ 4 callersMethodfromConnectSchemaWithCycle

( Schema schema, FromConnectContext fromConnectContext, boolean ignoreOpti

schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/AvroData.java:1340

↓ 4 callersMethodgetAccessKey

()

connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-core/src/main/java/org/apache/rocketmq/connect/debezium/RocketMqConfig.java:62

↓ 4 callersMethodgetConnectConfig

()

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/AbstractConnectController.java:183

↓ 4 callersMethodgetContextCurrentClassLoader

get context current class loader @return

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/Utils.java:163

↓ 4 callersMethodgetDbUserName

()

connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/TaskDivideConfig.java:68

↓ 4 callersMethodgetDestInstanceId

()

connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/ReplicatorConnectorConfig.java:288

↓ 4 callersMethodgetErrorCode

()

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/rest/entities/ErrorMessage.java:37

↓ 4 callersMethodgetForceOptionalDefault

()

schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/AvroData.java:1705

↓ 4 callersMethodgetMetricsConfigPath

()

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/config/WorkerConfig.java:538

↓ 4 callersMethodgetOffsetCommitIntervalMsConfig

()

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/config/WorkerConfig.java:466

↓ 4 callersMethodgetOrAdd

(ConnectorTaskId task)

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/common/ConnAndTaskStatus.java:65

↓ 4 callersMethodgetPassword

()

connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/Config.java:141

↓ 4 callersMethodgetPassword

()

connectors/rocketmq-connect-elasticsearch/src/main/java/org/apache/rocketmq/connect/elasticsearch/config/ElasticsearchConfig.java:93

↓ 4 callersMethodgetPausedQueues

()

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerSinkTaskContext.java:73

↓ 4 callersMethodgetPort

()

connectors/rocketmq-connect-hive/src/main/java/org/apache/rocketmq/connect/hive/config/HiveConfig.java:60

↓ 4 callersMethodgetPositionTable

Get the current position table. @return

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/PositionManagementService.java:73

↓ 4 callersMethodgetQuerySql

()

connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/common/QueryContext.java:64

↓ 4 callersMethodgetRedisAddr

()

connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/Config.java:143

↓ 4 callersMethodgetRedisPassword

()

connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/Config.java:159

↓ 4 callersMethodgetRedisPort

()

connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/Config.java:151

↓ 4 callersMethodgetReplicaConfigByName

()

connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSetManager.java:82

↓ 4 callersMethodgetSchema

(String type)

connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSourceTask.java:180

↓ 4 callersMethodgetSchemaPath

()

connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/HudiConnectConfig.java:160

↓ 4 callersMethodgetSchemasCacheSize

()

schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/AvroDataConfig.java:60

↓ 4 callersMethodgetSecretKey

()

connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-core/src/main/java/org/apache/rocketmq/connect/debezium/RocketMqConfig.java:66

↓ 4 callersMethodgetSocks5Password

()

connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/auth/SocksProxyConfig.java:47

↓ 4 callersMethodgetSocks5UserName

()

connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/auth/SocksProxyConfig.java:39

↓ 4 callersMethodgetSourceRocketmq

()

connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/TaskConfig.java:50

↓ 4 callersMethodgetSrcEndpoint

()

connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/ReplicatorConnectorConfig.java:256

↓ 4 callersMethodgetSrcInstanceId

()

connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/ReplicatorConnectorConfig.java:213

↓ 4 callersMethodgetSrcNamesrvs

()

connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/RmqConnectorConfig.java:102

↓ 4 callersMethodgetSrcTopicTagMap

(String srcInstanceId, String srcTopicTags)

connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/ReplicatorConnectorConfig.java:221

↓ 4 callersMethodgetStatement

()

connectors/rocketmq-connect-hive/src/main/java/org/apache/rocketmq/connect/hive/config/HiveJdbcDriverManager.java:69

↓ 4 callersMethodgetTPS

(final CallSnapshot begin, final CallSnapshot end)

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/stats/ConnectStatsService.java:341

↓ 4 callersMethodgetTableName

()

connectors/rocketmq-connect-hive/src/main/java/org/apache/rocketmq/connect/hive/config/HiveRecord.java:36

↓ 4 callersMethodgetTableName

()

connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/HudiConnectConfig.java:104

↓ 4 callersMethodgetTables

()

connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/JdbcSourceTaskConfig.java:37

↓ 4 callersMethodgetTaskConfigs

Get all Task configs. @return

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/ConfigManagementService.java:105

↓ 4 callersMethodgetTaskParallelism

()

connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/TaskDivideConfig.java:108

↓ 4 callersMethodgetTasks

()

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/rest/entities/ConnectorInfo.java:61

↓ 4 callersMethodgetTimeStamp

()

connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/Position.java:29

↓ 4 callersMethodgetTimestamp

()

connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/event/ReplicationEvent.java:70

↓ 4 callersMethodgetTypeName

(Schema schema)

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/converter/type/Type.java:55

↓ 4 callersMethodgetUsername

()

connectors/rocketmq-connect-elasticsearch/src/main/java/org/apache/rocketmq/connect/elasticsearch/config/ElasticsearchConfig.java:85

↓ 4 callersMethodgetValueType

()

connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/KVEntry.java:58

↓ 4 callersMethodhashCode

()

connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/Position.java:82

↓ 4 callersMethodidl

()

schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/AvroSchema.java:107

↓ 4 callersMethodinit

(HiveConfig config)

connectors/rocketmq-connect-hive/src/main/java/org/apache/rocketmq/connect/hive/config/HiveJdbcDriverManager.java:34

↓ 4 callersMethodinit

(KeyValue config)

connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/RmqConnectorConfig.java:49

↓ 4 callersMethodinitLoaders

()

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation/Plugin.java:90

↓ 4 callersMethodisFixedSchema

(Schema schema)

schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/AvroData.java:820

↓ 4 callersMethodisRunning

()

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerTask.java:135

↓ 4 callersMethodisStopping

()

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerTask.java:139

↓ 4 callersMethodisValid

()

connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/Position.java:63

↓ 4 callersMethodjdbcMajorVersion

Get the major version of the JDBC specification supported by the driver. @return the major version number

connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/JdbcDriverInfo.java:58

↓ 4 callersMethodkey

(String key)

connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/RedisEntry.java:102

↓ 4 callersMethodlogFilename

()

rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileSourceTask.java:239

↓ 4 callersMethodmarkAsFailed

()

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/errors/RetryWithToleranceOperator.java:180

↓ 4 callersMethodmetricNameToString

MetricName to string @param name @return

metric-exporter/src/main/java/org/apache/rocketmq/connect/metrics/MetricUtils.java:44

↓ 4 callersMethodnewPlugin

(Class<T> klass)

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation/Plugin.java:75

↓ 4 callersMethodnewTask

(Class<? extends Task> taskClass)

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation/Plugin.java:169

↓ 4 callersMethodnotify

(String key, byte[] value)

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/AbstractConfigManagementService.java:410

↓ 4 callersMethodopen

(String filename)

connectors/rocketmq-connect-sftp/src/main/java/org/apache/rocketmq/connect/http/sink/SftpClient.java:57

↓ 4 callersMethodparseCmdLine

(final String appName, String[] args, Options options, CommandLineP

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/ServerUtil.java:39

↓ 4 callersMethodpauseAll

()

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerSinkTask.java:235

↓ 4 callersMethodpush

(ConnectRecord record)

connectors/rocketmq-connect-mqtt/src/main/java/org/apache/rocketmq/connect/mqtt/sink/Updater.java:109

↓ 4 callersMethodputSafe

Safely set the state of the connector to the given value. What is considered "safe" depends on the implementation, but basically it means that the sto

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/StateManagementService.java:63

↓ 4 callersMethodquote

()

connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/ExpressionBuilder.java:74

← previous next →501–600 of 6,037, ranked by callers