Package org.apache.beam.sdk.extensions.avro.io

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:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	AvroSink.DatumWriterFactory<T>

Nested classes/interfaces inherited from class org.apache.beam.sdk.io.FileBasedSink

FileBasedSink.CompressionType, FileBasedSink.DynamicDestinations<UserT,DestinationT,OutputT>, FileBasedSink.FilenamePolicy, FileBasedSink.FileResult<DestinationT>, FileBasedSink.FileResultCoder<DestinationT>, FileBasedSink.OutputFileHints, FileBasedSink.WritableByteChannelFactory, FileBasedSink.WriteOperation<DestinationT,OutputT>, FileBasedSink.Writer<DestinationT,OutputT>

Method Summary

Modifier and Type	Method	Description
FileBasedSink.WriteOperation<DestinationT,OutputT>	createWriteOperation()	Return a subclass of FileBasedSink.WriteOperation that will manage the write to the sink.
DynamicAvroDestinations<UserT,DestinationT,OutputT>	getDynamicDestinations()	Return the FileBasedSink.DynamicDestinations used.

Methods inherited from class org.apache.beam.sdk.io.FileBasedSink

convertToFileResourceIfPossible, getTempDirectoryProvider, getWritableByteChannelFactory, populateDisplayData, validate

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

getDynamicDestinations

public DynamicAvroDestinations<UserT,DestinationT,OutputT> getDynamicDestinations()

Description copied from class: FileBasedSink

Return the FileBasedSink.DynamicDestinations used.

Overrides:

getDynamicDestinations in class FileBasedSink<UserT,DestinationT,OutputT>

createWriteOperation

public FileBasedSink.WriteOperation<DestinationT,OutputT> createWriteOperation()

Description copied from class: FileBasedSink

Return a subclass of FileBasedSink.WriteOperation that will manage the write to the sink.

Specified by:

createWriteOperation in class FileBasedSink<UserT,DestinationT,OutputT>