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

Class TokenIterator

java.lang.Object

org.apache.drill.exec.store.easy.json.parser.TokenIterator

public class TokenIterator
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TokenIterator.ParserManager
static class	TokenIterator.RecoverableJsonException Internal exception to unwind the stack when a syntax error is detected within a record.

Field Summary

Fields

Modifier and Type	Field and Description
static int	MAX_LOOKAHEAD

Constructor Summary

Constructors

Constructor and Description
TokenIterator(Iterable<InputStream> streams, Function<InputStream,com.fasterxml.jackson.core.JsonParser> parserFunction, JsonStructureOptions options, ErrorFactory errorFactory)

Method Summary

Modifier and Type	Method and Description
byte[]	binaryValue()
void	close()
int	columnNumber()
String	context()
double	doubleValue()
ErrorFactory	errorFactory()
com.fasterxml.jackson.core.JsonParser	getParser()
RuntimeException	invalidValue(com.fasterxml.jackson.core.JsonToken token)
int	lineNumber()
long	longValue()
com.fasterxml.jackson.core.JsonToken	next()
com.fasterxml.jackson.core.JsonToken	peek()
com.fasterxml.jackson.core.JsonToken	requireNext()
String	stringValue()
String	textValue()
String	token()
void	unget(com.fasterxml.jackson.core.JsonToken token)

Methods inherited from class java.lang.Object

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

Field Detail

MAX_LOOKAHEAD

public static final int MAX_LOOKAHEAD

See Also:

Constant Field Values

Constructor Detail

TokenIterator

public TokenIterator(Iterable<InputStream> streams,
                     Function<InputStream,com.fasterxml.jackson.core.JsonParser> parserFunction,
                     JsonStructureOptions options,
                     ErrorFactory errorFactory)

Method Detail

getParser

public com.fasterxml.jackson.core.JsonParser getParser()

errorFactory

public ErrorFactory errorFactory()

next

public com.fasterxml.jackson.core.JsonToken next()

context

public String context()

lineNumber

public int lineNumber()

columnNumber

public int columnNumber()

token

public String token()

requireNext

public com.fasterxml.jackson.core.JsonToken requireNext()

peek

public com.fasterxml.jackson.core.JsonToken peek()

unget

public void unget(com.fasterxml.jackson.core.JsonToken token)

textValue

public String textValue()

longValue

public long longValue()

stringValue

public String stringValue()

doubleValue

public double doubleValue()

binaryValue

public byte[] binaryValue()

invalidValue

public RuntimeException invalidValue(com.fasterxml.jackson.core.JsonToken token)

close

public void close()
           throws IOException

Throws:

IOException