Package org.apache.beam.sdk.io
Class AvroSink<UserT,DestinationT,OutputT>
- java.lang.Object
-
- org.apache.beam.sdk.io.FileBasedSink<UserT,DestinationT,OutputT>
-
- org.apache.beam.sdk.io.AvroSink<UserT,DestinationT,OutputT>
-
- All Implemented Interfaces:
java.io.Serializable
,HasDisplayData
public class AvroSink<UserT,DestinationT,OutputT> extends FileBasedSink<UserT,DestinationT,OutputT>
AFileBasedSink
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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description FileBasedSink.WriteOperation<DestinationT,OutputT>
createWriteOperation()
Return a subclass ofFileBasedSink.WriteOperation
that will manage the write to the sink.DynamicAvroDestinations<UserT,DestinationT,OutputT>
getDynamicDestinations()
Return theFileBasedSink.DynamicDestinations
used.-
Methods inherited from class org.apache.beam.sdk.io.FileBasedSink
convertToFileResourceIfPossible, getTempDirectoryProvider, getWritableByteChannelFactory, populateDisplayData, validate
-
-
-
-
Method Detail
-
getDynamicDestinations
public DynamicAvroDestinations<UserT,DestinationT,OutputT> getDynamicDestinations()
Description copied from class:FileBasedSink
Return theFileBasedSink.DynamicDestinations
used.- Overrides:
getDynamicDestinations
in classFileBasedSink<UserT,DestinationT,OutputT>
-
createWriteOperation
public FileBasedSink.WriteOperation<DestinationT,OutputT> createWriteOperation()
Description copied from class:FileBasedSink
Return a subclass ofFileBasedSink.WriteOperation
that will manage the write to the sink.- Specified by:
createWriteOperation
in classFileBasedSink<UserT,DestinationT,OutputT>
-
-