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

↓ 4 callersMethodrawSchema

()

schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/AvroSchema.java:89

↓ 4 callersMethodreadOffset

(RecordPartition partition)

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store/PositionStorageReaderImpl.java:40

↓ 4 callersMethodrecordFailure

()

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/errors/ErrorMetricsGroup.java:77

↓ 4 callersMethodrecordId

(long recordId)

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

↓ 4 callersMethodrecoverClassLoader

()

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

↓ 4 callersMethodrefresh

Refresh the cached {@link TableDefinition} for the given table. @param connection the JDBC connection to use; may not be null @param tableId the t

connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/table/TableDefinitions.java:79

↓ 4 callersMethodregisterListener

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

↓ 4 callersMethodremovePosition

Remove a position info. @param partitions

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/PositionManagementService.java:89

↓ 4 callersMethodreset

()

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/CountDownLatch2.java:131

↓ 4 callersMethodreset

(long now)

connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/querier/Querier.java:84

↓ 4 callersMethodresetAndRequeueHead

(Querier querier)

connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/JdbcSourceTask.java:141

↓ 4 callersMethodschemaName

(String schemaName)

schema-converter/schema-converter-common/src/main/java/org/apache/rocketmq/schema/common/AbstractLocalSchemaRegistryClient.java:210

↓ 4 callersMethodseek

(long signalOffset)

connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-mysql/src/main/java/io/debezium/connector/mysql/signal/RocketMqSignalThread.java:215

↓ 4 callersMethodsetConsumeFromWhere

(String consumeFromWhereValue)

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

↓ 4 callersMethodsetCredentials

(String user, String password)

connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/auth/ThreadLocalProxyAuthenticator.java:34

↓ 4 callersMethodsetName

(String name)

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/rest/entities/ConnectorInfo.java:49

↓ 4 callersMethodsetStorePathRootDir

(String storePathRootDir)

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

↓ 4 callersMethodsetUrl

(String url)

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

↓ 4 callersMethodshouldLoadInIsolation

Return whether the class with the given name should be loaded in isolation using a plugin classloader. @param name the fully qualified name of the cl

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

↓ 4 callersMethodsimpleName

Return the simple class name of a plugin as {@code String}. @param plugin the plugin descriptor. @return the plugin's simple class name.

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

↓ 4 callersMethodsourceId

(String id)

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

↓ 4 callersMethodsourceRecord

@return the source record being processed.

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

↓ 4 callersMethodsubmitRecord

submit record @param position @return

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/RecordOffsetManagement.java:55

↓ 4 callersMethodtableExists

(Connection connection, TableId tableId)

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

↓ 4 callersMethodtaskConfigs

(int maxTasks)

connectors/rocketmq-connect-mqtt/src/main/java/org/apache/rocketmq/connect/mqtt/connector/MqttSinkConnector.java:46

↓ 4 callersMethodtaskTagName

()

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/metrics/ConnectMetricsTemplates.java:149

↓ 4 callersMethodtemplates

get connect metrics template @return

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/metrics/ConnectMetrics.java:96

↓ 4 callersMethodtoString

()

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/stats/ConnectStatsService.java:64

↓ 4 callersMethodtoString

()

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

↓ 4 callersMethodtoString

()

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

↓ 4 callersMethodtriggerListener

()

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/memory/MemoryConfigManagementServiceImpl.java:204

↓ 4 callersMethodurl

Get the full JDBC URL. @return the URL.

connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/JdbcUrlInfo.java:42

↓ 4 callersMethodvalidateEnumInstances

(String value, String[] instances)

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/utils/ConfigCheckUtils.java:298

↓ 4 callersMethodwaitForRunning

(long interval)

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

↓ 4 callersMethodwakeup

()

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

↓ 4 callersMethodwithinToleranceLimits

()

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

↓ 3 callersMethodByteArray

A serde for nullable {@code byte[]} type.

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/serialization/Serdes.java:190

↓ 3 callersMethodTARGET_STATE_KEY

(String connectorName)

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

↓ 3 callersMethodaddAvroRecordField

