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
↓ 12 callersMethodtoString
()
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/config/WorkerConfig.java:594
↓ 12 callersMethodtoString
()
connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/SinkConnectConfig.java:139
↓ 12 callersMethodvalidate
validate data
schema-converter/schema-converter-common/src/main/java/org/apache/rocketmq/schema/common/ParsedSchema.java:51
↓ 11 callersMethodaddHeader
添加请求头 @param key 参数名 @param value 参数值 @return
connectors/aliyun/rocketmq-connect-dingtalk/src/main/java/org/apache/rocketmq/connect/dingtalk/sink/common/OkHttpUtils.java:90
↓ 11 callersMethodbuilder
()
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/model/TableDescriptor.java:39
↓ 11 callersMethodcatalogName
()
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/table/TableId.java:42
↓ 11 callersMethodgetEvent
()
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/RedisEvent.java:28
↓ 11 callersMethodgetHttpAddr
()
rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/commom/Config.java:29
↓ 11 callersMethodgetHttpPort
()
rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/commom/Config.java:37
↓ 11 callersMethodgetName
()
connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/Table.java:76
↓ 11 callersMethodgetUser
()
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/cfg/DorisOptions.java:182
↓ 11 callersMethodisSrcAclEnable
()
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/TaskConfig.java:110
↓ 11 callersMethodjoin
Create a string representation of an array joined by the given separator @param strs The array of items @param separator The separator @return T
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/Utils.java:119
↓ 11 callersMethodmaybeWrapSchemaless
(Schema schema, Object value, String typeField)
schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/AvroData.java:653
↓ 11 callersMethodschema
()
schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/AvroData.java:2307
↓ 11 callersMethodschemaName
()
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/table/TableId.java:46
↓ 11 callersMethodschemaType
get schema type @return
schema-converter/schema-converter-common/src/main/java/org/apache/rocketmq/schema/common/ParsedSchema.java:32
↓ 11 callersMethodsendHttpRequest
(String baseUrl, String configs)
rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/utils/RestSender.java:31
↓ 11 callersMethodserializer
()
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/serialization/Serde.java:43
↓ 11 callersMethodstartByDefaultConf
use the specified port to start the nameserver @param nameServerPort nameServer port @param brokerPort broker port @return ServerResponseMocker
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/NameServerMocker.java:39
↓ 11 callersMethodtoMap
()
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/offset/TimestampIncrementingOffset.java:51
↓ 11 callersMethodtoString
Returns a string identifying this latch, as well as its state. The state, in brackets, includes the String {@code "Count ="} followed by the current c
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/CountDownLatch2.java:141
↓ 11 callersMethodtoString
()
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerConnector.java:365
↓ 11 callersMethodtoString
()
connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/entity/TokenEntity.java:124
↓ 10 callersMethodcreateGroupName
(String prefix)
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/ConnectUtil.java:77
↓ 10 callersMethoddeserializer
()
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/serialization/Serde.java:45
↓ 10 callersMethodequals
(Object o)
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/status/AbstractStatus.java:88
↓ 10 callersMethodgetAuthType
()
connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/constant/AuthTypeEnum.java:40
↓ 10 callersMethodgetBoolean
(KeyValue config, String key, Boolean defaultValue)
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/AbstractConfig.java:123
↓ 10 callersMethodgetClassLoader
()
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation/PluginWrapper.java:51
↓ 10 callersMethodgetDatabase
()
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/cfg/DorisOptions.java:190
↓ 10 callersMethodgetName
()
connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/auth/ApacheHttpClientImpl.java:435
↓ 10 callersMethodgetOperationType
(String operation)
connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/event/OperationType.java:42
↓ 10 callersMethodgetReplId
()
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/RedisEvent.java:44
↓ 10 callersMethodgetSchema
()
schema-converter/json-schema-converter/src/main/java/org/apache/rocketmq/schema/json/JsonSchemaAndValue.java:38
↓ 10 callersMethodgetTaskConfigs
()
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/common/ConnAndTaskConfigs.java:40
↓ 10 callersMethodgetTopicName
(RecordPartition recordPartition)
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/utils/ConnectRecordUtil.java:21
↓ 10 callersMethodgetWorker
()
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/AbstractConnectController.java:199
↓ 10 callersMethodload
Persist position info in a persist store.
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/PositionManagementService.java:61
↓ 10 callersMethodonCompletion
Invoked upon completion of the operation. @param error the error that caused the operation to fail, or null if no error occurred @param result the r
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/Callback.java:29
↓ 10 callersMethodputPosition
Put a position info.
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/PositionManagementService.java:80
↓ 10 callersMethodsetFieldToDefaultValues
(KeyValue config, String field, String value)
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/cfg/DorisSinkConnectorConfig.java:119
↓ 10 callersMethodsetTimeZone
(TimeZone timeZone)
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/common/IncrementContext.java:90
↓ 10 callersMethodtoJson
(Schema schema, Object value, JsonConverterConfig config)
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/converter/record/json/JsonConverter.java:388
↓ 9 callersMethodappendColumnName
(String name)
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/ExpressionBuilder.java:208
↓ 9 callersMethodconsumerRecord
@param consumedMessage the record
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/errors/ProcessingContext.java:76
↓ 9 callersMethoddoTransform
(ConnectRecord r)
transforms/src/main/java/org/apache/rocketmq/connect/transforms/SetNull.java:43
↓ 9 callersMethodexecuteQuery
()
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/querier/Querier.java:76
↓ 9 callersMethodgetDatabase
()
connectors/rocketmq-connect-hive/src/main/java/org/apache/rocketmq/connect/hive/config/HiveConfig.java:100
↓ 9 callersMethodgetIdl
()
schema-converter/schema-converter-common/src/main/java/org/apache/rocketmq/schema/common/SchemaResponse.java:65
↓ 9 callersMethodgetList
get list @param config @param key @return
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/AbstractConfig.java:102
↓ 9 callersMethodgetPassword
()
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/cfg/DorisOptions.java:186
↓ 9 callersMethodgetTopic
()
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/model/KafkaRespContent.java:29
↓ 9 callersMethodgetTopicPrefix
()
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/common/QueryContext.java:72
↓ 9 callersMethodisStopped
()
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventProcessor.java:39
↓ 9 callersMethodkeySchema
(Schema schema)
schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/AvroData.java:918
↓ 9 callersMethodnewJSONObject
(String key, Object value)
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/converter/record/json/JsonSchema.java:91
↓ 9 callersMethodregister
(@NotNull WatchService watcher, @NotNull WatchEvent.Kind<?>[] events, WatchEvent.
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/controller/isolation/TestPath.java:157
↓ 9 callersMethodreport
report message @param context
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/errors/ErrorReporter.java:31
↓ 9 callersMethodscale
Gets the column's number of digits to right of the decimal point. 0 is returned for data types where the scale is not applicable. @return scale
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/ColumnDefinition.java:215
↓ 9 callersMethodsetTimestamp
(String timestamp)
connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/entity/TokenEntity.java:80
↓ 9 callersMethodstart
start exporter
metric-exporter/src/main/java/org/apache/rocketmq/connect/metrics/IReporter.java:27
↓ 9 callersMethodtoConnectData
to connect data @param schema @param jsonValue @return
schema-converter/json-schema-converter/src/main/java/org/apache/rocketmq/schema/json/JsonSchemaData.java:326
↓ 9 callersMethodtoString
()
schema-converter/json-schema-converter/src/main/java/org/apache/rocketmq/schema/json/JsonSchema.java:147
↓ 9 callersMethodtoString
()
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/model/doris/Field.java:131
↓ 9 callersMethodversion
get schema version @return
schema-converter/schema-converter-common/src/main/java/org/apache/rocketmq/schema/common/ParsedSchema.java:46
↓ 8 callersMethodbuild
()
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/utils/HttpPutBuilder.java:118
↓ 8 callersMethodcreatePrimitiveSchema
(String type)
schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/util/AvroSchemaUtils.java:68
↓ 8 callersMethoddelegatingLoader
()
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation/Plugin.java:100
↓ 8 callersMethodequals
(Object o)
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation/PluginWrapper.java:79
↓ 8 callersMethodgetAccessKey
()
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/config/WorkerConfig.java:418
↓ 8 callersMethodgetConnectorConfigs
()
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/common/ConnAndTaskConfigs.java:32
↓ 8 callersMethodgetHeaderMap
()
connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/entity/HttpRequest.java:55
↓ 8 callersMethodgetHost
()
connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSetConfig.java:61
↓ 8 callersMethodgetId
()
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/rest/entities/TaskInfo.java:36
↓ 8 callersMethodgetMessage
()
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/model/RespContent.java:96
↓ 8 callersMethodgetName
()
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/converter/RecordDescriptor.java:153
↓ 8 callersMethodgetOffsetSuffix
()
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/common/QueryContext.java:80
↓ 8 callersMethodgetRecordId
()
schema-converter/schema-converter-common/src/main/java/org/apache/rocketmq/schema/common/SchemaResponse.java:57
↓ 8 callersMethodgetSecretKey
()
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/config/WorkerConfig.java:426
↓ 8 callersMethodgetUrl
()
connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/entity/HttpRequest.java:39
↓ 8 callersMethodgetValue
Get the actual converted value based on the column type.
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/converter/type/Type.java:49
↓ 8 callersMethodid
()
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/table/TableDefinition.java:66
↓ 8 callersMethodinitDefaultMQProducer
(WorkerConfig connectConfig)
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/ConnectUtil.java:114
↓ 8 callersMethodisEmpty
()
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation/PluginScanResult.java:89
↓ 8 callersMethodnewConverter
(ConnectKeyValue config, boolean isKey, String classPropertyName, String defaultConverter, ClassLoaderUsage cl
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation/Plugin.java:173
↓ 8 callersMethodparam
(Options<T> k, T v)
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/RedisEntry.java:129
↓ 8 callersMethodpluginClass
( DelegatingClassLoader loader, String classOrAlias, Class<U> pluginClass
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation/Plugin.java:58
↓ 8 callersMethodprocess
(R record, Schema inputSchema, Object input)
transforms/src/main/java/org/apache/rocketmq/connect/transforms/BaseTransformation.java:111
↓ 8 callersMethodputConnectorConfig
Put the configs of the specified connector in the cluster. @param connectorName @param configs @return @throws Exception
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/ConfigManagementService.java:70
↓ 8 callersMethodschema
()
connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/schema/RocketMQSourceSchemaConverter.java:55
↓ 8 callersMethodsetEpoch
(long epoch)
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/common/ConnectKeyValue.java:180
↓ 8 callersMethodsetTargetState
(TargetState targetState)
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/common/ConnectKeyValue.java:172
↓ 8 callersMethodsetValue
(byte[] value)
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/datasync/BrokerBasedLog.java:347
↓ 8 callersMethodstart
Start dependent services (if needed)
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/StateManagementService.java:41
↓ 8 callersMethodstartMQAdminTool
(WorkerConfig connectConfig)
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/ConnectUtil.java:162
↓ 7 callersMethodaddAndGet
(int count)
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/context/UnAckMessage.java:41
↓ 7 callersMethodasColumns
(Collection<String> names, TableId tableId)
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/GenericDatabaseDialect.java:985
↓ 7 callersMethodcloseQuietly
Closes {@code closeable} and if an exception is thrown, it is logged at the WARN level.
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/Utils.java:55
↓ 7 callersMethodcoalesceTimestampColumns
(ExpressionBuilder builder)
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/TimestampIncrementingCriteria.java:260
← previousnext →201–300 of 6,037, ranked by callers