com.google.cloud.dataflow.sdk.runners.worker

Class MapTaskExecutorFactory.WindowingCoderGroupingKeyCreator<K>

java.lang.Object

com.google.cloud.dataflow.sdk.runners.worker.MapTaskExecutorFactory.WindowingCoderGroupingKeyCreator<K>

All Implemented Interfaces:

PartialGroupByKeyOperation.GroupingKeyCreator<WindowedValue<K>>

Enclosing class:

MapTaskExecutorFactory

public static class MapTaskExecutorFactory.WindowingCoderGroupingKeyCreator<K>
extends Object
implements PartialGroupByKeyOperation.GroupingKeyCreator<WindowedValue<K>>

Implements PGBKOp.GroupingKeyCreator via Coder.

Constructor Summary

Constructors

Constructor and Description
WindowingCoderGroupingKeyCreator(Coder<K> coder)

Method Summary

Modifier and Type	Method and Description
Object	createGroupingKey(WindowedValue<K> key)

Methods inherited from class java.lang.Object

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

Constructor Detail

WindowingCoderGroupingKeyCreator

public WindowingCoderGroupingKeyCreator(Coder<K> coder)

Method Detail

createGroupingKey

public Object createGroupingKey(WindowedValue<K> key)
                         throws Exception

Specified by:

createGroupingKey in interface PartialGroupByKeyOperation.GroupingKeyCreator<WindowedValue<K>>

Throws:

Exception