Types & classes — github.com/apache/rocketmq-connect

hub / github.com/apache/rocketmq-connect / types & classes

Types & classes1,172 in github.com/apache/rocketmq-connect

⨍ Functions 6,037◇ Types & classes 1,172

connectors/rocketmq-connect-cassandra/scripts/gen_data.py:34

connectors/rocketmq-connect-connectors-archetype/src/main/resources/archetype-resources/src/test/java/sink/__dbNameToCamel__SinkTaskTest.java:20

Class$

connectors/rocketmq-connect-connectors-archetype/src/main/resources/archetype-resources/src/test/java/source/__dbNameToCamel__SourceTaskTest.java:15

Class$

connectors/rocketmq-connect-connectors-archetype/src/main/resources/archetype-resources/src/main/java/sink/__dbNameToCamel__SinkTask.java:37

Class$

connectors/rocketmq-connect-connectors-archetype/src/main/resources/archetype-resources/src/main/java/sink/__dbNameToCamel__SinkConnector.java:30

Class$

connectors/rocketmq-connect-connectors-archetype/src/main/resources/archetype-resources/src/main/java/source/__dbNameToCamel__SourceTask.java:48

Class$

connectors/rocketmq-connect-connectors-archetype/src/main/resources/archetype-resources/src/main/java/source/__dbNameToCamel__SourceConnector.java:30

Class$

connectors/rocketmq-connect-connectors-archetype/src/main/resources/archetype-resources/src/main/java/helper/__dbNameToCamel__Record.java:23

Class$

connectors/rocketmq-connect-connectors-archetype/src/main/resources/archetype-resources/src/main/java/helper/__dbNameToCamel__HelperClient.java:35

Class$

connectors/rocketmq-connect-connectors-archetype/src/main/resources/archetype-resources/src/main/java/config/__dbNameToCamel__SourceConfig.java:26

Class$

connectors/rocketmq-connect-connectors-archetype/src/main/resources/archetype-resources/src/main/java/config/__dbNameToCamel__SinkConfig.java:26

ClassAbstractCommandParser

connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/AbstractCommandParser.java:31

ClassAbstractConfig

abstract config

connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/AbstractConfig.java:30

ClassAbstractConfigManagementService

Interface for config manager. Contains connector configs and task configs. All worker in a cluster should keep the same configs.

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

ClassAbstractConnectController

connect controller

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

ClassAbstractConnectMapType

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/converter/type/connect/AbstractConnectMapType.java:26

ClassAbstractConnectSchemaType

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/converter/type/connect/AbstractConnectSchemaType.java:24

ClassAbstractConverterConfig

abstract converter config

schema-converter/schema-converter-common/src/main/java/org/apache/rocketmq/schema/common/AbstractConverterConfig.java:25

ClassAbstractDateType

An abstract base class for all temporal date implementations of {@link Type}.

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/converter/type/AbstractDateType.java:28

ClassAbstractDebeziumTimeType

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/converter/type/debezium/AbstractDebeziumTimeType.java:27

ClassAbstractDebeziumTimestampType

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/converter/type/debezium/AbstractDebeziumTimestampType.java:26

ClassAbstractGeometryType

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/converter/type/AbstractGeometryType.java:25

ClassAbstractHistogram

Abstract Histogram

metric-exporter/src/main/java/org/apache/rocketmq/connect/metrics/stats/AbstractHistogram.java:25

InterfaceAbstractHttpClient

connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/auth/AbstractHttpClient.java:23

ClassAbstractJdbcRecordBinder

prepared statement binder

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

ClassAbstractKafkaConnectSink

abstract kafka connect sink

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

ClassAbstractKafkaConnectSource

abstract kafka connect

connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/task/AbstractKafkaConnectSource.java:43

ClassAbstractKafkaSinkConnector

kafka source connector

connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/connector/AbstractKafkaSinkConnector.java:36

ClassAbstractKafkaSourceConnector

kafka source connector

connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/connector/AbstractKafkaSourceConnector.java:36

ClassAbstractLocalSchemaRegistryClient

Local schema registry client

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

ClassAbstractMNSRecordConvert

connectors/aliyun/rocketmq-connect-mns/src/main/java/org/apache/rocketmq/connect/mns/source/AbstractMNSRecordConvert.java:14

ClassAbstractPositionManagementService

Abstract position management service

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/AbstractPositionManagementService.java:45

ClassAbstractRecordConverterTest

record converter test

rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/converter/record/AbstractRecordConverterTest.java:8

ClassAbstractState

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/rest/entities/ConnectorStateInfo.java:78

ClassAbstractStateManagementService

State management service

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/AbstractStateManagementService.java:54

ClassAbstractStatus

abstract state @param <T>

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

ClassAbstractTemporalType

An abstract base class for all temporal implementations of {@link Type}.

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/converter/type/AbstractTemporalType.java:31

ClassAbstractTimeType

An abstract temporal implementation of {@link Type} for {@code TIME} based columns.

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/converter/type/AbstractTimeType.java:30

ClassAbstractTimestampType

An abstract temporal implementation of {@link Type} for {@code TIMESTAMP} based columns.

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/converter/type/AbstractTimestampType.java:30

ClassAbstractType

An abstract implementation of {@link Type}, which all types should extend.

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/converter/type/AbstractType.java:31

ClassActivemqConnectorTest

