Skip to content

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

@bigdata-spec

Description

@bigdata-spec
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,是否正常呢?

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type
    No fields configured for issues without a type.

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions