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 and RegistryAvroSerializationSchema.

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)
void	writeSchema(org.apache.avro.Schema schema, OutputStream out)

Method Detail

readSchema

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

Throws:

IOException

writeSchema

void writeSchema(org.apache.avro.Schema schema,
                 OutputStream out)
          throws IOException

Throws:

IOException