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

↓ 7 callersMethodcompareTo

(TableId that)

connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/table/TableId.java:101

↓ 7 callersMethodconfigure

Allows a type to perform initialization/configuration tasks based on user configs.

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

↓ 7 callersMethodconnectors

Get all cached connectors. @return the set of connector names

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

↓ 7 callersMethodconstructMetricName

( final Integer taskId, final String domain, final String metricName)

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/metrics/MetricsUtil.java:45

↓ 7 callersMethodconvertToConnect

convert to connect @param schema @param value @return

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/converter/record/json/JsonConverter.java:754

↓ 7 callersMethodcreateRetryWithToleranceOperator

create retry operator @param connConfig @return

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/errors/ReporterManagerUtil.java:39

↓ 7 callersMethodequals

(Object o)

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/model/doris/Field.java:110

↓ 7 callersMethodfilterMeta

(CollectionMeta collectionMeta)

connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/OperationFilter.java:72

↓ 7 callersMethodgetBufferSizeBytes

@return Buffer size in bytes

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/writer/PartitionBuffer.java:53

↓ 7 callersMethodgetConnectorName

()

connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoSourceTaskTest.java:76

↓ 7 callersMethodgetEpoch

()

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

↓ 7 callersMethodgetGeneration

()

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/status/AbstractStatus.java:72

↓ 7 callersMethodgetGroupId

()

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

↓ 7 callersMethodgetInsertMode

()

connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/JdbcSinkConfig.java:179

↓ 7 callersMethodgetLong

(String key)

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

↓ 7 callersMethodgetMessageContent

(Message message)

connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceTask.java:103

↓ 7 callersMethodgetMultipartEntityBuilder

(String body)

connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/auth/ApacheHttpClientImpl.java:495

↓ 7 callersMethodgetNumOfRecords

@return Number of records in this buffer

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/writer/PartitionBuffer.java:46

↓ 7 callersMethodgetProcessor

()

connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/processor/ProcessorTest.java:159

↓ 7 callersMethodgetSrcCluster

()

connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/TaskDivideConfig.java:57

↓ 7 callersMethodgetStorePathRootDir

()

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

↓ 7 callersMethodgetTable

(String tableName)

connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/Database.java:129

↓ 7 callersMethodgetTargetState

()

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

↓ 7 callersMethodgetUrlEncodedFormEntity

(String body)

connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/auth/ApacheHttpClientImpl.java:430

↓ 7 callersMethodisOptional

()

connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/metadata/SinkRecordField.java:50

↓ 7 callersMethodnewBuilder

Creates a new User RecordBuilder. @return A new User RecordBuilder

connectors/rocketmq-connect-deltalake/src/main/java/example/avro/User.java:186

↓ 7 callersMethodnewConnector

(String connectorClassOrAlias)

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

↓ 7 callersMethodoffsetTopics

Get topic offsets

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

↓ 7 callersMethodparseTableNameToTableId

parse to Table Id @param fqn @return

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

↓ 7 callersMethodprintHelp

()

rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/ConnectAdminStartup.java:151

↓ 7 callersMethodrawSchema

raw schema @return

schema-converter/schema-converter-common/src/main/java/org/apache/rocketmq/schema/common/ParsedSchema.java:39

↓ 7 callersMethodschema

schema @return

connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/common/SchemaMapping.java:86

↓ 7 callersMethodsetReplId

(String replId)

connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/RedisEvent.java:48

↓ 7 callersMethodshouldPause

should pause @return

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

↓ 7 callersMethodstage

Set the stage in the connector pipeline which is currently executing. @param stage the stage

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

↓ 7 callersMethodsubjectName

generate subject name @param topic @param isKey @return

schema-converter/schema-converter-common/src/main/java/org/apache/rocketmq/schema/common/TopicNameStrategy.java:31

↓ 7 callersMethodtoConnectData

Convert a native object to a Rocketmq Connect data object.

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/converter/record/StringConverter.java:70

↓ 7 callersMethodtoString

()

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation/PluginType.java:57

↓ 7 callersMethodtoString

()

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/writer/PartitionBuffer.java:128

↓ 7 callersMethodtoString

()

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

↓ 6 callersMethodaddAliases

(Collection<PluginWrapper<S>> plugins)

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

↓ 6 callersMethodaddPlugins

(Collection<PluginWrapper<T>> plugins, ClassLoader loader)

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

↓ 6 callersMethodappendList

()

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

↓ 6 callersMethodbuildTopicWithNamespace

(String topic, String instanceId)

connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/utils/ReplicatorUtils.java:54

↓ 6 callersMethodcancel

()

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerConnector.java:361

↓ 6 callersMethodclassName

()

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation/PluginWrapper.java:59

↓ 6 callersMethodclose

close reporters

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/errors/ErrorReporter.java:36

↓ 6 callersMethodcommit

(RedisEvent event)

connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventProcessor.java:35

↓ 6 callersMethodconfig

configs @param configs

