org.apache.hadoop.hive.ql.exec.spark

Class SparkDynamicPartitionPruner

java.lang.Object

org.apache.hadoop.hive.ql.exec.spark.SparkDynamicPartitionPruner

public class SparkDynamicPartitionPruner
extends Object

The spark version of DynamicPartitionPruner.

Constructor Summary

Constructors

Constructor and Description
SparkDynamicPartitionPruner()

Method Summary

Modifier and Type	Method and Description
void	initialize(MapWork work, org.apache.hadoop.mapred.JobConf jobConf)
void	prune(MapWork work, org.apache.hadoop.mapred.JobConf jobConf)

Methods inherited from class java.lang.Object

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

Constructor Detail

SparkDynamicPartitionPruner

public SparkDynamicPartitionPruner()

Method Detail

prune

public void prune(MapWork work,
                  org.apache.hadoop.mapred.JobConf jobConf)
           throws HiveException,
                  SerDeException

Throws:

HiveException

SerDeException

initialize

public void initialize(MapWork work,
                       org.apache.hadoop.mapred.JobConf jobConf)
                throws SerDeException

Throws:

SerDeException