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
↓ 27 callersMethodtype
type @return
metric-exporter/src/main/java/org/apache/rocketmq/connect/metrics/stats/Stat.java:36
↓ 25 callersMethodaddExtension
(MessageExt message, ConnectRecord sinkDataEntry)
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerSinkTask.java:564
↓ 25 callersMethodequals
(Object obj)
connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/handler/RedisEventHandlerTest.java:340
↓ 25 callersMethodgetName
()
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/common/TableLoadMode.java:43
↓ 24 callersMethodcheckNullReturnDefault
(String check)
connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/util/CheckUtils.java:42
↓ 24 callersMethodcountDown
Decrements the count of the latch, releasing all waiting threads if the count reaches zero. <p>If the current count is greater than zero then it is d
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/CountDownLatch2.java:116
↓ 24 callersMethodequals
(Object o)
connectors/rocketmq-connect-iotdb/src/main/java/org/apache/rocketmq/connect/iotdb/replicator/source/DeviceEntity.java:66
↓ 24 callersMethodequals
(Object obj)
rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/commom/ConnectKeyValue.java:129
↓ 24 callersMethodfilter
(R record, Struct struct)
transforms/src/main/java/org/apache/rocketmq/connect/transforms/PatternFilter.java:52
↓ 24 callersMethodgetMessage
()
connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/entity/TokenEntity.java:100
↓ 24 callersMethodgetTimestamp
()
connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/entity/TokenEntity.java:76
↓ 24 callersMethodinit
@param config
connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/auth/AbstractHttpClient.java:29
↓ 24 callersMethodrecord
record @param value
metric-exporter/src/main/java/org/apache/rocketmq/connect/metrics/stats/Stat.java:29
↓ 24 callersMethodstop
Stop the synchronizer.
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/datasync/DataSynchronizer.java:39
↓ 24 callersMethodtoString
()
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/context/UnAckMessage.java:57
↓ 23 callersMethodid
()
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerTask.java:85
↓ 23 callersMethodof
(Iterable<? extends T> objects)
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/ExpressionBuilder.java:57
↓ 23 callersMethodschema
()
connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/schema/KafkaSinkSchemaConverter.java:54
↓ 22 callersMethodgetBrokerName
(RecordPartition recordPartition)
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/utils/ConnectRecordUtil.java:26
↓ 22 callersMethodgetName
()
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/rest/entities/ConfigKeyInfo.java:61
↓ 22 callersMethodsend
Send data to all workers. @param key @param value
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/datasync/DataSynchronizer.java:47
↓ 22 callersMethodsize
Get the size of current key/value store. @return
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store/KeyValueStore.java:59
↓ 21 callersMethodgetContext
()
connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-mysql/src/main/java/io/debezium/connector/mysql/MySqlReadOnlyIncrementalSnapshotChangeEventSource.java:250
↓ 21 callersMethodgetDefaultValue
()
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/model/ColumnDescriptor.java:46
↓ 21 callersMethodgetState
get state @return
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerTask.java:131
↓ 21 callersMethodputAll
Put a set of key/value into the store. @param map
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store/KeyValueStore.java:44
↓ 20 callersMethodbuilder
(Object input)
transforms/src/main/java/org/apache/rocketmq/connect/transforms/util/SchemaHelper.java:43
↓ 20 callersMethodkey
(String key)
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/KVEntry.java:48
↓ 20 callersMethodsensor
()
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/metrics/MetricGroup.java:41
↓ 19 callersMethodcommit
(Map<RecordPartition, RecordOffset> currentOffsets)
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/service/DorisSinkService.java:39
↓ 19 callersMethodexecute
(CommandLine commandLine, Options options)
rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command/SubCommand.java:31
↓ 19 callersMethodgetVersion
()
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/rest/entities/PluginInfo.java:58
↓ 19 callersMethodtopic
get topic @param partition @return
connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/schema/Converters.java:169
↓ 18 callersMethodexecute
@return @throws IOException
connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/auth/AbstractHttpClient.java:43
↓ 18 callersMethodgetFilename
()
rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileConfig.java:49
↓ 18 callersMethodgetName
(int index)
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/controller/isolation/TestPath.java:65
↓ 18 callersMethodgetQueueId
(RecordPartition recordPartition)
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/utils/ConnectRecordUtil.java:31
↓ 18 callersMethodgetWorkerId
()
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/config/WorkerConfig.java:230
↓ 18 callersMethodtask
()
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/ConnectorTaskId.java:41
↓ 18 callersMethodvalidate
(ConnectRecord record)
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/RecordValidator.java:84
↓ 17 callersMethodgetBody
()
connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/entity/HttpRequest.java:63
↓ 17 callersMethodgetKVMap
Get all data from the current store. Not recommend to use this method when the data set is large. @return
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store/KeyValueStore.java:82
↓ 17 callersMethodgetLong
(String key)
connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/config/ConnectKeyValue.java:73
↓ 17 callersMethodgetTopic
()
rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileConfig.java:57
↓ 17 callersMethodregistry
get metric registry @return
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/metrics/ConnectMetrics.java:105
↓ 16 callersMethodequals
(Object obj)
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/table/TableId.java:87
↓ 16 callersMethodgetName
()
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/converter/schema/SchemaEvolutionMode.java:37
↓ 16 callersMethodgetQueueOffset
(RecordOffset recordOffset)
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/utils/ConnectRecordUtil.java:13
↓ 16 callersMethodgetTimeZoneCalendar
(final TimeZone timeZone)
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/DateTimeUtils.java:41
↓ 16 callersMethodhandlerTest
(int rdbType, ValueSetter<T> setter)
connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/handler/RedisEventHandlerTest.java:432
↓ 16 callersMethodstringToMetricName
string to MetricName @param name @return
metric-exporter/src/main/java/org/apache/rocketmq/connect/metrics/MetricUtils.java:71
↓ 16 callersMethodtoString
()
schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/AvroSchema.java:152
↓ 15 callersMethodcommand
(String command)
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/KVEntry.java:44
↓ 15 callersMethoddefaultValue
()
schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/AvroData.java:2262
↓ 15 callersMethodequals
(Object o)
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/ConnectorTaskId.java:61
↓ 15 callersMethodgetNamesrvAddr
()
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/config/WorkerConfig.java:238
↓ 15 callersMethodgetReplicaSetName
()
connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSetConfig.java:53
↓ 15 callersMethodgetString
(String key)
rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/commom/ConnectKeyValue.java:101
↓ 15 callersMethodpersist
Persist all the configs in a store.
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/StateManagementService.java:116
↓ 15 callersMethodtoLogical
(final Struct value)
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/converter/type/debezium/VariableScaleDecimalType.java:71
↓ 15 callersMethodtoString
()
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/TableType.java:48
↓ 15 callersMethodwrite
(final Collection<ConnectRecord> records)
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/JdbcWriter.java:64
↓ 14 callersMethodclose
Close this connection provider.
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connection/ConnectionProvider.java:40
↓ 14 callersMethodencode
()
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/offset/OffsetSync.java:67
↓ 14 callersMethodequals
(Object o)
connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-core/src/main/java/org/apache/rocketmq/connect/debezium/RocketMqConfig.java:70
↓ 14 callersMethodfromConnectData
Convert a rocketmq Connect data object to a native object for serialization. @param topic the topic associated with the data @param schema the schem
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/converter/record/StringConverter.java:58
↓ 14 callersMethodgetIndex
()
connectors/rocketmq-connect-elasticsearch/src/main/java/org/apache/rocketmq/connect/elasticsearch/config/ElasticsearchConfig.java:61
↓ 14 callersMethodgetName
()
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/converter/record/ConverterType.java:56
↓ 14 callersMethodgetName
()
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/model/doris/Field.java:70
↓ 14 callersMethodgetTableId
()
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/common/QueryContext.java:56
↓ 14 callersMethodserdeFrom
serde from by type @param type @param <T> @return
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/serialization/Serdes.java:83
↓ 14 callersMethodserialize
serialize data @param topic @param isKey @param schema @param value @return
schema-converter/schema-converter-common/src/main/java/org/apache/rocketmq/schema/common/Serializer.java:35
↓ 14 callersMethodsetAdminExtGroup
(String adminExtGroup)
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/config/WorkerConfig.java:454
↓ 14 callersMethodtoString
()
rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/commom/ConnectKeyValue.java:144
↓ 14 callersMethodvalueSchema
(Schema schema)
schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/AvroData.java:927
↓ 13 callersMethodconfigure
configs in key/value pairs @param configs
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/serialization/Serde.java:34
↓ 13 callersMethoddeserialize
deserialize @param topic @param isKey @param payload @return
schema-converter/schema-converter-common/src/main/java/org/apache/rocketmq/schema/common/Deserializer.java:47
↓ 13 callersMethodequals
(Object o)
schema-converter/json-schema-converter/src/main/java/org/apache/rocketmq/schema/json/JsonSchema.java:132
↓ 13 callersMethodgetConnection
Create connection @return @throws SQLException
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connection/ConnectionProvider.java:33
↓ 13 callersMethodgetSchema
()
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/converter/RecordDescriptor.java:169
↓ 13 callersMethodgetSrcAccessKey
()
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/TaskConfig.java:118
↓ 13 callersMethodgetSrcSecretKey
()
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/TaskConfig.java:126
↓ 13 callersMethodnewInstance
Instantiate the class
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/Utils.java:68
↓ 13 callersMethodoffsetStorageReader
()
connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoSourceTaskTest.java:72
↓ 13 callersMethodremove
Remove a specified key. @param key @return
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store/KeyValueStore.java:52
↓ 13 callersMethodtableName
()
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/table/TableId.java:57
↓ 12 callersMethodawait
Causes the current thread to wait until the latch has counted down to zero, unless the thread is {@linkplain Thread#interrupt interrupted}. <p>If the
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/CountDownLatch2.java:63
↓ 12 callersMethodcastAndVerify
(Class<T> cls, Struct struct, Field field, boolean expected)
transforms/src/test/java/org/apache/rocketmq/connect/transforms/test/common/AssertStruct.java:42
↓ 12 callersMethodequals
(Object o)
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store/ClusterConfigState.java:157
↓ 12 callersMethodgeneration
()
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/status/WrapperStatusListener.java:186
↓ 12 callersMethodgetInt
(String key)
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/common/ConnectKeyValue.java:76
↓ 12 callersMethodgetMode
()
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/common/QueryContext.java:48
↓ 12 callersMethodgetString
(String s)
transforms/src/main/java/org/apache/rocketmq/connect/transforms/util/ExtendKeyValue.java:90
↓ 12 callersMethodgetTimeZone
()
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/JdbcSinkConfig.java:199
↓ 12 callersMethodgroup
get metrics group @param tagKeyValues @return
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/metrics/ConnectMetrics.java:116
↓ 12 callersMethodmaybeAddContainer
(org.apache.avro.Schema avroSchema, Object value, boolean wrap)
schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/AvroData.java:649
↓ 12 callersMethodread
(ByteBuffer buffer, Schema writerSchema, Schema readerSchema)
schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/serde/AvroDatumReaderFactory.java:70
↓ 12 callersMethodreadOffset
(RecordPartition partition)
connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/TestPositionStorageReader.java:28
↓ 12 callersMethodsetBody
(T body)
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/rest/entities/HttpResponse.java:51
↓ 12 callersMethodstartServer
(int port, byte[] body)
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/ServerResponseMocker.java:67
← previousnext →101–200 of 6,037, ranked by callers