object DeltaUDF
Define a few templates for udfs used by Delta. Use these templates to create
SparkUserDefinedFunction to avoid creating new Encoders. This would save us from touching
ScalaReflection to reduce the lock contention in concurrent queries.
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- DeltaUDF
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def boolean(f: () => Boolean): UserDefinedFunction
- def booleanFromByte(x: (Byte) => Boolean): UserDefinedFunction
- def booleanFromDeletionVectorDescriptor(f: (DeletionVectorDescriptor) => Boolean): UserDefinedFunction
- def booleanFromMap(f: (Map[String, String]) => Boolean): UserDefinedFunction
- def booleanFromProtocol(f: (Protocol) => Boolean): UserDefinedFunction
- def booleanFromString(s: (String) => Boolean): UserDefinedFunction
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- def deletedRecordCountsHistogramFromArrayLong(f: (Array[Long]) => DeletedRecordCountsHistogram): UserDefinedFunction
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def intFromString(f: (String) => Int): UserDefinedFunction
- def intFromStringBoolean(f: (String, Boolean) => Int): UserDefinedFunction
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- def stringFromDeletionVectorDescriptor(f: (DeletionVectorDescriptor) => String): UserDefinedFunction
- def stringFromMap(f: (Map[String, String]) => String): UserDefinedFunction
- def stringFromString(f: (String) => String): UserDefinedFunction
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)