org.apache.flink.formats.avro

Interface SchemaCoder.SchemaCoderProvider

All Superinterfaces:

Serializable

Enclosing interface:

SchemaCoder

public static interface SchemaCoder.SchemaCoderProvider
extends Serializable

Provider for SchemaCoder. It allows creating multiple instances of client in parallel operators without serializing it.

Method Summary

Modifier and Type	Method and Description
SchemaCoder	get() Creates a new instance of SchemaCoder.

Method Detail

get

SchemaCoder get()

Creates a new instance of SchemaCoder. Each time it should create a new instance, as it will be called on multiple nodes.

Returns:

new instance SchemaCoder