iotdb icon indicating copy to clipboard operation
iotdb copied to clipboard

关于udf中transform里面日志不打印

Open bigdata-spec opened this issue 1 year ago • 1 comments

public class UDTFSequenceFilter implements UDTF {
    @Override
    public void validate(UDFParameterValidator validator) {
        int childExpressionsSize = validator.getParameters().getChildExpressionsSize();
        LOG.info("childExpressionsSize "+childExpressionsSize);
        List<String> childExpressions = validator.getParameters().getChildExpressions();
        LOG.info("childExpressions "+childExpressions);
        for (int i = 0; i < validator.getParameters().getChildExpressionsSize(); ++i) {
            if(i==0){
            validator.validateInputSeriesDataType(i, Type.BOOLEAN);}
            else {
                validator
                        .validateInputSeriesDataType(0, Type.FLOAT, Type.DOUBLE, Type.INT32, Type.INT64, Type.BOOLEAN);
            }
        }
        LOG.info("validate完成");
    }

    @Override
    public void beforeStart(UDFParameters udfParameters, UDTFConfigurations udtfConfigurations) {
        udtfConfigurations
                .setAccessStrategy(new RowByRowAccessStrategy())
                .setOutputDataType(Type.TEXT);
        LOG.info("beforeStart完成");
    }

    @Override
    public void transform(Row row, PointCollector collector) throws Exception {
        LOG.info("进入transform....");
    
    }

    @Override
    public void terminate(PointCollector collector) {
      LOG.info("进入terminate....");
  
    }
}

请问下后台发现 validate 和beforeStart 日志正常打印,但是transform和 terminate 不打印日志,IotDB版本1.2.2,是否正常呢?

bigdata-spec avatar Jan 19 '24 08:01 bigdata-spec

validate完成 "beforeStart完成"这两个日志会打印出来 但是"进入transform...." 进入terminate....这两句不会打印出来。

bigdata-spec avatar Jan 26 '24 06:01 bigdata-spec