org.apache.hadoop.hive.ql.plan

Class ConditionalResolverCommonJoin

java.lang.Object

org.apache.hadoop.hive.ql.plan.ConditionalResolverCommonJoin

All Implemented Interfaces:

Serializable, ConditionalResolver

public class ConditionalResolverCommonJoin
extends Object
implements ConditionalResolver, Serializable

ConditionalResolverSkewJoin.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ConditionalResolverCommonJoin.ConditionalResolverCommonJoinCtx ConditionalResolverSkewJoinCtx.

Constructor Summary

Constructors

Constructor and Description
ConditionalResolverCommonJoin()

Method Summary

Methods

Modifier and Type	Method and Description
List<Task<? extends Serializable>>	getTasks(HiveConf conf, Object objCtx) All conditional resolvers implement this interface.
protected Task<? extends Serializable>	resolveMapJoinTask(ConditionalResolverCommonJoin.ConditionalResolverCommonJoinCtx ctx, HiveConf conf)
protected void	resolveUnknownSizes(ConditionalResolverCommonJoin.ConditionalResolverCommonJoinCtx ctx, HiveConf conf)

Methods inherited from class java.lang.Object

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

Constructor Detail

ConditionalResolverCommonJoin

public ConditionalResolverCommonJoin()

Method Detail

getTasks

public List<Task<? extends Serializable>> getTasks(HiveConf conf,
                                          Object objCtx)

Description copied from interface: ConditionalResolver

All conditional resolvers implement this interface.

Specified by:

getTasks in interface ConditionalResolver

Parameters:

conf - configuration

objCtx - opaque context

Returns:

position of the task

resolveMapJoinTask

protected Task<? extends Serializable> resolveMapJoinTask(ConditionalResolverCommonJoin.ConditionalResolverCommonJoinCtx ctx,
                                              HiveConf conf)
                                                   throws Exception

Throws:

Exception

resolveUnknownSizes

protected void resolveUnknownSizes(ConditionalResolverCommonJoin.ConditionalResolverCommonJoinCtx ctx,
                       HiveConf conf)
                            throws Exception

Throws:

Exception