public class JsonReader extends Object implements RecordReader
Constructor and Description |
---|
JsonReader(Iterator<com.google.gson.JsonElement> parser,
FSDataInputStream underlying,
long size,
TypeDescription schema) |
JsonReader(Reader reader,
FSDataInputStream underlying,
long size,
TypeDescription schema) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
float |
getProgress() |
long |
getRowNumber() |
boolean |
nextBatch(VectorizedRowBatch batch) |
void |
seekToRow(long rowCount) |
public JsonReader(Reader reader, FSDataInputStream underlying, long size, TypeDescription schema) throws IOException
IOException
public JsonReader(Iterator<com.google.gson.JsonElement> parser, FSDataInputStream underlying, long size, TypeDescription schema) throws IOException
IOException
public boolean nextBatch(VectorizedRowBatch batch) throws IOException
nextBatch
in interface RecordReader
IOException
public long getRowNumber() throws IOException
getRowNumber
in interface RecordReader
IOException
public float getProgress() throws IOException
getProgress
in interface RecordReader
IOException
public void close() throws IOException
close
in interface AutoCloseable
close
in interface RecordReader
IOException
public void seekToRow(long rowCount) throws IOException
seekToRow
in interface RecordReader
IOException
Copyright © 2013–2018 The Apache Software Foundation. All rights reserved.