hub / github.com/StarRocks/starrocks-connector-for-apache-flink

github.com/StarRocks/starrocks-connector-for-apache-flink @v1.2.15

repository ↗ · DeepWiki ↗ · release v1.2.15 ↗ · + Follow

2,624 symbols 10,129 edges 253 files 259 documented · 10% ● updated 14d agov1.2.15 · 2026-06-18★ 23277 open issues

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

loading…

README

StarRocks Connector for Apache Flink®

The connector supports to read from and write to StarRocks through Apache Flink®.

Documentation

For the user manual of the released version of the Flink connector, please visit the StarRocks official documentation.

For the new features in the snapshot version of the Flink connector, please see the docs in this repo.

LICENSE

The connector is under the Apache License 2.0.

Extension points exported contracts — how you extend this code

LabelGeneratorFactory (Interface)

Factory for LabelGenerator. [6 implementers]

starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream/LabelGeneratorFactory.java

RunnableWithException (Interface)

(no doc) [18 implementers]

src/test/java/com/starrocks/connector/flink/container/OperationManager.java

StarRocksISerializer (Interface)

(no doc) [7 implementers]

src/main/java/com/starrocks/connector/flink/row/sink/StarRocksISerializer.java

LabelGenerator (Interface)

Generate labels. [6 implementers]

starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream/LabelGenerator.java

ArrowFieldConverter (Interface)

(no doc) [14 implementers]

src/main/java/com/starrocks/connector/flink/row/source/ArrowFieldConverter.java

CompressionCodec (Interface)

Compress data with the specified compression algorithm. [3 implementers]

starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream/compress/CompressionCodec.java

RecordSerializationSchema (Interface)

A serialization schema which defines how to convert a value of type T to StarRocksRowData. @param t [3 implementers]

src/main/java/com/starrocks/connector/flink/table/sink/v2/RecordSerializationSchema.java

TableRegion (Interface)

(no doc) [4 implementers]

starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream/TableRegion.java

Core symbols most depended-on inside this repo

withProperty

called by 243

src/main/java/com/starrocks/connector/flink/table/sink/StarRocksSinkOptions.java

called by 109

src/main/java/com/starrocks/connector/flink/table/sink/StarrocksSnapshotState.java

getMessage

called by 101

starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream/StreamLoadResponse.java

isEmpty

called by 90

starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream/v2/PartitionCommitTracker.java

getLogger

called by 66

starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream/mergecommit/SharedService.java

getException

called by 58

starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream/v2/StreamLoadManagerV2.java

execute

called by 54

src/main/java/com/starrocks/connector/flink/table/sink/LingeringTransactionAborter.java

getString

called by 52

src/main/java/com/starrocks/connector/flink/cdc/SourceSchema.java

Shape

Method 2,258

Class 321

Interface 24

Enum 21

Languages

Java100%

Modules by API surface

starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream/properties/StreamLoadProperties.java85 symbols

starrocks-stream-load-sdk/src/test/java/com/starrocks/data/load/stream/MockedStarRocksHttpServer.java64 symbols

starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream/v2/TransactionTableRegion.java63 symbols

src/main/java/com/starrocks/connector/flink/table/sink/StarRocksSinkOptions.java63 symbols

starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream/StreamLoadResponse.java57 symbols

src/main/java/com/starrocks/connector/flink/catalog/FlinkCatalog.java53 symbols

src/test/java/com/starrocks/connector/flink/it/sink/MultiTableTransactionITTest.java50 symbols

src/main/java/com/starrocks/connector/flink/row/source/ArrowFieldConverter.java47 symbols

src/test/java/com/starrocks/connector/flink/it/sink/StarRocksSinkITTest.java44 symbols

starrocks-stream-load-sdk/src/test/java/com/starrocks/data/load/stream/mergecommit/TableTest.java41 symbols

starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream/v2/DefaultStreamLoadManager.java39 symbols

starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream/BatchTableRegion.java34 symbols

Datastores touched

(mysql)Database · 1 repos

For agents

$ claude mcp add starrocks-connector-for-apache-flink \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact