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
A
FileBasedSink
for Avro files.- See Also:
-
Nested Class Summary
Nested ClassesNested 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 TypeMethodDescriptionReturn a subclass ofFileBasedSink.WriteOperation
that will manage the write to the sink.Return theFileBasedSink.DynamicDestinations
used.Methods inherited from class org.apache.beam.sdk.io.FileBasedSink
convertToFileResourceIfPossible, getTempDirectoryProvider, getWritableByteChannelFactory, populateDisplayData, validate
-
Method Details
-
getDynamicDestinations
Description copied from class:FileBasedSink
Return theFileBasedSink.DynamicDestinations
used.- Overrides:
getDynamicDestinations
in classFileBasedSink<UserT,
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>
-