Package org.apache.drill.exec.store.easy.json.loader

Class JsonLoaderImpl.JsonLoaderBuilder

java.lang.Object

org.apache.drill.exec.store.easy.json.loader.JsonLoaderImpl.JsonLoaderBuilder

Direct Known Subclasses:

KafkaJsonLoader.KafkaJsonLoaderBuilder

Enclosing class:

JsonLoaderImpl

public static class JsonLoaderImpl.JsonLoaderBuilder
extends Object

Constructor Summary

Constructors

Constructor	Description
JsonLoaderBuilder()

Method Summary

Modifier and Type	Method	Description
JsonLoader	build()
JsonLoaderImpl.JsonLoaderBuilder	dataPath(String dataPath)
JsonLoaderImpl.JsonLoaderBuilder	errorContext(CustomErrorContext errorContext)
JsonLoaderImpl.JsonLoaderBuilder	fromReader(Reader reader)
JsonLoaderImpl.JsonLoaderBuilder	fromStream(int start, int end, DrillBuf buf)
JsonLoaderImpl.JsonLoaderBuilder	fromStream(InputStream... stream)
JsonLoaderImpl.JsonLoaderBuilder	fromStream(Iterable<InputStream> streams)
JsonLoaderImpl.JsonLoaderBuilder	fromString(String jsonString)
JsonLoaderImpl.JsonLoaderBuilder	implicitFields(ImplicitColumnUtils.ImplicitColumns metadata)
JsonLoaderImpl.JsonLoaderBuilder	listenerColumnMap(Map<String,Object> listenerColumnMap)
JsonLoaderImpl.JsonLoaderBuilder	maxRows(int maxRows)
JsonLoaderImpl.JsonLoaderBuilder	messageParser(MessageParser messageParser)
JsonLoaderImpl.JsonLoaderBuilder	options(JsonLoaderOptions options)
JsonLoaderImpl.JsonLoaderBuilder	providedSchema(TupleMetadata providedSchema)
JsonLoaderImpl.JsonLoaderBuilder	resultSetLoader(ResultSetLoader rsLoader)
JsonLoaderImpl.JsonLoaderBuilder	standardOptions(OptionSet optionSet)

Methods inherited from class java.lang.Object

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

Constructor Details

JsonLoaderBuilder

public JsonLoaderBuilder()

Method Details

resultSetLoader

public JsonLoaderImpl.JsonLoaderBuilder resultSetLoader(ResultSetLoader rsLoader)

providedSchema

public JsonLoaderImpl.JsonLoaderBuilder providedSchema(TupleMetadata providedSchema)

listenerColumnMap

public JsonLoaderImpl.JsonLoaderBuilder listenerColumnMap(Map<String,Object> listenerColumnMap)

standardOptions

public JsonLoaderImpl.JsonLoaderBuilder standardOptions(OptionSet optionSet)

options

public JsonLoaderImpl.JsonLoaderBuilder options(JsonLoaderOptions options)

implicitFields

public JsonLoaderImpl.JsonLoaderBuilder implicitFields(ImplicitColumnUtils.ImplicitColumns metadata)

errorContext

public JsonLoaderImpl.JsonLoaderBuilder errorContext(CustomErrorContext errorContext)

fromStream

public JsonLoaderImpl.JsonLoaderBuilder fromStream(InputStream... stream)

fromStream

public JsonLoaderImpl.JsonLoaderBuilder fromStream(Iterable<InputStream> streams)

fromStream

public JsonLoaderImpl.JsonLoaderBuilder fromStream(int start,
 int end,
 DrillBuf buf)

fromString

public JsonLoaderImpl.JsonLoaderBuilder fromString(String jsonString)

fromReader

public JsonLoaderImpl.JsonLoaderBuilder fromReader(Reader reader)

messageParser

public JsonLoaderImpl.JsonLoaderBuilder messageParser(MessageParser messageParser)

dataPath

public JsonLoaderImpl.JsonLoaderBuilder dataPath(String dataPath)

maxRows

public JsonLoaderImpl.JsonLoaderBuilder maxRows(int maxRows)

build

public JsonLoader build()