高级清洗抛错说明

Error Reporting in Data Cleaning Scripts

为了满足用户多样化的使用场景，我们对不同的高级清洗抛错做了不同的处理，详情如下：

1、数据进错误队列-CustomizedCodeEngineException

高级清洗中抛错"CustomizedCodeEngineException"，任务遇此错误，报错数据进错误队列。示例如下：

import java.util.Map;
import com.datapipeline.base.connector.codeengine.CustomizedCodeEngineException;

public class Mid_5_df135ce450322546db5b16f5801355f41e3c {
public Map<String, Object> process(Map<String, Object> record) throws CustomizedCodeEngineException
{ throw new CustomizedCodeEngineException("Error queue"); }
}

2、任务报错

高级清洗中抛出除"CustomizedCodeEngineException"外的错误，任务均报错暂停。示例如下：

import java.util.Map;
import com.datapipeline.base.connector.codeengine.CustomizedCodeEngineException;

public class Mid_5_df135ce450322546db5b16f5801355f41e3c {
public Map<String, Object> process(Map<String, Object> record) throws CustomizedCodeEngineException
{ throw new IllegalArgumentException("Wrong argument"); }
}