Package org.apache.orc.tools.convert

Class JsonReader

java.lang.Object

org.apache.orc.tools.convert.JsonReader

All Implemented Interfaces:

Closeable, AutoCloseable, RecordReader

public class JsonReader
extends Object
implements RecordReader

Constructor Summary

Constructors

Constructor	Description
JsonReader(Reader reader, FSDataInputStream underlying, long size, TypeDescription schema, String timestampFormat)
JsonReader(Reader reader, FSDataInputStream underlying, long size, TypeDescription schema, String timestampFormat, String unionTag, String unionValue)
JsonReader(Iterator<com.google.gson.JsonElement> parser, FSDataInputStream underlying, long size, TypeDescription schema, String timestampFormat)

Method Summary

Modifier and Type	Method	Description
void	close()
float	getProgress()
long	getRowNumber()
boolean	nextBatch(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch)
void	seekToRow(long rowCount)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

JsonReader

public JsonReader(Reader reader,
 FSDataInputStream underlying,
 long size,
 TypeDescription schema,
 String timestampFormat,
 String unionTag,
 String unionValue)
           throws IOException

Throws:

IOException

JsonReader

public JsonReader(Reader reader,
 FSDataInputStream underlying,
 long size,
 TypeDescription schema,
 String timestampFormat)
           throws IOException

Throws:

IOException

JsonReader

public JsonReader(Iterator<com.google.gson.JsonElement> parser,
 FSDataInputStream underlying,
 long size,
 TypeDescription schema,
 String timestampFormat)
           throws IOException

Throws:

IOException

Method Details

nextBatch

public boolean nextBatch(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch)
                  throws IOException

Specified by:

nextBatch in interface RecordReader

Throws:

IOException

getRowNumber

public long getRowNumber()
                  throws IOException

Specified by:

getRowNumber in interface RecordReader

Throws:

IOException

getProgress

public float getProgress()
                  throws IOException

Specified by:

getProgress in interface RecordReader

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface RecordReader

Throws:

IOException

seekToRow

public void seekToRow(long rowCount)
               throws IOException

Specified by:

seekToRow in interface RecordReader

Throws:

IOException