org.apache.drill.exec.vector.complex.fn

Class JsonReader

java.lang.Object

org.apache.drill.exec.store.easy.json.reader.BaseJsonProcessor

org.apache.drill.exec.store.easy.json.reader.BaseJsonReader

org.apache.drill.exec.vector.complex.fn.JsonReader

All Implemented Interfaces:

JsonProcessor

public class JsonReader
extends BaseJsonReader

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	JsonReader.Builder

Nested classes/interfaces inherited from class org.apache.drill.exec.store.easy.json.reader.BaseJsonProcessor

BaseJsonProcessor.JsonExceptionProcessingState

Nested classes/interfaces inherited from interface org.apache.drill.exec.store.easy.json.JsonProcessor

JsonProcessor.ReadState

Field Summary

Fields

Modifier and Type	Field and Description
static int	MAX_RECORD_SIZE

Fields inherited from class org.apache.drill.exec.store.easy.json.reader.BaseJsonProcessor

currentFieldName, lastSeenJsonToken, parser, workBuf

Constructor Summary

Constructors

Constructor and Description
JsonReader(JsonReader.Builder builder)

Method Summary

Modifier and Type	Method and Description
void	ensureAtLeastOneField(org.apache.drill.exec.vector.complex.writer.BaseWriter.ComplexWriter writer)
DrillBuf	getWorkBuf()
void	setSource(byte[] bytes)
void	setSource(InputStream is)
void	setSource(int start, int end, DrillBuf buf)
void	setSource(com.fasterxml.jackson.databind.JsonNode node)
void	setSource(String data)
protected void	writeDocument(org.apache.drill.exec.vector.complex.writer.BaseWriter.ComplexWriter writer, com.fasterxml.jackson.core.JsonToken t) Writes the contents of the json node starting with the specified token into a complex vector.

Methods inherited from class org.apache.drill.exec.store.easy.json.reader.BaseJsonReader

createDocumentTopLevelException, write

Methods inherited from class org.apache.drill.exec.store.easy.json.reader.BaseJsonProcessor

getCurrentField, getDefaultMapper, getExceptionWithContext, getExceptionWithContext, ignoreJSONParseError, processJSONException, setIgnoreJSONParseErrors, toString

Methods inherited from class java.lang.Object

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

Field Detail

MAX_RECORD_SIZE

public static final int MAX_RECORD_SIZE

See Also:

Constant Field Values

Constructor Detail

JsonReader

public JsonReader(JsonReader.Builder builder)

Method Detail

ensureAtLeastOneField

public void ensureAtLeastOneField(org.apache.drill.exec.vector.complex.writer.BaseWriter.ComplexWriter writer)

setSource

public void setSource(int start,
                      int end,
                      DrillBuf buf)
               throws IOException

Throws:

IOException

setSource

public void setSource(InputStream is)
               throws IOException

Specified by:

setSource in interface JsonProcessor

Overrides:

setSource in class BaseJsonProcessor

Throws:

IOException

setSource

public void setSource(com.fasterxml.jackson.databind.JsonNode node)

Specified by:

setSource in interface JsonProcessor

Overrides:

setSource in class BaseJsonProcessor

setSource

public void setSource(String data)
               throws IOException

Throws:

IOException

setSource

public void setSource(byte[] bytes)
               throws IOException

Throws:

IOException

writeDocument

protected void writeDocument(org.apache.drill.exec.vector.complex.writer.BaseWriter.ComplexWriter writer,
                             com.fasterxml.jackson.core.JsonToken t)
                      throws IOException

Description copied from class: BaseJsonReader

Writes the contents of the json node starting with the specified token into a complex vector. Token can take the following values: - START_ARRAY - the top level of json document is an array and skipping of the outer list is disabled - START_OBJECT - the top level of json document is a set of white space delimited maps or skipping of the outer list is enabled

Specified by:

writeDocument in class BaseJsonReader

Throws:

IOException

getWorkBuf

public DrillBuf getWorkBuf()