abstract class UDAF22[S, O, A0, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20, A21] extends UDAF
The Scala UDAF (user-defined aggregate function) abstract class that has 22 arguments.
- S
The type of the aggregation state.
- O
The type of the output value.
- Since
1.19.0
- Alphabetic
- By Inheritance
- UDAF22
- UDAF
- Serializable
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
- new UDAF22()(implicit a0Tag: scala.reflect.api.JavaUniverse.TypeTag[A0], a1Tag: scala.reflect.api.JavaUniverse.TypeTag[A1], a2Tag: scala.reflect.api.JavaUniverse.TypeTag[A2], a3Tag: scala.reflect.api.JavaUniverse.TypeTag[A3], a4Tag: scala.reflect.api.JavaUniverse.TypeTag[A4], a5Tag: scala.reflect.api.JavaUniverse.TypeTag[A5], a6Tag: scala.reflect.api.JavaUniverse.TypeTag[A6], a7Tag: scala.reflect.api.JavaUniverse.TypeTag[A7], a8Tag: scala.reflect.api.JavaUniverse.TypeTag[A8], a9Tag: scala.reflect.api.JavaUniverse.TypeTag[A9], a10Tag: scala.reflect.api.JavaUniverse.TypeTag[A10], a11Tag: scala.reflect.api.JavaUniverse.TypeTag[A11], a12Tag: scala.reflect.api.JavaUniverse.TypeTag[A12], a13Tag: scala.reflect.api.JavaUniverse.TypeTag[A13], a14Tag: scala.reflect.api.JavaUniverse.TypeTag[A14], a15Tag: scala.reflect.api.JavaUniverse.TypeTag[A15], a16Tag: scala.reflect.api.JavaUniverse.TypeTag[A16], a17Tag: scala.reflect.api.JavaUniverse.TypeTag[A17], a18Tag: scala.reflect.api.JavaUniverse.TypeTag[A18], a19Tag: scala.reflect.api.JavaUniverse.TypeTag[A19], a20Tag: scala.reflect.api.JavaUniverse.TypeTag[A20], a21Tag: scala.reflect.api.JavaUniverse.TypeTag[A21])
Abstract Value Members
-
abstract
def
accumulate(state: S, arg0: A0, arg1: A1, arg2: A2, arg3: A3, arg4: A4, arg5: A5, arg6: A6, arg7: A7, arg8: A8, arg9: A9, arg10: A10, arg11: A11, arg12: A12, arg13: A13, arg14: A14, arg15: A15, arg16: A16, arg17: A17, arg18: A18, arg19: A19, arg20: A20, arg21: A21): S
Updates the aggregation state with a new input row.
Updates the aggregation state with a new input row.
- state
The current aggregation state.
- arg0
The input value for argument 1.
- arg1
The input value for argument 2.
- arg2
The input value for argument 3.
- arg3
The input value for argument 4.
- arg4
The input value for argument 5.
- arg5
The input value for argument 6.
- arg6
The input value for argument 7.
- arg7
The input value for argument 8.
- arg8
The input value for argument 9.
- arg9
The input value for argument 10.
- arg10
The input value for argument 11.
- arg11
The input value for argument 12.
- arg12
The input value for argument 13.
- arg13
The input value for argument 14.
- arg14
The input value for argument 15.
- arg15
The input value for argument 16.
- arg16
The input value for argument 17.
- arg17
The input value for argument 18.
- arg18
The input value for argument 19.
- arg19
The input value for argument 20.
- arg20
The input value for argument 21.
- returns
The updated aggregation state.
- Since
1.19.0
-
abstract
def
initialize(): S
- returns
The initial state of the aggregation.
- Since
1.19.0
-
abstract
def
merge(state1: S, state2: S): S
Merges two aggregation states into one.
Merges two aggregation states into one.
- state1
The first aggregation state.
- state2
The second aggregation state.
- returns
The merged aggregation state.
- Since
1.19.0
-
abstract
def
outputType(): DataType
A DataType that describes the type of the value returned by the terminate() method.
A DataType that describes the type of the value returned by the terminate() method.
For example, if a UDAF returns an integer value, outputType() should return IntegerType: {{ override def outputType(): DataType = IntegerType }}
- returns
A DataType describing the output type.
- Definition Classes
- UDAF
- Since
1.19.0
-
abstract
def
terminate(state: S): O
Produces the final output value from the aggregation state.
Produces the final output value from the aggregation state.
- state
The final aggregation state.
- returns
The output value.
- Since
1.19.0
Concrete 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
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native() @HotSpotIntrinsicCandidate()
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
inputSchema(): StructType
A StructType that describes the input schema of the aggregate function.
A StructType that describes the input schema of the aggregate function. By default, returns an empty StructType.
- returns
A StructType describing the input schema.
- Definition Classes
- UDAF
- Since
1.19.0
-
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
- @native() @HotSpotIntrinsicCandidate()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
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( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
Deprecated Value Members
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] ) @Deprecated
- Deprecated