关于udf中transform里面日志不打印
- Langage dominant
- Java
- Étoiles
- 6.4k
- Forks
- 1.2k
- Merge moyen
- 1 j 23 h
- PR mergées (30 j)
- 115
Description
```
public class UDTFSequenceFilter implements UDTF {
@Override
public void validate(UDFParameterValidator validator) {
int childExpressionsSize = validator.getParameters().getChildExpressionsSize();
LOG.info("childExpressionsSize "+childExpressionsSize);
List 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,是否正常呢?
Guide de contribution
Ouvrir le guide de contribution
Piste de recherche
Commencez par reproduire l’exemple UDTFSequenceFilter sur IoTDB 1.2.2 et examinez quand validate, beforeStart, transform et terminate sont invoqués. Déterminez si l’absence des logs de transform et terminate est attendue ou indique un problème de cycle de vie ; documentez le comportement observé ou identifiez le correctif pertinent.
Rédigé par le modèle d'indexation à partir du texte de l'issue.
Évaluation
- Stack technique
- java
- Domaine
- database
- Type d'issue
- Bug
- Difficulté
- 3/5
- Temps estimé
- 1-2 jours
- Activité
- À l'abandon
- Clarté
- À clarifier
- Accessibilité débutants
- 30/100