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

Class BaseJsonProcessor

java.lang.Object

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

All Implemented Interfaces:

JsonProcessor

Direct Known Subclasses:

BaseJsonReader

public abstract class BaseJsonProcessor
extends Object
implements JsonProcessor

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	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
protected String	currentFieldName The name of the current field being parsed.
protected com.fasterxml.jackson.core.JsonToken	lastSeenJsonToken
protected com.fasterxml.jackson.core.JsonParser	parser
protected DrillBuf	workBuf

Constructor Summary

Constructors

Constructor and Description
BaseJsonProcessor(DrillBuf workBuf, boolean enableNanInf, boolean enableEscapeAnyChar)

Method Summary

Modifier and Type	Method and Description
protected String	getCurrentField()
static com.fasterxml.jackson.databind.ObjectMapper	getDefaultMapper()
UserException.Builder	getExceptionWithContext(Throwable e, String message)
UserException.Builder	getExceptionWithContext(UserException.Builder builder, String message)
boolean	ignoreJSONParseError()
protected BaseJsonProcessor.JsonExceptionProcessingState	processJSONException()
void	setIgnoreJSONParseErrors(boolean ignoreJSONParseErrors)
void	setSource(InputStream is)
void	setSource(com.fasterxml.jackson.databind.JsonNode node)
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.drill.exec.store.easy.json.JsonProcessor

ensureAtLeastOneField, write

Field Detail

parser

protected com.fasterxml.jackson.core.JsonParser parser

workBuf

protected DrillBuf workBuf

lastSeenJsonToken

protected com.fasterxml.jackson.core.JsonToken lastSeenJsonToken

currentFieldName

protected String currentFieldName

The name of the current field being parsed. For Error messages.

Constructor Detail

BaseJsonProcessor

public BaseJsonProcessor(DrillBuf workBuf,
                         boolean enableNanInf,
                         boolean enableEscapeAnyChar)

Method Detail

getDefaultMapper

public static com.fasterxml.jackson.databind.ObjectMapper getDefaultMapper()

Returns:

Default json mapper

ignoreJSONParseError

public boolean ignoreJSONParseError()

Specified by:

ignoreJSONParseError in interface JsonProcessor

setIgnoreJSONParseErrors

public void setIgnoreJSONParseErrors(boolean ignoreJSONParseErrors)

Specified by:

setIgnoreJSONParseErrors in interface JsonProcessor

setSource

public void setSource(InputStream is)
               throws IOException

Specified by:

setSource in interface JsonProcessor

Throws:

IOException

setSource

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

Specified by:

setSource in interface JsonProcessor

toString

public String toString()

Overrides:

toString in class Object

getExceptionWithContext

public UserException.Builder getExceptionWithContext(UserException.Builder builder,
                                                     String message)

Specified by:

getExceptionWithContext in interface JsonProcessor

getExceptionWithContext

public UserException.Builder getExceptionWithContext(Throwable e,
                                                     String message)

Specified by:

getExceptionWithContext in interface JsonProcessor

processJSONException

protected BaseJsonProcessor.JsonExceptionProcessingState processJSONException()
                                                                       throws IOException

Throws:

IOException

getCurrentField

protected String getCurrentField()