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

Interface JsonLoader

All Known Implementing Classes:

JsonLoaderImpl, KafkaJsonLoader

public interface JsonLoader

Enhanced second-generation JSON loader which takes an input source and creates a series of record batches using the ResultSetLoader abstraction.

Field Summary

Fields

Modifier and Type	Field and Description
static String	JSON_LITERAL_MODE
static String	JSON_MODE Column property specific to the JSON loader.
static String	JSON_TEXT_MODE
static String	JSON_TYPED_MODE

Method Summary

Modifier and Type	Method and Description
void	close() Releases resources held by this class including the input stream.
boolean	readBatch() Read one record of data.

Field Detail

JSON_MODE

static final String JSON_MODE

Column property specific to the JSON loader. Mode for reading Varchar columns from JSON. One of:

JSON_TYPED_MODE: Read using normal typing rules (default). JSON_TEXT_MODE: Like the JSON format plugin's "all-text mode", but for a single column. That JSON field is read as text regardless of the actual value. Applies only to scalars. JSON_LITERAL_MODE: Causes the field, and all its children, to be read as literal JSON: the values are returned as a valid JSON string.

See Also:

Constant Field Values

JSON_TEXT_MODE

static final String JSON_TEXT_MODE

See Also:

Constant Field Values

JSON_TYPED_MODE

static final String JSON_TYPED_MODE

See Also:

Constant Field Values

JSON_LITERAL_MODE

static final String JSON_LITERAL_MODE

See Also:

Constant Field Values

Method Detail

readBatch

boolean readBatch()

Read one record of data.

Returns:

true if a record was loaded, false if EOF.

Throws:

{org.apache.drill.common.exceptions.UserException - for most errors

RuntimeException - for unexpected errors, most often due to code errors

close

void close()

Releases resources held by this class including the input stream. Does not close the result set loader passed into this instance.