com.asakusafw.runtime.flow

Class Rendezvous<V extends org.apache.hadoop.io.Writable>

java.lang.Object

com.asakusafw.runtime.flow.Rendezvous<V>

Type Parameters:

V - the data type

public abstract class Rendezvous<V extends org.apache.hadoop.io.Writable>
extends Object

An abstract super interface for processing co-group like operations.

Field Summary

Fields

Modifier and Type	Field and Description
static String	BEGIN The method name of begin().
static String	END The method name of end().
static String	PROCESS The method name of process(Writable).

Constructor Summary

Constructors

Constructor and Description
Rendezvous()

Method Summary

Modifier and Type	Method and Description
abstract void	begin() Begins processing an input group.
abstract void	end() Ends processing the current input group.
abstract void	process(V value) Processes an input data.

Methods inherited from class java.lang.Object

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

Field Detail

BEGIN

public static final String BEGIN

The method name of begin().

See Also:

Constant Field Values

PROCESS

public static final String PROCESS

The method name of process(Writable).

See Also:

Constant Field Values

END

public static final String END

The method name of end().

See Also:

Constant Field Values

Constructor Detail

Rendezvous

public Rendezvous()

Method Detail

begin

public abstract void begin()

Begins processing an input group.

process

public abstract void process(V value)

Processes an input data. This must be invoked between begin() and end(), and the input data must be a member of the current group.

Parameters:

value - the input data

end

public abstract void end()

Ends processing the current input group.