public abstract class KafkaJsonTableSource extends KafkaTableSource
StreamTableSource
.
The version-specific Kafka consumers need to extend this class and
override KafkaTableSource.getKafkaConsumer(String, Properties, DeserializationSchema)
}.
The field names are used to parse the JSON file and so are the types.
Modifier and Type | Method and Description |
---|---|
void |
setFailOnMissingField(boolean failOnMissingField)
Configures the failure behaviour if a JSON field is missing.
|
explainSource, getDataStream, getDeserializationSchema, getReturnType
public void setFailOnMissingField(boolean failOnMissingField)
By default, a missing field is ignored and the field is set to null.
failOnMissingField
- Flag indicating whether to fail or not on a missing field.Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.