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

Deprecated.

Avro related classes are deprecated in module beam-sdks-java-core and will be eventually removed. Please, migrate to a new module beam-sdks-java-extensions-avro by importing org.apache.beam.sdk.extensions.avro.io.AvroSink instead of this one.

@Deprecated
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 and Description
static interface	AvroSink.DatumWriterFactory<T> Deprecated.

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 and Description
FileBasedSink.WriteOperation<DestinationT,OutputT>	createWriteOperation() Deprecated. Return a subclass of FileBasedSink.WriteOperation that will manage the write to the sink.
DynamicAvroDestinations<UserT,DestinationT,OutputT>	getDynamicDestinations() Deprecated. 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 Detail

getDynamicDestinations

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

Deprecated.

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()

Deprecated.

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>