org.apache.flink.formats.avro

Interface SchemaCoder

public interface SchemaCoder

Schema coder that allows reading schema that is somehow embedded into serialized record. Used by RegistryAvroDeserializationSchema.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	SchemaCoder.SchemaCoderProvider Provider for SchemaCoder.

Method Summary

Modifier and Type	Method and Description
org.apache.avro.Schema	readSchema(InputStream in)

Method Detail

readSchema

org.apache.avro.Schema readSchema(InputStream in)
                           throws IOException

Throws:

IOException