Types & classes — github.com/LioRoger/subscribe_example

CodeHub MCPcopy Create free account

hub / github.com/LioRoger/subscribe_example / types & classes

Types & classes82 in github.com/LioRoger/subscribe_example

⨍ Functions 648◇ Types & classes 82

ClassAbstractDateTimeAdapter

javaimpl/src/main/java/recordprocessor/mysql/MysqlFieldConverter.java:140

ClassAtomicFileStore

javaimpl/src/main/java/common/AtomicFileStore.java:9

ClassAvroDeserializer

javaimpl/src/main/java/recordprocessor/AvroDeserializer.java:11

ClassBinaryAdapter

javaimpl/src/main/java/recordprocessor/mysql/MysqlFieldConverter.java:340

ClassBinaryGeometry

javaimpl/src/main/java/com/alibaba/dts/formats/avro/BinaryGeometry.java:13

ClassBinaryObject

javaimpl/src/main/java/com/alibaba/dts/formats/avro/BinaryObject.java:13

javaimpl/src/main/java/boot/Boot.java:30

RecordBuilder for Float instances.

javaimpl/src/main/java/com/alibaba/dts/formats/avro/Float.java:176

RecordBuilder for Decimal instances.

javaimpl/src/main/java/com/alibaba/dts/formats/avro/Decimal.java:176

RecordBuilder for Record instances.

javaimpl/src/main/java/com/alibaba/dts/formats/avro/Record.java:448

RecordBuilder for Source instances.

javaimpl/src/main/java/com/alibaba/dts/formats/avro/Source.java:157

RecordBuilder for Character instances.

javaimpl/src/main/java/com/alibaba/dts/formats/avro/Character.java:155

RecordBuilder for Timestamp instances.

javaimpl/src/main/java/com/alibaba/dts/formats/avro/Timestamp.java:155

RecordBuilder for TextObject instances.

javaimpl/src/main/java/com/alibaba/dts/formats/avro/TextObject.java:155

RecordBuilder for TextGeometry instances.

javaimpl/src/main/java/com/alibaba/dts/formats/avro/TextGeometry.java:155

RecordBuilder for TimestampWithTimeZone instances.

javaimpl/src/main/java/com/alibaba/dts/formats/avro/TimestampWithTimeZone.java:155

RecordBuilder for BinaryGeometry instances.

javaimpl/src/main/java/com/alibaba/dts/formats/avro/BinaryGeometry.java:155

RecordBuilder for BinaryObject instances.

javaimpl/src/main/java/com/alibaba/dts/formats/avro/BinaryObject.java:155

RecordBuilder for Integer instances.

javaimpl/src/main/java/com/alibaba/dts/formats/avro/Integer.java:155

RecordBuilder for Field instances.

javaimpl/src/main/java/com/alibaba/dts/formats/avro/Field.java:155

RecordBuilder for DateTime instances.

javaimpl/src/main/java/com/alibaba/dts/formats/avro/DateTime.java:260

javaimpl/src/main/java/com/alibaba/dts/formats/avro/Character.java:13

ClassCharacterAdapter

javaimpl/src/main/java/recordprocessor/mysql/MysqlFieldConverter.java:309

ClassCheckpoint

javaimpl/src/main/java/common/Checkpoint.java:5

ClassClusterSwitchException

javaimpl/src/main/java/recordgenerator/ClusterSwitchListener.java:56

ClassClusterSwitchListener

We recommend user register this listener. Cause when origin cluster is unavailable and new cluster is created by HA(high available service). The clu

javaimpl/src/main/java/recordgenerator/ClusterSwitchListener.java:21

EnumConsumerSubscribeMode

javaimpl/src/main/java/recordgenerator/RecordGenerator.java:190

ClassConsumerWrap

javaimpl/src/main/java/recordgenerator/ConsumerWrap.java:21

InterfaceConsumerWrapFactory

javaimpl/src/main/java/recordgenerator/ConsumerWrapFactory.java:5

javaimpl/src/main/java/common/Context.java:8

InterfaceDataAdapter

javaimpl/src/main/java/recordprocessor/mysql/MysqlFieldConverter.java:60

ClassDateAdapter

javaimpl/src/main/java/recordprocessor/mysql/MysqlFieldConverter.java:188

javaimpl/src/main/java/com/alibaba/dts/formats/avro/DateTime.java:13

ClassDateTimeAdapter

javaimpl/src/main/java/recordprocessor/mysql/MysqlFieldConverter.java:263

javaimpl/src/main/java/com/alibaba/dts/formats/avro/Decimal.java:13

ClassDecimalStringAdapter

javaimpl/src/main/java/recordprocessor/mysql/MysqlFieldConverter.java:91

ClassDefaultConsumerWrap

javaimpl/src/main/java/recordgenerator/ConsumerWrap.java:39

ClassDoubleStringAdapter

javaimpl/src/main/java/recordprocessor/mysql/MysqlFieldConverter.java:103

