org.apache.beam.sdk.io

Interface ShardingFunction<UserT,DestinationT>

All Superinterfaces:

java.io.Serializable

@Experimental(value=SOURCE_SINK)
public interface ShardingFunction<UserT,DestinationT>
extends java.io.Serializable

Function for assigning ShardedKeys to input elements for sharded WriteFiles.

Method Summary

Modifier and Type	Method and Description
ShardedKey<java.lang.Integer>	assignShardKey(DestinationT destination, UserT element, int shardCount)

Method Detail

assignShardKey

ShardedKey<java.lang.Integer> assignShardKey(DestinationT destination,
                                             UserT element,
                                             int shardCount)
                                      throws java.lang.Exception

Throws:

java.lang.Exception