diff --git a/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/excel/ExcelReaderListener.java b/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/excel/ExcelReaderListener.java index ac3d9e208cc..84c6d500e68 100644 --- a/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/excel/ExcelReaderListener.java +++ b/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/excel/ExcelReaderListener.java @@ -55,8 +55,6 @@ public class ExcelReaderListener extends AnalysisEventListener customHeaders = new HashMap<>(); public ExcelReaderListener( @@ -74,19 +72,11 @@ public ExcelReaderListener( this.seaTunnelRowType = seaTunnelRowType; fieldTypes = seaTunnelRowType.getFieldTypes(); - - } - /** - * 这里会一行行的返回头 - * - * @param headMap - * @param context - */ + @Override public void invokeHead(Map> headMap, AnalysisContext context) { - for (int i = 0; i < headMap.size(); i++) { String header = headMap.get(i).getStringValue(); if (!"null".equals(header) ) { @@ -113,13 +103,6 @@ public void doAfterAllAnalysed(AnalysisContext context) { log.info("excel parsing completed"); } - /** - * 在转换异常 获取其他异常下会调用本接口。抛出异常则停止读取。如果这里不抛出异常则 继续读取下一行。 - * - * @param exception - * @param context - * @throws Exception - */ @Override public void onException(Exception exception, AnalysisContext context) { log.error("cell parsing exception :{}", exception.getMessage());