EnumEmptyObject

javaimpl/src/main/java/com/alibaba/dts/formats/avro/EmptyObject.java:7

ClassEtlRecordProcessor

This demo show how to resolve avro record deserialize from bytes We will show how to print a column from deserialize record

javaimpl/src/main/java/recordprocessor/EtlRecordProcessor.java:26

javaimpl/src/main/java/com/alibaba/dts/formats/avro/Field.java:13

InterfaceFieldConverter

javaimpl/src/main/java/recordprocessor/FieldConverter.java:7

ClassFieldEntryHolder

javaimpl/src/main/java/common/FieldEntryHolder.java:7

ClassFieldValue

javaimpl/src/main/java/recordprocessor/FieldValue.java:8

javaimpl/src/main/java/com/alibaba/dts/formats/avro/Float.java:13

ClassGeometryAdapter

javaimpl/src/main/java/recordprocessor/mysql/MysqlFieldConverter.java:326

javaimpl/src/main/java/com/alibaba/dts/formats/avro/Integer.java:13

ClassJDKEncodingMapper

javaimpl/src/main/java/recordprocessor/mysql/JDKEncodingMapper.java:6

ClassKafkaConsumerWrapFactory

javaimpl/src/main/java/recordgenerator/ConsumerWrapFactory.java:8

ClassKafkaMetaStore

javaimpl/src/main/java/metastore/KafkaMetaStore.java:18

ClassKafkaMetaStoreTest

javaimpl/src/test/java/store/KafkaMetaStoreTest.java:14

ClassLocalFileMetaStore

javaimpl/src/main/java/metastore/LocalFileMetaStore.java:14

ClassLocalFileMetaStoreTest

javaimpl/src/test/java/store/LocalFileMetaStoreTest.java:11

InterfaceMetaStore

javaimpl/src/main/java/metastore/MetaStore.java:7

ClassMetaStoreCenter

javaimpl/src/main/java/metastore/MetaStoreCenter.java:11

ClassMysqlFieldConverter

javaimpl/src/main/java/recordprocessor/mysql/MysqlFieldConverter.java:11

ClassMysqlRecordPrinter

this class show how to process record attribute and column

javaimpl/src/main/java/boot/MysqlRecordPrinter.java:19

javaimpl/src/main/java/recordgenerator/Names.java:3

ClassNotifyDemo

javaimpl/src/main/java/NotifyDemo.java:14

ClassNumberStringAdapter

javaimpl/src/main/java/recordprocessor/mysql/MysqlFieldConverter.java:79

InterfaceOffsetCommitCallBack

javaimpl/src/main/java/recordgenerator/OffsetCommitCallBack.java:6

javaimpl/src/main/java/com/alibaba/dts/formats/avro/Operation.java:7

javaimpl/src/main/java/com/alibaba/dts/formats/avro/Record.java:13

ClassRecordGenerator

javaimpl/src/main/java/recordgenerator/RecordGenerator.java:25

InterfaceRecordListener

javaimpl/src/main/java/common/RecordListener.java:5

javaimpl/src/main/java/com/alibaba/dts/formats/avro/Source.java:13

javaimpl/src/main/java/com/alibaba/dts/formats/avro/SourceType.java:7

ClassStoreElement

javaimpl/src/main/java/metastore/LocalFileMetaStore.java:23

ClassTextGeometry

javaimpl/src/main/java/com/alibaba/dts/formats/avro/TextGeometry.java:13

ClassTextObject

javaimpl/src/main/java/com/alibaba/dts/formats/avro/TextObject.java:13

ClassTextObjectAdapter

javaimpl/src/main/java/recordprocessor/mysql/MysqlFieldConverter.java:354

ClassTimeAdapter

javaimpl/src/main/java/recordprocessor/mysql/MysqlFieldConverter.java:208

javaimpl/src/main/java/com/alibaba/dts/formats/avro/Timestamp.java:13

ClassTimestampStringAdapter

javaimpl/src/main/java/recordprocessor/mysql/MysqlFieldConverter.java:115

ClassTimestampWithTimeZone

javaimpl/src/main/java/com/alibaba/dts/formats/avro/TimestampWithTimeZone.java:13

ClassUTF8StringEncodeAdapter

javaimpl/src/main/java/recordprocessor/mysql/MysqlFieldConverter.java:66

ClassUniqueKeyGenerator

for compaction enabled topic, empty key field in producer record is not allowed, so we gene random key to avoid compaction

javaimpl/src/main/java/common/UniqueKeyGenerator.java:7

InterfaceUserCommitCallBack

javaimpl/src/main/java/common/UserCommitCallBack.java:6

ClassUserRecord

javaimpl/src/main/java/common/UserRecord.java:6

javaimpl/src/main/java/common/Util.java:15

ClassWorkThread

javaimpl/src/main/java/common/WorkThread.java:7

ClassYearAdapter

javaimpl/src/main/java/recordprocessor/mysql/MysqlFieldConverter.java:293