cascading.flow.hadoop.planner.rule.expression

Class BalanceGroupNonBlockingHashJoinExpression

java.lang.Object

cascading.flow.planner.rule.RuleExpression

cascading.flow.hadoop.planner.rule.expression.BalanceGroupNonBlockingHashJoinExpression

public class BalanceGroupNonBlockingHashJoinExpression
extends RuleExpression

This rule is a compliment to GroupNonBlockingHashJoinTransformRule and is intended to prevent a HashJoin from landing in a Reducer until reduce side HashJoins are supported.

Field Summary

Fields inherited from class cascading.flow.planner.rule.RuleExpression

contractedMatchExpression, contractionExpression, matchExpression

Constructor Summary

Constructors

Constructor and Description
BalanceGroupNonBlockingHashJoinExpression()

Method Summary

Methods inherited from class cascading.flow.planner.rule.RuleExpression

getContractedMatchExpression, getContractionExpression, getExpressionName, getMatchExpression

Methods inherited from class java.lang.Object

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

Constructor Detail

BalanceGroupNonBlockingHashJoinExpression

public BalanceGroupNonBlockingHashJoinExpression()