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

Class MapTaskExecutorFactory.PairInfo

java.lang.Object

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

All Implemented Interfaces:

PartialGroupByKeyOperation.PairInfo

Enclosing class:

MapTaskExecutorFactory

public static class MapTaskExecutorFactory.PairInfo
extends Object
implements PartialGroupByKeyOperation.PairInfo

Implements PGBKOp.PairInfo via KVs.

Method Summary

Modifier and Type	Method and Description
static MapTaskExecutorFactory.PairInfo	create()
Object	getKeyFromInputPair(Object pair)
Object	getValueFromInputPair(Object pair)
Object	makeOutputPair(Object key, Object values)

Methods inherited from class java.lang.Object

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

Method Detail

create

public static MapTaskExecutorFactory.PairInfo create()

getKeyFromInputPair

public Object getKeyFromInputPair(Object pair)

Specified by:

getKeyFromInputPair in interface PartialGroupByKeyOperation.PairInfo

getValueFromInputPair

public Object getValueFromInputPair(Object pair)

Specified by:

getValueFromInputPair in interface PartialGroupByKeyOperation.PairInfo

makeOutputPair

public Object makeOutputPair(Object key,
                             Object values)

Specified by:

makeOutputPair in interface PartialGroupByKeyOperation.PairInfo