org.kepler.stratosphere.stub

Class SumValuesCoGroup

java.lang.Object

eu.stratosphere.api.common.functions.AbstractFunction

eu.stratosphere.api.java.record.functions.CoGroupFunction

org.kepler.stratosphere.stub.SumValuesCoGroup

All Implemented Interfaces:

eu.stratosphere.api.common.functions.Function, eu.stratosphere.api.common.functions.GenericCoGrouper<eu.stratosphere.types.Record,eu.stratosphere.types.Record,eu.stratosphere.types.Record>

public class SumValuesCoGroup
extends eu.stratosphere.api.java.record.functions.CoGroupFunction

A CoGroupStub that sums the values in both inputs. This class is used for word count using cogroup.

Author:

Daniel Crawl

Constructor Summary

Constructors

Constructor and Description
SumValuesCoGroup()

Method Summary

Modifier and Type	Method and Description
void	coGroup(java.util.Iterator<eu.stratosphere.types.Record> records1, java.util.Iterator<eu.stratosphere.types.Record> records2, eu.stratosphere.util.Collector<eu.stratosphere.types.Record> out)

Methods inherited from class eu.stratosphere.api.java.record.functions.CoGroupFunction

combineFirst, combineSecond

Methods inherited from class eu.stratosphere.api.common.functions.AbstractFunction

close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext

Methods inherited from class java.lang.Object

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

Methods inherited from interface eu.stratosphere.api.common.functions.Function

close, getRuntimeContext, open, setRuntimeContext

Constructor Detail

SumValuesCoGroup

public SumValuesCoGroup()

Method Detail

coGroup

public void coGroup(java.util.Iterator<eu.stratosphere.types.Record> records1,
                    java.util.Iterator<eu.stratosphere.types.Record> records2,
                    eu.stratosphere.util.Collector<eu.stratosphere.types.Record> out)
             throws java.lang.Exception

Specified by:

coGroup in interface eu.stratosphere.api.common.functions.GenericCoGrouper<eu.stratosphere.types.Record,eu.stratosphere.types.Record,eu.stratosphere.types.Record>

Specified by:

coGroup in class eu.stratosphere.api.java.record.functions.CoGroupFunction

Throws:

java.lang.Exception