org.apache.spark.sql.errors

Class DataTypeErrors

Object

org.apache.spark.sql.errors.DataTypeErrors

public class DataTypeErrors
extends Object

Object for grouping error messages from (most) exceptions thrown during query execution. This does not include exceptions thrown during the eager execution of commands, which are grouped into QueryCompilationErrors.

Constructor Summary

Constructors

Constructor and Description
DataTypeErrors()

Method Summary

Modifier and Type	Method and Description
static Throwable	ambiguousColumnOrFieldError(scala.collection.Seq<String> name, int numMatches, org.apache.spark.sql.catalyst.trees.Origin context)
static Throwable	attributeNameSyntaxError(String name)
static ArithmeticException	cannotChangeDecimalPrecisionError(Decimal value, int decimalPrecision, int decimalScale, org.apache.spark.sql.catalyst.trees.SQLQueryContext context)
static Throwable	cannotLoadUserDefinedTypeError(String name, String userClass)
static Throwable	cannotMergeDecimalTypesWithIncompatibleScaleError(int leftScale, int rightScale)
static Throwable	cannotMergeIncompatibleDataTypesError(DataType left, DataType right)
static ArithmeticException	castingCauseOverflowError(String t, DataType from, DataType to)
static Throwable	charOrVarcharTypeAsStringUnsupportedError()
static Throwable	dataTypeUnsupportedError(String dataType, String failure)
static Throwable	decimalCannotGreaterThanPrecisionError(int scale, int precision)
static org.apache.spark.SparkArithmeticException	decimalPrecisionExceedsMaxPrecisionError(int precision, int maxPrecision)
static org.apache.spark.SparkRuntimeException	failedParsingStructTypeError(String raw)
static org.apache.spark.SparkUnsupportedOperationException	fieldIndexOnRowWithoutSchemaError()
static QueryContext[]	getQueryContext(org.apache.spark.sql.catalyst.trees.SQLQueryContext sqlContext)
static String	getSummary(org.apache.spark.sql.catalyst.trees.SQLQueryContext sqlContext)
static Throwable	invalidDayTimeField(byte field, scala.collection.Seq<String> supportedIds)
static Throwable	invalidDayTimeIntervalType(String startFieldName, String endFieldName)
static Throwable	invalidFieldName(scala.collection.Seq<String> fieldName, scala.collection.Seq<String> path, org.apache.spark.sql.catalyst.trees.Origin context)
static org.apache.spark.SparkNumberFormatException	invalidInputInCastToNumberError(DataType to, org.apache.spark.unsafe.types.UTF8String s, org.apache.spark.sql.catalyst.trees.SQLQueryContext context)
static Throwable	invalidYearMonthField(byte field, scala.collection.Seq<String> supportedIds)
static Throwable	negativeScaleNotAllowedError(int scale)
static Throwable	notUserDefinedTypeError(String name, String userClass)
static org.apache.spark.SparkUnsupportedOperationException	nullLiteralsCannotBeCastedError(String name)
static org.apache.spark.SparkArithmeticException	outOfDecimalTypeRangeError(org.apache.spark.unsafe.types.UTF8String str)
static Throwable	schemaFailToParseError(String schema, Throwable e)
static String	toSQLConf(String conf)
static String	toSQLId(scala.collection.Seq<String> parts)
static String	toSQLId(String parts)
static String	toSQLStmt(String text)
static String	toSQLType(org.apache.spark.sql.types.AbstractDataType t)
static String	toSQLType(String text)
static String	toSQLValue(double value)
static String	toSQLValue(float value)
static String	toSQLValue(int value)
static String	toSQLValue(long value)
static String	toSQLValue(short value)
static String	toSQLValue(String value)
static String	toSQLValue(org.apache.spark.unsafe.types.UTF8String value)
static ArithmeticException	unscaledValueTooLargeForPrecisionError(Decimal value, int decimalPrecision, int decimalScale, org.apache.spark.sql.catalyst.trees.SQLQueryContext context)
static org.apache.spark.SparkRuntimeException	unsupportedArrayTypeError(Class<?> clazz)
static org.apache.spark.SparkRuntimeException	unsupportedJavaTypeError(Class<?> clazz)
static org.apache.spark.SparkUnsupportedOperationException	unsupportedOperationExceptionError()
static SparkException	unsupportedRoundingMode(scala.Enumeration.Value roundMode)
static Throwable	userSpecifiedSchemaUnsupportedError(String operation)
static Throwable	valueIsNullError(int index)

Methods inherited from class Object

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

Constructor Detail

DataTypeErrors

public DataTypeErrors()

Method Detail

unsupportedOperationExceptionError

public static org.apache.spark.SparkUnsupportedOperationException unsupportedOperationExceptionError()

decimalPrecisionExceedsMaxPrecisionError

public static org.apache.spark.SparkArithmeticException decimalPrecisionExceedsMaxPrecisionError(int precision,
                                                                                                 int maxPrecision)

unsupportedRoundingMode

public static SparkException unsupportedRoundingMode(scala.Enumeration.Value roundMode)

outOfDecimalTypeRangeError

