Updated pom.xml

Commented out a few files
apache · Mar 22, 2022 · bf6a16c · bf6a16c
1 parent b68c54d
commit bf6a16c
Show file tree

Hide file tree

Showing 2 changed files with 18 additions and 19 deletions.
diff --git a/contrib/format-fixedwidth/pom.xml b/contrib/format-fixedwidth/pom.xml
@@ -23,7 +23,7 @@
   <parent>
     <artifactId>drill-contrib-parent</artifactId>
     <groupId>org.apache.drill.contrib</groupId>
-    <version>1.21.0-SNAPSHOT</version>
+    <version>2.0.0-SNAPSHOT</version>
   </parent>
   <artifactId>drill-format-fixedwidth</artifactId>
   <name>Drill : Contrib : Format : FixedWidth</name>

diff --git a/...ixedwidth/src/main/java/org/apache/drill/exec/store/fixedwidth/FixedWidthBatchReader.java b/...ixedwidth/src/main/java/org/apache/drill/exec/store/fixedwidth/FixedWidthBatchReader.java
@@ -13,10 +13,9 @@
 import org.apache.hadoop.mapred.FileSplit;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import com.epam.parso.impl;
 
 import java.io.BufferedReader;
-import java.io.IOException;
+//import java.io.IOException;
 import java.io.InputStream;
 import java.io.InputStreamReader;
 
@@ -51,9 +50,9 @@ public void close() {
   }
 
   private ResultSetLoader open(FileSchemaNegotiator negotiator) {
-    this.split = (FileSplit) negotiator.split();
+//    this.split = (FileSplit) negotiator.split();
     this.errorContext = negotiator.parentErrorContext();
-    openFile(negotiator);
+//    openFile(negotiator);
 
     try {
       negotiator.tableSchema(buildSchema(), true);
@@ -70,20 +69,20 @@ private ResultSetLoader open(FileSchemaNegotiator negotiator) {
     return this.loader;
   }
 
-  private void openFile(FileSchemaNegotiator negotiator) {
-    try {
-      this.fsStream = negotiator.file().fileSystem().openPossiblyCompressedStream(this.split.getPath());
-      sasFileReader = new SasFileReaderImpl(this.fsStream);
-      firstRow = sasFileReader.readNext();
-    } catch (IOException e) {
-      throw UserException
-        .dataReadError(e)
-        .message("Unable to open Fixed Width File %s", this.split.getPath())
-        .addContext(e.getMessage())
-        .addContext(this.errorContext)
-        .build(FixedWidthBatchReader.logger);
-    }
-  }
+//  private void openFile(FileSchemaNegotiator negotiator) {
+//    try {
+//      this.fsStream = negotiator.file().fileSystem().openPossiblyCompressedStream(this.split.getPath());
+//      sasFileReader = new SasFileReaderImpl(this.fsStream);
+//      firstRow = sasFileReader.readNext();
+//    } catch (IOException e) {
+//      throw UserException
+//        .dataReadError(e)
+//        .message("Unable to open Fixed Width File %s", this.split.getPath())
+//        .addContext(e.getMessage())
+//        .addContext(this.errorContext)
+//        .build(FixedWidthBatchReader.logger);
+//    }
+//  }
 
   private TupleMetadata buildSchema() {
     SchemaBuilder builder = new SchemaBuilder();