MaxCompute:UDF の例：区切り文字を含む文字列から値を取得

Java

package com.aliyun.rewrite; // パッケージ名。ユーザー定義です。
import com.aliyun.odps.udf.UDF;

public class ExtractKeyValueWithSplit extends UDF{
    /**
     * split1 を使用して文字列を分割し、キーと値のペアを取得します。 次に、split2 を使用してキーと値のペアを分割し、キーと値を取得します。
     * @param str    ソース文字列。
     * @param split1  文字列を分割してキーと値のペアを取得するために使用されるデリミタ。
     * @param split2  キーと値のペアを分割してキーと値を取得するために使用されるデリミタ。
     * @param keyname 値を取得するキーの名前。
     * @return 返される値。
     */
    public String evaluate(String str, String split1, String split2, String keyname) {
        if(str==null || split1==null || split2==null || keyname==null){
            return null;
        }
        try {
            // keyname と split2 を結合します。
            String keySplit = keyname + split2;

            // 文字列を走査します。 split1 を使用して文字列を分割し、キーと値のペアを取得します。
            for(String subStr: str.split(split1)){
                // split2 を使用してキーと値のペアを分割し、キーと値を取得します。 次に、特定のキーに対応する値を取得します。
                if (subStr.startsWith(keySplit)){
                    return subStr.substring(keySplit.length());
                }
            }
        } catch (Exception e) {
            return null;
        }
        return null;
    }
}

Java UDF は UDF クラスを継承する必要があります。 evaluate メソッドは、SQL ステートメントで使用される関数シグネチャを定義します。このシグネチャは、4つの STRING 入力パラメーターと1つの STRING 戻り値で構成されます。 その他のコード仕様については、「Java UDF」をご参照ください。

Python 3

from odps.udf import annotate


@annotate("string,string,string,string->string")
class ExtractKeyValueWithSplit(object):
    def evaluate(self, s, split1, split2, keyname):
        if not s:
            return None
        key_split = keyname + split2
        # 文字列を走査します。 split1 を使用して文字列を分割し、キーと値のペアを取得します。
        for subStr in s.split(split1):
            # split2 を使用してキーと値のペアを分割し、キーと値を取得します。 次に、特定のキーに対応する値を取得します。
            if subStr.startswith(key_split):
                return subStr[len(key_split):]

Python 3 UDF の仕様については、「Python 3 UDF」をご参照ください。

Python 2

#coding:utf-8
from odps.udf import annotate


@annotate("string,string,string,string->string")
class ExtractKeyValueWithSplit(object):
    def evaluate(self, s, split1, split2, keyname):
        if not s:
            return None
        key_split = keyname + split2
        # 文字列を走査します。 split1 を使用して文字列を分割し、キーと値のペアを取得します。
        for subStr in s.split(split1):
            # split2 を使用してキーと値のペアを分割し、キーと値を取得します。 次に、特定のキーに対応する値を取得します。
            if subStr.startswith(key_split):
                return subStr[len(key_split):]

Python 2 UDF コードに中国語文字が含まれている場合は、ファイルの先頭にエンコーディング宣言を追加してください： #coding:utf-8 または # -*- coding: utf-8 -*-。 この宣言がない場合、MaxCompute は UDF の実行時にエラーを返します。

Python 2 UDF の仕様については、「Python 2 UDF」をご参照ください。