QueryExecutionErrors (Spark 3.3.4 JavaDoc)

Object
- org.apache.spark.sql.errors.QueryExecutionErrors

```
public class QueryExecutionErrors
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

QueryExecutionErrors()

Constructors
Constructor and Description
`QueryExecutionErrors()`

Method Summary

All Methods Static Methods Concrete Methods
Modifier and Type	Method and Description
`static Throwable`	`addFilesWithAbsolutePathUnsupportedError(String commitProtocol)`
`static Throwable`	`addNewFunctionMismatchedWithFunctionError(String funcName)`
`static RuntimeException`	`aesCryptoError(String detailMessage)`
`static RuntimeException`	`aesModeUnsupportedError(String mode, String padding)`
`static Throwable`	`alterTableWithDropPartitionAndPurgeUnsupportedError()`
`static java.time.DateTimeException`	`ansiDateTimeError(java.time.DateTimeException e)`
`static java.time.format.DateTimeParseException`	`ansiDateTimeParseError(java.time.format.DateTimeParseException e)`
`static IllegalArgumentException`	`ansiIllegalArgumentError(IllegalArgumentException e)`
`static IllegalArgumentException`	`ansiIllegalArgumentError(String message)`
`static java.text.ParseException`	`ansiParseError(java.text.ParseException e)`
`static ArithmeticException`	`arithmeticOverflowError(ArithmeticException e)`
`static ArithmeticException`	`arithmeticOverflowError(String message, String hint, String errorContext)`
`static Throwable`	`attributesForTypeUnsupportedError(org.apache.spark.sql.catalyst.ScalaReflection.Schema schema)`
`static Throwable`	`batchMetadataFileNotFoundError(org.apache.hadoop.fs.Path batchMetadataFile)`
`static ArithmeticException`	`binaryArithmeticCauseOverflowError(short eval1, String symbol, short eval2)`
`static Throwable`	`buildReaderUnsupportedForFileFormatError(String format)`
`static Throwable`	`cannotAcquireMemoryToBuildLongHashedRelationError(long size, long got)`
`static Throwable`	`cannotAcquireMemoryToBuildUnsafeHashedRelationError()`
`static Throwable`	`cannotAddMultiPartitionsOnNonatomicPartitionTableError(String tableName)`
`static Throwable`	`cannotAllocateMemoryToGrowBytesToBytesMapError()`
`static Throwable`	`cannotBroadcastTableOverMaxTableBytesError(long maxBroadcastTableBytes, long dataSize)`
`static Throwable`	`cannotBroadcastTableOverMaxTableRowsError(long maxBroadcastTableRows, long numRows)`
`static Throwable`	`cannotBuildHashedRelationLargerThan8GError()`
`static Throwable`	`cannotBuildHashedRelationWithUniqueKeysExceededError()`
`static Throwable`	`cannotCastError(DataType from, DataType to)`
`static Throwable`	`cannotCastFromNullTypeError(DataType to)`
`static Throwable`	`cannotCastToDateTimeError(Object value, DataType from, DataType to, String errorContext)`
`static ArithmeticException`	`cannotChangeDecimalPrecisionError(Decimal value, int decimalPrecision, int decimalScale, String context)`
`static Throwable`	`cannotClearOutputDirectoryError(org.apache.hadoop.fs.Path staticPrefixPath)`
`static Throwable`	`cannotClearPartitionDirectoryError(org.apache.hadoop.fs.Path path)`
`static Throwable`	`cannotCloneOrCopyReadOnlySQLConfError()`
`static Throwable`	`cannotCompareCostWithTargetCostError(String cost)`
`static Throwable`	`cannotConvertColumnToJSONError(String name, DataType dataType)`
`static Throwable`	`cannotConvertOrcTimestampNTZToTimestampLTZError()`
`static Throwable`	`cannotConvertOrcTimestampToTimestampNTZError()`
`static Throwable`	`cannotCreateArrayWithElementsExceedLimitError(long numElements, String additionalErrorMessage)`
`static Throwable`	`cannotCreateColumnarReaderError()`
`static Throwable`	`cannotCreateJDBCTableWithPartitionsError()`
`static Throwable`	`cannotCreateParquetConverterForDataTypeError(DataType t, String parquetType)`
`static Throwable`	`cannotCreateParquetConverterForDecimalTypeError(DecimalType t, String parquetType)`
`static Throwable`	`cannotCreateParquetConverterForTypeError(DecimalType t, String parquetType)`
`static Throwable`	`cannotCreateStagingDirError(String message, java.io.IOException e)`
`static Throwable`	`cannotDropMultiPartitionsOnNonatomicPartitionTableError(String tableName)`
`static Throwable`	`cannotEvaluateExpressionError(org.apache.spark.sql.catalyst.expressions.Expression expression)`
`static Throwable`	`cannotExecuteStreamingRelationExecError()`
`static Throwable`	`cannotFetchTablesOfDatabaseError(String dbName, Exception e)`
`static Throwable`	`cannotFindConstructorForTypeError(String tpe)`
`static Throwable`	`cannotFindEncoderForTypeError(String tpe, org.apache.spark.sql.catalyst.WalkedTypePath walkedTypePath)`
`static Throwable`	`cannotGenerateCodeForExpressionError(org.apache.spark.sql.catalyst.expressions.Expression expression)`
`static Throwable`	`cannotGenerateCodeForUncomparableTypeError(String codeType, DataType dataType)`
`static Throwable`	`cannotGenerateCodeForUnsupportedTypeError(DataType dataType)`
`static Throwable`	`cannotGetEventTimeWatermarkError()`
`static Throwable`	`cannotGetJdbcTypeError(DataType dt)`
`static Throwable`	`cannotGetOuterPointerForInnerClassError(Class<?> innerCls)`
`static Throwable`	`cannotGetSQLConfInSchedulerEventLoopThreadError()`
`static Throwable`	`cannotHaveCircularReferencesInBeanClassError(Class<?> clazz)`
`static Throwable`	`cannotHaveCircularReferencesInClassError(String t)`
`static Throwable`	`cannotInstantiateAbstractCatalogPluginClassError(String name, String pluginClassName, Exception e)`
`static Throwable`	`cannotInterpolateClassIntoCodeBlockError(Object arg)`
`static Throwable`	`cannotLoadUserDefinedTypeError(String name, String userClass)`
`static Throwable`	`cannotMergeClassWithOtherClassError(String className, String otherClass)`
`static Throwable`	`cannotMergeDecimalTypesWithIncompatiblePrecisionAndScaleError(int leftPrecision, int rightPrecision, int leftScale, int rightScale)`
`static Throwable`	`cannotMergeDecimalTypesWithIncompatiblePrecisionError(int leftPrecision, int rightPrecision)`
`static Throwable`	`cannotMergeDecimalTypesWithIncompatibleScaleError(int leftScale, int rightScale)`
`static Throwable`	`cannotMergeIncompatibleDataTypesError(DataType left, DataType right)`
`static Throwable`	`cannotMutateReadOnlySQLConfError()`
`static Throwable`	`cannotParseDecimalError()`
`static Throwable`	`cannotParseJsonArraysAsStructsError()`
`static Throwable`	`cannotParseStatisticAsPercentileError(String stats, NumberFormatException e)`
`static Throwable`	`cannotParseStringAsDataTypeError(com.fasterxml.jackson.core.JsonParser parser, com.fasterxml.jackson.core.JsonToken token, DataType dataType)`
`static Throwable`	`cannotParseStringAsDataTypeError(String pattern, String value, DataType dataType)`
`static Throwable`	`cannotPurgeAsBreakInternalStateError()`
`static Throwable`	`cannotReadFilesError(Throwable e, String path)`
`static Throwable`	`cannotReadFooterForFileError(org.apache.hadoop.fs.FileStatus file, RuntimeException e)`
`static Throwable`	`cannotReadFooterForFileError(org.apache.hadoop.fs.Path file, java.io.IOException e)`
`static Throwable`	`cannotRecognizeHiveTypeError(org.apache.spark.sql.catalyst.parser.ParseException e, String fieldType, String fieldName)`
`static Throwable`	`cannotRemovePartitionDirError(org.apache.hadoop.fs.Path partitionPath)`
`static Throwable`	`cannotRemoveReservedPropertyError(String property)`
`static Throwable`	`cannotRewriteDomainJoinWithConditionsError(scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> conditions, org.apache.spark.sql.catalyst.plans.logical.DomainJoin d)`
`static Throwable`	`cannotSafelyMergeSerdePropertiesError(scala.collection.immutable.Map<String,String> props1, scala.collection.immutable.Map<String,String> props2, scala.collection.immutable.Set<String> conflictKeys)`
`static Throwable`	`cannotSetTimeoutDurationError()`
`static Throwable`	`cannotSetTimeoutTimestampError()`
`static Throwable`	`cannotSpecifyBothJdbcTableNameAndQueryError(String jdbcTableName, String jdbcQueryString)`
`static Throwable`	`cannotTerminateGeneratorError(org.apache.spark.sql.catalyst.analysis.UnresolvedGenerator generator)`
`static Throwable`	`cannotTranslateNonNullValueForFieldError(int pos)`
`static Throwable`	`cannotUseInvalidJavaIdentifierAsFieldNameError(String fieldName, org.apache.spark.sql.catalyst.WalkedTypePath walkedTypePath)`
`static ArithmeticException`	`castingCauseOverflowError(Object t, DataType from, DataType to)`
`static ArithmeticException`	`castingCauseOverflowErrorInTableInsert(DataType from, DataType to, String columnName)`
`static Throwable`	`catalogFailToCallPublicNoArgConstructorError(String name, String pluginClassName, Exception e)`
`static Throwable`	`catalogFailToFindPublicNoArgConstructorError(String name, String pluginClassName, Exception e)`
`static Throwable`	`catalogPluginClassNotFoundError(String name)`
`static Throwable`	`catalogPluginClassNotFoundForCatalogError(String name, String pluginClassName, Exception e)`
`static Throwable`	`catalogPluginClassNotImplementedError(String name, String pluginClassName)`
`static Throwable`	`classHasUnexpectedSerializerError(String clsName, org.apache.spark.sql.catalyst.expressions.Expression objSerializer)`
`static RuntimeException`	`classUnsupportedByMapObjectsError(Class<?> cls)`
`static Throwable`	`cleanUpSourceFilesUnsupportedError()`
`static Throwable`	`commentOnTableUnsupportedError()`
`static Throwable`	`commitDeniedError(int partId, long taskId, int attemptId, int stageId, int stageAttempt)`
`static Throwable`	`compilerError(org.codehaus.commons.compiler.CompileException e)`
`static Throwable`	`concatArraysWithElementsExceedLimitError(long numberOfElements)`
`static Throwable`	`concurrentModificationOnExternalAppendOnlyUnsafeRowArrayError(String className)`
`static Throwable`	`concurrentQueryInstanceError()`
`static Throwable`	`constructorNotFoundError(String cls)`
`static Throwable`	`continuousProcessingUnsupportedByDataSourceError(String sourceName)`
`static Throwable`	`convertHiveTableToCatalogTableError(SparkException e, String dbName, String tableName)`
`static Throwable`	`copyNullFieldNotAllowedError()`
`static RuntimeException`	`createArrayWithElementsExceedLimitError(Object count)`
`static Throwable`	`createStreamingSourceNotSpecifySchemaError()`
`static Throwable`	`customCollectionClsNotResolvedError()`
`static Throwable`	`databaseNameConflictWithSystemPreservedDatabaseError(String globalTempDB)`
`static Throwable`	`dataPathNotSpecifiedError()`
`static Throwable`	`dataTypeOperationUnsupportedError()`
`static Throwable`	`dataTypeUnexpectedError(DataType dataType)`
`static Throwable`	`dataTypeUnsupportedError(String dataType, String failure)`
`static Throwable`	`dataTypeUnsupportedYetError(DataType dataType)`
`static Throwable`	`ddlUnsupportedTemporarilyError(String ddl)`
`static Throwable`	`decimalPrecisionExceedsMaxPrecisionError(int precision, int maxPrecision)`
`static Throwable`	`decorrelateInnerQueryThroughPlanUnsupportedError(org.apache.spark.sql.catalyst.plans.logical.LogicalPlan plan)`
`static ArithmeticException`	`divideByZeroError(String context)`
`static Throwable`	`doExecuteBroadcastNotImplementedError(String nodeName)`
`static Throwable`	`doGenCodeOfAliasShouldNotBeCalledError()`
`static Throwable`	`dropTableWithPurgeUnsupportedError()`
`static Throwable`	`duplicateMapKeyFoundError(Object key)`
`static Throwable`	`dynamicPartitionKeyNotAmongWrittenPartitionPathsError(String key)`
`static Throwable`	`dynamicPartitionOverwriteUnsupportedByTableError(Table table)`
`static Throwable`	`elementsOfTupleExceedLimitError()`
`static Throwable`	`emptyOptionError(String optionName)`
`static Throwable`	`endOfIteratorError()`
`static Throwable`	`endOfStreamError()`
`static Throwable`	`exceedMapSizeLimitError(int size)`
`static Throwable`	`executeBroadcastTimeoutError(long timeout, scala.Option<java.util.concurrent.TimeoutException> ex)`
`static Throwable`	`executeCodePathUnsupportedError(String execName)`
`static Throwable`	`expressionDecodingError(Exception e, scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> expressions)`
`static Throwable`	`expressionEncodingError(Exception e, scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> expressions)`
`static Throwable`	`failedExecuteUserDefinedFunctionError(String funcCls, String inputTypes, String outputType, Throwable e)`
`static Throwable`	`failedMergingFieldsError(String leftName, String rightName, Throwable e)`
`static Throwable`	`failedMergingSchemaError(StructType schema, SparkException e)`
`static Throwable`	`failedParsingStructTypeError(String raw)`
`static Throwable`	`failedRenameTempFileError(org.apache.hadoop.fs.Path srcPath, org.apache.hadoop.fs.Path dstPath)`
`static Throwable`	`failedSplitSubExpressionError(int length)`
`static String`	`failedSplitSubExpressionMsg(int length)`
`static Throwable`	`failedToCastValueToDataTypeForPartitionColumnError(String value, DataType dataType, String columnName)`
`static String`	`failedToCompileMsg(Exception e)`
`static org.apache.spark.sql.execution.QueryExecutionException`	`failedToExecuteQueryError(Throwable e)`
`static Throwable`	`failedToFindDataSourceError(String provider, Throwable error)`
`static Throwable`	`failedToGenerateEpochMarkerError(Throwable failureReason)`
`static Throwable`	`failedToInstantiateConstructorForCatalogError(String name, String pluginClassName, Exception e)`
`static Throwable`	`failedToMergeIncompatibleSchemasError(StructType left, StructType right, Throwable e)`
`static Throwable`	`failedToPushRowIntoRowQueueError(String rowQueue)`
`static Throwable`	`failedToReadDataError(Throwable failureReason)`
`static Throwable`	`failedToReadDeltaFileError(org.apache.hadoop.fs.Path fileToRead, String clazz, int keySize)`
`static Throwable`	`failedToReadSnapshotFileError(org.apache.hadoop.fs.Path fileToRead, String clazz, String message)`
`static Throwable`	`failToConvertValueToJsonError(Object value, Class<?> cls, DataType dataType)`
`static Throwable`	`failToFormatDateTimeInNewFormatterError(String resultCandidate, Throwable e)`
`static Throwable`	`failToParseDateTimeInNewParserError(String s, Throwable e)`
`static Throwable`	`failToParseEmptyStringForDataTypeError(DataType dataType)`
`static Throwable`	`failToParseValueForDataTypeError(com.fasterxml.jackson.core.JsonParser parser, com.fasterxml.jackson.core.JsonToken token, DataType dataType)`
`static Throwable`	`failToRecognizePatternAfterUpgradeError(String pattern, Throwable e)`
`static Throwable`	`failToRecognizePatternError(String pattern, Throwable e)`
`static Throwable`	`failToSetOriginalACLBackError(String aclEntries, org.apache.hadoop.fs.Path path, Throwable e)`
`static Throwable`	`failToSetOriginalPermissionBackError(org.apache.hadoop.fs.permission.FsPermission permission, org.apache.hadoop.fs.Path path, Throwable e)`
`static Throwable`	`fallbackV1RelationReportsInconsistentSchemaError(StructType v2Schema, StructType v1Schema)`
`static RuntimeException`	`fieldCannotBeNullError(int index, String fieldName)`
`static String`	`fieldCannotBeNullMsg(int index, String fieldName)`
`static Throwable`	`fieldDiffersFromDerivedLocalDateError(java.time.temporal.ChronoField field, int actual, int expected, java.time.LocalDate candidate)`
`static Throwable`	`fieldIndexOnRowWithoutSchemaError()`
`static Throwable`	`fileLengthExceedsMaxLengthError(org.apache.hadoop.fs.FileStatus status, int maxLength)`
`static Throwable`	`fileNotFoundError(java.io.FileNotFoundException e)`
`static Throwable`	`flattenArraysWithElementsExceedLimitError(long numberOfElements)`
`static Throwable`	`foreachWriterAbortedDueToTaskFailureError()`
`static Throwable`	`foundDuplicateFieldInCaseInsensitiveModeError(String requiredFieldName, String matchedOrcFields)`
`static Throwable`	`foundDuplicateFieldInFieldIdLookupModeError(int requiredId, String matchedFields)`
`static Throwable`	`foundNullValueForNotNullableFieldError(String name)`
`static Throwable`	`getParentLoggerNotImplementedError(String className)`
`static Throwable`	`getPartitionMetadataByFilterError(java.lang.reflect.InvocationTargetException e)`
`static Throwable`	`getTablesByTypeUnsupportedByHiveVersionError()`
`static Throwable`	`hiveTableWithAnsiIntervalsError(String tableName)`
`static Throwable`	`illegalLocationClauseForViewPartitionError()`
`static Throwable`	`incompatibleDataSourceRegisterError(Throwable e)`
`static Throwable`	`indexOutOfBoundsOfArrayDataError(int idx)`
`static Throwable`	`inferSchemaUnsupportedForHiveError()`
`static Throwable`	`initialTypeNotTargetDataTypeError(DataType dataType, String target)`
`static Throwable`	`initialTypeNotTargetDataTypesError(DataType dataType)`
`static RuntimeException`	`inputExternalRowCannotBeNullError()`
`static Throwable`	`inputFilterNotFullyConvertibleError(String owner)`
`static Throwable`	`inputTypeUnsupportedError(DataType dataType)`
`static Throwable`	`integerOverflowError(String message)`
`static Throwable`	`internalCompilerError(org.codehaus.janino.InternalCompilerException e)`
`static RuntimeException`	`invalidAesKeyLengthError(int actualLength)`
`static ArrayIndexOutOfBoundsException`	`invalidArrayIndexError(int index, int numElements)`
`static Throwable`	`invalidBucketFile(String path)`
`static ArrayIndexOutOfBoundsException`	`invalidElementAtIndexError(int index, int numElements)`
`static java.time.DateTimeException`	`invalidFractionOfSecondError()`
`static Throwable`	`invalidInputInCastToDatetimeError(Object value, DataType from, DataType to, String errorContext)`
`static org.apache.spark.SparkNumberFormatException`	`invalidInputInCastToNumberError(DataType to, org.apache.spark.unsafe.types.UTF8String s, String errorContext)`
`static ArrayIndexOutOfBoundsException`	`invalidInputIndexError(int index, int numElements)`
`static org.apache.spark.SparkRuntimeException`	`invalidInputSyntaxForBooleanError(org.apache.spark.unsafe.types.UTF8String s, String errorContext)`
`static Throwable`	`invalidJdbcNumPartitionsError(int n, String jdbcNumPartitions)`
`static Throwable`	`invalidJdbcTxnIsolationLevelError(String jdbcTxnIsolationLevel, String value)`
`static Throwable`	`invalidKerberosConfigForHiveServer2Error()`
`static Throwable`	`invalidNamespaceNameError(String[] namespace)`
`static Throwable`	`invalidNumberFormatError(org.apache.spark.unsafe.types.UTF8String input, String format)`
`static Throwable`	`invalidPartitionFilterError()`
`static RuntimeException`	`invalidPatternError(String funcName, String pattern)`
`static Throwable`	`invalidStartIndexError(int numRows, int startIndex)`
`static Throwable`	`invalidStreamingOutputModeError(scala.Option<OutputMode> outputMode)`
`static Throwable`	`invalidUrlError(org.apache.spark.unsafe.types.UTF8String url, java.net.URISyntaxException e)`
`static Throwable`	`jobAbortedError(Throwable cause)`
`static Throwable`	`latestOffsetNotCalledError()`
`static Throwable`	`legacyCheckpointDirectoryExistsError(org.apache.hadoop.fs.Path checkpointPath, String legacyCheckpointDir)`
`static Throwable`	`legacyMetadataPathExistsError(org.apache.hadoop.fs.Path metadataPath, org.apache.hadoop.fs.Path legacyMetadataPath)`
`static RuntimeException`	`literalTypeUnsupportedError(Object v)`
`static Throwable`	`loadHiveClientCausesNoClassDefFoundError(NoClassDefFoundError cnf, scala.collection.Seq<java.net.URL> execJars, String key, java.lang.reflect.InvocationTargetException e)`
`static Throwable`	`malformedCSVRecordError()`
`static Throwable`	`malformedJSONError()`
`static Throwable`	`malformedRecordsDetectedInRecordParsingError(org.apache.spark.sql.catalyst.util.BadRecordException e)`
`static Throwable`	`malformedRecordsDetectedInSchemaInferenceError(DataType dataType)`
`static Throwable`	`malformedRecordsDetectedInSchemaInferenceError(Throwable e)`
`static Throwable`	`mapDataKeyArrayLengthDiffersFromValueArrayLengthError()`
`static java.util.NoSuchElementException`	`mapKeyNotExistError(Object key, DataType dataType, String context)`
`static RuntimeException`	`mapSizeExceedArraySizeWhenZipMapError(int size)`
`static Throwable`	`mergeUnsupportedByWindowFunctionError()`
`static Throwable`	`methodCalledInAnalyzerNotAllowedError()`
`static Throwable`	`methodNotDeclaredError(String name)`
`static Throwable`	`methodNotImplementedError(String methodName)`
`static Throwable`	`microBatchUnsupportedByDataSourceError(String srcName)`
`static Throwable`	`missingDatabaseLocationError()`
`static Throwable`	`missingJdbcTableNameAndQueryError(String jdbcTableName, String jdbcQueryString)`
`static Throwable`	`multiFailuresInStageMaterializationError(Throwable error)`
`static Throwable`	`multipleBucketTransformsError()`
`static Throwable`	`multiplePathsSpecifiedError(scala.collection.Seq<String> allPaths)`
`static Throwable`	`multiStreamingQueriesUsingPathConcurrentlyError(String path, org.apache.hadoop.fs.FileAlreadyExistsException e)`
`static Throwable`	`namespaceNotEmptyError(String[] namespace)`
`static Throwable`	`negativeValueUnexpectedError(org.apache.spark.sql.catalyst.expressions.Expression frequencyExpression)`
`static Throwable`	`nestedArraysUnsupportedError()`
`static Throwable`	`nestedFieldUnsupportedError(String colName)`
`static RuntimeException`	`noDefaultForDataTypeError(DataType dataType)`
`static Throwable`	`noRecordsFromEmptyDataReaderError()`
`static Throwable`	`noSuchElementExceptionError()`
`static Throwable`	`noSuchElementExceptionError(String key)`
`static Throwable`	`notADatasourceRDDPartitionError(Partition split)`
`static Throwable`	`notEnoughMemoryToBuildAndBroadcastTableError(OutOfMemoryError oe)`
`static Throwable`	`notExpectedUnresolvedEncoderError(org.apache.spark.sql.catalyst.expressions.AttributeReference attr)`
`static Throwable`	`notOverrideExpectedMethodsError(String className, String m1, String m2)`
`static Throwable`	`notPublicClassError(String name)`
`static Throwable`	`notSupportNonPrimitiveTypeError()`
`static Throwable`	`notSupportTypeError(DataType dataType)`
`static Throwable`	`notUserDefinedTypeError(String name, String userClass)`
`static RuntimeException`	`nullAsMapKeyNotAllowedError()`
`static Throwable`	`nullComparisonResultError()`
`static Throwable`	`nullLiteralsCannotBeCastedError(String name)`
`static <TreeType extends org.apache.spark.sql.catalyst.trees.TreeNode<?>> Throwable`	`onceStrategyIdempotenceIsBrokenForBatchError(String batchName, TreeType plan, TreeType reOptimized)`
`static Throwable`	`onlySupportDataSourcesProvidingFileFormatError(String providingClass)`
`static Throwable`	`operatingOnCanonicalizationPlanError()`
`static Throwable`	`orderedOperationUnsupportedByDataTypeError(DataType dataType)`
`static Throwable`	`outOfDecimalTypeRangeError(org.apache.spark.unsafe.types.UTF8String str)`
`static Throwable`	`outputDataTypeUnsupportedByNodeWithoutSerdeError(String nodeName, DataType dt)`
`static ArithmeticException`	`overflowInIntegralDivideError(String context)`
`static ArithmeticException`	`overflowInSumOfDecimalError(String context)`
`static Throwable`	`overwriteTableByUnsupportedExpressionError(Table table)`
`static Throwable`	`pairUnsupportedAtFunctionError(org.apache.spark.sql.catalyst.plans.logical.statsEstimation.ValueInterval r1, org.apache.spark.sql.catalyst.plans.logical.statsEstimation.ValueInterval r2, String function)`
`static Throwable`	`paramExceedOneCharError(String paramName)`
`static Throwable`	`paramIsNotBooleanValueError(String paramName)`
`static Throwable`	`paramIsNotIntegerError(String paramName, String value)`
`static Throwable`	`parentSparkUIToAttachTabNotFoundError()`
`static Throwable`	`partitionColumnNotFoundInSchemaError(String col, StructType schema)`
`static RuntimeException`	`pivotColumnUnsupportedError(Object v, DataType dataType)`
`static Throwable`	`pivotNotAfterGroupByUnsupportedError()`
`static Throwable`	`primaryConstructorNotFoundError(Class<?> cls)`
`static Throwable`	`primitiveTypesNotSupportedError()`
`static Throwable`	`readCurrentFileNotFoundError(java.io.FileNotFoundException e)`
`static Throwable`	`regexGroupIndexExceedGroupCountError(int groupCount, int groupIndex)`
`static Throwable`	`regexGroupIndexLessThanZeroError()`
`static Throwable`	`registeringStreamingQueryListenerError(Exception e)`
`static Throwable`	`remoteOperationsUnsupportedError()`
`static Throwable`	`removedClassInSpark2Error(String className, Throwable e)`
`static Throwable`	`renameAsExistsPathError(org.apache.hadoop.fs.Path dstPath)`
`static Throwable`	`renameColumnUnsupportedForOlderMySQLError()`
`static Throwable`	`renamePathAsExistsPathError(org.apache.hadoop.fs.Path srcPath, org.apache.hadoop.fs.Path dstPath)`
`static Throwable`	`renameSrcPathNotFoundError(org.apache.hadoop.fs.Path srcPath)`
`static Throwable`	`repeatedPivotsUnsupportedError()`
`static Throwable`	`requestedPartitionsMismatchTablePartitionsError(org.apache.spark.sql.catalyst.catalog.CatalogTable table, scala.collection.immutable.Map<String,scala.Option<String>> partition)`
`static Throwable`	`resolveCannotHandleNestedSchema(org.apache.spark.sql.catalyst.plans.logical.LogicalPlan plan)`
`static Throwable`	`rootConverterReturnNullError()`
`static Throwable`	`rowLargerThan256MUnsupportedError()`
`static Throwable`	`ruleIdNotFoundForRuleError(String ruleName)`
`static Throwable`	`saveModeUnsupportedError(Object saveMode, boolean pathExists)`
`static Throwable`	`schemaForTypeUnsupportedError(String tpe)`
`static Throwable`	`serDeInterfaceNotFoundError(NoClassDefFoundError e)`
`static org.apache.spark.SparkUpgradeException`	`sparkUpgradeInReadingDatesError(String format, String config, String option)`
`static org.apache.spark.SparkUpgradeException`	`sparkUpgradeInWritingDatesError(String format, String config)`
`static ArrayIndexOutOfBoundsException`	`sqlArrayIndexNotStartAtOneError()`
`static Throwable`	`stateNotDefinedOrAlreadyRemovedError()`
`static Throwable`	`statisticNotRecognizedError(String stats)`
`static Throwable`	`streamedOperatorUnsupportedByDataSourceError(String className, String operator)`
`static Throwable`	`structuralIntegrityIsBrokenAfterApplyingRuleError(String ruleName, String batchName)`
`static Throwable`	`structuralIntegrityOfInputPlanIsBrokenInClassError(String className)`
`static Throwable`	`subprocessExitedError(int exitCode, org.apache.spark.util.CircularBuffer stderrBuffer, Throwable cause)`
`static Throwable`	`tableStatsNotSpecifiedError()`
`static Throwable`	`taskFailedWhileWritingRowsError(Throwable cause)`
`static ArithmeticException`	`timestampAddOverflowError(long micros, int amount, String unit)`
`static Throwable`	`timeZoneIdNotSpecifiedForTimestampTypeError()`
`static String`	`toDSOption(String option)`
`static String`	`toSQLConf(String conf)`
`static String`	`toSQLExpr(org.apache.spark.sql.catalyst.expressions.Expression e)`
`static String`	`toSQLId(scala.collection.Seq<String> parts)`
`static String`	`toSQLId(String parts)`
`static String`	`toSQLStmt(String text)`
`static String`	`toSQLType(DataType t)`
`static String`	`toSQLType(String text)`
`static String`	`toSQLValue(Object v, DataType t)`
`static Throwable`	`transactionUnsupportedByJdbcServerError()`
`static Throwable`	`transformationsAndActionsNotInvokedByDriverError()`
`static Throwable`	`truncateMultiPartitionUnsupportedError(String tableName)`
`static Throwable`	`typeUnsupportedError(DataType dataType)`
`static Throwable`	`unableToCreateDatabaseAsFailedToCreateDirectoryError(org.apache.spark.sql.catalyst.catalog.CatalogDatabase dbDefinition, java.io.IOException e)`
`static Throwable`	`unableToCreatePartitionPathError(org.apache.hadoop.fs.Path partitionPath, java.io.IOException e)`
`static Throwable`	`unableToCreateTableAsFailedToCreateDirectoryError(String table, org.apache.hadoop.fs.Path defaultTableLocation, java.io.IOException e)`
`static Throwable`	`unableToDeletePartitionPathError(org.apache.hadoop.fs.Path partitionPath, java.io.IOException e)`
`static Throwable`	`unableToDropDatabaseAsFailedToDeleteDirectoryError(org.apache.spark.sql.catalyst.catalog.CatalogDatabase dbDefinition, java.io.IOException e)`
`static Throwable`	`unableToDropTableAsFailedToDeleteDirectoryError(String table, org.apache.hadoop.fs.Path dir, java.io.IOException e)`
`static Throwable`	`unableToRenamePartitionPathError(org.apache.hadoop.fs.Path oldPartPath, java.io.IOException e)`
`static Throwable`	`unableToRenameTableAsFailedToRenameDirectoryError(String oldName, String newName, org.apache.hadoop.fs.Path oldDir, java.io.IOException e)`
`static ArithmeticException`	`unaryMinusCauseOverflowError(int originValue)`
`static Throwable`	`unexpectedAccumulableUpdateValueError(Object o)`
`static Throwable`	`unexpectedOperatorInCorrelatedSubquery(org.apache.spark.sql.catalyst.plans.logical.LogicalPlan op, String pos)`
`static RuntimeException`	`unexpectedValueForLengthInFunctionError(String prettyName)`
`static RuntimeException`	`unexpectedValueForStartInFunctionError(String prettyName)`
`static Throwable`	`unexpectedWindowFunctionFrameError(String frame)`
`static Throwable`	`unionArrayWithElementsExceedLimitError(int length)`
`static Throwable`	`unknownColumnError(String unknownColumn)`
`static Throwable`	`unreachableError(String err)`
`static Throwable`	`unrecognizedCompressionSchemaTypeIDError(int typeId)`
`static Throwable`	`unrecognizedFileFormatError(String format)`
`static Throwable`	`unrecognizedSqlTypeError(int sqlType)`
`static Throwable`	`unscaledValueTooLargeForPrecisionError()`
`static Throwable`	`unsupportedArrayElementTypeBasedOnBinaryError(DataType dt)`
`static Throwable`	`unsupportedArrayTypeError(Class<?> clazz)`
`static Throwable`	`unsupportedCreateNamespaceCommentError()`
`static Throwable`	`unsupportedDataTypeError(String dt)`
`static Throwable`	`unsupportedDropNamespaceRestrictError()`
`static Throwable`	`unsupportedEncoderError()`
`static Throwable`	`unsupportedFieldNameError(String fieldName)`
`static Throwable`	`unsupportedHiveMetastoreVersionError(String version, String key)`
`static Throwable`	`unsupportedJavaTypeError(Class<?> clazz)`
`static Throwable`	`unsupportedJdbcTypeError(String content)`
`static Throwable`	`unsupportedNaturalJoinTypeError(org.apache.spark.sql.catalyst.plans.JoinType joinType)`
`static Throwable`	`unsupportedOperandTypeForSizeFunctionError(DataType dataType)`
`static Throwable`	`unsupportedOperationExceptionError()`
`static Throwable`	`unsupportedOperationForDataTypeError(DataType dataType)`
`static Throwable`	`unsupportedPartitionTransformError(Transform transform)`
`static Throwable`	`unsupportedRemoveNamespaceCommentError()`
`static Throwable`	`unsupportedRoundingMode(scala.Enumeration.Value roundMode)`
`static Throwable`	`unsupportedSchemaColumnConvertError(String filePath, String column, String logicalType, String physicalType, Exception e)`
`static Throwable`	`unsupportedTableChangeError(IllegalArgumentException e)`
`static Throwable`	`unsupportedTableWritesError(Identifier ident)`
`static Throwable`	`unsupportedTypeError(DataType dataType)`
`static Throwable`	`unsupportedUpdateColumnNullabilityError()`
`static Throwable`	`unsupportedUserSpecifiedSchemaError()`
`static Throwable`	`useDictionaryEncodingWhenDictionaryOverflowError()`
`static Throwable`	`userDefinedTypeNotAnnotatedAndRegisteredError(UserDefinedType<?> udt)`
`static Throwable`	`userSpecifiedSchemaUnsupportedByDataSourceError(TableProvider provider)`
`static Throwable`	`valueIsNullError(int index)`
`static Throwable`	`writePartitionExceedConfigSizeWhenDynamicPartitionError(int numWrittenParts, int maxDynamicPartitions, String maxDynamicPartitionsKey)`
`static Throwable`	`writeUnsupportedForBinaryFileDataSourceError()`
`static Throwable`	`writingJobAbortedError(Throwable e)`
`static Throwable`	`writingJobFailedError(Throwable cause)`

Methods inherited from class Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail
- QueryExecutionErrors
```
public QueryExecutionErrors()
```

Method Detail

cannotEvaluateExpressionError

public static Throwable cannotEvaluateExpressionError(org.apache.spark.sql.catalyst.expressions.Expression expression)

cannotGenerateCodeForExpressionError

public static Throwable cannotGenerateCodeForExpressionError(org.apache.spark.sql.catalyst.expressions.Expression expression)

cannotTerminateGeneratorError

public static Throwable cannotTerminateGeneratorError(org.apache.spark.sql.catalyst.analysis.UnresolvedGenerator generator)

castingCauseOverflowError

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

castingCauseOverflowErrorInTableInsert

public static ArithmeticException castingCauseOverflowErrorInTableInsert(DataType from,
                                                                         DataType to,
                                                                         String columnName)

cannotChangeDecimalPrecisionError

public static ArithmeticException cannotChangeDecimalPrecisionError(Decimal value,
                                                                    int decimalPrecision,
                                                                    int decimalScale,
                                                                    String context)

invalidInputInCastToDatetimeError

public static Throwable invalidInputInCastToDatetimeError(Object value,
                                                          DataType from,
                                                          DataType to,
                                                          String errorContext)

invalidInputSyntaxForBooleanError

public static org.apache.spark.SparkRuntimeException invalidInputSyntaxForBooleanError(org.apache.spark.unsafe.types.UTF8String s,
                                                                                       String errorContext)

invalidInputInCastToNumberError

public static org.apache.spark.SparkNumberFormatException invalidInputInCastToNumberError(DataType to,
                                                                                          org.apache.spark.unsafe.types.UTF8String s,
                                                                                          String errorContext)

cannotCastFromNullTypeError

public static Throwable cannotCastFromNullTypeError(DataType to)

cannotCastError

public static Throwable cannotCastError(DataType from,
                                        DataType to)

cannotParseDecimalError

public static Throwable cannotParseDecimalError()

dataTypeUnsupportedError

public static Throwable dataTypeUnsupportedError(String dataType,
                                                 String failure)

failedExecuteUserDefinedFunctionError

public static Throwable failedExecuteUserDefinedFunctionError(String funcCls,
                                                              String inputTypes,
                                                              String outputType,
                                                              Throwable e)

divideByZeroError

public static ArithmeticException divideByZeroError(String context)

invalidArrayIndexError

public static ArrayIndexOutOfBoundsException invalidArrayIndexError(int index,
                                                                    int numElements)

invalidInputIndexError

public static ArrayIndexOutOfBoundsException invalidInputIndexError(int index,
                                                                    int numElements)

invalidElementAtIndexError

public static ArrayIndexOutOfBoundsException invalidElementAtIndexError(int index,
                                                                        int numElements)

mapKeyNotExistError

public static java.util.NoSuchElementException mapKeyNotExistError(Object key,
                                                                   DataType dataType,
                                                                   String context)

inputTypeUnsupportedError

public static Throwable inputTypeUnsupportedError(DataType dataType)

invalidFractionOfSecondError

public static java.time.DateTimeException invalidFractionOfSecondError()

ansiDateTimeParseError

public static java.time.format.DateTimeParseException ansiDateTimeParseError(java.time.format.DateTimeParseException e)

ansiDateTimeError

public static java.time.DateTimeException ansiDateTimeError(java.time.DateTimeException e)

ansiParseError

public static java.text.ParseException ansiParseError(java.text.ParseException e)

ansiIllegalArgumentError

public static IllegalArgumentException ansiIllegalArgumentError(String message)

ansiIllegalArgumentError

public static IllegalArgumentException ansiIllegalArgumentError(IllegalArgumentException e)

overflowInSumOfDecimalError

public static ArithmeticException overflowInSumOfDecimalError(String context)

overflowInIntegralDivideError

public static ArithmeticException overflowInIntegralDivideError(String context)

mapSizeExceedArraySizeWhenZipMapError

public static RuntimeException mapSizeExceedArraySizeWhenZipMapError(int size)

copyNullFieldNotAllowedError

public static Throwable copyNullFieldNotAllowedError()

literalTypeUnsupportedError

public static RuntimeException literalTypeUnsupportedError(Object v)

pivotColumnUnsupportedError

public static RuntimeException pivotColumnUnsupportedError(Object v,
                                                           DataType dataType)

noDefaultForDataTypeError

public static RuntimeException noDefaultForDataTypeError(DataType dataType)

doGenCodeOfAliasShouldNotBeCalledError

public static Throwable doGenCodeOfAliasShouldNotBeCalledError()

orderedOperationUnsupportedByDataTypeError

public static Throwable orderedOperationUnsupportedByDataTypeError(DataType dataType)

regexGroupIndexLessThanZeroError

public static Throwable regexGroupIndexLessThanZeroError()

regexGroupIndexExceedGroupCountError

public static Throwable regexGroupIndexExceedGroupCountError(int groupCount,
                                                             int groupIndex)

invalidUrlError

public static Throwable invalidUrlError(org.apache.spark.unsafe.types.UTF8String url,
                                        java.net.URISyntaxException e)

dataTypeOperationUnsupportedError

public static Throwable dataTypeOperationUnsupportedError()

mergeUnsupportedByWindowFunctionError

public static Throwable mergeUnsupportedByWindowFunctionError()

dataTypeUnexpectedError

public static Throwable dataTypeUnexpectedError(DataType dataType)

typeUnsupportedError

public static Throwable typeUnsupportedError(DataType dataType)

negativeValueUnexpectedError

public static Throwable negativeValueUnexpectedError(org.apache.spark.sql.catalyst.expressions.Expression frequencyExpression)

addNewFunctionMismatchedWithFunctionError

public static Throwable addNewFunctionMismatchedWithFunctionError(String funcName)

cannotGenerateCodeForUncomparableTypeError

public static Throwable cannotGenerateCodeForUncomparableTypeError(String codeType,
                                                                   DataType dataType)

cannotGenerateCodeForUnsupportedTypeError

public static Throwable cannotGenerateCodeForUnsupportedTypeError(DataType dataType)

cannotInterpolateClassIntoCodeBlockError

public static Throwable cannotInterpolateClassIntoCodeBlockError(Object arg)

customCollectionClsNotResolvedError

public static Throwable customCollectionClsNotResolvedError()

classUnsupportedByMapObjectsError

public static RuntimeException classUnsupportedByMapObjectsError(Class<?> cls)

nullAsMapKeyNotAllowedError

public static RuntimeException nullAsMapKeyNotAllowedError()

methodNotDeclaredError

public static Throwable methodNotDeclaredError(String name)

constructorNotFoundError

public static Throwable constructorNotFoundError(String cls)

primaryConstructorNotFoundError

public static Throwable primaryConstructorNotFoundError(Class<?> cls)

unsupportedNaturalJoinTypeError

public static Throwable unsupportedNaturalJoinTypeError(org.apache.spark.sql.catalyst.plans.JoinType joinType)

notExpectedUnresolvedEncoderError

public static Throwable notExpectedUnresolvedEncoderError(org.apache.spark.sql.catalyst.expressions.AttributeReference attr)

unsupportedEncoderError

public static Throwable unsupportedEncoderError()

notOverrideExpectedMethodsError

public static Throwable notOverrideExpectedMethodsError(String className,
                                                        String m1,
                                                        String m2)

failToConvertValueToJsonError

public static Throwable failToConvertValueToJsonError(Object value,
                                                      Class<?> cls,
                                                      DataType dataType)

unexpectedOperatorInCorrelatedSubquery

public static Throwable unexpectedOperatorInCorrelatedSubquery(org.apache.spark.sql.catalyst.plans.logical.LogicalPlan op,
                                                               String pos)

unreachableError

public static Throwable unreachableError(String err)

unsupportedRoundingMode

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

resolveCannotHandleNestedSchema

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

inputExternalRowCannotBeNullError

public static RuntimeException inputExternalRowCannotBeNullError()

fieldCannotBeNullMsg

public static String fieldCannotBeNullMsg(int index,
                                          String fieldName)

fieldCannotBeNullError

public static RuntimeException fieldCannotBeNullError(int index,
                                                      String fieldName)

unableToCreateDatabaseAsFailedToCreateDirectoryError

public static Throwable unableToCreateDatabaseAsFailedToCreateDirectoryError(org.apache.spark.sql.catalyst.catalog.CatalogDatabase dbDefinition,
                                                                             java.io.IOException e)

unableToDropDatabaseAsFailedToDeleteDirectoryError

public static Throwable unableToDropDatabaseAsFailedToDeleteDirectoryError(org.apache.spark.sql.catalyst.catalog.CatalogDatabase dbDefinition,
                                                                           java.io.IOException e)

unableToCreateTableAsFailedToCreateDirectoryError

public static Throwable unableToCreateTableAsFailedToCreateDirectoryError(String table,
                                                                          org.apache.hadoop.fs.Path defaultTableLocation,
                                                                          java.io.IOException e)

unableToDeletePartitionPathError

public static Throwable unableToDeletePartitionPathError(org.apache.hadoop.fs.Path partitionPath,
                                                         java.io.IOException e)

unableToDropTableAsFailedToDeleteDirectoryError

public static Throwable unableToDropTableAsFailedToDeleteDirectoryError(String table,
                                                                        org.apache.hadoop.fs.Path dir,
                                                                        java.io.IOException e)

unableToRenameTableAsFailedToRenameDirectoryError

public static Throwable unableToRenameTableAsFailedToRenameDirectoryError(String oldName,
                                                                          String newName,
                                                                          org.apache.hadoop.fs.Path oldDir,
                                                                          java.io.IOException e)

unableToCreatePartitionPathError

public static Throwable unableToCreatePartitionPathError(org.apache.hadoop.fs.Path partitionPath,
                                                         java.io.IOException e)

unableToRenamePartitionPathError

public static Throwable unableToRenamePartitionPathError(org.apache.hadoop.fs.Path oldPartPath,
                                                         java.io.IOException e)

methodNotImplementedError

public static Throwable methodNotImplementedError(String methodName)

tableStatsNotSpecifiedError

public static Throwable tableStatsNotSpecifiedError()

arithmeticOverflowError

public static ArithmeticException arithmeticOverflowError(ArithmeticException e)

arithmeticOverflowError

public static ArithmeticException arithmeticOverflowError(String message,
                                                          String hint,
                                                          String errorContext)

unaryMinusCauseOverflowError

public static ArithmeticException unaryMinusCauseOverflowError(int originValue)

binaryArithmeticCauseOverflowError

public static ArithmeticException binaryArithmeticCauseOverflowError(short eval1,
                                                                     String symbol,
                                                                     short eval2)

failedSplitSubExpressionMsg

public static String failedSplitSubExpressionMsg(int length)

failedSplitSubExpressionError

public static Throwable failedSplitSubExpressionError(int length)

failedToCompileMsg

public static String failedToCompileMsg(Exception e)

internalCompilerError

public static Throwable internalCompilerError(org.codehaus.janino.InternalCompilerException e)

compilerError

public static Throwable compilerError(org.codehaus.commons.compiler.CompileException e)

unsupportedTableChangeError

public static Throwable unsupportedTableChangeError(IllegalArgumentException e)

notADatasourceRDDPartitionError

public static Throwable notADatasourceRDDPartitionError(Partition split)

dataPathNotSpecifiedError

public static Throwable dataPathNotSpecifiedError()

createStreamingSourceNotSpecifySchemaError

public static Throwable createStreamingSourceNotSpecifySchemaError()

streamedOperatorUnsupportedByDataSourceError

public static Throwable streamedOperatorUnsupportedByDataSourceError(String className,
                                                                     String operator)

multiplePathsSpecifiedError

public static Throwable multiplePathsSpecifiedError(scala.collection.Seq<String> allPaths)

failedToFindDataSourceError

public static Throwable failedToFindDataSourceError(String provider,
                                                    Throwable error)

removedClassInSpark2Error

public static Throwable removedClassInSpark2Error(String className,
                                                  Throwable e)

incompatibleDataSourceRegisterError

public static Throwable incompatibleDataSourceRegisterError(Throwable e)

unrecognizedFileFormatError

public static Throwable unrecognizedFileFormatError(String format)

sparkUpgradeInReadingDatesError

public static org.apache.spark.SparkUpgradeException sparkUpgradeInReadingDatesError(String format,
                                                                                     String config,
                                                                                     String option)

sparkUpgradeInWritingDatesError

public static org.apache.spark.SparkUpgradeException sparkUpgradeInWritingDatesError(String format,
                                                                                     String config)

buildReaderUnsupportedForFileFormatError

public static Throwable buildReaderUnsupportedForFileFormatError(String format)

jobAbortedError

public static Throwable jobAbortedError(Throwable cause)

taskFailedWhileWritingRowsError

public static Throwable taskFailedWhileWritingRowsError(Throwable cause)

readCurrentFileNotFoundError

public static Throwable readCurrentFileNotFoundError(java.io.FileNotFoundException e)

saveModeUnsupportedError

public static Throwable saveModeUnsupportedError(Object saveMode,
                                                 boolean pathExists)

cannotClearOutputDirectoryError

public static Throwable cannotClearOutputDirectoryError(org.apache.hadoop.fs.Path staticPrefixPath)

cannotClearPartitionDirectoryError

public static Throwable cannotClearPartitionDirectoryError(org.apache.hadoop.fs.Path path)

failedToCastValueToDataTypeForPartitionColumnError

public static Throwable failedToCastValueToDataTypeForPartitionColumnError(String value,
                                                                           DataType dataType,
                                                                           String columnName)

endOfStreamError

public static Throwable endOfStreamError()

fallbackV1RelationReportsInconsistentSchemaError

public static Throwable fallbackV1RelationReportsInconsistentSchemaError(StructType v2Schema,
                                                                         StructType v1Schema)

noRecordsFromEmptyDataReaderError

public static Throwable noRecordsFromEmptyDataReaderError()

fileNotFoundError

public static Throwable fileNotFoundError(java.io.FileNotFoundException e)

unsupportedSchemaColumnConvertError

public static Throwable unsupportedSchemaColumnConvertError(String filePath,
                                                            String column,
                                                            String logicalType,
                                                            String physicalType,
                                                            Exception e)

cannotReadFilesError

public static Throwable cannotReadFilesError(Throwable e,
                                             String path)

cannotCreateColumnarReaderError

public static Throwable cannotCreateColumnarReaderError()

invalidNamespaceNameError

public static Throwable invalidNamespaceNameError(String[] namespace)

unsupportedPartitionTransformError

public static Throwable unsupportedPartitionTransformError(Transform transform)

missingDatabaseLocationError

public static Throwable missingDatabaseLocationError()

cannotRemoveReservedPropertyError

public static Throwable cannotRemoveReservedPropertyError(String property)

namespaceNotEmptyError

public static Throwable namespaceNotEmptyError(String[] namespace)

writingJobFailedError

public static Throwable writingJobFailedError(Throwable cause)

writingJobAbortedError

public static Throwable writingJobAbortedError(Throwable e)

commitDeniedError

public static Throwable commitDeniedError(int partId,
                                          long taskId,
                                          int attemptId,
                                          int stageId,
                                          int stageAttempt)

unsupportedTableWritesError

public static Throwable unsupportedTableWritesError(Identifier ident)

cannotCreateJDBCTableWithPartitionsError

public static Throwable cannotCreateJDBCTableWithPartitionsError()

unsupportedUserSpecifiedSchemaError

public static Throwable unsupportedUserSpecifiedSchemaError()

writeUnsupportedForBinaryFileDataSourceError

public static Throwable writeUnsupportedForBinaryFileDataSourceError()

fileLengthExceedsMaxLengthError

public static Throwable fileLengthExceedsMaxLengthError(org.apache.hadoop.fs.FileStatus status,
                                                        int maxLength)

unsupportedFieldNameError

public static Throwable unsupportedFieldNameError(String fieldName)

cannotSpecifyBothJdbcTableNameAndQueryError

public static Throwable cannotSpecifyBothJdbcTableNameAndQueryError(String jdbcTableName,
                                                                    String jdbcQueryString)

missingJdbcTableNameAndQueryError

public static Throwable missingJdbcTableNameAndQueryError(String jdbcTableName,
                                                          String jdbcQueryString)

emptyOptionError

public static Throwable emptyOptionError(String optionName)

invalidJdbcTxnIsolationLevelError

public static Throwable invalidJdbcTxnIsolationLevelError(String jdbcTxnIsolationLevel,
                                                          String value)

cannotGetJdbcTypeError

public static Throwable cannotGetJdbcTypeError(DataType dt)

unrecognizedSqlTypeError

public static Throwable unrecognizedSqlTypeError(int sqlType)

unsupportedJdbcTypeError

public static Throwable unsupportedJdbcTypeError(String content)

unsupportedArrayElementTypeBasedOnBinaryError

public static Throwable unsupportedArrayElementTypeBasedOnBinaryError(DataType dt)

nestedArraysUnsupportedError

public static Throwable nestedArraysUnsupportedError()

cannotTranslateNonNullValueForFieldError

public static Throwable cannotTranslateNonNullValueForFieldError(int pos)

invalidJdbcNumPartitionsError

public static Throwable invalidJdbcNumPartitionsError(int n,
                                                      String jdbcNumPartitions)

transactionUnsupportedByJdbcServerError

public static Throwable transactionUnsupportedByJdbcServerError()

dataTypeUnsupportedYetError

public static Throwable dataTypeUnsupportedYetError(DataType dataType)

unsupportedOperationForDataTypeError

public static Throwable unsupportedOperationForDataTypeError(DataType dataType)

inputFilterNotFullyConvertibleError

public static Throwable inputFilterNotFullyConvertibleError(String owner)

cannotReadFooterForFileError

public static Throwable cannotReadFooterForFileError(org.apache.hadoop.fs.Path file,
                                                     java.io.IOException e)

cannotReadFooterForFileError

public static Throwable cannotReadFooterForFileError(org.apache.hadoop.fs.FileStatus file,
                                                     RuntimeException e)

foundDuplicateFieldInCaseInsensitiveModeError

public static Throwable foundDuplicateFieldInCaseInsensitiveModeError(String requiredFieldName,
                                                                      String matchedOrcFields)

foundDuplicateFieldInFieldIdLookupModeError

public static Throwable foundDuplicateFieldInFieldIdLookupModeError(int requiredId,
                                                                    String matchedFields)

failedToMergeIncompatibleSchemasError

public static Throwable failedToMergeIncompatibleSchemasError(StructType left,
                                                              StructType right,
                                                              Throwable e)

ddlUnsupportedTemporarilyError

public static Throwable ddlUnsupportedTemporarilyError(String ddl)

operatingOnCanonicalizationPlanError

public static Throwable operatingOnCanonicalizationPlanError()

executeBroadcastTimeoutError

public static Throwable executeBroadcastTimeoutError(long timeout,
                                                     scala.Option<java.util.concurrent.TimeoutException> ex)

cannotCompareCostWithTargetCostError

public static Throwable cannotCompareCostWithTargetCostError(String cost)

unsupportedDataTypeError

public static Throwable unsupportedDataTypeError(String dt)

notSupportTypeError

public static Throwable notSupportTypeError(DataType dataType)

notSupportNonPrimitiveTypeError

public static Throwable notSupportNonPrimitiveTypeError()

unsupportedTypeError

public static Throwable unsupportedTypeError(DataType dataType)

useDictionaryEncodingWhenDictionaryOverflowError

public static Throwable useDictionaryEncodingWhenDictionaryOverflowError()

endOfIteratorError

public static Throwable endOfIteratorError()

cannotAllocateMemoryToGrowBytesToBytesMapError

public static Throwable cannotAllocateMemoryToGrowBytesToBytesMapError()

cannotAcquireMemoryToBuildLongHashedRelationError

public static Throwable cannotAcquireMemoryToBuildLongHashedRelationError(long size,
                                                                          long got)

cannotAcquireMemoryToBuildUnsafeHashedRelationError

public static Throwable cannotAcquireMemoryToBuildUnsafeHashedRelationError()

rowLargerThan256MUnsupportedError

public static Throwable rowLargerThan256MUnsupportedError()

cannotBuildHashedRelationWithUniqueKeysExceededError

public static Throwable cannotBuildHashedRelationWithUniqueKeysExceededError()

cannotBuildHashedRelationLargerThan8GError

public static Throwable cannotBuildHashedRelationLargerThan8GError()

failedToPushRowIntoRowQueueError

public static Throwable failedToPushRowIntoRowQueueError(String rowQueue)

unexpectedWindowFunctionFrameError

public static Throwable unexpectedWindowFunctionFrameError(String frame)

cannotParseStatisticAsPercentileError

public static Throwable cannotParseStatisticAsPercentileError(String stats,
                                                              NumberFormatException e)

statisticNotRecognizedError

public static Throwable statisticNotRecognizedError(String stats)

unknownColumnError

public static Throwable unknownColumnError(String unknownColumn)

unexpectedAccumulableUpdateValueError

public static Throwable unexpectedAccumulableUpdateValueError(Object o)

unscaledValueTooLargeForPrecisionError

public static Throwable unscaledValueTooLargeForPrecisionError()

decimalPrecisionExceedsMaxPrecisionError

public static Throwable decimalPrecisionExceedsMaxPrecisionError(int precision,
                                                                 int maxPrecision)

outOfDecimalTypeRangeError

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

unsupportedArrayTypeError

public static Throwable unsupportedArrayTypeError(Class<?> clazz)

unsupportedJavaTypeError

public static Throwable unsupportedJavaTypeError(Class<?> clazz)

failedParsingStructTypeError

public static Throwable failedParsingStructTypeError(String raw)

failedMergingFieldsError

public static Throwable failedMergingFieldsError(String leftName,
                                                 String rightName,
                                                 Throwable e)

cannotMergeDecimalTypesWithIncompatiblePrecisionAndScaleError

public static Throwable cannotMergeDecimalTypesWithIncompatiblePrecisionAndScaleError(int leftPrecision,
                                                                                      int rightPrecision,
                                                                                      int leftScale,
                                                                                      int rightScale)

cannotMergeDecimalTypesWithIncompatiblePrecisionError

public static Throwable cannotMergeDecimalTypesWithIncompatiblePrecisionError(int leftPrecision,
                                                                              int rightPrecision)

cannotMergeDecimalTypesWithIncompatibleScaleError

public static Throwable cannotMergeDecimalTypesWithIncompatibleScaleError(int leftScale,
                                                                          int rightScale)

cannotMergeIncompatibleDataTypesError

public static Throwable cannotMergeIncompatibleDataTypesError(DataType left,
                                                              DataType right)

exceedMapSizeLimitError

public static Throwable exceedMapSizeLimitError(int size)

duplicateMapKeyFoundError

public static Throwable duplicateMapKeyFoundError(Object key)

mapDataKeyArrayLengthDiffersFromValueArrayLengthError

public static Throwable mapDataKeyArrayLengthDiffersFromValueArrayLengthError()

fieldDiffersFromDerivedLocalDateError

public static Throwable fieldDiffersFromDerivedLocalDateError(java.time.temporal.ChronoField field,
                                                              int actual,
                                                              int expected,
                                                              java.time.LocalDate candidate)

failToParseDateTimeInNewParserError

public static Throwable failToParseDateTimeInNewParserError(String s,
                                                            Throwable e)

failToFormatDateTimeInNewFormatterError

public static Throwable failToFormatDateTimeInNewFormatterError(String resultCandidate,
                                                                Throwable e)

failToRecognizePatternAfterUpgradeError

public static Throwable failToRecognizePatternAfterUpgradeError(String pattern,
                                                                Throwable e)

failToRecognizePatternError

public static Throwable failToRecognizePatternError(String pattern,
                                                    Throwable e)

cannotCastToDateTimeError

public static Throwable cannotCastToDateTimeError(Object value,
                                                  DataType from,
                                                  DataType to,
                                                  String errorContext)

registeringStreamingQueryListenerError

public static Throwable registeringStreamingQueryListenerError(Exception e)

concurrentQueryInstanceError

public static Throwable concurrentQueryInstanceError()

cannotParseJsonArraysAsStructsError

public static Throwable cannotParseJsonArraysAsStructsError()

cannotParseStringAsDataTypeError

public static Throwable cannotParseStringAsDataTypeError(com.fasterxml.jackson.core.JsonParser parser,
                                                         com.fasterxml.jackson.core.JsonToken token,
                                                         DataType dataType)

cannotParseStringAsDataTypeError

public static Throwable cannotParseStringAsDataTypeError(String pattern,
                                                         String value,
                                                         DataType dataType)

failToParseEmptyStringForDataTypeError

public static Throwable failToParseEmptyStringForDataTypeError(DataType dataType)

failToParseValueForDataTypeError

public static Throwable failToParseValueForDataTypeError(com.fasterxml.jackson.core.JsonParser parser,
                                                         com.fasterxml.jackson.core.JsonToken token,
                                                         DataType dataType)

rootConverterReturnNullError

public static Throwable rootConverterReturnNullError()

cannotHaveCircularReferencesInBeanClassError

public static Throwable cannotHaveCircularReferencesInBeanClassError(Class<?> clazz)

cannotHaveCircularReferencesInClassError

public static Throwable cannotHaveCircularReferencesInClassError(String t)

cannotUseInvalidJavaIdentifierAsFieldNameError

public static Throwable cannotUseInvalidJavaIdentifierAsFieldNameError(String fieldName,
                                                                       org.apache.spark.sql.catalyst.WalkedTypePath walkedTypePath)

cannotFindEncoderForTypeError

public static Throwable cannotFindEncoderForTypeError(String tpe,
                                                      org.apache.spark.sql.catalyst.WalkedTypePath walkedTypePath)

attributesForTypeUnsupportedError

public static Throwable attributesForTypeUnsupportedError(org.apache.spark.sql.catalyst.ScalaReflection.Schema schema)

schemaForTypeUnsupportedError

public static Throwable schemaForTypeUnsupportedError(String tpe)

cannotFindConstructorForTypeError

public static Throwable cannotFindConstructorForTypeError(String tpe)

paramExceedOneCharError

public static Throwable paramExceedOneCharError(String paramName)

paramIsNotIntegerError

public static Throwable paramIsNotIntegerError(String paramName,
                                               String value)

paramIsNotBooleanValueError

public static Throwable paramIsNotBooleanValueError(String paramName)

foundNullValueForNotNullableFieldError

public static Throwable foundNullValueForNotNullableFieldError(String name)

malformedCSVRecordError

public static Throwable malformedCSVRecordError()

elementsOfTupleExceedLimitError

public static Throwable elementsOfTupleExceedLimitError()

expressionDecodingError

public static Throwable expressionDecodingError(Exception e,
                                                scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> expressions)

expressionEncodingError

public static Throwable expressionEncodingError(Exception e,
                                                scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> expressions)

classHasUnexpectedSerializerError

public static Throwable classHasUnexpectedSerializerError(String clsName,
                                                          org.apache.spark.sql.catalyst.expressions.Expression objSerializer)

cannotGetOuterPointerForInnerClassError

public static Throwable cannotGetOuterPointerForInnerClassError(Class<?> innerCls)

userDefinedTypeNotAnnotatedAndRegisteredError

public static Throwable userDefinedTypeNotAnnotatedAndRegisteredError(UserDefinedType<?> udt)

unsupportedOperandTypeForSizeFunctionError

public static Throwable unsupportedOperandTypeForSizeFunctionError(DataType dataType)

unexpectedValueForStartInFunctionError

public static RuntimeException unexpectedValueForStartInFunctionError(String prettyName)

unexpectedValueForLengthInFunctionError

public static RuntimeException unexpectedValueForLengthInFunctionError(String prettyName)

sqlArrayIndexNotStartAtOneError

public static ArrayIndexOutOfBoundsException sqlArrayIndexNotStartAtOneError()

concatArraysWithElementsExceedLimitError

public static Throwable concatArraysWithElementsExceedLimitError(long numberOfElements)

flattenArraysWithElementsExceedLimitError

public static Throwable flattenArraysWithElementsExceedLimitError(long numberOfElements)

createArrayWithElementsExceedLimitError

public static RuntimeException createArrayWithElementsExceedLimitError(Object count)

unionArrayWithElementsExceedLimitError

public static Throwable unionArrayWithElementsExceedLimitError(int length)

initialTypeNotTargetDataTypeError

public static Throwable initialTypeNotTargetDataTypeError(DataType dataType,
                                                          String target)

initialTypeNotTargetDataTypesError

public static Throwable initialTypeNotTargetDataTypesError(DataType dataType)

cannotConvertColumnToJSONError

public static Throwable cannotConvertColumnToJSONError(String name,
                                                       DataType dataType)

malformedRecordsDetectedInSchemaInferenceError

public static Throwable malformedRecordsDetectedInSchemaInferenceError(Throwable e)

malformedJSONError

public static Throwable malformedJSONError()

malformedRecordsDetectedInSchemaInferenceError

public static Throwable malformedRecordsDetectedInSchemaInferenceError(DataType dataType)

cannotRewriteDomainJoinWithConditionsError

public static Throwable cannotRewriteDomainJoinWithConditionsError(scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> conditions,
                                                                   org.apache.spark.sql.catalyst.plans.logical.DomainJoin d)

decorrelateInnerQueryThroughPlanUnsupportedError

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

methodCalledInAnalyzerNotAllowedError

public static Throwable methodCalledInAnalyzerNotAllowedError()

cannotSafelyMergeSerdePropertiesError

public static Throwable cannotSafelyMergeSerdePropertiesError(scala.collection.immutable.Map<String,String> props1,
                                                              scala.collection.immutable.Map<String,String> props2,
                                                              scala.collection.immutable.Set<String> conflictKeys)

pairUnsupportedAtFunctionError

public static Throwable pairUnsupportedAtFunctionError(org.apache.spark.sql.catalyst.plans.logical.statsEstimation.ValueInterval r1,
                                                       org.apache.spark.sql.catalyst.plans.logical.statsEstimation.ValueInterval r2,
                                                       String function)

onceStrategyIdempotenceIsBrokenForBatchError

public static <TreeType extends org.apache.spark.sql.catalyst.trees.TreeNode<?>> Throwable onceStrategyIdempotenceIsBrokenForBatchError(String batchName,
                                                                                                                                        TreeType plan,
                                                                                                                                        TreeType reOptimized)

structuralIntegrityOfInputPlanIsBrokenInClassError

public static Throwable structuralIntegrityOfInputPlanIsBrokenInClassError(String className)

structuralIntegrityIsBrokenAfterApplyingRuleError

public static Throwable structuralIntegrityIsBrokenAfterApplyingRuleError(String ruleName,
                                                                          String batchName)

ruleIdNotFoundForRuleError

public static Throwable ruleIdNotFoundForRuleError(String ruleName)

cannotCreateArrayWithElementsExceedLimitError

public static Throwable cannotCreateArrayWithElementsExceedLimitError(long numElements,
                                                                      String additionalErrorMessage)

indexOutOfBoundsOfArrayDataError

public static Throwable indexOutOfBoundsOfArrayDataError(int idx)

malformedRecordsDetectedInRecordParsingError

public static Throwable malformedRecordsDetectedInRecordParsingError(org.apache.spark.sql.catalyst.util.BadRecordException e)

remoteOperationsUnsupportedError

public static Throwable remoteOperationsUnsupportedError()

invalidKerberosConfigForHiveServer2Error

public static Throwable invalidKerberosConfigForHiveServer2Error()

parentSparkUIToAttachTabNotFoundError

public static Throwable parentSparkUIToAttachTabNotFoundError()

inferSchemaUnsupportedForHiveError

public static Throwable inferSchemaUnsupportedForHiveError()

requestedPartitionsMismatchTablePartitionsError

public static Throwable requestedPartitionsMismatchTablePartitionsError(org.apache.spark.sql.catalyst.catalog.CatalogTable table,
                                                                        scala.collection.immutable.Map<String,scala.Option<String>> partition)

dynamicPartitionKeyNotAmongWrittenPartitionPathsError

public static Throwable dynamicPartitionKeyNotAmongWrittenPartitionPathsError(String key)

cannotRemovePartitionDirError

public static Throwable cannotRemovePartitionDirError(org.apache.hadoop.fs.Path partitionPath)

cannotCreateStagingDirError

public static Throwable cannotCreateStagingDirError(String message,
                                                    java.io.IOException e)

serDeInterfaceNotFoundError

public static Throwable serDeInterfaceNotFoundError(NoClassDefFoundError e)

convertHiveTableToCatalogTableError

public static Throwable convertHiveTableToCatalogTableError(SparkException e,
                                                            String dbName,
                                                            String tableName)

cannotRecognizeHiveTypeError

public static Throwable cannotRecognizeHiveTypeError(org.apache.spark.sql.catalyst.parser.ParseException e,
                                                     String fieldType,
                                                     String fieldName)

getTablesByTypeUnsupportedByHiveVersionError

public static Throwable getTablesByTypeUnsupportedByHiveVersionError()

dropTableWithPurgeUnsupportedError

public static Throwable dropTableWithPurgeUnsupportedError()

alterTableWithDropPartitionAndPurgeUnsupportedError

public static Throwable alterTableWithDropPartitionAndPurgeUnsupportedError()

invalidPartitionFilterError

public static Throwable invalidPartitionFilterError()

getPartitionMetadataByFilterError

public static Throwable getPartitionMetadataByFilterError(java.lang.reflect.InvocationTargetException e)

unsupportedHiveMetastoreVersionError

public static Throwable unsupportedHiveMetastoreVersionError(String version,
                                                             String key)

loadHiveClientCausesNoClassDefFoundError

public static Throwable loadHiveClientCausesNoClassDefFoundError(NoClassDefFoundError cnf,
                                                                 scala.collection.Seq<java.net.URL> execJars,
                                                                 String key,
                                                                 java.lang.reflect.InvocationTargetException e)

cannotFetchTablesOfDatabaseError

public static Throwable cannotFetchTablesOfDatabaseError(String dbName,
                                                         Exception e)

illegalLocationClauseForViewPartitionError

public static Throwable illegalLocationClauseForViewPartitionError()

renamePathAsExistsPathError

public static Throwable renamePathAsExistsPathError(org.apache.hadoop.fs.Path srcPath,
                                                    org.apache.hadoop.fs.Path dstPath)

renameAsExistsPathError

public static Throwable renameAsExistsPathError(org.apache.hadoop.fs.Path dstPath)

renameSrcPathNotFoundError

public static Throwable renameSrcPathNotFoundError(org.apache.hadoop.fs.Path srcPath)

failedRenameTempFileError

public static Throwable failedRenameTempFileError(org.apache.hadoop.fs.Path srcPath,
                                                  org.apache.hadoop.fs.Path dstPath)

legacyMetadataPathExistsError

public static Throwable legacyMetadataPathExistsError(org.apache.hadoop.fs.Path metadataPath,
                                                      org.apache.hadoop.fs.Path legacyMetadataPath)

partitionColumnNotFoundInSchemaError

public static Throwable partitionColumnNotFoundInSchemaError(String col,
                                                             StructType schema)

stateNotDefinedOrAlreadyRemovedError

public static Throwable stateNotDefinedOrAlreadyRemovedError()

cannotSetTimeoutDurationError

public static Throwable cannotSetTimeoutDurationError()

cannotGetEventTimeWatermarkError

public static Throwable cannotGetEventTimeWatermarkError()

cannotSetTimeoutTimestampError

public static Throwable cannotSetTimeoutTimestampError()

batchMetadataFileNotFoundError

public static Throwable batchMetadataFileNotFoundError(org.apache.hadoop.fs.Path batchMetadataFile)

multiStreamingQueriesUsingPathConcurrentlyError

public static Throwable multiStreamingQueriesUsingPathConcurrentlyError(String path,
                                                                        org.apache.hadoop.fs.FileAlreadyExistsException e)

addFilesWithAbsolutePathUnsupportedError

public static Throwable addFilesWithAbsolutePathUnsupportedError(String commitProtocol)

microBatchUnsupportedByDataSourceError

public static Throwable microBatchUnsupportedByDataSourceError(String srcName)

cannotExecuteStreamingRelationExecError

public static Throwable cannotExecuteStreamingRelationExecError()

invalidStreamingOutputModeError

public static Throwable invalidStreamingOutputModeError(scala.Option<OutputMode> outputMode)

catalogPluginClassNotFoundError

public static Throwable catalogPluginClassNotFoundError(String name)

catalogPluginClassNotImplementedError

public static Throwable catalogPluginClassNotImplementedError(String name,
                                                              String pluginClassName)

catalogPluginClassNotFoundForCatalogError

public static Throwable catalogPluginClassNotFoundForCatalogError(String name,
                                                                  String pluginClassName,
                                                                  Exception e)

catalogFailToFindPublicNoArgConstructorError

public static Throwable catalogFailToFindPublicNoArgConstructorError(String name,
                                                                     String pluginClassName,
                                                                     Exception e)

catalogFailToCallPublicNoArgConstructorError

public static Throwable catalogFailToCallPublicNoArgConstructorError(String name,
                                                                     String pluginClassName,
                                                                     Exception e)

cannotInstantiateAbstractCatalogPluginClassError

public static Throwable cannotInstantiateAbstractCatalogPluginClassError(String name,
                                                                         String pluginClassName,
                                                                         Exception e)

failedToInstantiateConstructorForCatalogError

public static Throwable failedToInstantiateConstructorForCatalogError(String name,
                                                                      String pluginClassName,
                                                                      Exception e)

noSuchElementExceptionError

public static Throwable noSuchElementExceptionError()

noSuchElementExceptionError

public static Throwable noSuchElementExceptionError(String key)

cannotMutateReadOnlySQLConfError

public static Throwable cannotMutateReadOnlySQLConfError()

cannotCloneOrCopyReadOnlySQLConfError

public static Throwable cannotCloneOrCopyReadOnlySQLConfError()

cannotGetSQLConfInSchedulerEventLoopThreadError

public static Throwable cannotGetSQLConfInSchedulerEventLoopThreadError()

unsupportedOperationExceptionError

public static Throwable unsupportedOperationExceptionError()

nullLiteralsCannotBeCastedError

public static Throwable nullLiteralsCannotBeCastedError(String name)

notUserDefinedTypeError

public static Throwable notUserDefinedTypeError(String name,
                                                String userClass)

cannotLoadUserDefinedTypeError

public static Throwable cannotLoadUserDefinedTypeError(String name,
                                                       String userClass)

timeZoneIdNotSpecifiedForTimestampTypeError

public static Throwable timeZoneIdNotSpecifiedForTimestampTypeError()

notPublicClassError

public static Throwable notPublicClassError(String name)

primitiveTypesNotSupportedError

public static Throwable primitiveTypesNotSupportedError()

fieldIndexOnRowWithoutSchemaError

public static Throwable fieldIndexOnRowWithoutSchemaError()

valueIsNullError

public static Throwable valueIsNullError(int index)

onlySupportDataSourcesProvidingFileFormatError

public static Throwable onlySupportDataSourcesProvidingFileFormatError(String providingClass)

failToSetOriginalPermissionBackError

public static Throwable failToSetOriginalPermissionBackError(org.apache.hadoop.fs.permission.FsPermission permission,
                                                             org.apache.hadoop.fs.Path path,
                                                             Throwable e)

failToSetOriginalACLBackError

public static Throwable failToSetOriginalACLBackError(String aclEntries,
                                                      org.apache.hadoop.fs.Path path,
                                                      Throwable e)

multiFailuresInStageMaterializationError

public static Throwable multiFailuresInStageMaterializationError(Throwable error)

unrecognizedCompressionSchemaTypeIDError

public static Throwable unrecognizedCompressionSchemaTypeIDError(int typeId)

getParentLoggerNotImplementedError

public static Throwable getParentLoggerNotImplementedError(String className)

cannotCreateParquetConverterForTypeError

public static Throwable cannotCreateParquetConverterForTypeError(DecimalType t,
                                                                 String parquetType)

cannotCreateParquetConverterForDecimalTypeError

public static Throwable cannotCreateParquetConverterForDecimalTypeError(DecimalType t,
                                                                        String parquetType)

cannotCreateParquetConverterForDataTypeError

public static Throwable cannotCreateParquetConverterForDataTypeError(DataType t,
                                                                     String parquetType)

cannotAddMultiPartitionsOnNonatomicPartitionTableError

public static Throwable cannotAddMultiPartitionsOnNonatomicPartitionTableError(String tableName)

userSpecifiedSchemaUnsupportedByDataSourceError

public static Throwable userSpecifiedSchemaUnsupportedByDataSourceError(TableProvider provider)

cannotDropMultiPartitionsOnNonatomicPartitionTableError

public static Throwable cannotDropMultiPartitionsOnNonatomicPartitionTableError(String tableName)

truncateMultiPartitionUnsupportedError

public static Throwable truncateMultiPartitionUnsupportedError(String tableName)

overwriteTableByUnsupportedExpressionError

public static Throwable overwriteTableByUnsupportedExpressionError(Table table)

dynamicPartitionOverwriteUnsupportedByTableError

public static Throwable dynamicPartitionOverwriteUnsupportedByTableError(Table table)

failedMergingSchemaError

public static Throwable failedMergingSchemaError(StructType schema,
                                                 SparkException e)

cannotBroadcastTableOverMaxTableRowsError

public static Throwable cannotBroadcastTableOverMaxTableRowsError(long maxBroadcastTableRows,
                                                                  long numRows)

cannotBroadcastTableOverMaxTableBytesError

public static Throwable cannotBroadcastTableOverMaxTableBytesError(long maxBroadcastTableBytes,
                                                                   long dataSize)

notEnoughMemoryToBuildAndBroadcastTableError

public static Throwable notEnoughMemoryToBuildAndBroadcastTableError(OutOfMemoryError oe)

executeCodePathUnsupportedError

public static Throwable executeCodePathUnsupportedError(String execName)

cannotMergeClassWithOtherClassError

public static Throwable cannotMergeClassWithOtherClassError(String className,
                                                            String otherClass)

continuousProcessingUnsupportedByDataSourceError

public static Throwable continuousProcessingUnsupportedByDataSourceError(String sourceName)

failedToReadDataError

public static Throwable failedToReadDataError(Throwable failureReason)

failedToGenerateEpochMarkerError

public static Throwable failedToGenerateEpochMarkerError(Throwable failureReason)

foreachWriterAbortedDueToTaskFailureError

public static Throwable foreachWriterAbortedDueToTaskFailureError()

integerOverflowError

public static Throwable integerOverflowError(String message)

failedToReadDeltaFileError

public static Throwable failedToReadDeltaFileError(org.apache.hadoop.fs.Path fileToRead,
                                                   String clazz,
                                                   int keySize)

failedToReadSnapshotFileError

public static Throwable failedToReadSnapshotFileError(org.apache.hadoop.fs.Path fileToRead,
                                                      String clazz,
                                                      String message)

cannotPurgeAsBreakInternalStateError

public static Throwable cannotPurgeAsBreakInternalStateError()

cleanUpSourceFilesUnsupportedError

public static Throwable cleanUpSourceFilesUnsupportedError()

latestOffsetNotCalledError

public static Throwable latestOffsetNotCalledError()

legacyCheckpointDirectoryExistsError

public static Throwable legacyCheckpointDirectoryExistsError(org.apache.hadoop.fs.Path checkpointPath,
                                                             String legacyCheckpointDir)

subprocessExitedError

public static Throwable subprocessExitedError(int exitCode,
                                              org.apache.spark.util.CircularBuffer stderrBuffer,
                                              Throwable cause)

outputDataTypeUnsupportedByNodeWithoutSerdeError

public static Throwable outputDataTypeUnsupportedByNodeWithoutSerdeError(String nodeName,
                                                                         DataType dt)

invalidStartIndexError

public static Throwable invalidStartIndexError(int numRows,
                                               int startIndex)

concurrentModificationOnExternalAppendOnlyUnsafeRowArrayError

public static Throwable concurrentModificationOnExternalAppendOnlyUnsafeRowArrayError(String className)

doExecuteBroadcastNotImplementedError

public static Throwable doExecuteBroadcastNotImplementedError(String nodeName)

databaseNameConflictWithSystemPreservedDatabaseError

public static Throwable databaseNameConflictWithSystemPreservedDatabaseError(String globalTempDB)

commentOnTableUnsupportedError

public static Throwable commentOnTableUnsupportedError()

unsupportedUpdateColumnNullabilityError

public static Throwable unsupportedUpdateColumnNullabilityError()

renameColumnUnsupportedForOlderMySQLError

public static Throwable renameColumnUnsupportedForOlderMySQLError()

failedToExecuteQueryError

public static org.apache.spark.sql.execution.QueryExecutionException failedToExecuteQueryError(Throwable e)

nestedFieldUnsupportedError

public static Throwable nestedFieldUnsupportedError(String colName)

transformationsAndActionsNotInvokedByDriverError

public static Throwable transformationsAndActionsNotInvokedByDriverError()

repeatedPivotsUnsupportedError

public static Throwable repeatedPivotsUnsupportedError()

pivotNotAfterGroupByUnsupportedError

public static Throwable pivotNotAfterGroupByUnsupportedError()

invalidAesKeyLengthError

public static RuntimeException invalidAesKeyLengthError(int actualLength)

aesModeUnsupportedError

public static RuntimeException aesModeUnsupportedError(String mode,
                                                       String padding)

aesCryptoError

public static RuntimeException aesCryptoError(String detailMessage)

hiveTableWithAnsiIntervalsError

public static Throwable hiveTableWithAnsiIntervalsError(String tableName)

cannotConvertOrcTimestampToTimestampNTZError

public static Throwable cannotConvertOrcTimestampToTimestampNTZError()

cannotConvertOrcTimestampNTZToTimestampLTZError

public static Throwable cannotConvertOrcTimestampNTZToTimestampLTZError()

writePartitionExceedConfigSizeWhenDynamicPartitionError

public static Throwable writePartitionExceedConfigSizeWhenDynamicPartitionError(int numWrittenParts,
                                                                                int maxDynamicPartitions,
                                                                                String maxDynamicPartitionsKey)

invalidNumberFormatError

public static Throwable invalidNumberFormatError(org.apache.spark.unsafe.types.UTF8String input,
                                                 String format)

multipleBucketTransformsError

public static Throwable multipleBucketTransformsError()

unsupportedCreateNamespaceCommentError

public static Throwable unsupportedCreateNamespaceCommentError()

unsupportedRemoveNamespaceCommentError

public static Throwable unsupportedRemoveNamespaceCommentError()

unsupportedDropNamespaceRestrictError

public static Throwable unsupportedDropNamespaceRestrictError()

timestampAddOverflowError

public static ArithmeticException timestampAddOverflowError(long micros,
                                                            int amount,
                                                            String unit)

nullComparisonResultError

public static Throwable nullComparisonResultError()

invalidBucketFile

public static Throwable invalidBucketFile(String path)

invalidPatternError

public static RuntimeException invalidPatternError(String funcName,
                                                   String pattern)

toSQLValue

public static String toSQLValue(Object v,
                                DataType t)

toSQLStmt

public static String toSQLStmt(String text)

toSQLId

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

toSQLId

public static String toSQLId(String parts)

toSQLType

public static String toSQLType(DataType t)

toSQLType

public static String toSQLType(String text)

toSQLConf

public static String toSQLConf(String conf)

toDSOption

public static String toDSOption(String option)

toSQLExpr

public static String toSQLExpr(org.apache.spark.sql.catalyst.expressions.Expression e)

Class QueryExecutionErrors

Constructor Summary

Method Summary

Methods inherited from class Object

Constructor Detail

QueryExecutionErrors

Method Detail

cannotEvaluateExpressionError

cannotGenerateCodeForExpressionError

cannotTerminateGeneratorError

castingCauseOverflowError

castingCauseOverflowErrorInTableInsert

cannotChangeDecimalPrecisionError

invalidInputInCastToDatetimeError

invalidInputSyntaxForBooleanError

invalidInputInCastToNumberError

cannotCastFromNullTypeError

cannotCastError

cannotParseDecimalError

dataTypeUnsupportedError

failedExecuteUserDefinedFunctionError

divideByZeroError

invalidArrayIndexError

invalidInputIndexError

invalidElementAtIndexError

mapKeyNotExistError

inputTypeUnsupportedError

invalidFractionOfSecondError

ansiDateTimeParseError

ansiDateTimeError

ansiParseError

ansiIllegalArgumentError

ansiIllegalArgumentError

overflowInSumOfDecimalError

overflowInIntegralDivideError

mapSizeExceedArraySizeWhenZipMapError

copyNullFieldNotAllowedError

literalTypeUnsupportedError

pivotColumnUnsupportedError

noDefaultForDataTypeError

doGenCodeOfAliasShouldNotBeCalledError

orderedOperationUnsupportedByDataTypeError

regexGroupIndexLessThanZeroError

regexGroupIndexExceedGroupCountError

invalidUrlError

dataTypeOperationUnsupportedError

mergeUnsupportedByWindowFunctionError

dataTypeUnexpectedError

typeUnsupportedError

negativeValueUnexpectedError

addNewFunctionMismatchedWithFunctionError

cannotGenerateCodeForUncomparableTypeError

cannotGenerateCodeForUnsupportedTypeError

cannotInterpolateClassIntoCodeBlockError

customCollectionClsNotResolvedError

classUnsupportedByMapObjectsError

nullAsMapKeyNotAllowedError

methodNotDeclaredError

constructorNotFoundError

primaryConstructorNotFoundError

unsupportedNaturalJoinTypeError

notExpectedUnresolvedEncoderError

unsupportedEncoderError

notOverrideExpectedMethodsError

failToConvertValueToJsonError

unexpectedOperatorInCorrelatedSubquery

unreachableError

unsupportedRoundingMode

resolveCannotHandleNestedSchema

inputExternalRowCannotBeNullError

fieldCannotBeNullMsg

fieldCannotBeNullError

unableToCreateDatabaseAsFailedToCreateDirectoryError

unableToDropDatabaseAsFailedToDeleteDirectoryError

unableToCreateTableAsFailedToCreateDirectoryError

unableToDeletePartitionPathError

unableToDropTableAsFailedToDeleteDirectoryError

unableToRenameTableAsFailedToRenameDirectoryError

unableToCreatePartitionPathError

unableToRenamePartitionPathError