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(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(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(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(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()