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 from FileBasedSink.DynamicDestinations.

Constructor Summary

Constructors

Constructor and Description
DynamicFileDestinations()

Method Summary

Modifier and Type	Method and Description
static <UserT> FileBasedSink.DynamicDestinations<UserT,java.lang.Void,UserT>	constant(FileBasedSink.FilenamePolicy filenamePolicy) A specialization of #constant(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 a FileBasedSink.DynamicDestinations that always returns the same FileBasedSink.FilenamePolicy.
static <UserT,OutputT> FileBasedSink.DynamicDestinations<UserT,DefaultFilenamePolicy.Params,OutputT>	toDefaultPolicies(SerializableFunction<UserT,DefaultFilenamePolicy.Params> destinationFunction, DefaultFilenamePolicy.Params emptyDestination, SerializableFunction<UserT,OutputT> formatFunction) Returns a FileBasedSink.DynamicDestinations that returns instances of DefaultFilenamePolicy configured with the given DefaultFilenamePolicy.Params.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DynamicFileDestinations

public DynamicFileDestinations()

Method Detail

constant

public static <UserT,OutputT> FileBasedSink.DynamicDestinations<UserT,java.lang.Void,OutputT> constant(FileBasedSink.FilenamePolicy filenamePolicy,
                                                                                                       SerializableFunction<UserT,OutputT> formatFunction)

Returns a FileBasedSink.DynamicDestinations that always returns the same FileBasedSink.FilenamePolicy.

constant

public static <UserT> FileBasedSink.DynamicDestinations<UserT,java.lang.Void,UserT> constant(FileBasedSink.FilenamePolicy filenamePolicy)

A specialization of #constant(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 a FileBasedSink.DynamicDestinations that returns instances of DefaultFilenamePolicy configured with the given DefaultFilenamePolicy.Params.