com.google.cloud.dataflow.sdk.util.common.worker

Interface PartialGroupByKeyOperation.GroupingKeyCreator<K>

All Known Implementing Classes:

MapTaskExecutorFactory.WindowingCoderGroupingKeyCreator

Enclosing class:

PartialGroupByKeyOperation

public static interface PartialGroupByKeyOperation.GroupingKeyCreator<K>

Provides client-specific operations for grouping keys.

Method Summary

Modifier and Type	Method and Description
Object	createGroupingKey(K key)

Method Detail

createGroupingKey

Object createGroupingKey(K key)
                  throws Exception

Throws:

Exception