nit

Author: pan3793

spark-3.4/clickhouse-spark/src/main/scala/xenon/clickhouse/func/Days.scala

@@ -22,15 +22,15 @@ import java.time.format.DateTimeFormatter
 
 object Days extends UnboundFunction with ScalarFunction[Int] with ClickhouseEquivFunction {
 
-  override def name: String = "clickhouse_days"
+  override def name: String = "clickhouse_toYYYYMMDD"
 
   override def canonicalName: String = s"clickhouse.$name"
 
   override def toString: String = name
 
   override val ckFuncNames: Array[String] = Array("toYYYYMMDD")
 
-  override def description: String = s"$name: (date: Date) => shard_num: int"
+  override def description: String = s"$name: (date: DATE) => YYYYMMDD: STRING"
 
   override def bind(inputType: StructType): BoundFunction = inputType.fields match {
     case Array(StructField(_, DateType, _, _)) => this

spark-3.4/clickhouse-spark/src/main/scala/xenon/clickhouse/func/FunctionRegistry.scala

@@ -48,17 +48,17 @@ object StaticFunctionRegistry extends FunctionRegistry {
 
   private val functions = Map[String, UnboundFunction](
     "ck_xx_hash64" -> ClickHouseXxHash64, // for compatible
-    "clickhouse_xxHash64" -> ClickHouseXxHash64,
-    "clickhouse_murmurHash2_32" -> MurmurHash2_32,
-    "clickhouse_murmurHash2_64" -> MurmurHash2_64,
-    "clickhouse_murmurHash3_32" -> MurmurHash3_32,
-    "clickhouse_murmurHash3_64" -> MurmurHash3_64,
-    "clickhouse_cityHash64" -> CityHash64,
-    "clickhouse_years" -> Years,
-    "clickhouse_months" -> Months,
-    "clickhouse_days" -> Days,
-    "clickhouse_hours" -> Hours,
-    "sharding_mod" -> Mod
+    ClickHouseXxHash64.name -> ClickHouseXxHash64,
+    MurmurHash2_32.name -> MurmurHash2_32,
+    MurmurHash2_64.name -> MurmurHash2_64,
+    MurmurHash3_32.name -> MurmurHash3_32,
+    MurmurHash3_64.name -> MurmurHash3_64,
+    CityHash64.name -> CityHash64,
+    Years.name -> Years,
+    Months.name -> Months,
+    Days.name -> Days,
+    Hours.name -> Hours,
+    Mod.name -> Mod
   )
 
   override def list: Array[String] = functions.keys.toArray

spark-3.4/clickhouse-spark/src/main/scala/xenon/clickhouse/func/Hours.scala

@@ -22,15 +22,15 @@ import java.text.SimpleDateFormat
 
 object Hours extends UnboundFunction with ScalarFunction[Int] with ClickhouseEquivFunction {
 
-  override def name: String = "clickhouse_hours"
+  override def name: String = "clickhouse_toHour"
 
   override def canonicalName: String = s"clickhouse.$name"
 
   override def toString: String = name
 
   override val ckFuncNames: Array[String] = Array("toHour", "HOUR")
 
-  override def description: String = s"$name: (time: timestamp) => shard_num: int"
+  override def description: String = s"$name: (time: TIMESTAMP) => HH: INT"
 
   override def bind(inputType: StructType): BoundFunction = inputType.fields match {
     case Array(StructField(_, TimestampType, _, _)) | Array(StructField(_, TimestampNTZType, _, _)) => this

spark-3.4/clickhouse-spark/src/main/scala/xenon/clickhouse/func/Mod.scala

@@ -19,7 +19,7 @@ import org.apache.spark.sql.types._
 
 object Mod extends UnboundFunction with ScalarFunction[Long] with ClickhouseEquivFunction {
 
-  override def name: String = "sharding_mod"
+  override def name: String = "clickhouse_modulo"
 
   override def canonicalName: String = s"clickhouse.$name"
 
@@ -29,7 +29,7 @@ object Mod extends UnboundFunction with ScalarFunction[Long] with ClickhouseEqui
   // Added remainder as a synonym.
   override val ckFuncNames: Array[String] = Array("modulo", "remainder")
 
-  override def description: String = s"$name: (a: long, b: long) => mod: long"
+  override def description: String = s"$name: (a: LONG, b: LONG) => a % b: LONG"
 
   override def bind(inputType: StructType): BoundFunction = inputType.fields match {
     case Array(a, b) if

spark-3.4/clickhouse-spark/src/main/scala/xenon/clickhouse/func/Months.scala

@@ -22,15 +22,15 @@ import java.time.format.DateTimeFormatter
 
 object Months extends UnboundFunction with ScalarFunction[Int] with ClickhouseEquivFunction {
 
-  override def name: String = "clickhouse_months"
+  override def name: String = "clickhouse_toYYYYMM"
 
   override def canonicalName: String = s"clickhouse.$name"
 
   override def toString: String = name
 
   override val ckFuncNames: Array[String] = Array("toYYYYMM")
 
-  override def description: String = s"$name: (date: Date) => shard_num: int"
+  override def description: String = s"$name: (date: DATE) => YYYYMM: INT"
 
   override def bind(inputType: StructType): BoundFunction = inputType.fields match {
     case Array(StructField(_, DateType, _, _)) => this

spark-3.4/clickhouse-spark/src/main/scala/xenon/clickhouse/func/MultiStringArgsHash.scala

@@ -27,7 +27,7 @@ abstract class MultiStringArgsHash extends UnboundFunction with ClickhouseEquivF
 
   override val ckFuncNames: Array[String]
 
-  override def description: String = s"$name: (value: string, ...) => hash_value: long"
+  override def description: String = s"$name: (value: STRING, ...) => hash_value: LONG"
 
   private def isExceptedType(dt: DataType): Boolean =
     dt.isInstanceOf[StringType]

spark-3.4/clickhouse-spark/src/main/scala/xenon/clickhouse/func/XxHash64.scala

@@ -36,7 +36,7 @@ object ClickHouseXxHash64 extends UnboundFunction with ScalarFunction[Long] with
 
   override val ckFuncNames: Array[String] = Array("xxHash64")
 
-  override def description: String = s"$name: (value: string) => hash_value: long"
+  override def description: String = s"$name: (value: STRING) => hash_value: LONG"
 
   override def bind(inputType: StructType): BoundFunction = inputType.fields match {
     case Array(StructField(_, StringType, _, _)) => this
@@ -75,7 +75,7 @@ class ClickHouseXxHash64Shard(clusters: Seq[ClusterSpec]) extends UnboundFunctio
 
   override def canonicalName: String = s"clickhouse.$name"
 
-  override def description: String = s"$name: (cluster_name: string, value: string) => shard_num: int"
+  override def description: String = s"$name: (cluster_name: STRING, value: STRING) => shard_num: INT"
 
   override def bind(inputType: StructType): BoundFunction = inputType.fields match {
     case Array(StructField(_, StringType, _, _), StructField(_, StringType, _, _)) => this

spark-3.4/clickhouse-spark/src/main/scala/xenon/clickhouse/func/Years.scala

@@ -22,15 +22,15 @@ import java.time.format.DateTimeFormatter
 
 object Years extends UnboundFunction with ScalarFunction[Int] with ClickhouseEquivFunction {
 
-  override def name: String = "clickhouse_years"
+  override def name: String = "clickhouse_toYear"
 
   override def canonicalName: String = s"clickhouse.$name"
 
   override def toString: String = name
 
   override val ckFuncNames: Array[String] = Array("toYear", "YEAR")
 
-  override def description: String = s"$name: (date: Date) => shard_num: int"
+  override def description: String = s"$name: (date: DATE) => YYYY: INT"
 
   override def bind(inputType: StructType): BoundFunction = inputType.fields match {
     case Array(StructField(_, DateType, _, _)) => this