( List<org.apache.avro.Schema.Field> fields, String fieldName, Schema fiel

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

↓ 3 callersMethodaddLogicalTypeConversion

add logical type conversion @param avroData

schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/serde/AvroSerdeFactory.java:33

↓ 3 callersMethodappendIdentifierDelimiter

()

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

↓ 3 callersMethodapply

()

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

↓ 3 callersMethodavroSchemaForUnderlyingTypeIfOptional

Connect optional fields are represented as a unions (null & type) in Avro Return the Avro schema of the actual type in the Union (instead of the union

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

↓ 3 callersMethodbindKeyFields

(ConnectRecord record, int index)

connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/binder/AbstractJdbcRecordBinder.java:86

↓ 3 callersMethodbuild

()

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/converter/RecordDescriptor.java:202

↓ 3 callersMethodbuildCommandlineOptions

(final Options options)

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/ServerUtil.java:31

↓ 3 callersMethodbuildCommandlineOptions

(final Options options)

rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/utils/ServerUtil.java:31

↓ 3 callersMethodbuildDeadLetterQueueReporter

()

rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/errors/DeadLetterQueueReporterTest.java:88

↓ 3 callersMethodbuildRecordPartition

(String dbName, String tableName)

connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/source/Querier.java:174

↓ 3 callersMethodbuildRoute

()

connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqSourceReplicator.java:207

↓ 3 callersMethodcast

(Object value)

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/converter/record/NumberConverter.java:84

↓ 3 callersMethodcheckConfig

(KeyValue config)

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

↓ 3 callersMethodcheckEnqueuedSnapshotSignals

(OffsetContext offsetContext)

connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-mysql/src/main/java/io/debezium/connector/mysql/MySqlReadOnlyIncrementalSnapshotChangeEventSource.java:239

↓ 3 callersMethodcheckNeedParams

(String connectorName, KeyValue config, Set<String> neededParamKeys)

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

↓ 3 callersMethodclone

(T obj)

connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/CloneUtils.java:26

↓ 3 callersMethodcommitOffsets

()

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerSourceTask.java:562

↓ 3 callersMethodcommitTaskRecord

(ConnectRecord preTransformRecord, SendResult result)

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerSourceTask.java:382

↓ 3 callersMethodcommonHash

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

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

↓ 3 callersMethodcommonMapParser

(KVEntry builder, String[] args)

connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/CommonParser.java:57

↓ 3 callersMethodcommonZSet

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

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

↓ 3 callersMethodcompare

(Map<String, Set<TaskTopicInfo>> origin, Map<String, Set<TaskTopicInfo>> updated)

connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqSourceReplicator.java:145

↓ 3 callersMethodconfigs

()

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

↓ 3 callersMethodconvert

(Document document, String replicaSetName)

connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/event/Document2EventConverter.java:34

↓ 3 callersMethodconvertToJson

Convert this object, in the org.apache.kafka.connect.data format, into a JSON object, returning both the schema and the converted object.

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

↓ 3 callersMethodconvertToRecordOffset

(Long offset)

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

↓ 3 callersMethodconverters

()

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

↓ 3 callersMethodcopyOf

(AvroSchema schema)

schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/util/AvroSchemaUtils.java:73

↓ 3 callersMethodcreate

()

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

↓ 3 callersMethodcreateGroupName

(String prefix)

connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/Utils.java:37

↓ 3 callersMethodcreateMongoClient

(ReplicaSetConfig replicaSetConfig)

connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSetsContext.java:59

↓ 3 callersMethodcreateUniqInstance

(String prefix)

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

↓ 3 callersMethodcreateUniqInstanceName

(String prefix)

connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/common/Utils.java:79

↓ 3 callersMethodcurrentContext

A helper method to set both the stage and the class. @param stage the stage @param klass the class which will execute the operation in this stage.

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

↓ 3 callersMethoddecimalFormat

Get the serialization format for decimal types. @return the decimal serialization format

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/converter/record/json/JsonConverterConfig.java:86

↓ 3 callersMethoddecode

(byte[] body)

connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/offset/OffsetSync.java:71

↓ 3 callersMethoddeepEquals

deep equals @param schema @return

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

↓ 3 callersMethoddefinitionsForColumns

()

connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/table/TableDefinition.java:82

↓ 3 callersMethoddescribeColumns

(Connection connection, String tablePattern, String columnPattern)

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

↓ 3 callersMethoddestroy

()

connectors/rocketmq-connect-hive/src/main/java/org/apache/rocketmq/connect/hive/config/HiveJdbcDriverManager.java:56

↓ 3 callersMethoddisplayableTableTypes

(String[] types, String delim)

connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/GenericDatabaseDialect.java:404

↓ 3 callersMethoddoClose

()

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

↓ 3 callersMethoddoRetry

(Callable<T> callable, int retryTimes, long sleepTimeInMilliSecond, boolean exponential, List<Class<?>> retryE

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/RetryUtil.java:115

↓ 3 callersMethodenabledCompactTopic

()

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/ICommonConfiguration.java:21

↓ 3 callersMethodequals

(Object obj)

connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/common/ColumnMapping.java:64

↓ 3 callersMethodexecuteFailed

(ErrorReporter.Stage stage, Class<?> executingClass,

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

↓ 3 callersMethodexpressionBuilder

()

connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/GenericDatabaseDialect.java:330

↓ 3 callersMethodextractColumnValuesBySQL

( String sql, int columnIndex, Predicate<String> filterFunc, Object... params)

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/service/DorisSystemService.java:87

↓ 3 callersMethodfailed

failed @return

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

↓ 3 callersMethodfilePrefix

generate file prefix @param appName connector name @param partition partition index @return file prefix

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/utils/FileNameUtils.java:51

↓ 3 callersMethodfilterEvent

(ReplicationEvent event)

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

↓ 3 callersMethodfinalOffsetCommit

(boolean b)

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerSourceTask.java:552

↓ 3 callersMethodfinishedAllWrites

()

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerSourceTask.java:743

↓ 3 callersMethodflush

Support doris's two-phase commit

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/DorisSinkTask.java:54

↓ 3 callersMethodflush

(final RecordBuffer buff)

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/writer/DorisWriter.java:177

↓ 3 callersMethodfree

(Blob blob)

connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/converter/DefaultColumnConverter.java:276

↓ 3 callersMethodfromConnectData

from connect data @param topic the topic associated with the data @param schema record schema @param value record value @return

schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/AvroConverter.java:62

↓ 3 callersMethodgenerateTaskIdWithIndexAsConsumerGroup

()

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

↓ 3 callersMethodgetAll

Get the states of all tasks for the given connector. @param connector the connector name @return a map from task ids to their respective status

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

↓ 3 callersMethodgetAllAliveWorkers

Get all alive workers in the cluster. @return

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/ClusterManagementService.java:62

↓ 3 callersMethodgetArrayKVEntry

(int size)

connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/converter/RedisEntryConverterTest.java:98

← previous next →601–700 of 6,037, ranked by callers