public class SparkStrategies.HashAggregation extends org.apache.spark.sql.catalyst.planning.GenericStrategy<SparkPlan>
Constructor and Description |
---|
SparkStrategies.HashAggregation() |
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) |
isTraceEnabled, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning, org$apache$spark$Logging$$log__$eq, org$apache$spark$Logging$$log_
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
initializeIfNecessary, initializeLogging, log_
public scala.collection.Seq<SparkPlan> apply(org.apache.spark.sql.catalyst.plans.logical.LogicalPlan plan)
apply
in class org.apache.spark.sql.catalyst.planning.GenericStrategy<SparkPlan>
public boolean canBeCodeGened(scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.AggregateExpression> aggs)
public scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.AggregateExpression> allAggregates(scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> exprs)