org.apache.spark.sql.errors

Class QueryCompilationErrors

Object

org.apache.spark.sql.errors.QueryCompilationErrors

public class QueryCompilationErrors
extends Object

Object for grouping all error messages of the query compilation. Currently it includes all AnalysisExcpetions created and thrown directly in org.apache.spark.sql.catalyst.analysis.Analyzer.

Constructor Summary

Constructors

Constructor and Description
QueryCompilationErrors()

Method Summary

Modifier and Type	Method and Description
static Throwable	addStaticValToUnknownColError(String staticName)
static Throwable	dataTypeMismatchForDeserializerError(DataType dataType, String desiredType)
static Throwable	fieldNumberMismatchForDeserializerError(StructType schema, int maxOrdinal)
static Throwable	generatorOutsideSelectError(org.apache.spark.sql.catalyst.plans.logical.LogicalPlan plan)
static Throwable	groupingColInvalidError(org.apache.spark.sql.catalyst.expressions.Expression groupingCol, scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> groupByExprs)
static Throwable	groupingIDMismatchError(org.apache.spark.sql.catalyst.expressions.GroupingID groupingID, scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> groupByExprs)
static Throwable	groupingSizeTooLargeError(int sizeLimit)
static Throwable	legacyStoreAssignmentPolicyError()
static Throwable	moreThanOneGeneratorError(scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> generators, String clause)
static Throwable	nestedGeneratorError(org.apache.spark.sql.catalyst.expressions.Expression trimmedNestedGenerator)
static Throwable	nonLiteralPivotValError(org.apache.spark.sql.catalyst.expressions.Expression pivotVal)
static Throwable	nonPartitionColError(String partitionName)
static Throwable	outerScopeFailureForNewInstanceError(String className)
static Throwable	pivotValDataTypeMismatchError(org.apache.spark.sql.catalyst.expressions.Expression pivotVal, org.apache.spark.sql.catalyst.expressions.Expression pivotCol)
static Throwable	referenceColNotFoundForAlterTableChangesError(TableChange.After after, String parentName)
static Throwable	unknownStaticPartitionColError(String name)
static Throwable	unorderablePivotColError(org.apache.spark.sql.catalyst.expressions.Expression pivotCol)
static Throwable	unresolvedUsingColForJoinError(String colName, org.apache.spark.sql.catalyst.plans.logical.LogicalPlan plan, String side)
static Throwable	unsupportedAbstractDataTypeForUpCastError(org.apache.spark.sql.types.AbstractDataType gotType)
static Throwable	unsupportedIfNotExistsError(String tableName)
static Throwable	upCastFailureError(String fromStr, org.apache.spark.sql.catalyst.expressions.Expression from, DataType to, scala.collection.Seq<String> walkedTypePath)

Methods inherited from class Object

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

Constructor Detail

QueryCompilationErrors

public QueryCompilationErrors()

Method Detail

groupingIDMismatchError

public static Throwable groupingIDMismatchError(org.apache.spark.sql.catalyst.expressions.GroupingID groupingID,
                                                scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> groupByExprs)

groupingColInvalidError

public static Throwable groupingColInvalidError(org.apache.spark.sql.catalyst.expressions.Expression groupingCol,
                                                scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> groupByExprs)

groupingSizeTooLargeError

public static Throwable groupingSizeTooLargeError(int sizeLimit)

unorderablePivotColError

public static Throwable unorderablePivotColError(org.apache.spark.sql.catalyst.expressions.Expression pivotCol)

nonLiteralPivotValError

public static Throwable nonLiteralPivotValError(org.apache.spark.sql.catalyst.expressions.Expression pivotVal)

pivotValDataTypeMismatchError

public static Throwable pivotValDataTypeMismatchError(org.apache.spark.sql.catalyst.expressions.Expression pivotVal,
                                                      org.apache.spark.sql.catalyst.expressions.Expression pivotCol)

unsupportedIfNotExistsError

public static Throwable unsupportedIfNotExistsError(String tableName)

nonPartitionColError

public static Throwable nonPartitionColError(String partitionName)

addStaticValToUnknownColError

public static Throwable addStaticValToUnknownColError(String staticName)

unknownStaticPartitionColError

public static Throwable unknownStaticPartitionColError(String name)

nestedGeneratorError

public static Throwable nestedGeneratorError(org.apache.spark.sql.catalyst.expressions.Expression trimmedNestedGenerator)

moreThanOneGeneratorError

public static Throwable moreThanOneGeneratorError(scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> generators,
                                                  String clause)

generatorOutsideSelectError

public static Throwable generatorOutsideSelectError(org.apache.spark.sql.catalyst.plans.logical.LogicalPlan plan)

legacyStoreAssignmentPolicyError

public static Throwable legacyStoreAssignmentPolicyError()

unresolvedUsingColForJoinError

public static Throwable unresolvedUsingColForJoinError(String colName,
                                                       org.apache.spark.sql.catalyst.plans.logical.LogicalPlan plan,
                                                       String side)

dataTypeMismatchForDeserializerError

public static Throwable dataTypeMismatchForDeserializerError(DataType dataType,
                                                             String desiredType)

fieldNumberMismatchForDeserializerError

public static Throwable fieldNumberMismatchForDeserializerError(StructType schema,
                                                                int maxOrdinal)

upCastFailureError

public static Throwable upCastFailureError(String fromStr,
                                           org.apache.spark.sql.catalyst.expressions.Expression from,
                                           DataType to,
                                           scala.collection.Seq<String> walkedTypePath)

unsupportedAbstractDataTypeForUpCastError

public static Throwable unsupportedAbstractDataTypeForUpCastError(org.apache.spark.sql.types.AbstractDataType gotType)

outerScopeFailureForNewInstanceError

public static Throwable outerScopeFailureForNewInstanceError(String className)

referenceColNotFoundForAlterTableChangesError

public static Throwable referenceColNotFoundForAlterTableChangesError(TableChange.After after,
                                                                      String parentName)