Package org.apache.beam.sdk.io
Interface FileBasedSink.WritableByteChannelFactory
- All Superinterfaces:
FileBasedSink.OutputFileHints
,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
Methods inherited from interface org.apache.beam.sdk.io.FileBasedSink.OutputFileHints
getMimeType, getSuggestedFilenameSuffix
-
Method Details
-
create
- Parameters:
channel
- theWritableByteChannel
to wrap- Returns:
- the
WritableByteChannel
to be used during output - Throws:
IOException
-