CREATE FUNCTION (Dış)

  • Makale

Şunlar için geçerlidir:onay işareti evet olarak işaretlenmiş Databricks Runtime

Geçici veya kalıcı bir dış işlev oluşturur. Geçici işlevlerin kapsamı, kalıcı katalogda kalıcı işlevler oluşturulduğu ve tüm oturumlarda kullanılabilir hale getirildiği bir oturum düzeyindedir. yan tümcesinde USING belirtilen kaynaklar ilk kez yürütülürken tüm yürütücüler tarafından kullanılabilir hale getirilir.

Spark, SQL arabirimine ek olarak Scala, Python ve Java API'lerini kullanarak özel kullanıcı tanımlı skaler ve toplama işlevleri oluşturmanıza olanak tanır. Daha fazla bilgi için bkz. Dış kullanıcı tanımlı skaler işlevler (UDF) ve Kullanıcı tanımlı toplama işlevleri (UDAF'ler).

Sözdizimi

CREATE [ OR REPLACE ] [ TEMPORARY ] FUNCTION [ IF NOT EXISTS ]
    function_name AS class_name [ resource_locations ]

Parametreler

  • VEYA DEĞİşTİr

    Belirtilirse, işlevin kaynakları yeniden yüklenir. Bu, işlevin uygulanmasında yapılan değişiklikleri almak için esas olarak yararlıdır. Bu parametre birbirini dışlar IF NOT EXISTS ve birlikte belirtilemez.

  • GEÇİ -Cİ

    Oluşturulan işlevin kapsamını gösterir. Belirtildiğinde TEMPORARY , oluşturulan işlev geçerli olur ve geçerli oturumda görünür. Bu tür işlevler için katalogda kalıcı giriş yapılmaz.

  • YOKSA

    Belirtilirse, işlevi yalnızca mevcut olmadığında oluşturur. Belirtilen işlev sistemde zaten varsa, işlevin oluşturulması başarılı olur (hata oluşturulmaz). Bu parametre birbirini dışlar OR REPLACE ve birlikte belirtilemez.

  • function_name

    İşlev için bir ad. İşlev adı isteğe bağlı olarak bir şema adıyla nitelenebilir.

    içinde hive_metastore oluşturulan işlevler yalnızca alfasayısal ASCII karakterleri ve alt çizgi içerebilir.

  • class_name

    Oluşturulacak işlevin uygulamasını sağlayan sınıfın adı. Uygulayan sınıf aşağıdaki gibi temel sınıflardan birini genişletmelidir:

    • Paket içinde org.apache.hadoop.hive.ql.exec veya UDAF genişletilmelidirUDF.
    • , GenericUDFveya GenericUDTForg.apache.hadoop.hive.ql.udf.generic paketini genişletmelidirAbstractGenericUDAFResolver.
    • Pakette org.apache.spark.sql.expressions genişletilmelidirUserDefinedAggregateFunction.

  • resource_locations

    İşlevin uygulanmasını ve bağımlılıklarını içeren kaynakların listesi.

    Söz dizimi:USING { { (JAR | FILE | ARCHIVE) resource_uri } , ... }

Örnekler

-- 1. Create a simple UDF `SimpleUdf` that increments the supplied integral value by 10.
--    import org.apache.hadoop.hive.ql.exec.UDF;
--    public class SimpleUdf extends UDF {
--      public int evaluate(int value) {
--        return value + 10;
--      }
--    }
-- 2. Compile and place it in a JAR file called `SimpleUdf.jar` in /tmp.

-- Create a table called `test` and insert two rows.
> CREATE TABLE test(c1 INT);
> INSERT INTO test VALUES (1), (2);

-- Create a permanent function called `simple_udf`.
> CREATE FUNCTION simple_udf AS 'SimpleUdf'
    USING JAR '/tmp/SimpleUdf.jar';

-- Verify that the function is in the registry.
> SHOW USER FUNCTIONS;
           function
 ------------------
 default.simple_udf

-- Invoke the function. Every selected value should be incremented by 10.
> SELECT simple_udf(c1) AS function_return_value FROM t1;
 function_return_value
 ---------------------
                    11
                    12

-- Created a temporary function.
> CREATE TEMPORARY FUNCTION simple_temp_udf AS 'SimpleUdf'
    USING JAR '/tmp/SimpleUdf.jar';

-- Verify that the newly created temporary function is in the registry.
-- The temporary function does not have a qualified
-- schema associated with it.
> SHOW USER FUNCTIONS;
           function
 ------------------
 default.simple_udf
    simple_temp_udf

-- 1. Modify `SimpleUdf`'s implementation to add supplied integral value by 20.
--    import org.apache.hadoop.hive.ql.exec.UDF;

--    public class SimpleUdfR extends UDF {
--      public int evaluate(int value) {
--        return value + 20;
--      }
--    }
-- 2. Compile and place it in a jar file called `SimpleUdfR.jar` in /tmp.

-- Replace the implementation of `simple_udf`
> CREATE OR REPLACE FUNCTION simple_udf AS 'SimpleUdfR'
    USING JAR '/tmp/SimpleUdfR.jar';

-- Invoke the function. Every selected value should be incremented by 20.
> SELECT simple_udf(c1) AS function_return_value FROM t1;
 function_return_value
 ---------------------
                    21
                    22