Skip to content

Spark 4.0 - Duplicate and Adjust code base from previous versions #406

@BentsiLeviav

Description

@BentsiLeviav

All versions' implementation in this connector shares the same code base, with some adjustments for each version, for instance:

  • spark-3.5/clickhouse-spark/src/main/scala/org/apache/spark/sql/clickhouse/ClickHouseSQLConf.scala
  • spark-3.5/clickhouse-spark/src/main/scala/org/apache/spark/sql/clickhouse/ExprUtils.scala
  • spark-3.5/clickhouse-spark/src/main/scala/org/apache/spark/sql/clickhouse/JsonWriter.scala
  • spark-3.5/clickhouse-spark/src/main/scala/org/apache/spark/sql/clickhouse/SchemaUtils.scala (Spark 4.0 - Add VARIANT data type support #404 Writing StructType to ClickHouse #278)
  • spark-3.5/clickhouse-spark/src/main/scala/org/apache/spark/sql/clickhouse/SparkOptions.scala
  • spark-3.5/clickhouse-spark/src/main/scala/org/apache/spark/sql/clickhouse/SparkUtils.scala
  • spark-3.5/clickhouse-spark/src/main/scala/com/clickhouse/ClickHouseCatalog.scala
  • spark-3.5/clickhouse-spark/src/main/scala/com/clickhouse/ClickHouseCommandRunner.scala
  • spark-3.5/clickhouse-spark/src/main/scala/com/clickhouse/ClickHouseHelper.scala
  • spark-3.5/clickhouse-spark/src/main/scala/com/clickhouse/ClickHouseTable.scala
  • spark-3.5/clickhouse-spark/src/main/scala/com/clickhouse/CommitMessage.scala
  • spark-3.5/clickhouse-spark/src/main/scala/com/clickhouse/Constants.scala
  • spark-3.5/clickhouse-spark/src/main/scala/com/clickhouse/Metrics.scala
  • spark-3.5/clickhouse-spark/src/main/scala/com/clickhouse/SQLHelper.scala
  • spark-3.5/clickhouse-spark/src/main/scala/com/clickhouse/func/CityHash64.scala
  • spark-3.5/clickhouse-spark/src/main/scala/com/clickhouse/func/FunctionRegistry.scala
  • spark-3.5/clickhouse-spark/src/main/scala/com/clickhouse/func/MultiStringArgsHash.scala
  • spark-3.5/clickhouse-spark/src/main/scala/com/clickhouse/func/MurmurHash2.scala
  • spark-3.5/clickhouse-spark/src/main/scala/com/clickhouse/func/MurmurHash3.scala
  • spark-3.5/clickhouse-spark/src/main/scala/com/clickhouse/func/XxHash64.scala
  • spark-3.5/clickhouse-spark/src/main/scala/com/clickhouse/read/ClickHouseMetadataColumn.scala
  • spark-3.5/clickhouse-spark/src/main/scala/com/clickhouse/read/ClickHouseRead.scala
  • spark-3.5/clickhouse-spark/src/main/scala/com/clickhouse/read/ClickHouseReader.scala
  • spark-3.5/clickhouse-spark/src/main/scala/com/clickhouse/read/InputPartitions.scala
  • spark-3.5/clickhouse-spark/src/main/scala/com/clickhouse/read/ScanJobDescription.scala
  • spark-3.5/clickhouse-spark/src/main/scala/com/clickhouse/read/format/ClickHouseBinaryReader.scala
  • spark-3.5/clickhouse-spark/src/main/scala/com/clickhouse/read/format/ClickHouseJsonReader.scala
  • spark-3.5/clickhouse-spark/src/main/scala/com/clickhouse/write/ClickHouseWrite.scala
  • spark-3.5/clickhouse-spark/src/main/scala/com/clickhouse/write/ClickHouseWriter.scala
  • spark-3.5/clickhouse-spark/src/main/scala/com/clickhouse/write/WriteJobDescription.scala
  • spark-3.5/clickhouse-spark/src/main/scala/xenon/clickhouse/write/format/ClickHouseArrowStreamWriter.scala
  • spark-3.5/clickhouse-spark/src/main/scala/xenon/clickhouse/write/format/ClickHouseJsonEachRowWriter.scala

This is a partial list, and there might be more files to copy & adjust.

Metadata

Metadata

Assignees

Labels

No labels
No labels

Type

No type

Projects

No projects

Relationships

None yet

Development

No branches or pull requests

Issue actions