MCPcopy Index your code
hub / github.com/StarRocks/starrocks-connector-for-apache-spark

github.com/StarRocks/starrocks-connector-for-apache-spark @v1.1.3

Chat with this repo
repository ↗ · DeepWiki ↗ · release v1.1.3 ↗ · + Follow
395 symbols 1,118 edges 56 files 21 documented · 5% ● updated 35d agov1.1.3 · 2025-05-15★ 5128 open issues
What it actually does AI analysis from the code graph — generated when you open this
loading…
README

StarRocks Connector for Apache Spark™

The connector supports to read from and write to StarRocks through Apache Spark™.

Documentation

For the user manual of the released version of the Spark connector, please visit the StarRocks official documentation. * Read data from StarRocks using Spark connector * Load data using Spark connector

For the new features in the snapshot version of the Spark connector, please see the docs in this repo. * Read from StarRocks * Write to StarRocks

LICENSE

The connector is under the Apache License 2.0.

Contributing to StarRocks

We appreciate your interest in contributing to the Spark Connector. If you plan to make your first contribution, you can start with the CONTRIBUTING.md.

Acknowledgments

Apache doris-spark-connector is the upstream of this connector for reading from StarRocks. We are very grateful to Apache Doris community for contributing such an excellent connector.

Extension points exported contracts — how you extend this code

RowStringConverter (Interface)
(no doc) [4 implementers]
src/main/java/com/starrocks/connector/spark/sql/schema/RowStringConverter.java
StarRocksConfig (Interface)
(no doc) [2 implementers]
src/main/java/com/starrocks/connector/spark/sql/conf/StarRocksConfig.java
ConfigurationOptions (Interface)
(no doc)
src/main/java/com/starrocks/connector/spark/cfg/ConfigurationOptions.java

Core symbols most depended-on inside this repo

put
called by 100
src/main/java/com/starrocks/connector/spark/rest/models/Schema.java
get
called by 51
src/main/java/com/starrocks/connector/spark/sql/conf/StarRocksConfigBase.java
get
called by 22
src/main/java/com/starrocks/connector/spark/rest/models/Schema.java
addValueToRow
called by 19
src/main/java/com/starrocks/connector/spark/serialization/RowBatch.java
size
called by 19
src/main/java/com/starrocks/connector/spark/rest/models/Schema.java
next
called by 18
src/main/java/com/starrocks/connector/spark/serialization/RowBatch.java
hasNext
called by 17
src/main/java/com/starrocks/connector/spark/serialization/RowBatch.java
getStatus
called by 16
src/main/java/com/starrocks/connector/spark/rest/models/Schema.java

Shape

Method 334
Class 58
Interface 3

Languages

Java100%

Modules by API surface

src/test/java/com/starrocks/connector/spark/sql/ReadWriteITTest.java42 symbols
src/main/java/com/starrocks/connector/spark/sql/conf/StarRocksConfigBase.java21 symbols
src/main/java/com/starrocks/connector/spark/rest/models/Field.java15 symbols
src/main/java/com/starrocks/connector/spark/sql/conf/WriteStarRocksConfig.java14 symbols
src/main/java/com/starrocks/connector/spark/sql/conf/StarRocksConfig.java14 symbols
src/main/java/com/starrocks/connector/spark/serialization/RowBatch.java13 symbols
src/main/java/com/starrocks/connector/spark/rest/models/Schema.java12 symbols
src/main/java/com/starrocks/connector/spark/rest/RestService.java12 symbols
src/main/java/com/starrocks/connector/spark/rest/PartitionDefinition.java12 symbols
src/test/java/com/starrocks/connector/spark/sql/ITTestBase.java11 symbols
src/test/java/com/starrocks/connector/spark/sql/ConfigurationITTest.java11 symbols
src/main/java/com/starrocks/connector/spark/sql/write/StarRocksWriteBuilder.java11 symbols

Datastores touched

(mysql)Database · 1 repos

For agents

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

⬇ download graph artifact

Ask about this repo answers extend the page