Spark StarRocks Connector

CREATE TEMPORARY VIEW spark_starrocks
USING starrocks
OPTIONS(
  "table.identifier" = "$STARROCKS_DATABASE_NAME.$STARROCKS_TABLE_NAME",
  "fenodes" = "$STARROCKS_FE_HOSTNAME:$STARROCKS_FE_RESTFUL_PORT",
  "user" = "$STARROCKS_USERNAME",
  "password" = "$STARROCKS_PASSWORD"
);

SELECT * FROM spark_starrocks;

val starrocksSparkDF = spark.read.format("starrocks")
  .option("starrocks.table.identifier", "$STARROCKS_DATABASE_NAME.$STARROCKS_TABLE_NAME")
  .option("starrocks.fenodes", "$STARROCKS_FE_HOSTNAME:$STARROCKS_FE_RESTFUL_PORT")
  .option("user", "$STARROCKS_USERNAME")
  .option("password", "$STARROCKS_PASSWORD")
  .load()

starrocksSparkDF.show(5)

import com.starrocks.connector.spark._
val starrocksSparkRDD = sc.starrocksRDD(
  tableIdentifier = Some("$STARROCKS_DATABASE_NAME.$STARROCKS_TABLE_NAME"),
  cfg = Some(Map(
    "starrocks.fenodes" -> "$STARROCKS_FE_HOSTNAME:$STARROCKS_FE_RESTFUL_PORT",
    "starrocks.request.auth.user" -> "$STARROCKS_USERNAME",
    "starrocks.request.auth.password" -> "$STARROCKS_PASSWORD"
  ))
)

starrocksSparkRDD.collect()