connectors/rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/connector/ActivemqConnectorTest.java:28

ClassActivemqSourceConnector

connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceConnector.java:27

ClassActivemqSourceTask

connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceTask.java:50

ClassActivemqSourceTaskTest

connectors/rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceTaskTest.java:58

ClassAliyunMnsUtil

connectors/aliyun/rocketmq-connect-mns/src/main/java/org/apache/rocketmq/connect/mns/source/utils/AliyunMnsUtil.java:5

InterfaceAllocateConnAndTaskStrategy

Connectors and tasks distribute strategy.

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

ClassAllocateConnAndTaskStrategyByConsistentHash

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/strategy/AllocateConnAndTaskStrategyByConsistentHash.java:36

ClassAllocateConnAndTaskStrategyByConsistentHashTest

rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/service/strategy/AllocateConnAndTaskStrategyByConsistentHashTest.java:34

ClassApacheHttpClientImpl

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

ClassApiKeyAuthImpl

connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/auth/ApiKeyAuthImpl.java:28

ClassAppendParser

APPEND key value

connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/AppendParser.java:27

ClassArgumentsException

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/exception/ArgumentsException.java:22

ClassArrayType

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/converter/type/debezium/ArrayType.java:32

ClassAssertSchema

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

ClassAssertStruct

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

ClassAssignEncodedPartitionRocketmqRecordPartitionKafkaTopicPartitionMapper

connectors/rocketmq-connect-kafka-connector-adapter/src/main/java/org/apache/rocketmq/connect/kafka/util/AssignEncodedPartitionRocketmqRecordPartitionKafkaTopicPartitionMapper.java:8

ClassAsyncRetry

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

InterfaceAuth

connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/auth/Auth.java:21

EnumAuthTypeEnum

connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/constant/AuthTypeEnum.java:19

InterfaceAutoConfiguration

auto configuration

metric-exporter/src/main/java/org/apache/rocketmq/connect/metrics/AutoConfiguration.java:24

ClassAvg

avg

metric-exporter/src/main/java/org/apache/rocketmq/connect/metrics/stats/Avg.java:26

ClassAvroConverter

avro converter

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

ClassAvroConverterConfig

Avro converter config

schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/AvroConverterConfig.java:27

ClassAvroConverterTest

schema-converter/avro-schema-converter/src/test/java/com/apache/rocketmq/schema/avro/test/AvroConverterTest.java:16

ClassAvroData

Avro serialization and deserialization

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

ClassAvroDataConfig

avro data config

schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/AvroDataConfig.java:27

ClassAvroDatumReaderFactory

schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/serde/AvroDatumReaderFactory.java:37

ClassAvroDatumWriterFactory

schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/serde/AvroDatumWriterFactory.java:34

ClassAvroDeserializer

avro serializer

schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/serde/AvroDeserializer.java:38

ClassAvroSchema

avro schema

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

ClassAvroSchemaRegistryClient

avro local schema registry client

schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/AvroSchemaRegistryClient.java:31

ClassAvroSchemaUtils

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

ClassAvroSerdeFactory

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

ClassAvroSerializer

avro serializer

schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/serde/AvroSerializer.java:42

ClassBackendRowV2

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/model/BackendV2.java:43

ClassBackendUtils

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/utils/BackendUtils.java:32

ClassBackendV2

Be response model.

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/model/BackendV2.java:29

ClassBackoffAndRetryUtils

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

ClassBase64Util

base64 utils

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

ClassBase64UtilTest

rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/utils/Base64UtilTest.java:24

ClassBaseJmsSourceConnector

connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceConnector.java:27

ClassBaseJmsSourceConnectorTest

connectors/rocketmq-connect-jms/src/test/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceConnectorTest.java:33

ClassBaseJmsSourceTask

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

ClassBaseRegistrySchema

schema-converter/schema-converter-common/src/test/java/com/apache/rocketmq/schema/common/BaseRegistrySchema.java:6

ClassBaseResponse

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/model/BaseResponse.java:24

ClassBaseTransformation

transforms/src/main/java/org/apache/rocketmq/connect/transforms/BaseTransformation.java:38

ClassBasicAuthImpl

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

ClassBasicListBuilder

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

ClassBigIntColumnParser

connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/BigIntColumnParser.java:22

ClassBitFieldParser

BITFIELD key [GET type offset] [SET type offset value] [INCRBY type offset increment] [OVERFLOW WRAP|SAT|FAIL]

connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BitFieldParser.java:27

ClassBitOpParser

BITOP operation destkey key [key ...]

connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BitOpParser.java:31

ClassBooleanColumnParser

connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/BooleanColumnParser.java:21

ClassBrPopLPushParser

BRPOPLPUSH source destination timeout

connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BrPopLPushParser.java:28

ClassBrokerBasedLog

A Broker base data synchronizer, synchronize data between workers. @param <K> @param <V>

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/datasync/BrokerBasedLog.java:61

ClassBrokerBasedLogTest

rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/utils/datasync/BrokerBasedLogTest.java:53

ClassBufferedRecords

buffered records

connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/BufferedRecords.java:42

ClassBuilder

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

ClassBuilder

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/model/ColumnDescriptor.java:58

ClassBuilder

connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/model/TableDescriptor.java:63

ClassBuilder

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

next →1–100 of 1,172, ranked by callers