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–2021 The Apache Software Foundation. All rights reserved.