MAPR-22405: DocumentStream interface in OJAI API need not be parametr…

…ized
apache · Sep 9, 2016 · 48d195c · 48d195c
1 parent 869cfbd
commit 48d195c
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/...-maprdb/src/main/java/org/apache/drill/exec/store/maprdb/json/MaprDBJsonRecordReader.java b/...-maprdb/src/main/java/org/apache/drill/exec/store/maprdb/json/MaprDBJsonRecordReader.java
@@ -43,7 +43,6 @@
 import org.apache.drill.exec.vector.complex.writer.BaseWriter.MapWriter;
 import org.apache.drill.exec.vector.complex.writer.VarBinaryWriter;
 import org.apache.drill.exec.vector.complex.writer.VarCharWriter;
-import org.ojai.Document;
 import org.ojai.DocumentReader;
 import org.ojai.DocumentReader.EventType;
 import org.ojai.DocumentStream;
@@ -80,7 +79,7 @@ public class MaprDBJsonRecordReader extends AbstractRecordReader {
 
   private DrillBuf buffer;
 
-  private DocumentStream<Document> documentStream;
+  private DocumentStream documentStream;
 
   private Iterator<DocumentReader> documentReaderIterators;
 

diff --git a/contrib/format-maprdb/src/test/java/com/mapr/drill/maprdb/tests/MaprDBTestsSuite.java b/contrib/format-maprdb/src/test/java/com/mapr/drill/maprdb/tests/MaprDBTestsSuite.java
@@ -147,7 +147,7 @@ public static void createJsonTables() throws IOException {
 
     try (Table table = admin.createTable(TMP_BUSINESS_TABLE);
          InputStream in = getJsonStream("json/business.json");
-         DocumentStream<Document> stream = Json.newDocumentStream(in)) {
+         DocumentStream stream = Json.newDocumentStream(in)) {
       for (Document document : stream) {
         table.insert(document, "business_id");
       }