Package org.apache.beam.sdk.io
Class DynamicFileDestinations
- java.lang.Object
-
- org.apache.beam.sdk.io.DynamicFileDestinations
-
public class DynamicFileDestinations extends java.lang.Object
Some helper classes that derive fromFileBasedSink.DynamicDestinations
.
-
-
Constructor Summary
Constructors Constructor Description DynamicFileDestinations()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static <UserT> FileBasedSink.DynamicDestinations<UserT,java.lang.Void,UserT>
constant(FileBasedSink.FilenamePolicy filenamePolicy)
A specialization ofconstant(FilenamePolicy, SerializableFunction)
for the case where UserT and OutputT are the same type and the format function is the identity.static <UserT,OutputT>
FileBasedSink.DynamicDestinations<UserT,java.lang.Void,OutputT>constant(FileBasedSink.FilenamePolicy filenamePolicy, SerializableFunction<UserT,OutputT> formatFunction)
Returns aFileBasedSink.DynamicDestinations
that always returns the sameFileBasedSink.FilenamePolicy
.static <UserT,OutputT>
FileBasedSink.DynamicDestinations<UserT,DefaultFilenamePolicy.Params,OutputT>toDefaultPolicies(SerializableFunction<UserT,DefaultFilenamePolicy.Params> destinationFunction, DefaultFilenamePolicy.Params emptyDestination, SerializableFunction<UserT,OutputT> formatFunction)
Returns aFileBasedSink.DynamicDestinations
that returns instances ofDefaultFilenamePolicy
configured with the givenDefaultFilenamePolicy.Params
.
-
-
-
Method Detail
-
constant
public static <UserT,OutputT> FileBasedSink.DynamicDestinations<UserT,java.lang.Void,OutputT> constant(FileBasedSink.FilenamePolicy filenamePolicy, SerializableFunction<UserT,OutputT> formatFunction)
Returns aFileBasedSink.DynamicDestinations
that always returns the sameFileBasedSink.FilenamePolicy
.
-
constant
public static <UserT> FileBasedSink.DynamicDestinations<UserT,java.lang.Void,UserT> constant(FileBasedSink.FilenamePolicy filenamePolicy)
A specialization ofconstant(FilenamePolicy, SerializableFunction)
for the case where UserT and OutputT are the same type and the format function is the identity.
-
toDefaultPolicies
public static <UserT,OutputT> FileBasedSink.DynamicDestinations<UserT,DefaultFilenamePolicy.Params,OutputT> toDefaultPolicies(SerializableFunction<UserT,DefaultFilenamePolicy.Params> destinationFunction, DefaultFilenamePolicy.Params emptyDestination, SerializableFunction<UserT,OutputT> formatFunction)
Returns aFileBasedSink.DynamicDestinations
that returns instances ofDefaultFilenamePolicy
configured with the givenDefaultFilenamePolicy.Params
.
-
-