MAPREDUCE服务 MRS-IoTDB自定义函数（UDF）样例程序:代码样例

时间：2024-12-09 15:37:28

MAPREDUCE服务 MRS

代码样例

以下为代码片段示例：

package com.huawei.bigdata.iotdb;
import org.apache.iotdb.udf.api.UDTF;
import org.apache.iotdb.udf.api.access.Row;
import org.apache.iotdb.udf.api.collector.PointCollector;
import org.apache.iotdb.udf.api.customizer.config.UDTFConfigurations;
import org.apache.iotdb.udf.api.customizer.parameter.UDFParameters;
import org.apache.iotdb.udf.api.customizer.strategy.RowByRowAccessStrategy;
import org.apache.iotdb.udf.api.type.Type;
import java.io.IOException;

public class UDTFExample implements UDTF {
    @Override    
     public void beforeStart(UDFParameters parameters, UDTFConfigurations configurations) {        
       configurations.setAccessStrategy(new RowByRowAccessStrategy()).setOutputDataType(Type.INT32);    
    }

    @Override    
    public void transform(Row row, PointCollector collector) throws IOException {        
      collector.putInt(row.getTime(), -row.getInt(0));    
    }
}

上一篇：MAPREDUCE服务 MRS-在Linux环境中调测Hive JDBC样例程序:操作步骤

下一篇：MAPREDUCE服务 MRS-Hive JDBC样例程序开发思路:开发思路