apache/sedona

feat: add to_sedonadb() method

Open

#2511 aperta il 19 nov 2025

Vedi su GitHub
 (1 commento) (0 reazioni) (0 assegnatari)Scala (693 fork)batch import
help wanted

Metriche repository

Star
 (1953 star)
Metriche merge PR
 (Merge medio 1g 3h) (35 PR mergiate in 30 g)

Descrizione

It would be nice to have an interface that converts a SedonaSpark DataFrame to a SedonaDB DataFrame easily. Here is a current solution that works:

import sedona.db
sd = sedona.db.connect()

df = sd.create_data_frame(dataframe_to_arrow(spark_df))

This could be nice:

spark_df.to_sedonadb()

But maybe we'd have to do this:

spark_df.to_sedonadb(sd)

This would allow for cool spatial workflows, like this:

  • Read an Iceberg table with SedonaSpark and perform big data operations with a filtering operation at the end to make the data small enough to fit on a single machine
  • Convert the SedonaSpark DataFrame to SedonaDB
  • Use a library that's compatible with SedonaDB, like lonboard, to create a graph

Let me know what you think!

Guida contributor