MCPcopy Create free account

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

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

⨍ Functions 6,037◇ Types & classes 1,172
↓ 1,382 callersMethodput
put a data to cache @param key @param value
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/common/cache/Cache.java:40
↓ 911 callersMethodget
@param key @return
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/common/cache/Cache.java:32
↓ 622 callersMethodadd
add record @param record @return @throws SQLException
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/BufferedRecords.java:78
↓ 531 callersMethodgetString
(String key)
connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/config/ConnectKeyValue.java:97
↓ 414 callersMethoderror
()
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/errors/ProcessingContext.java:168
↓ 406 callersMethodappend
( Object obj, boolean useQuotes )
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/ExpressionBuilder.java:235
↓ 289 callersMethodsize
@return
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/common/cache/Cache.java:55
↓ 286 callersMethodgetKey
()
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/KVEntry.java:50
↓ 237 callersMethodname
dialect name @return
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/DatabaseDialect.java:57
↓ 206 callersMethodgetValue
()
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/KVEntry.java:54
↓ 186 callersMethodequals
(Object o)
connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/Position.java:71
↓ 185 callersMethodbuild
()
connectors/rocketmq-connect-deltalake/src/main/java/example/avro/User.java:392
↓ 182 callersMethodcontainsKey
Whether a key is contained in current store. @param key @return
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store/KeyValueStore.java:67
↓ 178 callersMethodgetBytes
()
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/common/FastJsonTest.java:21
↓ 173 callersMethodvalueOf
(String name)
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/Options.java:88
↓ 169 callersMethodgetName
Gets the value of the 'name' field. @return The value of the 'name' field.
connectors/rocketmq-connect-deltalake/src/main/java/example/avro/User.java:135
↓ 145 callersMethodfield
()
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/common/ColumnMapping.java:47
↓ 144 callersMethodbuild
build reporter @param connectorTaskId @param sinkConfig @param workerConfig @return
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/errors/DeadLetterQueueReporter.java:110
↓ 140 callersMethodcontains
Check whether this snapshot contains configuration for a connector. @param connector name of the connector @return true if this state contains config
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store/ClusterConfigState.java:63
↓ 137 callersMethodgetClass
get class @param key @return
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/Utils.java:179
↓ 113 callersMethodisEmpty
@return true if buffer is empty
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/writer/PartitionBuffer.java:102
↓ 112 callersMethodgetClass
(String key)
connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/transforms/TransformationWrapper.java:80
↓ 109 callersMethodparse
(Command command)
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/Parser.java:23
↓ 98 callersMethodname
get schema name @return
schema-converter/schema-converter-common/src/main/java/org/apache/rocketmq/schema/common/ParsedSchema.java:67
↓ 96 callersMethodgetPartition
()
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/KVEntry.java:30
↓ 95 callersMethodshutdown
shutdown controller
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/ConnectController.java:33
↓ 94 callersMethodset
send position @param partition @param position
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/AbstractPositionManagementService.java:176
↓ 93 callersMethodnewEntry
(FieldType valueType)
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/RedisEntry.java:35
↓ 92 callersMethodgetCommand
()
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/KVEntry.java:46
↓ 92 callersMethodparseCommand
(String command)
connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/parser/ParserTest.java:97
↓ 89 callersMethodstart
(Long offset)
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventProcessor.java:31
↓ 84 callersMethodvalue
(Object value)
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/KVEntry.java:52
↓ 79 callersMethodgetOffset
()
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/KVEntry.java:42
↓ 75 callersMethoddoc
()
schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/AvroData.java:2277
↓ 73 callersMethodgetData
()
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/model/BaseResponse.java:39
↓ 73 callersMethodtrace
(Throwable t)
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/status/WrapperStatusListener.java:65
↓ 66 callersMethoddefaultValue
(String defaultValue)
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/model/ColumnDescriptor.java:79
↓ 64 callersMethodparam
(Options<T> k, T v)
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/KVEntry.java:60
↓ 62 callersMethodgetFields
()
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/converter/RecordDescriptor.java:74
↓ 61 callersMethodstartsWith
(@NotNull Path other)
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/controller/isolation/TestPath.java:77
↓ 60 callersMethodget
Get the current state of the task. @param id the id of the task @return the state or null if there is none
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/StateManagementService.java:88
↓ 60 callersMethodgetSchema
()
connectors/rocketmq-connect-deltalake/src/main/java/example/avro/User.java:109
↓ 59 callersMethodput
(String key, int value)
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/common/ConnectKeyValue.java:52
↓ 59 callersMethodstruct
(String value)
transforms/src/test/java/org/apache/rocketmq/connect/transforms/test/PatternFilterTest.java:64
↓ 57 callersMethodgetString
(String key)
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/common/ConnectKeyValue.java:112
↓ 56 callersMethodgetPosition
(ExtendRecordPartition partition)
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/PositionManagementService.java:75
↓ 56 callersMethodvalue
()
metric-exporter/src/main/java/org/apache/rocketmq/connect/metrics/stats/Measure.java:23
↓ 55 callersMethodkeySet
()
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/common/ConnectKeyValue.java:122
↓ 54 callersMethodtoConnectData
(String topic, byte[] value)
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestConverter.java:31
↓ 52 callersMethodgetParam
(Options<T> k)
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/KVEntry.java:62
↓ 51 callersMethodput
Set the state of the connector to the given value. @param status the status of the connector
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/StateManagementService.java:53
↓ 50 callersMethodget
Get the value of a key. @param key @return
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store/KeyValueStore.java:75
↓ 50 callersMethodkeySet
()
connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/config/ConnectKeyValue.java:107
↓ 50 callersMethodparameters
()
schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/AvroData.java:2282
↓ 49 callersMethodschema
(Object input)
transforms/src/main/java/org/apache/rocketmq/connect/transforms/util/SchemaHelper.java:39
↓ 46 callersMethodparse
(byte[] json)
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/converter/record/JsonConverterTest.java:841
↓ 45 callersMethodisEmpty
()
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/Table.java:61
↓ 44 callersMethodbuilder
()
schema-converter/schema-converter-common/src/main/java/org/apache/rocketmq/schema/common/SchemaResponse.java:37
↓ 44 callersMethodequals
(Object o)
connectors/rocketmq-connect-hive/src/main/java/org/apache/rocketmq/connect/hive/config/HiveColumn.java:47
↓ 43 callersMethodnewOption
(String name)
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/Options.java:96
↓ 43 callersMethodsetNamesrvAddr
(String namesrvAddr)
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/config/WorkerConfig.java:242
↓ 42 callersMethodclose
()
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/serialization/Serde.java:38
↓ 42 callersMethodparseObject
(byte[] json)
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/converter/record/JsonConverterTest.java:851
↓ 42 callersMethodremove
remove a data to cache @param key @return
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/common/cache/Cache.java:49
↓ 42 callersMethodstart
start controller
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/ConnectController.java:28
↓ 41 callersMethodmap
(String value)
transforms/src/test/java/org/apache/rocketmq/connect/transforms/test/PatternFilterTest.java:52
↓ 40 callersMethodbuild
()
schema-converter/schema-converter-common/src/main/java/org/apache/rocketmq/schema/common/SchemaResponse.java:122
↓ 40 callersMethodcreate
(JdbcSinkConfig config)
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/RecordValidator.java:29
↓ 39 callersMethodequals
(Object o)
schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/AvroData.java:2217
↓ 39 callersMethodfromConnectData
(String topic, Schema schema, Object value)
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestConverter.java:26
↓ 39 callersMethodgetInt
(String key)
connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/config/ConnectKeyValue.java:61
↓ 39 callersMethodgetType
()
metric-exporter/src/main/java/org/apache/rocketmq/connect/metrics/MetricName.java:75
↓ 39 callersMethodhasNext
()
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/querier/Querier.java:78
↓ 39 callersMethodput
Put a key/value into the store. @param key @param value @return
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store/KeyValueStore.java:37
↓ 39 callersMethodstop
()
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventProcessor.java:33
↓ 38 callersMethodclose
()
connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/auth/AbstractHttpClient.java:45
↓ 37 callersMethodload
Load the data from back store. @return
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store/KeyValueStore.java:89
↓ 36 callersMethodtoString
()
metric-exporter/src/main/java/org/apache/rocketmq/connect/metrics/MetricName.java:87
↓ 35 callersMethodtoString
()
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/rest/entities/TaskInfo.java:65
↓ 34 callersMethodgetProperties
()
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/common/ConnectKeyValue.java:132
↓ 34 callersMethodisOptional
()
schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/AvroData.java:2257
↓ 34 callersMethodpoll
()
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventProcessor.java:37
↓ 34 callersMethodsetEntity
(HttpEntity httpEntity)
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/utils/HttpPutBuilder.java:95
↓ 33 callersMethodconnector
()
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/ConnectorTaskId.java:37
↓ 33 callersMethodisEmpty
()
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/RecordOffsetManagement.java:212
↓ 32 callersMethodbuild
()
connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-core/src/main/java/org/apache/rocketmq/connect/debezium/RocketMqConfig.java:129
↓ 31 callersMethodaddStat
(Stat stat)
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/metrics/Sensor.java:34
↓ 31 callersMethodcreateTemplate
(String name, String group, Set<String> tags)
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/metrics/ConnectMetricsTemplates.java:135
↓ 31 callersMethodgetDefaultValue
()
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/rest/entities/ConfigKeyInfo.java:73
↓ 31 callersMethoditerator
()
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/controller/isolation/TestPath.java:170
↓ 31 callersMethodtoString
()
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/Config.java:73
↓ 30 callersMethodcompareAndSwapLoaders
(ClassLoader loader)
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation/Plugin.java:50
↓ 30 callersMethodsleep
Sleep for a bit @param ms The duration of the sleep
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/Utils.java:43
↓ 29 callersMethodequals
(Object o)
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/rest/entities/TaskInfo.java:52
↓ 29 callersMethodgetSettings
()
connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoFactoryTest.java:161
↓ 28 callersMethodgetMessage
()
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/rest/entities/ErrorMessage.java:45
↓ 28 callersMethodregisterType
(Type type)
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/converter/RecordTypeRegister.java:103
↓ 27 callersMethodfields
(Schema schema)
schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/AvroData.java:909
↓ 27 callersMethodgetSchema
(Object object)
schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/util/AvroSchemaUtils.java:81
↓ 27 callersMethodinitialize
init state management service @param workerConfig @param converter
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/StateManagementService.java:36
next →1–100 of 6,037, ranked by callers