hub / github.com/LioRoger/subscribe_example

github.com/LioRoger/subscribe_example @main

Chat with this repo

repository ↗ · DeepWiki ↗ · + Follow

730 symbols 1,137 edges 49 files 411 documented · 56%

What it actually does AI analysis from the code graph — generated when you open this

loading…

Extension points exported contracts — how you extend this code

OffsetCommitCallBack (Interface)

(no doc) [3 implementers]

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

ConsumerWrapFactory (Interface)

(no doc) [3 implementers]

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

UserCommitCallBack (Interface)

(no doc) [3 implementers]

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

MetaStore (Interface)

(no doc) [2 implementers]

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

FieldConverter (Interface)

(no doc) [1 implementers]

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

Core symbols most depended-on inside this repo

put

called by 59

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

setValue

called by 13

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

getMillis

called by 13

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

setEncoding

called by 12

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

get

called by 12

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

getValue

called by 11

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

getBytes

called by 10

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

getHour

called by 10

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

Shape

Method 647

Class 71

Interface 7

Enum 4

Function 1

Languages

Java100%

Go1%

Modules by API surface

javaimpl/src/main/java/com/alibaba/dts/formats/avro/Record.java109 symbols

javaimpl/src/main/java/com/alibaba/dts/formats/avro/DateTime.java58 symbols

javaimpl/src/main/java/recordprocessor/mysql/MysqlFieldConverter.java35 symbols

javaimpl/src/main/java/com/alibaba/dts/formats/avro/Float.java34 symbols

javaimpl/src/main/java/com/alibaba/dts/formats/avro/Decimal.java34 symbols

javaimpl/src/main/java/com/alibaba/dts/formats/avro/TimestampWithTimeZone.java31 symbols

javaimpl/src/main/java/com/alibaba/dts/formats/avro/Timestamp.java28 symbols

javaimpl/src/main/java/com/alibaba/dts/formats/avro/TextObject.java28 symbols

javaimpl/src/main/java/com/alibaba/dts/formats/avro/TextGeometry.java28 symbols

javaimpl/src/main/java/com/alibaba/dts/formats/avro/Source.java28 symbols

javaimpl/src/main/java/com/alibaba/dts/formats/avro/Integer.java28 symbols

javaimpl/src/main/java/com/alibaba/dts/formats/avro/Field.java28 symbols

For agents

$ claude mcp add subscribe_example \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact