Class CoGroupRawOperatorBase<IN1,IN2,OUT,FT extends CoGroupFunction<IN1,IN2,OUT>>

• Method Detail

• setGroupOrder

public void setGroupOrder(int inputNum,
Ordering order)
Sets the order of the elements within a group for the given input.
Parameters:
inputNum - The number of the input (here either 0 or 1).
order - The order for the elements in a group.
• setGroupOrderForInputOne

public void setGroupOrderForInputOne(Ordering order)
Sets the order of the elements within a group for the first input.
Parameters:
order - The order for the elements in a group.
• setGroupOrderForInputTwo

public void setGroupOrderForInputTwo(Ordering order)
Sets the order of the elements within a group for the second input.
Parameters:
order - The order for the elements in a group.
• getGroupOrder

public Ordering getGroupOrder(int inputNum)
Gets the value order for an input, i.e. the order of elements within a group. If no such order has been set, this method returns null.
Parameters:
inputNum - The number of the input (here either 0 or 1).
Returns:
The group order.
• getGroupOrderForInputOne

public Ordering getGroupOrderForInputOne()
Gets the order of elements within a group for the first input. If no such order has been set, this method returns null.
Returns:
The group order for the first input.
• getGroupOrderForInputTwo

public Ordering getGroupOrderForInputTwo()
Gets the order of elements within a group for the second input. If no such order has been set, this method returns null.
Returns:
The group order for the second input.
• isCombinableFirst

public boolean isCombinableFirst()
• setCombinableFirst

public void setCombinableFirst(boolean combinableFirst)
• isCombinableSecond

public boolean isCombinableSecond()
• setCombinableSecond

public void setCombinableSecond(boolean combinableSecond)