只需使用错误处理程序,除非您自己抛出异常,否则它将继续运行:
//Let's set a RowProcessorErrorHandler to log the error. The parser will keep running.
settings.setProcessorErrorHandler(new RowProcessorErrorHandler() {
@Override
public void handleError(DataProcessingException error,Object[] inputRow,ParsingContext context) {
println(out,"Error processing row: " + Arrays.toString(inputRow));
println(out,"Error details: column '" + error.getColumnName() + "' (index " + error.getColumnIndex() + ") has value '" + inputRow[error.getColumnIndex()] + "'");
}
});
更新:您可以使用RetryableErrorHandler来防止丢弃该行.这是添加到版本2.3.0的特殊实现,允许用户调用方法setDefaultValue()为有问题的列分配值,并使用keepRecord来防止记录被丢弃.
例:
settings.setProcessorErrorHandler(new RetryableErrorHandler
请注意,如果error.getColumnIndex()返回-1,则无法保存记录,无论如何都会跳过它.您可以使用它来记录错误详细信息.