MaxCompute:UDAF ve UDTF'ler için dinamik parametreler

MaxCompute'te UDAF ve UDTF'ler, işlevin imzasını belirlemek için Resolve ek açıklamasını kullanır.

@com.aliyun.odps.udf.annotation.Resolve("BIGINT->DOUBLE")
public class UDTFClass extends UDTF {
    ...
}

MaxCompute, Resolve ek açıklaması söz dizimi için aşağıdaki uzantıları destekler:

• Giriş parametresi listesinde değişken sayıda ve herhangi bir türde giriş parametresini kabul etmek için * karakterini kullanabilirsiniz. Örneğin, @Resolve('double,*->String') ifadesi, işlevin ilk giriş parametresi olarak bir DOUBLE değerini, ardından ise herhangi bir türde istenilen sayıda parametreyi kabul ettiğini gösterir. Giriş parametrelerinin sayısını ve türlerini kontrol etmek ve buna göre işlemek için kod yazmanız gerekir. Bu mekanizma, C dilindeki printf işlevine benzer.

  Not

  Yıldız işaretinin dönüş değeri listesindeki anlamı farklıdır.

• Giriş parametresi listesinde herhangi bir türdeki parametreyi temsil etmek için any anahtar sözcüğünü kullanabilirsiniz. Örneğin, @Resolve('double,any->string') ifadesi, işlevin ilk giriş parametresi olarak DOUBLE türünde, ikinci giriş parametresi olarak ise herhangi bir türde bir değer kabul ettiğini gösterir.

  Not

  any anahtar sözcüğü, dönüş değeri listesinde veya ARRAY gibi karmaşık türlerin alt türleri için kullanılamaz.

• Bir UDTF'nin dönüş değeri, isteğe bağlı sayıda STRING türü değeri temsil eden bir yıldız işareti (*) olabilir. Dönüş değerlerinin sayısı, işlev çağrılırken belirtilen diğer adların sayısına bağlıdır. Örneğin, @Resolve("ANY,ANY->DOUBLE,*") ek açıklamasıyla işlev UDTF(x, y) as (a, b, c) şeklinde çağrılırsa, as anahtar sözcüğünden sonra a, b ve c olmak üzere üç diğer ad belirtilmiş olur. Düzenleyici, a değişkeninin ek açıklamada ilk dönüş değeri olarak belirtilen DOUBLE türünde olduğunu; b ve c değişkenlerinin ise STRING türünde olduğunu belirler. Üç dönüş değeri belirtildiği için, UDTF forward yöntemi çağrıldığında uzunluğu 3 olan bir diziyi forward ile iletmelidir. Aksi takdirde çalışma zamanı hatası oluşur.

  Not

  Bu tür bir hata derleme zamanında tespit edilemez. Bu nedenle, bir UDTF çağrırken SQL sorgunuzdaki diğer adların sayısı, UDTF tarafından döndürülen sütun sayısıyla eşleşmelidir. Bu özellik, her zaman tek bir dönüş değeri olan UDAF'ler için geçerli değildir.

import com.aliyun.odps.udf.UDFException;
import com.aliyun.odps.udf.UDTF;
import com.aliyun.odps.udf.annotation.Resolve;
import org.json.JSONException;
import org.json.JSONObject;
@Resolve("STRING,*->STRING,*")
public class JsonTuple extends UDTF {
  private Object[] result = null;
  @Override
  public void process(Object[] input) throws UDFException {
    if (result == null) {
      result = new Object[input.length];
    }
    try {
      JSONObject obj = new JSONObject((String)input[0]);
      for (int i = 1; i < input.length; i++) {
        // The variable-length part of the return value must consist of STRING types.
        result[i] = String.valueOf(obj.get((String)(input[i])));
      }
      result[0] = null;
    } catch (JSONException ex) {
      for (int i = 1; i < result.length; i++) {
        result[i] = null;
      }
      result[0] = ex.getMessage();
    }
    forward(result);
  }
}

-- Customize the number of output aliases based on the number of input parameters.
SELECT my_json_tuple(json, 'a', 'b') as exceptions, a, b FROM jsons;

-- When no JSON fields are to be parsed, expect only the error message column.
SELECT my_json_tuple(json) as exceptions FROM jsons;

-- The following SQL statement causes a runtime error because the number of aliases
-- does not match the actual number of outputs.
-- Note that this error cannot be detected at compile time.
SELECT my_json_tuple(json, 'a', 'b') as exceptions, a, b, c FROM jsons;