Package org.apache.spark.sql
Class UDFRegistration
Object
org.apache.spark.sql.UDFRegistration
Functions for registering user-defined functions. Use
SparkSession.udf
to access this:
spark.udf
- Since:
- 4.0.0
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
Register a deterministic Java UDF0 instance as user-defined function (UDF).void
Register a deterministic Java UDF1 instance as user-defined function (UDF).void
Register a deterministic Java UDF10 instance as user-defined function (UDF).void
Register a deterministic Java UDF11 instance as user-defined function (UDF).void
Register a deterministic Java UDF12 instance as user-defined function (UDF).void
Register a deterministic Java UDF13 instance as user-defined function (UDF).void
Register a deterministic Java UDF14 instance as user-defined function (UDF).void
Register a deterministic Java UDF15 instance as user-defined function (UDF).void
Register a deterministic Java UDF16 instance as user-defined function (UDF).void
Register a deterministic Java UDF17 instance as user-defined function (UDF).void
Register a deterministic Java UDF18 instance as user-defined function (UDF).void
Register a deterministic Java UDF19 instance as user-defined function (UDF).void
Register a deterministic Java UDF2 instance as user-defined function (UDF).void
Register a deterministic Java UDF20 instance as user-defined function (UDF).void
Register a deterministic Java UDF21 instance as user-defined function (UDF).void
Register a deterministic Java UDF22 instance as user-defined function (UDF).void
Register a deterministic Java UDF3 instance as user-defined function (UDF).void
Register a deterministic Java UDF4 instance as user-defined function (UDF).void
Register a deterministic Java UDF5 instance as user-defined function (UDF).void
Register a deterministic Java UDF6 instance as user-defined function (UDF).void
Register a deterministic Java UDF7 instance as user-defined function (UDF).void
Register a deterministic Java UDF8 instance as user-defined function (UDF).void
Register a deterministic Java UDF9 instance as user-defined function (UDF).abstract UserDefinedAggregateFunction
register
(String name, UserDefinedAggregateFunction udaf) Deprecated.this method and the use of UserDefinedAggregateFunction are deprecated.register
(String name, UserDefinedFunction udf) Registers a user-defined function (UDF), for a UDF that's already defined using the Dataset API (i.e.<RT> UserDefinedFunction
Registers a deterministic Scala closure of 0 arguments as user-defined function (UDF).<RT,
A1> UserDefinedFunction register
(String name, scala.Function1<A1, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$2, scala.reflect.api.TypeTags.TypeTag<A1> evidence$3) Registers a deterministic Scala closure of 1 arguments as user-defined function (UDF).<RT,
A1, A2, A3, A4, A5, A6, A7, A8, A9, A10>
UserDefinedFunctionregister
(String name, scala.Function10<A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$56, scala.reflect.api.TypeTags.TypeTag<A1> evidence$57, scala.reflect.api.TypeTags.TypeTag<A2> evidence$58, scala.reflect.api.TypeTags.TypeTag<A3> evidence$59, scala.reflect.api.TypeTags.TypeTag<A4> evidence$60, scala.reflect.api.TypeTags.TypeTag<A5> evidence$61, scala.reflect.api.TypeTags.TypeTag<A6> evidence$62, scala.reflect.api.TypeTags.TypeTag<A7> evidence$63, scala.reflect.api.TypeTags.TypeTag<A8> evidence$64, scala.reflect.api.TypeTags.TypeTag<A9> evidence$65, scala.reflect.api.TypeTags.TypeTag<A10> evidence$66) Registers a deterministic Scala closure of 10 arguments as user-defined function (UDF).<RT,
A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11>
UserDefinedFunctionregister
(String name, scala.Function11<A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$67, scala.reflect.api.TypeTags.TypeTag<A1> evidence$68, scala.reflect.api.TypeTags.TypeTag<A2> evidence$69, scala.reflect.api.TypeTags.TypeTag<A3> evidence$70, scala.reflect.api.TypeTags.TypeTag<A4> evidence$71, scala.reflect.api.TypeTags.TypeTag<A5> evidence$72, scala.reflect.api.TypeTags.TypeTag<A6> evidence$73, scala.reflect.api.TypeTags.TypeTag<A7> evidence$74, scala.reflect.api.TypeTags.TypeTag<A8> evidence$75, scala.reflect.api.TypeTags.TypeTag<A9> evidence$76, scala.reflect.api.TypeTags.TypeTag<A10> evidence$77, scala.reflect.api.TypeTags.TypeTag<A11> evidence$78) Registers a deterministic Scala closure of 11 arguments as user-defined function (UDF).<RT,
A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12>
UserDefinedFunctionregister
(String name, scala.Function12<A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$79, scala.reflect.api.TypeTags.TypeTag<A1> evidence$80, scala.reflect.api.TypeTags.TypeTag<A2> evidence$81, scala.reflect.api.TypeTags.TypeTag<A3> evidence$82, scala.reflect.api.TypeTags.TypeTag<A4> evidence$83, scala.reflect.api.TypeTags.TypeTag<A5> evidence$84, scala.reflect.api.TypeTags.TypeTag<A6> evidence$85, scala.reflect.api.TypeTags.TypeTag<A7> evidence$86, scala.reflect.api.TypeTags.TypeTag<A8> evidence$87, scala.reflect.api.TypeTags.TypeTag<A9> evidence$88, scala.reflect.api.TypeTags.TypeTag<A10> evidence$89, scala.reflect.api.TypeTags.TypeTag<A11> evidence$90, scala.reflect.api.TypeTags.TypeTag<A12> evidence$91) Registers a deterministic Scala closure of 12 arguments as user-defined function (UDF).<RT,
A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13>
UserDefinedFunctionregister
(String name, scala.Function13<A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$92, scala.reflect.api.TypeTags.TypeTag<A1> evidence$93, scala.reflect.api.TypeTags.TypeTag<A2> evidence$94, scala.reflect.api.TypeTags.TypeTag<A3> evidence$95, scala.reflect.api.TypeTags.TypeTag<A4> evidence$96, scala.reflect.api.TypeTags.TypeTag<A5> evidence$97, scala.reflect.api.TypeTags.TypeTag<A6> evidence$98, scala.reflect.api.TypeTags.TypeTag<A7> evidence$99, scala.reflect.api.TypeTags.TypeTag<A8> evidence$100, scala.reflect.api.TypeTags.TypeTag<A9> evidence$101, scala.reflect.api.TypeTags.TypeTag<A10> evidence$102, scala.reflect.api.TypeTags.TypeTag<A11> evidence$103, scala.reflect.api.TypeTags.TypeTag<A12> evidence$104, scala.reflect.api.TypeTags.TypeTag<A13> evidence$105) Registers a deterministic Scala closure of 13 arguments as user-defined function (UDF).<RT,
A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14>
UserDefinedFunctionregister
(String name, scala.Function14<A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$106, scala.reflect.api.TypeTags.TypeTag<A1> evidence$107, scala.reflect.api.TypeTags.TypeTag<A2> evidence$108, scala.reflect.api.TypeTags.TypeTag<A3> evidence$109, scala.reflect.api.TypeTags.TypeTag<A4> evidence$110, scala.reflect.api.TypeTags.TypeTag<A5> evidence$111, scala.reflect.api.TypeTags.TypeTag<A6> evidence$112, scala.reflect.api.TypeTags.TypeTag<A7> evidence$113, scala.reflect.api.TypeTags.TypeTag<A8> evidence$114, scala.reflect.api.TypeTags.TypeTag<A9> evidence$115, scala.reflect.api.TypeTags.TypeTag<A10> evidence$116, scala.reflect.api.TypeTags.TypeTag<A11> evidence$117, scala.reflect.api.TypeTags.TypeTag<A12> evidence$118, scala.reflect.api.TypeTags.TypeTag<A13> evidence$119, scala.reflect.api.TypeTags.TypeTag<A14> evidence$120) Registers a deterministic Scala closure of 14 arguments as user-defined function (UDF).<RT,
A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15>
UserDefinedFunctionregister
(String name, scala.Function15<A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$121, scala.reflect.api.TypeTags.TypeTag<A1> evidence$122, scala.reflect.api.TypeTags.TypeTag<A2> evidence$123, scala.reflect.api.TypeTags.TypeTag<A3> evidence$124, scala.reflect.api.TypeTags.TypeTag<A4> evidence$125, scala.reflect.api.TypeTags.TypeTag<A5> evidence$126, scala.reflect.api.TypeTags.TypeTag<A6> evidence$127, scala.reflect.api.TypeTags.TypeTag<A7> evidence$128, scala.reflect.api.TypeTags.TypeTag<A8> evidence$129, scala.reflect.api.TypeTags.TypeTag<A9> evidence$130, scala.reflect.api.TypeTags.TypeTag<A10> evidence$131, scala.reflect.api.TypeTags.TypeTag<A11> evidence$132, scala.reflect.api.TypeTags.TypeTag<A12> evidence$133, scala.reflect.api.TypeTags.TypeTag<A13> evidence$134, scala.reflect.api.TypeTags.TypeTag<A14> evidence$135, scala.reflect.api.TypeTags.TypeTag<A15> evidence$136) Registers a deterministic Scala closure of 15 arguments as user-defined function (UDF).<RT,
A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16>
UserDefinedFunctionregister
(String name, scala.Function16<A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$137, scala.reflect.api.TypeTags.TypeTag<A1> evidence$138, scala.reflect.api.TypeTags.TypeTag<A2> evidence$139, scala.reflect.api.TypeTags.TypeTag<A3> evidence$140, scala.reflect.api.TypeTags.TypeTag<A4> evidence$141, scala.reflect.api.TypeTags.TypeTag<A5> evidence$142, scala.reflect.api.TypeTags.TypeTag<A6> evidence$143, scala.reflect.api.TypeTags.TypeTag<A7> evidence$144, scala.reflect.api.TypeTags.TypeTag<A8> evidence$145, scala.reflect.api.TypeTags.TypeTag<A9> evidence$146, scala.reflect.api.TypeTags.TypeTag<A10> evidence$147, scala.reflect.api.TypeTags.TypeTag<A11> evidence$148, scala.reflect.api.TypeTags.TypeTag<A12> evidence$149, scala.reflect.api.TypeTags.TypeTag<A13> evidence$150, scala.reflect.api.TypeTags.TypeTag<A14> evidence$151, scala.reflect.api.TypeTags.TypeTag<A15> evidence$152, scala.reflect.api.TypeTags.TypeTag<A16> evidence$153) Registers a deterministic Scala closure of 16 arguments as user-defined function (UDF).<RT,
A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17>
UserDefinedFunctionregister
(String name, scala.Function17<A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$154, scala.reflect.api.TypeTags.TypeTag<A1> evidence$155, scala.reflect.api.TypeTags.TypeTag<A2> evidence$156, scala.reflect.api.TypeTags.TypeTag<A3> evidence$157, scala.reflect.api.TypeTags.TypeTag<A4> evidence$158, scala.reflect.api.TypeTags.TypeTag<A5> evidence$159, scala.reflect.api.TypeTags.TypeTag<A6> evidence$160, scala.reflect.api.TypeTags.TypeTag<A7> evidence$161, scala.reflect.api.TypeTags.TypeTag<A8> evidence$162, scala.reflect.api.TypeTags.TypeTag<A9> evidence$163, scala.reflect.api.TypeTags.TypeTag<A10> evidence$164, scala.reflect.api.TypeTags.TypeTag<A11> evidence$165, scala.reflect.api.TypeTags.TypeTag<A12> evidence$166, scala.reflect.api.TypeTags.TypeTag<A13> evidence$167, scala.reflect.api.TypeTags.TypeTag<A14> evidence$168, scala.reflect.api.TypeTags.TypeTag<A15> evidence$169, scala.reflect.api.TypeTags.TypeTag<A16> evidence$170, scala.reflect.api.TypeTags.TypeTag<A17> evidence$171) Registers a deterministic Scala closure of 17 arguments as user-defined function (UDF).<RT,
A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18>
UserDefinedFunctionregister
(String name, scala.Function18<A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$172, scala.reflect.api.TypeTags.TypeTag<A1> evidence$173, scala.reflect.api.TypeTags.TypeTag<A2> evidence$174, scala.reflect.api.TypeTags.TypeTag<A3> evidence$175, scala.reflect.api.TypeTags.TypeTag<A4> evidence$176, scala.reflect.api.TypeTags.TypeTag<A5> evidence$177, scala.reflect.api.TypeTags.TypeTag<A6> evidence$178, scala.reflect.api.TypeTags.TypeTag<A7> evidence$179, scala.reflect.api.TypeTags.TypeTag<A8> evidence$180, scala.reflect.api.TypeTags.TypeTag<A9> evidence$181, scala.reflect.api.TypeTags.TypeTag<A10> evidence$182, scala.reflect.api.TypeTags.TypeTag<A11> evidence$183, scala.reflect.api.TypeTags.TypeTag<A12> evidence$184, scala.reflect.api.TypeTags.TypeTag<A13> evidence$185, scala.reflect.api.TypeTags.TypeTag<A14> evidence$186, scala.reflect.api.TypeTags.TypeTag<A15> evidence$187, scala.reflect.api.TypeTags.TypeTag<A16> evidence$188, scala.reflect.api.TypeTags.TypeTag<A17> evidence$189, scala.reflect.api.TypeTags.TypeTag<A18> evidence$190) Registers a deterministic Scala closure of 18 arguments as user-defined function (UDF).<RT,
A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19>
UserDefinedFunctionregister
(String name, scala.Function19<A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$191, scala.reflect.api.TypeTags.TypeTag<A1> evidence$192, scala.reflect.api.TypeTags.TypeTag<A2> evidence$193, scala.reflect.api.TypeTags.TypeTag<A3> evidence$194, scala.reflect.api.TypeTags.TypeTag<A4> evidence$195, scala.reflect.api.TypeTags.TypeTag<A5> evidence$196, scala.reflect.api.TypeTags.TypeTag<A6> evidence$197, scala.reflect.api.TypeTags.TypeTag<A7> evidence$198, scala.reflect.api.TypeTags.TypeTag<A8> evidence$199, scala.reflect.api.TypeTags.TypeTag<A9> evidence$200, scala.reflect.api.TypeTags.TypeTag<A10> evidence$201, scala.reflect.api.TypeTags.TypeTag<A11> evidence$202, scala.reflect.api.TypeTags.TypeTag<A12> evidence$203, scala.reflect.api.TypeTags.TypeTag<A13> evidence$204, scala.reflect.api.TypeTags.TypeTag<A14> evidence$205, scala.reflect.api.TypeTags.TypeTag<A15> evidence$206, scala.reflect.api.TypeTags.TypeTag<A16> evidence$207, scala.reflect.api.TypeTags.TypeTag<A17> evidence$208, scala.reflect.api.TypeTags.TypeTag<A18> evidence$209, scala.reflect.api.TypeTags.TypeTag<A19> evidence$210) Registers a deterministic Scala closure of 19 arguments as user-defined function (UDF).<RT,
A1, A2> UserDefinedFunction register
(String name, scala.Function2<A1, A2, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$4, scala.reflect.api.TypeTags.TypeTag<A1> evidence$5, scala.reflect.api.TypeTags.TypeTag<A2> evidence$6) Registers a deterministic Scala closure of 2 arguments as user-defined function (UDF).<RT,
A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20>
UserDefinedFunctionregister
(String name, scala.Function20<A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$211, scala.reflect.api.TypeTags.TypeTag<A1> evidence$212, scala.reflect.api.TypeTags.TypeTag<A2> evidence$213, scala.reflect.api.TypeTags.TypeTag<A3> evidence$214, scala.reflect.api.TypeTags.TypeTag<A4> evidence$215, scala.reflect.api.TypeTags.TypeTag<A5> evidence$216, scala.reflect.api.TypeTags.TypeTag<A6> evidence$217, scala.reflect.api.TypeTags.TypeTag<A7> evidence$218, scala.reflect.api.TypeTags.TypeTag<A8> evidence$219, scala.reflect.api.TypeTags.TypeTag<A9> evidence$220, scala.reflect.api.TypeTags.TypeTag<A10> evidence$221, scala.reflect.api.TypeTags.TypeTag<A11> evidence$222, scala.reflect.api.TypeTags.TypeTag<A12> evidence$223, scala.reflect.api.TypeTags.TypeTag<A13> evidence$224, scala.reflect.api.TypeTags.TypeTag<A14> evidence$225, scala.reflect.api.TypeTags.TypeTag<A15> evidence$226, scala.reflect.api.TypeTags.TypeTag<A16> evidence$227, scala.reflect.api.TypeTags.TypeTag<A17> evidence$228, scala.reflect.api.TypeTags.TypeTag<A18> evidence$229, scala.reflect.api.TypeTags.TypeTag<A19> evidence$230, scala.reflect.api.TypeTags.TypeTag<A20> evidence$231) Registers a deterministic Scala closure of 20 arguments as user-defined function (UDF).<RT,
A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20, A21>
UserDefinedFunctionregister
(String name, scala.Function21<A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20, A21, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$232, scala.reflect.api.TypeTags.TypeTag<A1> evidence$233, scala.reflect.api.TypeTags.TypeTag<A2> evidence$234, scala.reflect.api.TypeTags.TypeTag<A3> evidence$235, scala.reflect.api.TypeTags.TypeTag<A4> evidence$236, scala.reflect.api.TypeTags.TypeTag<A5> evidence$237, scala.reflect.api.TypeTags.TypeTag<A6> evidence$238, scala.reflect.api.TypeTags.TypeTag<A7> evidence$239, scala.reflect.api.TypeTags.TypeTag<A8> evidence$240, scala.reflect.api.TypeTags.TypeTag<A9> evidence$241, scala.reflect.api.TypeTags.TypeTag<A10> evidence$242, scala.reflect.api.TypeTags.TypeTag<A11> evidence$243, scala.reflect.api.TypeTags.TypeTag<A12> evidence$244, scala.reflect.api.TypeTags.TypeTag<A13> evidence$245, scala.reflect.api.TypeTags.TypeTag<A14> evidence$246, scala.reflect.api.TypeTags.TypeTag<A15> evidence$247, scala.reflect.api.TypeTags.TypeTag<A16> evidence$248, scala.reflect.api.TypeTags.TypeTag<A17> evidence$249, scala.reflect.api.TypeTags.TypeTag<A18> evidence$250, scala.reflect.api.TypeTags.TypeTag<A19> evidence$251, scala.reflect.api.TypeTags.TypeTag<A20> evidence$252, scala.reflect.api.TypeTags.TypeTag<A21> evidence$253) Registers a deterministic Scala closure of 21 arguments as user-defined function (UDF).<RT,
A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20, A21, A22>
UserDefinedFunctionregister
(String name, scala.Function22<A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20, A21, A22, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$254, scala.reflect.api.TypeTags.TypeTag<A1> evidence$255, scala.reflect.api.TypeTags.TypeTag<A2> evidence$256, scala.reflect.api.TypeTags.TypeTag<A3> evidence$257, scala.reflect.api.TypeTags.TypeTag<A4> evidence$258, scala.reflect.api.TypeTags.TypeTag<A5> evidence$259, scala.reflect.api.TypeTags.TypeTag<A6> evidence$260, scala.reflect.api.TypeTags.TypeTag<A7> evidence$261, scala.reflect.api.TypeTags.TypeTag<A8> evidence$262, scala.reflect.api.TypeTags.TypeTag<A9> evidence$263, scala.reflect.api.TypeTags.TypeTag<A10> evidence$264, scala.reflect.api.TypeTags.TypeTag<A11> evidence$265, scala.reflect.api.TypeTags.TypeTag<A12> evidence$266, scala.reflect.api.TypeTags.TypeTag<A13> evidence$267, scala.reflect.api.TypeTags.TypeTag<A14> evidence$268, scala.reflect.api.TypeTags.TypeTag<A15> evidence$269, scala.reflect.api.TypeTags.TypeTag<A16> evidence$270, scala.reflect.api.TypeTags.TypeTag<A17> evidence$271, scala.reflect.api.TypeTags.TypeTag<A18> evidence$272, scala.reflect.api.TypeTags.TypeTag<A19> evidence$273, scala.reflect.api.TypeTags.TypeTag<A20> evidence$274, scala.reflect.api.TypeTags.TypeTag<A21> evidence$275, scala.reflect.api.TypeTags.TypeTag<A22> evidence$276) Registers a deterministic Scala closure of 22 arguments as user-defined function (UDF).<RT,
A1, A2, A3>
UserDefinedFunctionregister
(String name, scala.Function3<A1, A2, A3, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$7, scala.reflect.api.TypeTags.TypeTag<A1> evidence$8, scala.reflect.api.TypeTags.TypeTag<A2> evidence$9, scala.reflect.api.TypeTags.TypeTag<A3> evidence$10) Registers a deterministic Scala closure of 3 arguments as user-defined function (UDF).<RT,
A1, A2, A3, A4>
UserDefinedFunctionregister
(String name, scala.Function4<A1, A2, A3, A4, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$11, scala.reflect.api.TypeTags.TypeTag<A1> evidence$12, scala.reflect.api.TypeTags.TypeTag<A2> evidence$13, scala.reflect.api.TypeTags.TypeTag<A3> evidence$14, scala.reflect.api.TypeTags.TypeTag<A4> evidence$15) Registers a deterministic Scala closure of 4 arguments as user-defined function (UDF).<RT,
A1, A2, A3, A4, A5>
UserDefinedFunctionregister
(String name, scala.Function5<A1, A2, A3, A4, A5, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$16, scala.reflect.api.TypeTags.TypeTag<A1> evidence$17, scala.reflect.api.TypeTags.TypeTag<A2> evidence$18, scala.reflect.api.TypeTags.TypeTag<A3> evidence$19, scala.reflect.api.TypeTags.TypeTag<A4> evidence$20, scala.reflect.api.TypeTags.TypeTag<A5> evidence$21) Registers a deterministic Scala closure of 5 arguments as user-defined function (UDF).<RT,
A1, A2, A3, A4, A5, A6>
UserDefinedFunctionregister
(String name, scala.Function6<A1, A2, A3, A4, A5, A6, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$22, scala.reflect.api.TypeTags.TypeTag<A1> evidence$23, scala.reflect.api.TypeTags.TypeTag<A2> evidence$24, scala.reflect.api.TypeTags.TypeTag<A3> evidence$25, scala.reflect.api.TypeTags.TypeTag<A4> evidence$26, scala.reflect.api.TypeTags.TypeTag<A5> evidence$27, scala.reflect.api.TypeTags.TypeTag<A6> evidence$28) Registers a deterministic Scala closure of 6 arguments as user-defined function (UDF).<RT,
A1, A2, A3, A4, A5, A6, A7>
UserDefinedFunctionregister
(String name, scala.Function7<A1, A2, A3, A4, A5, A6, A7, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$29, scala.reflect.api.TypeTags.TypeTag<A1> evidence$30, scala.reflect.api.TypeTags.TypeTag<A2> evidence$31, scala.reflect.api.TypeTags.TypeTag<A3> evidence$32, scala.reflect.api.TypeTags.TypeTag<A4> evidence$33, scala.reflect.api.TypeTags.TypeTag<A5> evidence$34, scala.reflect.api.TypeTags.TypeTag<A6> evidence$35, scala.reflect.api.TypeTags.TypeTag<A7> evidence$36) Registers a deterministic Scala closure of 7 arguments as user-defined function (UDF).<RT,
A1, A2, A3, A4, A5, A6, A7, A8>
UserDefinedFunctionregister
(String name, scala.Function8<A1, A2, A3, A4, A5, A6, A7, A8, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$37, scala.reflect.api.TypeTags.TypeTag<A1> evidence$38, scala.reflect.api.TypeTags.TypeTag<A2> evidence$39, scala.reflect.api.TypeTags.TypeTag<A3> evidence$40, scala.reflect.api.TypeTags.TypeTag<A4> evidence$41, scala.reflect.api.TypeTags.TypeTag<A5> evidence$42, scala.reflect.api.TypeTags.TypeTag<A6> evidence$43, scala.reflect.api.TypeTags.TypeTag<A7> evidence$44, scala.reflect.api.TypeTags.TypeTag<A8> evidence$45) Registers a deterministic Scala closure of 8 arguments as user-defined function (UDF).<RT,
A1, A2, A3, A4, A5, A6, A7, A8, A9>
UserDefinedFunctionregister
(String name, scala.Function9<A1, A2, A3, A4, A5, A6, A7, A8, A9, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$46, scala.reflect.api.TypeTags.TypeTag<A1> evidence$47, scala.reflect.api.TypeTags.TypeTag<A2> evidence$48, scala.reflect.api.TypeTags.TypeTag<A3> evidence$49, scala.reflect.api.TypeTags.TypeTag<A4> evidence$50, scala.reflect.api.TypeTags.TypeTag<A5> evidence$51, scala.reflect.api.TypeTags.TypeTag<A6> evidence$52, scala.reflect.api.TypeTags.TypeTag<A7> evidence$53, scala.reflect.api.TypeTags.TypeTag<A8> evidence$54, scala.reflect.api.TypeTags.TypeTag<A9> evidence$55) Registers a deterministic Scala closure of 9 arguments as user-defined function (UDF).abstract void
registerJava
(String name, String className, DataType returnDataType) Register a Java UDF class using it's class name.
-
Constructor Details
-
UDFRegistration
public UDFRegistration()
-
-
Method Details
-
register
Registers a user-defined function (UDF), for a UDF that's already defined using the Dataset API (i.e. of type UserDefinedFunction). To change a UDF to nondeterministic, call the APIUserDefinedFunction.asNondeterministic()
. To change a UDF to nonNullable, call the APIUserDefinedFunction.asNonNullable()
.Example:
val foo = udf(() => Math.random()) spark.udf.register("random", foo.asNondeterministic()) val bar = udf(() => "bar") spark.udf.register("stringLit", bar.asNonNullable())
- Parameters:
name
- the name of the UDF.udf
- the UDF needs to be registered.- Returns:
- the registered UDF.
- Since:
- 2.2.0
-
register
public abstract UserDefinedAggregateFunction register(String name, UserDefinedAggregateFunction udaf) Deprecated.this method and the use of UserDefinedAggregateFunction are deprecated. Aggregator[IN, BUF, OUT] should now be registered as a UDF via the functions.udaf(agg) method.Registers a user-defined aggregate function (UDAF).- Parameters:
name
- the name of the UDAF.udaf
- the UDAF needs to be registered.- Returns:
- the registered UDAF.
- Since:
- 1.5.0
-
register
public <RT> UserDefinedFunction register(String name, scala.Function0<RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$1) Registers a deterministic Scala closure of 0 arguments as user-defined function (UDF).- Parameters:
name
- (undocumented)func
- (undocumented)evidence$1
- (undocumented)- Returns:
- (undocumented)
- Since:
- 1.3.0
-
register
public <RT,A1> UserDefinedFunction register(String name, scala.Function1<A1, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$2, scala.reflect.api.TypeTags.TypeTag<A1> evidence$3) Registers a deterministic Scala closure of 1 arguments as user-defined function (UDF).- Parameters:
name
- (undocumented)func
- (undocumented)evidence$2
- (undocumented)evidence$3
- (undocumented)- Returns:
- (undocumented)
- Since:
- 1.3.0
-
register
public <RT,A1, UserDefinedFunction registerA2> (String name, scala.Function2<A1, A2, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$4, scala.reflect.api.TypeTags.TypeTag<A1> evidence$5, scala.reflect.api.TypeTags.TypeTag<A2> evidence$6) Registers a deterministic Scala closure of 2 arguments as user-defined function (UDF).- Parameters:
name
- (undocumented)func
- (undocumented)evidence$4
- (undocumented)evidence$5
- (undocumented)evidence$6
- (undocumented)- Returns:
- (undocumented)
- Since:
- 1.3.0
-
register
public <RT,A1, UserDefinedFunction registerA2, A3> (String name, scala.Function3<A1, A2, A3, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$7, scala.reflect.api.TypeTags.TypeTag<A1> evidence$8, scala.reflect.api.TypeTags.TypeTag<A2> evidence$9, scala.reflect.api.TypeTags.TypeTag<A3> evidence$10) Registers a deterministic Scala closure of 3 arguments as user-defined function (UDF).- Parameters:
name
- (undocumented)func
- (undocumented)evidence$7
- (undocumented)evidence$8
- (undocumented)evidence$9
- (undocumented)evidence$10
- (undocumented)- Returns:
- (undocumented)
- Since:
- 1.3.0
-
register
public <RT,A1, UserDefinedFunction registerA2, A3, A4> (String name, scala.Function4<A1, A2, A3, A4, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$11, scala.reflect.api.TypeTags.TypeTag<A1> evidence$12, scala.reflect.api.TypeTags.TypeTag<A2> evidence$13, scala.reflect.api.TypeTags.TypeTag<A3> evidence$14, scala.reflect.api.TypeTags.TypeTag<A4> evidence$15) Registers a deterministic Scala closure of 4 arguments as user-defined function (UDF).- Parameters:
name
- (undocumented)func
- (undocumented)evidence$11
- (undocumented)evidence$12
- (undocumented)evidence$13
- (undocumented)evidence$14
- (undocumented)evidence$15
- (undocumented)- Returns:
- (undocumented)
- Since:
- 1.3.0
-
register
public <RT,A1, UserDefinedFunction registerA2, A3, A4, A5> (String name, scala.Function5<A1, A2, A3, A4, A5, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$16, scala.reflect.api.TypeTags.TypeTag<A1> evidence$17, scala.reflect.api.TypeTags.TypeTag<A2> evidence$18, scala.reflect.api.TypeTags.TypeTag<A3> evidence$19, scala.reflect.api.TypeTags.TypeTag<A4> evidence$20, scala.reflect.api.TypeTags.TypeTag<A5> evidence$21) Registers a deterministic Scala closure of 5 arguments as user-defined function (UDF).- Parameters:
name
- (undocumented)func
- (undocumented)evidence$16
- (undocumented)evidence$17
- (undocumented)evidence$18
- (undocumented)evidence$19
- (undocumented)evidence$20
- (undocumented)evidence$21
- (undocumented)- Returns:
- (undocumented)
- Since:
- 1.3.0
-
register
public <RT,A1, UserDefinedFunction registerA2, A3, A4, A5, A6> (String name, scala.Function6<A1, A2, A3, A4, A5, A6, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$22, scala.reflect.api.TypeTags.TypeTag<A1> evidence$23, scala.reflect.api.TypeTags.TypeTag<A2> evidence$24, scala.reflect.api.TypeTags.TypeTag<A3> evidence$25, scala.reflect.api.TypeTags.TypeTag<A4> evidence$26, scala.reflect.api.TypeTags.TypeTag<A5> evidence$27, scala.reflect.api.TypeTags.TypeTag<A6> evidence$28) Registers a deterministic Scala closure of 6 arguments as user-defined function (UDF).- Parameters:
name
- (undocumented)func
- (undocumented)evidence$22
- (undocumented)evidence$23
- (undocumented)evidence$24
- (undocumented)evidence$25
- (undocumented)evidence$26
- (undocumented)evidence$27
- (undocumented)evidence$28
- (undocumented)- Returns:
- (undocumented)
- Since:
- 1.3.0
-
register
public <RT,A1, UserDefinedFunction registerA2, A3, A4, A5, A6, A7> (String name, scala.Function7<A1, A2, A3, A4, A5, A6, A7, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$29, scala.reflect.api.TypeTags.TypeTag<A1> evidence$30, scala.reflect.api.TypeTags.TypeTag<A2> evidence$31, scala.reflect.api.TypeTags.TypeTag<A3> evidence$32, scala.reflect.api.TypeTags.TypeTag<A4> evidence$33, scala.reflect.api.TypeTags.TypeTag<A5> evidence$34, scala.reflect.api.TypeTags.TypeTag<A6> evidence$35, scala.reflect.api.TypeTags.TypeTag<A7> evidence$36) Registers a deterministic Scala closure of 7 arguments as user-defined function (UDF).- Parameters:
name
- (undocumented)func
- (undocumented)evidence$29
- (undocumented)evidence$30
- (undocumented)evidence$31
- (undocumented)evidence$32
- (undocumented)evidence$33
- (undocumented)evidence$34
- (undocumented)evidence$35
- (undocumented)evidence$36
- (undocumented)- Returns:
- (undocumented)
- Since:
- 1.3.0
-
register
public <RT,A1, UserDefinedFunction registerA2, A3, A4, A5, A6, A7, A8> (String name, scala.Function8<A1, A2, A3, A4, A5, A6, A7, A8, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$37, scala.reflect.api.TypeTags.TypeTag<A1> evidence$38, scala.reflect.api.TypeTags.TypeTag<A2> evidence$39, scala.reflect.api.TypeTags.TypeTag<A3> evidence$40, scala.reflect.api.TypeTags.TypeTag<A4> evidence$41, scala.reflect.api.TypeTags.TypeTag<A5> evidence$42, scala.reflect.api.TypeTags.TypeTag<A6> evidence$43, scala.reflect.api.TypeTags.TypeTag<A7> evidence$44, scala.reflect.api.TypeTags.TypeTag<A8> evidence$45) Registers a deterministic Scala closure of 8 arguments as user-defined function (UDF).- Parameters:
name
- (undocumented)func
- (undocumented)evidence$37
- (undocumented)evidence$38
- (undocumented)evidence$39
- (undocumented)evidence$40
- (undocumented)evidence$41
- (undocumented)evidence$42
- (undocumented)evidence$43
- (undocumented)evidence$44
- (undocumented)evidence$45
- (undocumented)- Returns:
- (undocumented)
- Since:
- 1.3.0
-
register
public <RT,A1, UserDefinedFunction registerA2, A3, A4, A5, A6, A7, A8, A9> (String name, scala.Function9<A1, A2, A3, A4, A5, A6, A7, A8, A9, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$46, scala.reflect.api.TypeTags.TypeTag<A1> evidence$47, scala.reflect.api.TypeTags.TypeTag<A2> evidence$48, scala.reflect.api.TypeTags.TypeTag<A3> evidence$49, scala.reflect.api.TypeTags.TypeTag<A4> evidence$50, scala.reflect.api.TypeTags.TypeTag<A5> evidence$51, scala.reflect.api.TypeTags.TypeTag<A6> evidence$52, scala.reflect.api.TypeTags.TypeTag<A7> evidence$53, scala.reflect.api.TypeTags.TypeTag<A8> evidence$54, scala.reflect.api.TypeTags.TypeTag<A9> evidence$55) Registers a deterministic Scala closure of 9 arguments as user-defined function (UDF).- Parameters:
name
- (undocumented)func
- (undocumented)evidence$46
- (undocumented)evidence$47
- (undocumented)evidence$48
- (undocumented)evidence$49
- (undocumented)evidence$50
- (undocumented)evidence$51
- (undocumented)evidence$52
- (undocumented)evidence$53
- (undocumented)evidence$54
- (undocumented)evidence$55
- (undocumented)- Returns:
- (undocumented)
- Since:
- 1.3.0
-
register
public <RT,A1, UserDefinedFunction registerA2, A3, A4, A5, A6, A7, A8, A9, A10> (String name, scala.Function10<A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$56, scala.reflect.api.TypeTags.TypeTag<A1> evidence$57, scala.reflect.api.TypeTags.TypeTag<A2> evidence$58, scala.reflect.api.TypeTags.TypeTag<A3> evidence$59, scala.reflect.api.TypeTags.TypeTag<A4> evidence$60, scala.reflect.api.TypeTags.TypeTag<A5> evidence$61, scala.reflect.api.TypeTags.TypeTag<A6> evidence$62, scala.reflect.api.TypeTags.TypeTag<A7> evidence$63, scala.reflect.api.TypeTags.TypeTag<A8> evidence$64, scala.reflect.api.TypeTags.TypeTag<A9> evidence$65, scala.reflect.api.TypeTags.TypeTag<A10> evidence$66) Registers a deterministic Scala closure of 10 arguments as user-defined function (UDF).- Parameters:
name
- (undocumented)func
- (undocumented)evidence$56
- (undocumented)evidence$57
- (undocumented)evidence$58
- (undocumented)evidence$59
- (undocumented)evidence$60
- (undocumented)evidence$61
- (undocumented)evidence$62
- (undocumented)evidence$63
- (undocumented)evidence$64
- (undocumented)evidence$65
- (undocumented)evidence$66
- (undocumented)- Returns:
- (undocumented)
- Since:
- 1.3.0
-
register
public <RT,A1, UserDefinedFunction registerA2, A3, A4, A5, A6, A7, A8, A9, A10, A11> (String name, scala.Function11<A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$67, scala.reflect.api.TypeTags.TypeTag<A1> evidence$68, scala.reflect.api.TypeTags.TypeTag<A2> evidence$69, scala.reflect.api.TypeTags.TypeTag<A3> evidence$70, scala.reflect.api.TypeTags.TypeTag<A4> evidence$71, scala.reflect.api.TypeTags.TypeTag<A5> evidence$72, scala.reflect.api.TypeTags.TypeTag<A6> evidence$73, scala.reflect.api.TypeTags.TypeTag<A7> evidence$74, scala.reflect.api.TypeTags.TypeTag<A8> evidence$75, scala.reflect.api.TypeTags.TypeTag<A9> evidence$76, scala.reflect.api.TypeTags.TypeTag<A10> evidence$77, scala.reflect.api.TypeTags.TypeTag<A11> evidence$78) Registers a deterministic Scala closure of 11 arguments as user-defined function (UDF).- Parameters:
name
- (undocumented)func
- (undocumented)evidence$67
- (undocumented)evidence$68
- (undocumented)evidence$69
- (undocumented)evidence$70
- (undocumented)evidence$71
- (undocumented)evidence$72
- (undocumented)evidence$73
- (undocumented)evidence$74
- (undocumented)evidence$75
- (undocumented)evidence$76
- (undocumented)evidence$77
- (undocumented)evidence$78
- (undocumented)- Returns:
- (undocumented)
- Since:
- 1.3.0
-
register
public <RT,A1, UserDefinedFunction registerA2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12> (String name, scala.Function12<A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$79, scala.reflect.api.TypeTags.TypeTag<A1> evidence$80, scala.reflect.api.TypeTags.TypeTag<A2> evidence$81, scala.reflect.api.TypeTags.TypeTag<A3> evidence$82, scala.reflect.api.TypeTags.TypeTag<A4> evidence$83, scala.reflect.api.TypeTags.TypeTag<A5> evidence$84, scala.reflect.api.TypeTags.TypeTag<A6> evidence$85, scala.reflect.api.TypeTags.TypeTag<A7> evidence$86, scala.reflect.api.TypeTags.TypeTag<A8> evidence$87, scala.reflect.api.TypeTags.TypeTag<A9> evidence$88, scala.reflect.api.TypeTags.TypeTag<A10> evidence$89, scala.reflect.api.TypeTags.TypeTag<A11> evidence$90, scala.reflect.api.TypeTags.TypeTag<A12> evidence$91) Registers a deterministic Scala closure of 12 arguments as user-defined function (UDF).- Parameters:
name
- (undocumented)func
- (undocumented)evidence$79
- (undocumented)evidence$80
- (undocumented)evidence$81
- (undocumented)evidence$82
- (undocumented)evidence$83
- (undocumented)evidence$84
- (undocumented)evidence$85
- (undocumented)evidence$86
- (undocumented)evidence$87
- (undocumented)evidence$88
- (undocumented)evidence$89
- (undocumented)evidence$90
- (undocumented)evidence$91
- (undocumented)- Returns:
- (undocumented)
- Since:
- 1.3.0
-
register
public <RT,A1, UserDefinedFunction registerA2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13> (String name, scala.Function13<A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$92, scala.reflect.api.TypeTags.TypeTag<A1> evidence$93, scala.reflect.api.TypeTags.TypeTag<A2> evidence$94, scala.reflect.api.TypeTags.TypeTag<A3> evidence$95, scala.reflect.api.TypeTags.TypeTag<A4> evidence$96, scala.reflect.api.TypeTags.TypeTag<A5> evidence$97, scala.reflect.api.TypeTags.TypeTag<A6> evidence$98, scala.reflect.api.TypeTags.TypeTag<A7> evidence$99, scala.reflect.api.TypeTags.TypeTag<A8> evidence$100, scala.reflect.api.TypeTags.TypeTag<A9> evidence$101, scala.reflect.api.TypeTags.TypeTag<A10> evidence$102, scala.reflect.api.TypeTags.TypeTag<A11> evidence$103, scala.reflect.api.TypeTags.TypeTag<A12> evidence$104, scala.reflect.api.TypeTags.TypeTag<A13> evidence$105) Registers a deterministic Scala closure of 13 arguments as user-defined function (UDF).- Parameters:
name
- (undocumented)func
- (undocumented)evidence$92
- (undocumented)evidence$93
- (undocumented)evidence$94
- (undocumented)evidence$95
- (undocumented)evidence$96
- (undocumented)evidence$97
- (undocumented)evidence$98
- (undocumented)evidence$99
- (undocumented)evidence$100
- (undocumented)evidence$101
- (undocumented)evidence$102
- (undocumented)evidence$103
- (undocumented)evidence$104
- (undocumented)evidence$105
- (undocumented)- Returns:
- (undocumented)
- Since:
- 1.3.0
-
register
public <RT,A1, UserDefinedFunction registerA2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14> (String name, scala.Function14<A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$106, scala.reflect.api.TypeTags.TypeTag<A1> evidence$107, scala.reflect.api.TypeTags.TypeTag<A2> evidence$108, scala.reflect.api.TypeTags.TypeTag<A3> evidence$109, scala.reflect.api.TypeTags.TypeTag<A4> evidence$110, scala.reflect.api.TypeTags.TypeTag<A5> evidence$111, scala.reflect.api.TypeTags.TypeTag<A6> evidence$112, scala.reflect.api.TypeTags.TypeTag<A7> evidence$113, scala.reflect.api.TypeTags.TypeTag<A8> evidence$114, scala.reflect.api.TypeTags.TypeTag<A9> evidence$115, scala.reflect.api.TypeTags.TypeTag<A10> evidence$116, scala.reflect.api.TypeTags.TypeTag<A11> evidence$117, scala.reflect.api.TypeTags.TypeTag<A12> evidence$118, scala.reflect.api.TypeTags.TypeTag<A13> evidence$119, scala.reflect.api.TypeTags.TypeTag<A14> evidence$120) Registers a deterministic Scala closure of 14 arguments as user-defined function (UDF).- Parameters:
name
- (undocumented)func
- (undocumented)evidence$106
- (undocumented)evidence$107
- (undocumented)evidence$108
- (undocumented)evidence$109
- (undocumented)evidence$110
- (undocumented)evidence$111
- (undocumented)evidence$112
- (undocumented)evidence$113
- (undocumented)evidence$114
- (undocumented)evidence$115
- (undocumented)evidence$116
- (undocumented)evidence$117
- (undocumented)evidence$118
- (undocumented)evidence$119
- (undocumented)evidence$120
- (undocumented)- Returns:
- (undocumented)
- Since:
- 1.3.0
-
register
public <RT,A1, UserDefinedFunction registerA2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15> (String name, scala.Function15<A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$121, scala.reflect.api.TypeTags.TypeTag<A1> evidence$122, scala.reflect.api.TypeTags.TypeTag<A2> evidence$123, scala.reflect.api.TypeTags.TypeTag<A3> evidence$124, scala.reflect.api.TypeTags.TypeTag<A4> evidence$125, scala.reflect.api.TypeTags.TypeTag<A5> evidence$126, scala.reflect.api.TypeTags.TypeTag<A6> evidence$127, scala.reflect.api.TypeTags.TypeTag<A7> evidence$128, scala.reflect.api.TypeTags.TypeTag<A8> evidence$129, scala.reflect.api.TypeTags.TypeTag<A9> evidence$130, scala.reflect.api.TypeTags.TypeTag<A10> evidence$131, scala.reflect.api.TypeTags.TypeTag<A11> evidence$132, scala.reflect.api.TypeTags.TypeTag<A12> evidence$133, scala.reflect.api.TypeTags.TypeTag<A13> evidence$134, scala.reflect.api.TypeTags.TypeTag<A14> evidence$135, scala.reflect.api.TypeTags.TypeTag<A15> evidence$136) Registers a deterministic Scala closure of 15 arguments as user-defined function (UDF).- Parameters:
name
- (undocumented)func
- (undocumented)evidence$121
- (undocumented)evidence$122
- (undocumented)evidence$123
- (undocumented)evidence$124
- (undocumented)evidence$125
- (undocumented)evidence$126
- (undocumented)evidence$127
- (undocumented)evidence$128
- (undocumented)evidence$129
- (undocumented)evidence$130
- (undocumented)evidence$131
- (undocumented)evidence$132
- (undocumented)evidence$133
- (undocumented)evidence$134
- (undocumented)evidence$135
- (undocumented)evidence$136
- (undocumented)- Returns:
- (undocumented)
- Since:
- 1.3.0
-
register
public <RT,A1, UserDefinedFunction registerA2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16> (String name, scala.Function16<A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$137, scala.reflect.api.TypeTags.TypeTag<A1> evidence$138, scala.reflect.api.TypeTags.TypeTag<A2> evidence$139, scala.reflect.api.TypeTags.TypeTag<A3> evidence$140, scala.reflect.api.TypeTags.TypeTag<A4> evidence$141, scala.reflect.api.TypeTags.TypeTag<A5> evidence$142, scala.reflect.api.TypeTags.TypeTag<A6> evidence$143, scala.reflect.api.TypeTags.TypeTag<A7> evidence$144, scala.reflect.api.TypeTags.TypeTag<A8> evidence$145, scala.reflect.api.TypeTags.TypeTag<A9> evidence$146, scala.reflect.api.TypeTags.TypeTag<A10> evidence$147, scala.reflect.api.TypeTags.TypeTag<A11> evidence$148, scala.reflect.api.TypeTags.TypeTag<A12> evidence$149, scala.reflect.api.TypeTags.TypeTag<A13> evidence$150, scala.reflect.api.TypeTags.TypeTag<A14> evidence$151, scala.reflect.api.TypeTags.TypeTag<A15> evidence$152, scala.reflect.api.TypeTags.TypeTag<A16> evidence$153) Registers a deterministic Scala closure of 16 arguments as user-defined function (UDF).- Parameters:
name
- (undocumented)func
- (undocumented)evidence$137
- (undocumented)evidence$138
- (undocumented)evidence$139
- (undocumented)evidence$140
- (undocumented)evidence$141
- (undocumented)evidence$142
- (undocumented)evidence$143
- (undocumented)evidence$144
- (undocumented)evidence$145
- (undocumented)evidence$146
- (undocumented)evidence$147
- (undocumented)evidence$148
- (undocumented)evidence$149
- (undocumented)evidence$150
- (undocumented)evidence$151
- (undocumented)evidence$152
- (undocumented)evidence$153
- (undocumented)- Returns:
- (undocumented)
- Since:
- 1.3.0
-
register
public <RT,A1, UserDefinedFunction registerA2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17> (String name, scala.Function17<A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$154, scala.reflect.api.TypeTags.TypeTag<A1> evidence$155, scala.reflect.api.TypeTags.TypeTag<A2> evidence$156, scala.reflect.api.TypeTags.TypeTag<A3> evidence$157, scala.reflect.api.TypeTags.TypeTag<A4> evidence$158, scala.reflect.api.TypeTags.TypeTag<A5> evidence$159, scala.reflect.api.TypeTags.TypeTag<A6> evidence$160, scala.reflect.api.TypeTags.TypeTag<A7> evidence$161, scala.reflect.api.TypeTags.TypeTag<A8> evidence$162, scala.reflect.api.TypeTags.TypeTag<A9> evidence$163, scala.reflect.api.TypeTags.TypeTag<A10> evidence$164, scala.reflect.api.TypeTags.TypeTag<A11> evidence$165, scala.reflect.api.TypeTags.TypeTag<A12> evidence$166, scala.reflect.api.TypeTags.TypeTag<A13> evidence$167, scala.reflect.api.TypeTags.TypeTag<A14> evidence$168, scala.reflect.api.TypeTags.TypeTag<A15> evidence$169, scala.reflect.api.TypeTags.TypeTag<A16> evidence$170, scala.reflect.api.TypeTags.TypeTag<A17> evidence$171) Registers a deterministic Scala closure of 17 arguments as user-defined function (UDF).- Parameters:
name
- (undocumented)func
- (undocumented)evidence$154
- (undocumented)evidence$155
- (undocumented)evidence$156
- (undocumented)evidence$157
- (undocumented)evidence$158
- (undocumented)evidence$159
- (undocumented)evidence$160
- (undocumented)evidence$161
- (undocumented)evidence$162
- (undocumented)evidence$163
- (undocumented)evidence$164
- (undocumented)evidence$165
- (undocumented)evidence$166
- (undocumented)evidence$167
- (undocumented)evidence$168
- (undocumented)evidence$169
- (undocumented)evidence$170
- (undocumented)evidence$171
- (undocumented)- Returns:
- (undocumented)
- Since:
- 1.3.0
-
register
public <RT,A1, UserDefinedFunction registerA2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18> (String name, scala.Function18<A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$172, scala.reflect.api.TypeTags.TypeTag<A1> evidence$173, scala.reflect.api.TypeTags.TypeTag<A2> evidence$174, scala.reflect.api.TypeTags.TypeTag<A3> evidence$175, scala.reflect.api.TypeTags.TypeTag<A4> evidence$176, scala.reflect.api.TypeTags.TypeTag<A5> evidence$177, scala.reflect.api.TypeTags.TypeTag<A6> evidence$178, scala.reflect.api.TypeTags.TypeTag<A7> evidence$179, scala.reflect.api.TypeTags.TypeTag<A8> evidence$180, scala.reflect.api.TypeTags.TypeTag<A9> evidence$181, scala.reflect.api.TypeTags.TypeTag<A10> evidence$182, scala.reflect.api.TypeTags.TypeTag<A11> evidence$183, scala.reflect.api.TypeTags.TypeTag<A12> evidence$184, scala.reflect.api.TypeTags.TypeTag<A13> evidence$185, scala.reflect.api.TypeTags.TypeTag<A14> evidence$186, scala.reflect.api.TypeTags.TypeTag<A15> evidence$187, scala.reflect.api.TypeTags.TypeTag<A16> evidence$188, scala.reflect.api.TypeTags.TypeTag<A17> evidence$189, scala.reflect.api.TypeTags.TypeTag<A18> evidence$190) Registers a deterministic Scala closure of 18 arguments as user-defined function (UDF).- Parameters:
name
- (undocumented)func
- (undocumented)evidence$172
- (undocumented)evidence$173
- (undocumented)evidence$174
- (undocumented)evidence$175
- (undocumented)evidence$176
- (undocumented)evidence$177
- (undocumented)evidence$178
- (undocumented)evidence$179
- (undocumented)evidence$180
- (undocumented)evidence$181
- (undocumented)evidence$182
- (undocumented)evidence$183
- (undocumented)evidence$184
- (undocumented)evidence$185
- (undocumented)evidence$186
- (undocumented)evidence$187
- (undocumented)evidence$188
- (undocumented)evidence$189
- (undocumented)evidence$190
- (undocumented)- Returns:
- (undocumented)
- Since:
- 1.3.0
-
register
public <RT,A1, UserDefinedFunction registerA2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19> (String name, scala.Function19<A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$191, scala.reflect.api.TypeTags.TypeTag<A1> evidence$192, scala.reflect.api.TypeTags.TypeTag<A2> evidence$193, scala.reflect.api.TypeTags.TypeTag<A3> evidence$194, scala.reflect.api.TypeTags.TypeTag<A4> evidence$195, scala.reflect.api.TypeTags.TypeTag<A5> evidence$196, scala.reflect.api.TypeTags.TypeTag<A6> evidence$197, scala.reflect.api.TypeTags.TypeTag<A7> evidence$198, scala.reflect.api.TypeTags.TypeTag<A8> evidence$199, scala.reflect.api.TypeTags.TypeTag<A9> evidence$200, scala.reflect.api.TypeTags.TypeTag<A10> evidence$201, scala.reflect.api.TypeTags.TypeTag<A11> evidence$202, scala.reflect.api.TypeTags.TypeTag<A12> evidence$203, scala.reflect.api.TypeTags.TypeTag<A13> evidence$204, scala.reflect.api.TypeTags.TypeTag<A14> evidence$205, scala.reflect.api.TypeTags.TypeTag<A15> evidence$206, scala.reflect.api.TypeTags.TypeTag<A16> evidence$207, scala.reflect.api.TypeTags.TypeTag<A17> evidence$208, scala.reflect.api.TypeTags.TypeTag<A18> evidence$209, scala.reflect.api.TypeTags.TypeTag<A19> evidence$210) Registers a deterministic Scala closure of 19 arguments as user-defined function (UDF).- Parameters:
name
- (undocumented)func
- (undocumented)evidence$191
- (undocumented)evidence$192
- (undocumented)evidence$193
- (undocumented)evidence$194
- (undocumented)evidence$195
- (undocumented)evidence$196
- (undocumented)evidence$197
- (undocumented)evidence$198
- (undocumented)evidence$199
- (undocumented)evidence$200
- (undocumented)evidence$201
- (undocumented)evidence$202
- (undocumented)evidence$203
- (undocumented)evidence$204
- (undocumented)evidence$205
- (undocumented)evidence$206
- (undocumented)evidence$207
- (undocumented)evidence$208
- (undocumented)evidence$209
- (undocumented)evidence$210
- (undocumented)- Returns:
- (undocumented)
- Since:
- 1.3.0
-
register
public <RT,A1, UserDefinedFunction registerA2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20> (String name, scala.Function20<A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$211, scala.reflect.api.TypeTags.TypeTag<A1> evidence$212, scala.reflect.api.TypeTags.TypeTag<A2> evidence$213, scala.reflect.api.TypeTags.TypeTag<A3> evidence$214, scala.reflect.api.TypeTags.TypeTag<A4> evidence$215, scala.reflect.api.TypeTags.TypeTag<A5> evidence$216, scala.reflect.api.TypeTags.TypeTag<A6> evidence$217, scala.reflect.api.TypeTags.TypeTag<A7> evidence$218, scala.reflect.api.TypeTags.TypeTag<A8> evidence$219, scala.reflect.api.TypeTags.TypeTag<A9> evidence$220, scala.reflect.api.TypeTags.TypeTag<A10> evidence$221, scala.reflect.api.TypeTags.TypeTag<A11> evidence$222, scala.reflect.api.TypeTags.TypeTag<A12> evidence$223, scala.reflect.api.TypeTags.TypeTag<A13> evidence$224, scala.reflect.api.TypeTags.TypeTag<A14> evidence$225, scala.reflect.api.TypeTags.TypeTag<A15> evidence$226, scala.reflect.api.TypeTags.TypeTag<A16> evidence$227, scala.reflect.api.TypeTags.TypeTag<A17> evidence$228, scala.reflect.api.TypeTags.TypeTag<A18> evidence$229, scala.reflect.api.TypeTags.TypeTag<A19> evidence$230, scala.reflect.api.TypeTags.TypeTag<A20> evidence$231) Registers a deterministic Scala closure of 20 arguments as user-defined function (UDF).- Parameters:
name
- (undocumented)func
- (undocumented)evidence$211
- (undocumented)evidence$212
- (undocumented)evidence$213
- (undocumented)evidence$214
- (undocumented)evidence$215
- (undocumented)evidence$216
- (undocumented)evidence$217
- (undocumented)evidence$218
- (undocumented)evidence$219
- (undocumented)evidence$220
- (undocumented)evidence$221
- (undocumented)evidence$222
- (undocumented)evidence$223
- (undocumented)evidence$224
- (undocumented)evidence$225
- (undocumented)evidence$226
- (undocumented)evidence$227
- (undocumented)evidence$228
- (undocumented)evidence$229
- (undocumented)evidence$230
- (undocumented)evidence$231
- (undocumented)- Returns:
- (undocumented)
- Since:
- 1.3.0
-
register
public <RT,A1, UserDefinedFunction registerA2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20, A21> (String name, scala.Function21<A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20, A21, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$232, scala.reflect.api.TypeTags.TypeTag<A1> evidence$233, scala.reflect.api.TypeTags.TypeTag<A2> evidence$234, scala.reflect.api.TypeTags.TypeTag<A3> evidence$235, scala.reflect.api.TypeTags.TypeTag<A4> evidence$236, scala.reflect.api.TypeTags.TypeTag<A5> evidence$237, scala.reflect.api.TypeTags.TypeTag<A6> evidence$238, scala.reflect.api.TypeTags.TypeTag<A7> evidence$239, scala.reflect.api.TypeTags.TypeTag<A8> evidence$240, scala.reflect.api.TypeTags.TypeTag<A9> evidence$241, scala.reflect.api.TypeTags.TypeTag<A10> evidence$242, scala.reflect.api.TypeTags.TypeTag<A11> evidence$243, scala.reflect.api.TypeTags.TypeTag<A12> evidence$244, scala.reflect.api.TypeTags.TypeTag<A13> evidence$245, scala.reflect.api.TypeTags.TypeTag<A14> evidence$246, scala.reflect.api.TypeTags.TypeTag<A15> evidence$247, scala.reflect.api.TypeTags.TypeTag<A16> evidence$248, scala.reflect.api.TypeTags.TypeTag<A17> evidence$249, scala.reflect.api.TypeTags.TypeTag<A18> evidence$250, scala.reflect.api.TypeTags.TypeTag<A19> evidence$251, scala.reflect.api.TypeTags.TypeTag<A20> evidence$252, scala.reflect.api.TypeTags.TypeTag<A21> evidence$253) Registers a deterministic Scala closure of 21 arguments as user-defined function (UDF).- Parameters:
name
- (undocumented)func
- (undocumented)evidence$232
- (undocumented)evidence$233
- (undocumented)evidence$234
- (undocumented)evidence$235
- (undocumented)evidence$236
- (undocumented)evidence$237
- (undocumented)evidence$238
- (undocumented)evidence$239
- (undocumented)evidence$240
- (undocumented)evidence$241
- (undocumented)evidence$242
- (undocumented)evidence$243
- (undocumented)evidence$244
- (undocumented)evidence$245
- (undocumented)evidence$246
- (undocumented)evidence$247
- (undocumented)evidence$248
- (undocumented)evidence$249
- (undocumented)evidence$250
- (undocumented)evidence$251
- (undocumented)evidence$252
- (undocumented)evidence$253
- (undocumented)- Returns:
- (undocumented)
- Since:
- 1.3.0
-
register
public <RT,A1, UserDefinedFunction registerA2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20, A21, A22> (String name, scala.Function22<A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20, A21, A22, RT> func, scala.reflect.api.TypeTags.TypeTag<RT> evidence$254, scala.reflect.api.TypeTags.TypeTag<A1> evidence$255, scala.reflect.api.TypeTags.TypeTag<A2> evidence$256, scala.reflect.api.TypeTags.TypeTag<A3> evidence$257, scala.reflect.api.TypeTags.TypeTag<A4> evidence$258, scala.reflect.api.TypeTags.TypeTag<A5> evidence$259, scala.reflect.api.TypeTags.TypeTag<A6> evidence$260, scala.reflect.api.TypeTags.TypeTag<A7> evidence$261, scala.reflect.api.TypeTags.TypeTag<A8> evidence$262, scala.reflect.api.TypeTags.TypeTag<A9> evidence$263, scala.reflect.api.TypeTags.TypeTag<A10> evidence$264, scala.reflect.api.TypeTags.TypeTag<A11> evidence$265, scala.reflect.api.TypeTags.TypeTag<A12> evidence$266, scala.reflect.api.TypeTags.TypeTag<A13> evidence$267, scala.reflect.api.TypeTags.TypeTag<A14> evidence$268, scala.reflect.api.TypeTags.TypeTag<A15> evidence$269, scala.reflect.api.TypeTags.TypeTag<A16> evidence$270, scala.reflect.api.TypeTags.TypeTag<A17> evidence$271, scala.reflect.api.TypeTags.TypeTag<A18> evidence$272, scala.reflect.api.TypeTags.TypeTag<A19> evidence$273, scala.reflect.api.TypeTags.TypeTag<A20> evidence$274, scala.reflect.api.TypeTags.TypeTag<A21> evidence$275, scala.reflect.api.TypeTags.TypeTag<A22> evidence$276) Registers a deterministic Scala closure of 22 arguments as user-defined function (UDF).- Parameters:
name
- (undocumented)func
- (undocumented)evidence$254
- (undocumented)evidence$255
- (undocumented)evidence$256
- (undocumented)evidence$257
- (undocumented)evidence$258
- (undocumented)evidence$259
- (undocumented)evidence$260
- (undocumented)evidence$261
- (undocumented)evidence$262
- (undocumented)evidence$263
- (undocumented)evidence$264
- (undocumented)evidence$265
- (undocumented)evidence$266
- (undocumented)evidence$267
- (undocumented)evidence$268
- (undocumented)evidence$269
- (undocumented)evidence$270
- (undocumented)evidence$271
- (undocumented)evidence$272
- (undocumented)evidence$273
- (undocumented)evidence$274
- (undocumented)evidence$275
- (undocumented)evidence$276
- (undocumented)- Returns:
- (undocumented)
- Since:
- 1.3.0
-
register
Register a deterministic Java UDF0 instance as user-defined function (UDF).- Parameters:
name
- (undocumented)f
- (undocumented)returnType
- (undocumented)- Since:
- 2.3.0
-
register
Register a deterministic Java UDF1 instance as user-defined function (UDF).- Parameters:
name
- (undocumented)f
- (undocumented)returnType
- (undocumented)- Since:
- 1.3.0
-
register
Register a deterministic Java UDF2 instance as user-defined function (UDF).- Parameters:
name
- (undocumented)f
- (undocumented)returnType
- (undocumented)- Since:
- 1.3.0
-
register
Register a deterministic Java UDF3 instance as user-defined function (UDF).- Parameters:
name
- (undocumented)f
- (undocumented)returnType
- (undocumented)- Since:
- 1.3.0
-
register
Register a deterministic Java UDF4 instance as user-defined function (UDF).- Parameters:
name
- (undocumented)f
- (undocumented)returnType
- (undocumented)- Since:
- 1.3.0
-
register
Register a deterministic Java UDF5 instance as user-defined function (UDF).- Parameters:
name
- (undocumented)f
- (undocumented)returnType
- (undocumented)- Since:
- 1.3.0
-
register
Register a deterministic Java UDF6 instance as user-defined function (UDF).- Parameters:
name
- (undocumented)f
- (undocumented)returnType
- (undocumented)- Since:
- 1.3.0
-
register
Register a deterministic Java UDF7 instance as user-defined function (UDF).- Parameters:
name
- (undocumented)f
- (undocumented)returnType
- (undocumented)- Since:
- 1.3.0
-
register
Register a deterministic Java UDF8 instance as user-defined function (UDF).- Parameters:
name
- (undocumented)f
- (undocumented)returnType
- (undocumented)- Since:
- 1.3.0
-
register
Register a deterministic Java UDF9 instance as user-defined function (UDF).- Parameters:
name
- (undocumented)f
- (undocumented)returnType
- (undocumented)- Since:
- 1.3.0
-
register
Register a deterministic Java UDF10 instance as user-defined function (UDF).- Parameters:
name
- (undocumented)f
- (undocumented)returnType
- (undocumented)- Since:
- 1.3.0
-
register
Register a deterministic Java UDF11 instance as user-defined function (UDF).- Parameters:
name
- (undocumented)f
- (undocumented)returnType
- (undocumented)- Since:
- 1.3.0
-
register
Register a deterministic Java UDF12 instance as user-defined function (UDF).- Parameters:
name
- (undocumented)f
- (undocumented)returnType
- (undocumented)- Since:
- 1.3.0
-
register
Register a deterministic Java UDF13 instance as user-defined function (UDF).- Parameters:
name
- (undocumented)f
- (undocumented)returnType
- (undocumented)- Since:
- 1.3.0
-
register
Register a deterministic Java UDF14 instance as user-defined function (UDF).- Parameters:
name
- (undocumented)f
- (undocumented)returnType
- (undocumented)- Since:
- 1.3.0
-
register
Register a deterministic Java UDF15 instance as user-defined function (UDF).- Parameters:
name
- (undocumented)f
- (undocumented)returnType
- (undocumented)- Since:
- 1.3.0
-
register
Register a deterministic Java UDF16 instance as user-defined function (UDF).- Parameters:
name
- (undocumented)f
- (undocumented)returnType
- (undocumented)- Since:
- 1.3.0
-
register
public void register(String name, UDF17<?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?> f, DataType returnType) Register a deterministic Java UDF17 instance as user-defined function (UDF).- Parameters:
name
- (undocumented)f
- (undocumented)returnType
- (undocumented)- Since:
- 1.3.0
-
register
public void register(String name, UDF18<?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?> f, DataType returnType) Register a deterministic Java UDF18 instance as user-defined function (UDF).- Parameters:
name
- (undocumented)f
- (undocumented)returnType
- (undocumented)- Since:
- 1.3.0
-
register
public void register(String name, UDF19<?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?> f, DataType returnType) Register a deterministic Java UDF19 instance as user-defined function (UDF).- Parameters:
name
- (undocumented)f
- (undocumented)returnType
- (undocumented)- Since:
- 1.3.0
-
register
public void register(String name, UDF20<?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?> f, DataType returnType) Register a deterministic Java UDF20 instance as user-defined function (UDF).- Parameters:
name
- (undocumented)f
- (undocumented)returnType
- (undocumented)- Since:
- 1.3.0
-
register
public void register(String name, UDF21<?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?> f, DataType returnType) Register a deterministic Java UDF21 instance as user-defined function (UDF).- Parameters:
name
- (undocumented)f
- (undocumented)returnType
- (undocumented)- Since:
- 1.3.0
-
register
public void register(String name, UDF22<?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?> f, DataType returnType) Register a deterministic Java UDF22 instance as user-defined function (UDF).- Parameters:
name
- (undocumented)f
- (undocumented)returnType
- (undocumented)- Since:
- 1.3.0
-
registerJava
Register a Java UDF class using it's class name. The class must implement one of the UDF interfaces in theorg.apache.spark.sql.api.java
package, and discoverable by the current session's class loader.- Parameters:
name
- Name of the UDF.className
- Fully qualified class name of the UDF.returnDataType
- Return type of UDF. If it isnull
, Spark would try to infer via reflection.- Since:
- 4.0.0
- Note:
- this method is currently not supported in Spark Connect.
-