metric-exporter/src/main/java/org/apache/rocketmq/connect/metrics/AutoConfiguration.java:30

↓ 6 callersMethodcreate

(String hosts)

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

↓ 6 callersMethodcreateTopic

(WorkerConfig connectConfig, TopicConfig topicConfig)

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

↓ 6 callersMethodcurrentTaskConfig

()

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

↓ 6 callersMethodcurrentThreadLoader

()

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

↓ 6 callersMethoddelimitedBy

(String delimiter)

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

↓ 6 callersMethoderror

error @return

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

↓ 6 callersMethodexecuteNotReturn

@return @throws IOException

connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/auth/AbstractHttpClient.java:36

↓ 6 callersMethodexecutingClass

@return the class which is going to execute the current operation.

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

↓ 6 callersMethodgetAccessToken

()

connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/entity/TokenEntity.java:36

↓ 6 callersMethodgetAclEnable

()

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

↓ 6 callersMethodgetConnectorConfigs

Get all connector configs from the cluster filter out DELETE set to 1 @return

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

↓ 6 callersMethodgetCountDownLatch

()

connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/auth/HttpCallback.java:54

↓ 6 callersMethodgetDbPort

()

connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/Config.java:104

↓ 6 callersMethodgetDbUrl

()

connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/Config.java:100

↓ 6 callersMethodgetDouble

(String key)

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

↓ 6 callersMethodgetHttpMethod

()

connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/entity/HttpOAuthParameters.java:49

↓ 6 callersMethodgetInstance

(DorisOptions dorisOptions, Logger logger)

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/utils/BackendUtils.java:42

↓ 6 callersMethodgetLocalDataCenter

()

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

↓ 6 callersMethodgetMethod

()

connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/entity/HttpRequest.java:47

↓ 6 callersMethodgetMode

()

connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/Config.java:148

↓ 6 callersMethodgetName

()

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/converter/ConverterMode.java:38

↓ 6 callersMethodgetNamesrvAddr

()

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

↓ 6 callersMethodgetPluginWrapper

( Reflections reflections, Class<T> klass, ClassLoader loader )

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

↓ 6 callersMethodgetPositionStoreTopic

()

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

↓ 6 callersMethodgetRedisUri

()

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

↓ 6 callersMethodgetRefreshInterval

()

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

↓ 6 callersMethodgetReplOffset

()

connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/RedisEvent.java:36

↓ 6 callersMethodgetSchemaParameter

(Schema schema, String parameterName)

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/converter/type/util/SchemaUtils.java:53

↓ 6 callersMethodgetTablePath

()

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

↓ 6 callersMethodgetTimeout

()

connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/entity/HttpRequest.java:71

↓ 6 callersMethodgetValue

()

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

↓ 6 callersMethodhasTimestampColumns

()

connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/TimestampIncrementingCriteria.java:68

↓ 6 callersMethodinitDefaultLitePullConsumer

init default lite pull consumer @param connectConfig @return @throws MQClientException

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

↓ 6 callersMethodisDeleteEnabled

()

connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/JdbcSinkConfig.java:167

↓ 6 callersMethodnotify

(K k, V v)

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/IChangeNotifier.java:28

↓ 6 callersMethodoffset

(Long offset)

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

↓ 6 callersMethodpartition

(String partition)

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

↓ 6 callersMethodpluginClassLoader

Retrieve the PluginClassLoader associated with a plugin class @param name @return

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

↓ 6 callersMethodput

(List<ConnectRecord> records)

connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/HttpSinkTask.java:95

↓ 6 callersMethodreporters

Set the error reporters for this connector. @param reporters the error reporters (should not be null).

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

↓ 6 callersMethodsetBody

(String body)

connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/entity/HttpRequest.java:67

↓ 6 callersMethodsetEvent

(Event event)

connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/RedisEvent.java:32

↓ 6 callersMethodsetHeader

为request添加请求头 @param request

connectors/aliyun/rocketmq-connect-dingtalk/src/main/java/org/apache/rocketmq/connect/dingtalk/sink/common/OkHttpUtils.java:221

↓ 6 callersMethodsetPosition

(Position position)

connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSetConfig.java:41

↓ 6 callersMethodsetReplOffset

(Long replOffset)

connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/RedisEvent.java:40

↓ 6 callersMethodsetType

(String type)

metric-exporter/src/main/java/org/apache/rocketmq/connect/metrics/MetricName.java:79

↓ 6 callersMethodsourceTaskReporters

build source task reporter @param connectorTaskId @param connConfig @return

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/errors/ReporterManagerUtil.java:103

↓ 6 callersMethodstart

(KeyValue config)

connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/HttpSinkTask.java:195

↓ 6 callersMethodstop

Stop dependent services (if needed)

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

↓ 6 callersMethodstop

()

connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/HttpSinkTask.java:238

↓ 6 callersMethodtoString

()

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/converter/type/AbstractType.java:47

← previous next →301–400 of 6,037, ranked by callers