Package org.apache.beam.sdk.io

Interface FileBasedSink.WritableByteChannelFactory

All Superinterfaces:

FileBasedSink.OutputFileHints, java.io.Serializable

All Known Implementing Classes:

FileBasedSink.CompressionType

Enclosing class:

FileBasedSink<UserT,DestinationT,OutputT>

public static interface FileBasedSink.WritableByteChannelFactory
extends FileBasedSink.OutputFileHints

Implementations create instances of WritableByteChannel used by FileBasedSink and related classes to allow decorating, or otherwise transforming, the raw data that would normally be written directly to the WritableByteChannel passed into create(WritableByteChannel).

Subclasses should override Object.toString() with something meaningful, as it is used when building DisplayData.

Method Summary

Modifier and Type	Method	Description
java.nio.channels.WritableByteChannel	create(java.nio.channels.WritableByteChannel channel)

Methods inherited from interface org.apache.beam.sdk.io.FileBasedSink.OutputFileHints

getMimeType, getSuggestedFilenameSuffix

Method Detail

create

java.nio.channels.WritableByteChannel create(java.nio.channels.WritableByteChannel channel)
                                      throws java.io.IOException

Parameters:

channel - the WritableByteChannel to wrap

Returns:

the WritableByteChannel to be used during output

Throws:

java.io.IOException