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

↓ 6 callersMethodtoString

()

connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/querier/BulkQuerier.java:124

↓ 6 callersMethodtoString

()

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

↓ 6 callersMethodvalidate

(KeyValue config)

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

↓ 6 callersMethodvalue

(Object value)

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

↓ 5 callersMethodbackoffAndRetry

Backoff logic @param operation Load Operation Type which corresponds to the lambda function runnable @param runnable the lambda function itself @ret

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/utils/BackoffAndRetryUtils.java:49

↓ 5 callersMethodbase64Encode

encode @param in @return

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

↓ 5 callersMethodcancelFlush

Cancel a flush that has been initiated by {@link #beginFlush}.

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store/PositionStorageWriter.java:118

↓ 5 callersMethodclassName

(Object o)

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

↓ 5 callersMethodcommonArray

(KeyValuePair<byte[], ? extends Collection<byte[]>> keyValuePair)

connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DefaultRedisRdbParser.java:149

↓ 5 callersMethodconfigure

(Map<String, ?> props)

schema-converter/schema-converter-common/src/main/java/org/apache/rocketmq/schema/common/Serializer.java:23

↓ 5 callersMethodconvertToRecordPartition

(MessageQueue messageQueue)

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

↓ 5 callersMethodconvertWorkerTaskToString

(Set<Runnable> tasks)

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/rest/RestHandler.java:337

↓ 5 callersMethodcreateTopic

Create rocketMq topic @param config @param topicConfig

connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-core/src/main/java/org/apache/rocketmq/connect/debezium/RocketMqAdminUtil.java:128

↓ 5 callersMethodcreateUniqInstance

(String prefix)

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

↓ 5 callersMethoddefaultValue

()

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

↓ 5 callersMethoddefaultValueFromAvro

(Schema schema, org.apache.avro.Schema avroSchema,

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

↓ 5 callersMethoddelete

if it has been deleted, it is meaningless to send it again

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

↓ 5 callersMethoddivide

(Map<String, Set<TaskTopicInfo>> topicRouteMap, TaskDivideConfig tdc, int maxTasks)

connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/strategy/DivideTaskByQueue.java:34

↓ 5 callersMethodendsWith

(@NotNull Path other)

rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/controller/isolation/TestPath.java:87

↓ 5 callersMethodexists

()

connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-core/src/main/java/org/apache/rocketmq/connect/debezium/RocketMqDatabaseHistory.java:302

↓ 5 callersMethodexpressionBuilder

()

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

↓ 5 callersMethodfile2String

(final String fileName)

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/FileAndPropertyUtil.java:78

↓ 5 callersMethodgenerateDestinationString

()

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

↓ 5 callersMethodgenerateSourceString

()

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

↓ 5 callersMethodgetCheckpointIntervalMs

()

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

↓ 5 callersMethodgetClassLoader

()

connectors/rocketmq-connect-kafka-connector-adapter/src/main/java/org/apache/rocketmq/connect/kafka/connector/KafkaRocketmqTask.java:25

↓ 5 callersMethodgetClusterStoreTopic

()

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

↓ 5 callersMethodgetCollectionName

()

connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/initsync/CollectionMeta.java:33

↓ 5 callersMethodgetColumnName

()

connectors/rocketmq-connect-hive/src/main/java/org/apache/rocketmq/connect/hive/config/HiveColumn.java:31

↓ 5 callersMethodgetConfig

()

connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/Replicator.java:60

↓ 5 callersMethodgetConfig

()

connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/processor/ListenerTest.java:128

↓ 5 callersMethodgetConfigStoreTopic

()

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

↓ 5 callersMethodgetConnectHome

()

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

↓ 5 callersMethodgetConnectors

()

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/Worker.java:501

↓ 5 callersMethodgetDatabaseName

()

connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/initsync/CollectionMeta.java:25

↓ 5 callersMethodgetDbPassword

()

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

↓ 5 callersMethodgetDestinationType

()

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

↓ 5 callersMethodgetDestinationType

()

connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/Config.java:131

↓ 5 callersMethodgetEncoder

Return the BinaryMessageEncoder instance used by this class. @return the message encoder used by this class

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

↓ 5 callersMethodgetLastOffset

@return Last offset number in this buffer

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

↓ 5 callersMethodgetMessageContent

(Message message)

connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceTask.java:111

↓ 5 callersMethodgetOffsetCommitTimeoutMsConfig

()

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

↓ 5 callersMethodgetPluginPaths

()

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

↓ 5 callersMethodgetPositionPartitionKey

()

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

↓ 5 callersMethodgetProperties

()

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/model/doris/Schema.java:55

↓ 5 callersMethodgetSchema

(Object value)

connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/connector/builder/MongoDataEntry.java:113

↓ 5 callersMethodgetSchema

(Object obj)

connectors/rocketmq-connect-elasticsearch/src/main/java/org/apache/rocketmq/connect/elasticsearch/connector/ElasticsearchSourceTask.java:138

↓ 5 callersMethodgetSchema

()

connectors/rocketmq-connect-deltalake/src/main/java/org/apache/rocketmq/connect/deltalake/config/DeltalakeConnectConfig.java:45

↓ 5 callersMethodgetServiceName

()

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/ServiceThread.java:42

↓ 5 callersMethodgetSocks5Endpoint

()

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

↓ 5 callersMethodgetStoreTopic

()

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

↓ 5 callersMethodgetTaskDivideStrategy

()

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

↓ 5 callersMethodgetTaskName

()

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

↓ 5 callersMethodgetTrace

()

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

↓ 5 callersMethodgetType

()

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

↓ 5 callersMethodhasIncrementedColumn

()

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

↓ 5 callersMethodisArchive

(Path path)

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation/PluginUtils.java:145

↓ 5 callersMethodisSignedNumber

Indicates whether values in the column are signed numbers. @return <code>true</code> if so; <code>false</code> otherwise

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

↓ 5 callersMethodisTopicExist

(WorkerConfig connectConfig, String topic)

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

↓ 5 callersMethodkVEntryToConnectRecord

(KVEntry kvEntry)

connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/RedisEntryConverter.java:39

↓ 5 callersMethodkeySet

()

transforms/src/main/java/org/apache/rocketmq/connect/transforms/util/ExtendKeyValue.java:100

↓ 5 callersMethodload

(KeyValue props, Object object)

connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/ConfigUtil.java:24

↓ 5 callersMethodloadClass

Look up a class by name.

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

↓ 5 callersMethodloadClass

(String name, boolean resolve)

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation/PluginClassLoader.java:56

↓ 5 callersMethodonCommitCompleted

commit @param error @param seqno @param committedOffsets

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

↓ 5 callersMethodonFailure

error @param connector @param cause

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/status/ConnectorStatus.java:51

↓ 5 callersMethodonPause

Invoked when the connector is paused through the REST API @param connector The connector name

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/status/ConnectorStatus.java:58

↓ 5 callersMethodonResume

Invoked after the connector has been resumed. @param connector The connector name

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/status/ConnectorStatus.java:65

↓ 5 callersMethodpersist

Persist all data into the store.

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store/KeyValueStore.java:94

↓ 5 callersMethodplugin

()

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

↓ 5 callersMethodprecision

Get the column's specified column size. For numeric data, this is the maximum precision. For character data, this is the length in characters. For da

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

↓ 5 callersMethodsend

(MetricName name, Double value)

metric-exporter/src/main/java/org/apache/rocketmq/connect/metrics/reporter/RocketMQScheduledReporter.java:157

↓ 5 callersMethodsetHttpPort

(int httpPort)

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

↓ 5 callersMethodsetOperationType

(OperationType operationType)

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

↓ 5 callersMethodsetPassword

(String password)

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

↓ 5 callersMethodsetRedisAddr

(String redisAddr)

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

↓ 5 callersMethodsetRedisPort

(Integer redisPort)

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

↓ 5 callersMethodsetRmqConsumerGroup

(String rmqConsumerGroup)

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

↓ 5 callersMethodsetStreamDB

(int streamDB)

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

↓ 5 callersMethodsetTopic

(String topic)

rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileConfig.java:61

↓ 5 callersMethodsetTopic

(String topic)

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/model/KafkaRespContent.java:33

↓ 5 callersMethodsnapshot

()

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

↓ 5 callersMethodstart

Start the synchronizer.

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/datasync/DataSynchronizer.java:34

↓ 5 callersMethodstartMQAdminTool

(RocketMqConfig config)

connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-core/src/main/java/org/apache/rocketmq/connect/debezium/RocketMqAdminUtil.java:107

↓ 5 callersMethodtoConnectData

Convert the given object, in Avro format, into a Connect data object. @param avroSchema the Avro schema @param value the value to convert into a

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

↓ 5 callersMethodtoConnectSchema

convert json schema to connect schema @param jsonSchema @return

schema-converter/json-schema-converter/src/main/java/org/apache/rocketmq/schema/json/JsonSchemaData.java:623

↓ 5 callersMethodtoConnectSchemaWithCycles

(org.apache.avro.Schema schema, boolean forceOptional,

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

↓ 5 callersMethodtoString

()

schema-converter/schema-converter-common/src/main/java/org/apache/rocketmq/schema/common/SchemaResponse.java:86

↓ 5 callersMethodtransformedBy

(Transform<R> transform)

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

↓ 5 callersMethodunionMemberFieldName

(org.apache.avro.Schema schema, boolean enhancedSchemaSupport)

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

↓ 5 callersMethodvalue

(Schema schema, Object value)

connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/schema/RocketMQSourceValueConverter.java:40

↓ 4 callersMethodaddCommonHeader

()

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

↓ 4 callersMethodaddConnectorPlugins

(Collection<PluginWrapper<T>> plugins, Collection<Class<? extends T>> excludes)

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/rest/ConnectorPluginsResource.java:63

↓ 4 callersMethodallocate

Allocate connectors and tasks to current worker @param allWorker All alive worker info. @param curWorker Current worker. @param connect

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/strategy/AllocateConnAndTaskStrategy.java:40

↓ 4 callersMethodappendLeadingQuote

()

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

↓ 4 callersMethodappendTrailingQuote

()

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

↓ 4 callersMethodapply

( ExpressionBuilder builder, T input )

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

↓ 4 callersMethodassertSchema

(Schema expected, Schema actual)

transforms/src/test/java/org/apache/rocketmq/connect/transforms/test/common/AssertSchema.java:30

↓ 4 callersMethodassertStruct

(Struct expected, Struct actual, String message)

transforms/src/test/java/org/apache/rocketmq/connect/transforms/test/common/AssertStruct.java:57

↓ 4 callersMethodawaitUnpause

Await task resumption. @return true if the task's target state is not paused, false if the task is shutdown before resumption @throws InterruptedExce

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

← previous next →401–500 of 6,037, ranked by callers