Package org.apache.beam.sdk.io

Interface ShardingFunction<UserT,DestinationT>

All Superinterfaces:

Serializable

public interface ShardingFunction<UserT,DestinationT>
extends Serializable

Function for assigning ShardedKeys to input elements for sharded WriteFiles.

Method Summary

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

Method Details

assignShardKey

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

Throws:

Exception