Class AvroSink<UserT,DestinationT,OutputT>

java.lang.Object
org.apache.beam.sdk.io.FileBasedSink<UserT,DestinationT,OutputT>
org.apache.beam.sdk.extensions.avro.io.AvroSink<UserT,DestinationT,OutputT>
All Implemented Interfaces:
Serializable, HasDisplayData

public class AvroSink<UserT,DestinationT,OutputT> extends FileBasedSink<UserT,DestinationT,OutputT>
A FileBasedSink for Avro files.
See Also: