public class SparkGroupCmd extends SparkCommand
AbstractSyntaxTree.LogCounter
Constructor and Description |
---|
SparkGroupCmd(TemplateUtils templateUtils,
MapPhysicalNode physicalNode) |
Modifier and Type | Method and Description |
---|---|
java.util.List |
getAllAggFunctions()
Gets names of all the aggregate functions.
|
java.util.List |
getAllAggrAliases()
Gets the list of aliases for aggregation expressions.
|
java.util.List |
getAllAggrExprs()
Gets the list of aggregation expressions.
|
java.util.List |
getComplexAggrAliases()
Gets the list of names for complex aggregation expressions.
|
java.util.List |
getComplexAggrExprs()
Gets the list of complex aggregation expressions.
|
java.util.List |
getDirectMapAliases()
Gets the list of names for directly mapped attributes.
|
java.util.List |
getDirectMapExprs()
Gets the list of expressions on directly mapped attributes.
|
java.util.List |
getGroupByAliases()
Gets the names of group by fields.
|
java.util.List |
getGroupByExprs()
Gets the list of expressions for "group by" fields
|
MapExpression |
getHavingCond()
Gets the having condition.
|
MapExpression |
getManualGroupBy()
Gets the manual gourp by clause.
|
java.util.List |
getSimpleAggrAliases()
Gets the list of names for simple aggregate expressions.
|
java.util.List |
getSimpleAggrEpxrs()
Gets the list of simple aggregate expressions.
|
java.util.List |
getSimpleAggrFuncs()
Gets the list of aggregate functions on simple aggr exprs.
|
int |
getStateRetention()
Gets the retention period for the spark command.
|
SparkCommandType |
getTypeEnum()
Get the type of this spark command.
|
boolean |
isStatefulEnabled()
Return true if stateful is enabled
|
boolean |
isUpdatesOnlyEnabled()
Return true if updates only is enabled.
|
convertExprs, convertExprsDF, getChildren, getCommandIndex, getExprText, getExprTextDF, getFlexField, getModulePaths, getOptionValue, getParentScript, getPhysicalNode, getScriptLevelCommonContext, getSourceAlias, getSourceAliases, getSparkContextName, getSparkContextType, getStrctType, getStreamEnableWindowing, getStreamSlideInterval, getStreamWindowLength, getTargetAlias, getTemplateSubstitutionMap, getText, getType, isStreamingMode, setSourceAliases, toString, useSQLExpressions
getCodeGenerationTemplate, getCodeGenerationTemplateName, getCustomTemplate, getKMName, getLeafLevelChildren, getMapPhysicalNode, getOrder, getParentAST, getParentOfType, getPropertyValue, getSourceLanguage, getSourceLocation, getSourceTechnology, getSourceText, getTargetLanguage, getTargetLocation, getTargetTechnology, getTargetText, hasCustomTemplate, hasSourceAndTargetText, isLeafLevelNode, isPushFromSource
public SparkGroupCmd(TemplateUtils templateUtils, MapPhysicalNode physicalNode)
public SparkCommandType getTypeEnum()
getTypeEnum
in class SparkCommand
public java.util.List getGroupByExprs()
public java.util.List getGroupByAliases()
public java.util.List getSimpleAggrEpxrs()
public java.util.List getSimpleAggrFuncs()
public java.util.List getSimpleAggrAliases()
public java.util.List getComplexAggrExprs()
public java.util.List getComplexAggrAliases()
public java.util.List getAllAggrExprs()
public java.util.List getAllAggrAliases()
public java.util.List getDirectMapExprs()
public java.util.List getDirectMapAliases()
public MapExpression getHavingCond()
public MapExpression getManualGroupBy()
public java.util.List getAllAggFunctions()
public boolean isStatefulEnabled()
public boolean isUpdatesOnlyEnabled()
public int getStateRetention()