public class KafkaJsonLoader extends JsonLoaderImpl
| Modifier and Type | Class and Description |
|---|---|
static class |
KafkaJsonLoader.KafkaJsonLoaderBuilder |
JsonLoaderImpl.JsonLoaderBuilderJSON_LITERAL_MODE, JSON_MODE, JSON_TEXT_MODE, JSON_TYPED_MODE| Modifier | Constructor and Description |
|---|---|
protected |
KafkaJsonLoader(KafkaJsonLoader.KafkaJsonLoaderBuilder builder) |
| Modifier and Type | Method and Description |
|---|---|
void |
endBatch()
Finish reading a batch of data.
|
addNullMarker, buildError, buildError, close, dataConversionError, fieldFactory, ioException, messageParseError, nullDisallowedError, options, parseError, parser, readBatch, removeNullMarker, structureError, syntaxError, syntaxError, typeConversionError, typeConversionError, typeError, unrecoverableError, unsupportedJsonTypeException, unsupportedTypeprotected KafkaJsonLoader(KafkaJsonLoader.KafkaJsonLoaderBuilder builder)
public void endBatch()
JsonLoaderImplThis choices is not perfect. Switching to text mode means results will vary from run to run depending on the order that we see empty and non-empty values for this column. Plus, since the system is distributed, the decision made here may conflict with that made in some other fragment.
The only real solution is for the user to provide a schema.
Bottom line: the user is responsible for not giving Drill ambiguous data that would require Drill to predict the future.
endBatch in class JsonLoaderImplCopyright © 2021 The Apache Software Foundation. All rights reserved.