File tree Expand file tree Collapse file tree
spark/src/main/scala/org/apache/comet/serde Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -103,10 +103,14 @@ object CometOctetLength extends CometScalarFunction[OctetLength]("octet_length")
103103}
104104
105105object CometStringTranslate extends CometScalarFunction [StringTranslate ](" translate" ) {
106+ private val incompatReason =
107+ " DataFusion's translate iterates over Unicode graphemes (Spark uses code points) and" +
108+ " substitutes U+0000 instead of treating it as a deletion sentinel"
109+
110+ override def getIncompatibleReasons (): Seq [String ] = Seq (incompatReason)
111+
106112 override def getSupportLevel (expr : StringTranslate ): SupportLevel = Incompatible (
107- Some (
108- " DataFusion's translate iterates over Unicode graphemes (Spark uses code points) and" +
109- " substitutes U+0000 instead of treating it as a deletion sentinel" ))
113+ Some (incompatReason))
110114}
111115
112116object CometInitCap extends CometScalarFunction [InitCap ](" initcap" ) {
You can’t perform that action at this time.
0 commit comments