Package org.apache.beam.sdk.io
Interface ShardingFunction<UserT,DestinationT>
-
- All Superinterfaces:
java.io.Serializable
@Experimental(SOURCE_SINK) public interface ShardingFunction<UserT,DestinationT> extends java.io.Serializable
Function for assigningShardedKey
s to input elements for shardedWriteFiles
.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method 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
-
-