org.apache.spark.sql.execution

Class SparkStrategies.HashAggregation

Object

org.apache.spark.sql.catalyst.planning.GenericStrategy<SparkPlan>

org.apache.spark.sql.execution.SparkStrategies.HashAggregation

All Implemented Interfaces:

Logging

Enclosing class:

SparkStrategies

public class SparkStrategies.HashAggregation
extends org.apache.spark.sql.catalyst.planning.GenericStrategy<SparkPlan>

Constructor Summary

Constructors

Constructor and Description
SparkStrategies.HashAggregation()

Method Summary

Methods

Modifier and Type	Method and Description
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.AggregateExpression>	allAggregates(scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> exprs)
scala.collection.Seq<SparkPlan>	apply(org.apache.spark.sql.catalyst.plans.logical.LogicalPlan plan)
boolean	canBeCodeGened(scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.AggregateExpression> aggs)

Methods inherited from class org.apache.spark.sql.catalyst.planning.GenericStrategy

isTraceEnabled, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning, org$apache$spark$Logging$$log__$eq, org$apache$spark$Logging$$log_

Methods inherited from class Object

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

Methods inherited from interface org.apache.spark.Logging

initializeIfNecessary, initializeLogging, log_

Constructor Detail

SparkStrategies.HashAggregation

public SparkStrategies.HashAggregation()

Method Detail

apply

public scala.collection.Seq<SparkPlan> apply(org.apache.spark.sql.catalyst.plans.logical.LogicalPlan plan)

Specified by:

apply in class org.apache.spark.sql.catalyst.planning.GenericStrategy<SparkPlan>

canBeCodeGened

public boolean canBeCodeGened(scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.AggregateExpression> aggs)

allAggregates

public scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.AggregateExpression> allAggregates(scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> exprs)