| Package | Description |
|---|---|
| org.apache.flink.table.descriptors |
| Modifier and Type | Method and Description |
|---|---|
Avro |
Avro.avroSchema(String avroSchema)
Sets the Avro schema for specific or generic Avro records.
|
Avro |
Avro.recordClass(Class<? extends org.apache.avro.specific.SpecificRecord> recordClass)
Sets the class of the Avro specific record.
|
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.