public static org.apache.spark.SparkArithmeticException outOfDecimalTypeRangeError(org.apache.spark.unsafe.types.UTF8String str)

unsupportedJavaTypeError

public static org.apache.spark.SparkRuntimeException unsupportedJavaTypeError(Class<?> clazz)

nullLiteralsCannotBeCastedError

public static org.apache.spark.SparkUnsupportedOperationException nullLiteralsCannotBeCastedError(String name)

notUserDefinedTypeError

public static Throwable notUserDefinedTypeError(String name,
                                                String userClass)

cannotLoadUserDefinedTypeError

public static Throwable cannotLoadUserDefinedTypeError(String name,
                                                       String userClass)

unsupportedArrayTypeError

public static org.apache.spark.SparkRuntimeException unsupportedArrayTypeError(Class<?> clazz)

schemaFailToParseError

public static Throwable schemaFailToParseError(String schema,
                                               Throwable e)

invalidDayTimeIntervalType

public static Throwable invalidDayTimeIntervalType(String startFieldName,
                                                   String endFieldName)

invalidDayTimeField

public static Throwable invalidDayTimeField(byte field,
                                            scala.collection.Seq<String> supportedIds)

invalidYearMonthField

public static Throwable invalidYearMonthField(byte field,
                                              scala.collection.Seq<String> supportedIds)

decimalCannotGreaterThanPrecisionError

public static Throwable decimalCannotGreaterThanPrecisionError(int scale,
                                                               int precision)

negativeScaleNotAllowedError

public static Throwable negativeScaleNotAllowedError(int scale)

attributeNameSyntaxError

public static Throwable attributeNameSyntaxError(String name)

cannotMergeIncompatibleDataTypesError

public static Throwable cannotMergeIncompatibleDataTypesError(DataType left,
                                                              DataType right)

cannotMergeDecimalTypesWithIncompatibleScaleError

public static Throwable cannotMergeDecimalTypesWithIncompatibleScaleError(int leftScale,
                                                                          int rightScale)

dataTypeUnsupportedError

public static Throwable dataTypeUnsupportedError(String dataType,
                                                 String failure)

invalidFieldName

public static Throwable invalidFieldName(scala.collection.Seq<String> fieldName,
                                         scala.collection.Seq<String> path,
                                         org.apache.spark.sql.catalyst.trees.Origin context)

unscaledValueTooLargeForPrecisionError

public static ArithmeticException unscaledValueTooLargeForPrecisionError(Decimal value,
                                                                         int decimalPrecision,
                                                                         int decimalScale,
                                                                         org.apache.spark.sql.catalyst.trees.SQLQueryContext context)

cannotChangeDecimalPrecisionError

public static ArithmeticException cannotChangeDecimalPrecisionError(Decimal value,
                                                                    int decimalPrecision,
                                                                    int decimalScale,
                                                                    org.apache.spark.sql.catalyst.trees.SQLQueryContext context)

invalidInputInCastToNumberError

public static org.apache.spark.SparkNumberFormatException invalidInputInCastToNumberError(DataType to,
                                                                                          org.apache.spark.unsafe.types.UTF8String s,
                                                                                          org.apache.spark.sql.catalyst.trees.SQLQueryContext context)

ambiguousColumnOrFieldError

public static Throwable ambiguousColumnOrFieldError(scala.collection.Seq<String> name,
                                                    int numMatches,
                                                    org.apache.spark.sql.catalyst.trees.Origin context)

castingCauseOverflowError

public static ArithmeticException castingCauseOverflowError(String t,
                                                            DataType from,
                                                            DataType to)

failedParsingStructTypeError

public static org.apache.spark.SparkRuntimeException failedParsingStructTypeError(String raw)

fieldIndexOnRowWithoutSchemaError

public static org.apache.spark.SparkUnsupportedOperationException fieldIndexOnRowWithoutSchemaError()

valueIsNullError

public static Throwable valueIsNullError(int index)

charOrVarcharTypeAsStringUnsupportedError

public static Throwable charOrVarcharTypeAsStringUnsupportedError()

userSpecifiedSchemaUnsupportedError

public static Throwable userSpecifiedSchemaUnsupportedError(String operation)

toSQLId

public static String toSQLId(String parts)

toSQLId

public static String toSQLId(scala.collection.Seq<String> parts)

toSQLStmt

public static String toSQLStmt(String text)

toSQLConf

public static String toSQLConf(String conf)

toSQLType

public static String toSQLType(String text)

toSQLType

public static String toSQLType(org.apache.spark.sql.types.AbstractDataType t)

toSQLValue

public static String toSQLValue(String value)

toSQLValue

public static String toSQLValue(org.apache.spark.unsafe.types.UTF8String value)

toSQLValue

public static String toSQLValue(short value)

toSQLValue

public static String toSQLValue(int value)

toSQLValue

public static String toSQLValue(long value)

toSQLValue

public static String toSQLValue(float value)

toSQLValue

public static String toSQLValue(double value)

getSummary

public static String getSummary(org.apache.spark.sql.catalyst.trees.SQLQueryContext sqlContext)

getQueryContext

public static QueryContext[] getQueryContext(org.apache.spark.sql.catalyst.trees.SQLQueryContext sqlContext)