public class QueryCompilationErrors
extends Object
Constructor and Description |
---|
QueryCompilationErrors() |
Modifier and Type | Method and Description |
---|---|
static Throwable |
actionNotAllowedOnTableSincePartitionMetadataNotStoredError(String action,
String tableName) |
static Throwable |
actionNotAllowedOnTableWithFilesourcePartitionManagementDisabledError(String action,
String tableName) |
static Throwable |
addColumnWithV1TableCannotSpecifyNotNullError() |
static Throwable |
addNewDefaultColumnToExistingTableNotAllowed(String statementType,
String dataSource) |
static Throwable |
aggregateExpressionRequiredForPivotError(String sql) |
static Throwable |
aggregateInAggregateFilterError() |
static Throwable |
aggregationFunctionAppliedOnNonNumericColumnError(String colName) |
static Throwable |
aggregationFunctionAppliedOnNonNumericColumnError(String pivotColumn,
int maxValues) |
static Throwable |
aggregationNotAllowedInMergeCondition(String condName,
org.apache.spark.sql.catalyst.expressions.Expression cond) |
static Throwable |
aliasesNumberNotMatchUDTFOutputError(int aliasesSize,
String aliasesNames) |
static Throwable |
aliasNumberNotMatchColumnNumberError(int columnSize,
int outputSize,
org.apache.spark.sql.catalyst.trees.TreeNode<?> t) |
static Throwable |
alterAddColNotSupportDatasourceTableError(Object tableType,
org.apache.spark.sql.catalyst.TableIdentifier table) |
static Throwable |
alterAddColNotSupportViewError(org.apache.spark.sql.catalyst.TableIdentifier table) |
static Throwable |
alterColumnCannotFindColumnInV1TableError(String colName,
org.apache.spark.sql.connector.catalog.V1Table v1Table) |
static Throwable |
alterColumnWithV1TableCannotSpecifyNotNullError() |
static Throwable |
alterDatabaseLocationUnsupportedError() |
static Throwable |
alterTableChangeColumnNotSupportedForColumnTypeError(String tableName,
StructField originColumn,
StructField newColumn) |
static Throwable |
alterTableRecoverPartitionsNotSupportedForV2TablesError() |
static Throwable |
alterTableSerDePropertiesNotSupportedForV2TablesError() |
static Throwable |
alterTableSetSerdeForSpecificPartitionNotSupportedError() |
static Throwable |
alterTableSetSerdeNotSupportedError() |
static Throwable |
alterV2TableSetLocationWithPartitionNotSupportedError() |
static Throwable |
ambiguousAttributesInSelfJoinError(scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.AttributeReference> ambiguousAttrs) |
static Throwable |
ambiguousColumnOrFieldError(scala.collection.Seq<String> name,
int numMatches,
org.apache.spark.sql.catalyst.trees.Origin context) |
static Throwable |
ambiguousLateralColumnAliasError(scala.collection.Seq<String> nameParts,
int numOfMatches) |
static Throwable |
ambiguousLateralColumnAliasError(String name,
int numOfMatches) |
static Throwable |
ambiguousReferenceError(String name,
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> ambiguousReferences) |
static Throwable |
ambiguousReferenceToFieldsError(String field,
int numberOfAppearance) |
static Throwable |
ambiguousRelationAliasNameInNestedCTEError(String name) |
static Throwable |
analyzeTableNotSupportedForV2TablesError() |
static Throwable |
analyzeTableNotSupportedOnViewsError() |
static Throwable |
analyzingColumnStatisticsNotSupportedForColumnTypeError(String name,
DataType dataType) |
static Throwable |
arrayComponentTypeUnsupportedError(Class<?> clz) |
static Throwable |
attributeNameSyntaxError(String name) |
static Throwable |
batchWriteCapabilityError(org.apache.spark.sql.connector.catalog.Table table,
String v2WriteClassName,
String v1WriteClassName) |
static Throwable |
bucketByAndSortByUnsupportedByOperationError(String operation) |
static Throwable |
bucketByUnsupportedByOperationError(String operation) |
static Throwable |
bucketingColumnCannotBePartOfPartitionColumnsError(String bucketCol,
scala.collection.Seq<String> normalizedPartCols) |
static Throwable |
bucketSortingColumnCannotBePartOfPartitionColumnsError(String sortCol,
scala.collection.Seq<String> normalizedPartCols) |
static Throwable |
cannotAlterTableWithAlterViewError() |
static Throwable |
cannotAlterViewWithAlterTableError() |
static Throwable |
cannotConvertCatalystTypeToProtobufTypeError(scala.collection.Seq<String> sqlColumn,
String protobufColumn,
DataType sqlType,
String protobufType) |
static Throwable |
cannotConvertDataTypeToParquetTypeError(StructField field) |
static Throwable |
cannotConvertProtobufTypeToCatalystTypeError(String protobufType,
DataType sqlType,
Throwable cause) |
static Throwable |
cannotConvertProtobufTypeToSqlTypeError(String protobufColumn,
scala.collection.Seq<String> sqlColumn,
String protobufType,
DataType sqlType) |
static Throwable |
cannotConvertSqlTypeToProtobufError(String protobufType,
DataType sqlType,
Throwable cause) |
static Throwable |
cannotCreateDatabaseWithSameNameAsPreservedDatabaseError(String database) |
static Throwable |
cannotCreateJDBCNamespaceUsingProviderError() |
static Throwable |
cannotCreateJDBCNamespaceWithPropertyError(String property) |
static Throwable |
cannotCreateJDBCTableUsingLocationError() |
static Throwable |
cannotCreateJDBCTableUsingProviderError() |
static Throwable |
cannotCreateTableWithBothProviderAndSerdeError(scala.Option<String> provider,
scala.Option<org.apache.spark.sql.catalyst.plans.logical.SerdeInfo> maybeSerdeInfo) |
static Throwable |
cannotCreateTempViewUsingHiveDataSourceError() |
static Throwable |
cannotCreateViewNotEnoughColumnsError(org.apache.spark.sql.catalyst.TableIdentifier viewIdent,
scala.collection.Seq<String> expected,
org.apache.spark.sql.catalyst.plans.logical.LogicalPlan query) |
static Throwable |
cannotCreateViewTooManyColumnsError(org.apache.spark.sql.catalyst.TableIdentifier viewIdent,
scala.collection.Seq<String> expected,
org.apache.spark.sql.catalyst.plans.logical.LogicalPlan query) |
static Throwable |
cannotDeleteTableWhereFiltersError(org.apache.spark.sql.connector.catalog.Table table,
org.apache.spark.sql.connector.expressions.filter.Predicate[] filters) |
static Throwable |
cannotDropBuiltinFuncError(String functionName) |
static Throwable |
cannotDropDefaultDatabaseError(String database) |
static Throwable |
cannotDropNonemptyDatabaseError(String db) |
static Throwable |
cannotDropNonemptyNamespaceError(scala.collection.Seq<String> namespace) |
static Throwable |
cannotFindCatalogToHandleIdentifierError(String quote) |
static Throwable |
cannotFindCatalystTypeInProtobufSchemaError(String catalystFieldPath) |
static Throwable |
cannotFindColumnError(String name,
String[] fieldNames) |
static Throwable |
cannotFindColumnInRelationOutputError(String colName,
org.apache.spark.sql.catalyst.plans.logical.LogicalPlan relation) |
static AnalysisException |
cannotFindDescriptorFileError(String filePath,
Throwable cause) |
static Throwable |
cannotFindPartitionColumnInPartitionSchemaError(StructField readField,
StructType partitionSchema) |
static Throwable |
cannotFindProtobufFieldInCatalystError(String field) |
static Throwable |
cannotLoadClassNotOnClassPathError(String className) |
static Throwable |
cannotLoadClassWhenRegisteringFunctionError(String className,
org.apache.spark.sql.catalyst.FunctionIdentifier func) |
static Throwable |
cannotModifyValueOfSparkConfigError(String key,
String docroot) |
static Throwable |
cannotModifyValueOfStaticConfigError(String key) |
static Throwable |
cannotOperateOnHiveDataSourceFilesError(String operation) |
static Throwable |
cannotOverwritePathBeingReadFromError(String path) |
static Throwable |
cannotOverwriteTableThatIsBeingReadFromError(org.apache.spark.sql.catalyst.TableIdentifier tableIdent) |
static Throwable |
cannotParseIntervalError(String delayThreshold,
Throwable e) |
static Throwable |
cannotPassTypedColumnInUntypedSelectError(String typedCol) |
static Throwable |
cannotRefreshBuiltInFuncError(String functionName) |
static Throwable |
cannotRefreshTempFuncError(String functionName) |
static Throwable |
cannotRenameTableAcrossSchemaError() |
static Throwable |
cannotRenameTableWithAlterViewError() |
static Throwable |
cannotRenameTempViewToExistingTableError(org.apache.spark.sql.catalyst.TableIdentifier newName) |
static Throwable |
cannotRenameTempViewWithDatabaseSpecifiedError(org.apache.spark.sql.catalyst.TableIdentifier oldName,
org.apache.spark.sql.catalyst.TableIdentifier newName) |
static Throwable |
cannotReplaceMissingTableError(org.apache.spark.sql.connector.catalog.Identifier tableIdentifier) |
static Throwable |
cannotReplaceMissingTableError(org.apache.spark.sql.connector.catalog.Identifier tableIdentifier,
scala.Option<Throwable> cause) |
static Throwable |
cannotResolveAttributeError(String name,
String outputStr) |
static Throwable |
cannotResolveColumnGivenInputColumnsError(String col,
String inputColumns) |
static Throwable |
cannotResolveColumnNameAmongAttributesError(String colName,
String fieldNames) |
static Throwable |
cannotResolveStarExpandGivenInputColumnsError(String targetString,
String columns) |
static Throwable |
cannotRetrieveTableOrViewNotInSameDatabaseError(scala.collection.Seq<org.apache.spark.sql.catalyst.QualifiedTableName> qualifiedTableNames) |
static Throwable |
cannotSaveIntervalIntoExternalStorageError() |
static Throwable |
cannotSetJDBCNamespaceWithPropertyError(String property) |
static Throwable |
cannotSpecifyDatabaseForTempViewError(org.apache.spark.sql.catalyst.TableIdentifier tableIdent) |
static Throwable |
cannotSpecifyWindowFrameError(String prettyName) |
static Throwable |
cannotTranslateExpressionToSourceFilterError(org.apache.spark.sql.catalyst.expressions.Expression f) |
static Throwable |
cannotUnsetJDBCNamespaceWithPropertyError(String property) |
static Throwable |
cannotUseAllColumnsForPartitionColumnsError() |
static Throwable |
cannotUseDataTypeForPartitionColumnError(StructField field) |
static Throwable |
cannotUseIntervalTypeInTableSchemaError() |
static Throwable |
cannotUsePreservedDatabaseAsCurrentDatabaseError(String database) |
static Throwable |
cannotWriteDataToRelationsWithMultiplePathsError() |
static Throwable |
cannotWriteNotEnoughColumnsToTableError(String tableName,
scala.collection.Seq<String> expected,
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> queryOutput) |
static Throwable |
cannotWriteTooManyColumnsToTableError(String tableName,
scala.collection.Seq<String> expected,
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> queryOutput) |
static Throwable |
catalogOperationNotSupported(org.apache.spark.sql.connector.catalog.CatalogPlugin catalog,
String operation) |
static Throwable |
charOrVarcharTypeAsStringUnsupportedError() |
static Throwable |
checkpointLocationNotSpecifiedError() |
static Throwable |
classDoesNotImplementUserDefinedAggregateFunctionError(String className) |
static Throwable |
classWithoutPublicNonArgumentConstructorError(String className) |
static Throwable |
cmdOnlyWorksOnPartitionedTablesError(String operation,
String tableIdentWithDB) |
static Throwable |
cmdOnlyWorksOnTableWithLocationError(String cmd,
String tableIdentWithDB) |
static Throwable |
columnAlreadyExistsError(String columnName) |
static Throwable |
columnNotDefinedInTableError(String colType,
String colName,
String tableName,
scala.collection.Seq<String> tableCols) |
static AnalysisException |
columnNotFoundError(String colName) |
static Throwable |
columnNotFoundInExistingColumnsError(String columnType,
String columnName,
scala.collection.Seq<String> validColumnNames) |
static Throwable |
columnNotFoundInSchemaError(StructField col,
scala.Option<StructType> tableSchema) |
static Throwable |
columnNotInGroupByClauseError(org.apache.spark.sql.catalyst.expressions.Expression expression) |
static Throwable |
columnStatisticsDeserializationNotSupportedError(String name,
DataType dataType) |
static Throwable |
columnStatisticsSerializationNotSupportedError(String colName,
DataType dataType) |
static Throwable |
columnTypeNotSupportStatisticsCollectionError(String name,
org.apache.spark.sql.catalyst.TableIdentifier tableIdent,
DataType dataType) |
static Throwable |
commandExecutionInRunnerUnsupportedError(String runner) |
static Throwable |
commandNotSupportNestedColumnError(String command,
String quoted) |
static Throwable |
commandUnsupportedInV2TableError(String name) |
static Throwable |
configRemovedInVersionError(String configName,
String version,
String comment) |
static Throwable |
conflictingAttributesInJoinConditionError(org.apache.spark.sql.catalyst.expressions.AttributeSet conflictingAttrs,
org.apache.spark.sql.catalyst.plans.logical.LogicalPlan outerPlan,
org.apache.spark.sql.catalyst.plans.logical.LogicalPlan subplan) |
static Throwable |
corruptedTableNameContextInCatalogError(int numParts,
int index) |
static Throwable |
corruptedViewQueryOutputColumnsInCatalogError(String numCols,
int index) |
static Throwable |
corruptedViewReferredTempFunctionsInCatalogError(Exception e) |
static Throwable |
corruptedViewReferredTempViewInCatalogError(Exception e) |
static Throwable |
corruptedViewSQLConfigsInCatalogError(Exception e) |
static Throwable |
createExternalTableWithoutLocationError() |
static Throwable |
createPersistedViewFromDatasetAPINotAllowedError() |
static Throwable |
createTableAsSelectWithNonEmptyDirectoryError(String tablePath) |
static Throwable |
createTableColumnTypesOptionColumnNotFoundInSchemaError(String col,
StructType schema) |
static Throwable |
databaseFromV1SessionCatalogNotSpecifiedError() |
static Throwable |
dataPathNotExistError(String path) |
static Throwable |
dataSchemaNotSpecifiedError(String format) |
static Throwable |
dataSchemaNotSpecifiedError(String format,
String fileCatalog) |
static Throwable |
dataSourceOutputModeUnsupportedError(String className,
OutputMode outputMode) |
static Throwable |
dataTypeMismatchForDeserializerError(DataType dataType,
String desiredType) |
static Throwable |
dataTypeOperationUnsupportedError() |
static Throwable |
dataTypeUnsupportedByClassError(DataType x,
String className) |
static Throwable |
dataTypeUnsupportedByDataSourceError(String format,
StructField column) |
static Throwable |
dataTypeUnsupportedByExtractValueError(DataType dataType,
org.apache.spark.sql.catalyst.expressions.Expression extraction,
org.apache.spark.sql.catalyst.expressions.Expression child) |
static Throwable |
ddlWithoutHiveSupportEnabledError(String cmd) |
static Throwable |
defaultReferencesNotAllowedInComplexExpressionsInInsertValuesList() |
static Throwable |
defaultReferencesNotAllowedInComplexExpressionsInMergeInsertsOrUpdates() |
static Throwable |
defaultReferencesNotAllowedInComplexExpressionsInUpdateSetClause() |
static Throwable |
defaultReferencesNotAllowedInDataSource(String statementType,
String dataSource) |
static Throwable |
defaultValuesDataTypeError(String statement,
String colName,
String defaultValue,
DataType expectedType,
DataType actualType) |
static Throwable |
defaultValuesMayNotContainSubQueryExpressions(String statement,
String colName,
String defaultValue) |
static Throwable |
defaultValuesUnresolvedExprError(String statement,
String colName,
String defaultValue,
Throwable cause) |
static Throwable |
descPartitionNotAllowedOnTempView(String table) |
static Throwable |
descPartitionNotAllowedOnView(String table) |
static Throwable |
describeDoesNotSupportPartitionForV2TablesError() |
static AnalysisException |
descriptorParseError(Throwable cause) |
static Throwable |
doubleNamedArgumentReference(String functionName,
String parameterName) |
static Throwable |
dropNonExistentColumnsNotSupportedError(scala.collection.Seq<String> nonExistentColumnNames) |
static Throwable |
emptyMultipartIdentifierError() |
static Throwable |
emptyWindowExpressionError(org.apache.spark.sql.catalyst.plans.logical.Window expr) |
static Throwable |
escapeCharacterAtTheEndError(String pattern) |
static Throwable |
escapeCharacterInTheMiddleError(String pattern,
String char_) |
static Throwable |
expectPersistentFuncError(String name,
String cmd,
scala.Option<String> mismatchHint,
org.apache.spark.sql.catalyst.trees.TreeNode<?> t) |
static Throwable |
expectTableNotViewError(scala.collection.Seq<String> nameParts,
boolean isTemp,
String cmd,
scala.Option<String> mismatchHint,
org.apache.spark.sql.catalyst.trees.TreeNode<?> t) |
static Throwable |
expectTableOrPermanentViewNotTempViewError(scala.collection.Seq<String> nameParts,
String cmd,
org.apache.spark.sql.catalyst.trees.TreeNode<?> t) |
static Throwable |
expectViewNotTableError(org.apache.spark.sql.catalyst.analysis.ResolvedTable v,
String cmd,
scala.Option<String> mismatchHint,
org.apache.spark.sql.catalyst.trees.TreeNode<?> t) |
static Throwable |
expectViewNotTempViewError(scala.collection.Seq<String> nameParts,
String cmd,
org.apache.spark.sql.catalyst.trees.TreeNode<?> t) |
static Throwable |
expressionWithMultiWindowExpressionsError(org.apache.spark.sql.catalyst.expressions.NamedExpression expr,
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.WindowSpecDefinition> distinctWindowSpec) |
static Throwable |
expressionWithoutWindowExpressionError(org.apache.spark.sql.catalyst.expressions.NamedExpression expr) |
static Throwable |
failedToFindAvroDataSourceError(String provider) |
static Throwable |
failedToFindKafkaDataSourceError(String provider) |
static Throwable |
failedToParseExistenceDefaultAsLiteral(String fieldName,
String defaultValue) |
static Throwable |
failedToRebuildExpressionError(Filter filter) |
static Throwable |
failToResolveDataSourceForTableError(org.apache.spark.sql.catalyst.catalog.CatalogTable table,
String key) |
static Throwable |
failToTruncateTableWhenRemovingDataError(String tableIdentWithDB,
org.apache.hadoop.fs.Path path,
Throwable e) |
static Throwable |
fieldNumberMismatchForDeserializerError(StructType schema,
int maxOrdinal) |
static Throwable |
findMultipleDataSourceError(String provider,
scala.collection.Seq<String> sourceNames) |
static Throwable |
foundDifferentWindowFunctionTypeError(scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.NamedExpression> windowExpressions) |
static Throwable |
foundRecursionInProtobufSchema(String fieldDescriptor) |
static Throwable |
funcBuildError(String funcName,
Exception cause) |
static Throwable |
functionAlreadyExistsError(org.apache.spark.sql.catalyst.FunctionIdentifier func) |
static Throwable |
functionCannotProcessInputError(org.apache.spark.sql.connector.catalog.functions.UnboundFunction unbound,
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> arguments,
UnsupportedOperationException unsupported) |
static Throwable |
functionWithUnsupportedSyntaxError(String prettyName,
String syntax) |
static Throwable |
generatorNotExpectedError(org.apache.spark.sql.catalyst.FunctionIdentifier name,
String classCanonicalName) |
static Throwable |
generatorOutsideSelectError(org.apache.spark.sql.catalyst.plans.logical.LogicalPlan plan) |
static QueryContext[] |
getQueryContext(org.apache.spark.sql.catalyst.trees.SQLQueryContext sqlContext) |
static String |
getSummary(org.apache.spark.sql.catalyst.trees.SQLQueryContext sqlContext) |
static Throwable |
groupByPositionRangeError(int index,
int size) |
static Throwable |
groupByPositionRefersToAggregateFunctionError(int index,
org.apache.spark.sql.catalyst.expressions.Expression expr) |
static Throwable |
groupingColInvalidError(org.apache.spark.sql.catalyst.expressions.Expression groupingCol,
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> groupByExprs) |
static Throwable |
groupingIDMismatchError(org.apache.spark.sql.catalyst.expressions.GroupingID groupingID,
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> groupByExprs) |
static Throwable |
groupingMustWithGroupingSetsOrCubeOrRollupError() |
static Throwable |
groupingSizeTooLargeError(int sizeLimit) |
static Throwable |
hiveCreatePermanentFunctionsUnsupportedError() |
static Throwable |
hiveTableTypeUnsupportedError(String tableName,
String tableType) |
static Throwable |
hostOptionNotSetError() |
static Throwable |
identifierTooManyNamePartsError(String originalIdentifier) |
static Throwable |
illegalParquetTypeError(String parquetType) |
static Throwable |
incompatibleDataToTableAmbiguousColumnNameError(String tableName,
String colName) |
static Throwable |
incompatibleDataToTableCannotFindDataError(String tableName,
String colName) |
static Throwable |
incompatibleDataToTableCannotSafelyCastError(String tableName,
String colName,
String srcType,
String targetType) |
static Throwable |
incompatibleDataToTableExtraColumnsError(String tableName,
String extraColumns) |
static Throwable |
incompatibleDataToTableExtraStructFieldsError(String tableName,
String colName,
String extraFields) |
static Throwable |
incompatibleDataToTableNullableArrayElementsError(String tableName,
String colName) |
static Throwable |
incompatibleDataToTableNullableColumnError(String tableName,
String colName) |
static Throwable |
incompatibleDataToTableNullableMapValuesError(String tableName,
String colName) |
static Throwable |
incompatibleDataToTableStructMissingFieldsError(String tableName,
String colName,
String missingFields) |
static Throwable |
incompatibleDataToTableUnexpectedColumnNameError(String tableName,
String colName,
int order,
String expected,
String found) |
static Throwable |
incompatibleViewSchemaChangeError(String viewName,
String colName,
int expectedNum,
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> actualCols,
scala.Option<String> viewDDL) |
static Throwable |
inputSourceDiffersFromDataSourceProviderError(String source,
String tableName,
org.apache.spark.sql.catalyst.catalog.CatalogTable table) |
static Throwable |
insertIntoViewNotAllowedError(org.apache.spark.sql.catalyst.TableIdentifier identifier,
org.apache.spark.sql.catalyst.trees.TreeNode<?> t) |
static Throwable |
insertMismatchedColumnNumberError(scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> targetAttributes,
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> sourceAttributes,
int staticPartitionsSize) |
static Throwable |
insertMismatchedPartitionNumberError(StructType targetPartitionSchema,
int providedPartitionsSize) |
static Throwable |
insufficientTablePropertyError(String key) |
static Throwable |
insufficientTablePropertyPartError(String key,
String totalAmountOfParts) |
static Throwable |
invalidBoundaryEndError(long end) |
static Throwable |
invalidBoundaryStartError(long start) |
static Throwable |
invalidBucketNumberError(int bucketingMaxBuckets,
int numBuckets) |
static Throwable |
invalidBucketsNumberError(String numBuckets,
String e) |
static Throwable |
invalidByteStringFormatError(Object unsupported) |
static Throwable |
invalidCoalesceHintParameterError(String hintName) |
static Throwable |
invalidColumnNameAsPathError(String datasource,
String columnName) |
static Throwable |
invalidColumnOrFieldDataTypeError(scala.collection.Seq<String> name,
DataType dt,
DataType expected) |
static Throwable |
invalidDatabaseNameError(String quoted) |
static Throwable |
invalidDataSourceError(String className) |
static Throwable |
invalidEscapeChar(org.apache.spark.sql.catalyst.expressions.Expression sqlExpr) |
static Throwable |
invalidFieldName(scala.collection.Seq<String> fieldName,
scala.collection.Seq<String> path,
org.apache.spark.sql.catalyst.trees.Origin context) |
static Throwable |
invalidFieldTypeForCorruptRecordError() |
static Throwable |
invalidFileFormatForStoredAsError(org.apache.spark.sql.catalyst.plans.logical.SerdeInfo serdeInfo) |
static Throwable |
invalidHintParameterError(String hintName,
scala.collection.Seq<Object> invalidParams) |
static Throwable |
invalidIncludeTimestampValueError() |
static Throwable |
invalidJoinTypeInJoinWithError(org.apache.spark.sql.catalyst.plans.JoinType joinType) |
static Throwable |
invalidJsonSchema(DataType schema) |
static Throwable |
invalidLiteralForWindowDurationError() |
static Throwable |
invalidNameForTableOrDatabaseError(String name) |
static Throwable |
invalidOrderingForConstantValuePartitionColumnError(StructType targetPartitionSchema) |
static Throwable |
invalidPandasUDFPlacementError(scala.collection.Seq<String> groupAggPandasUDFNames) |
static Throwable |
invalidPartitionColumnError(String partKey,
StructType targetPartitionSchema) |
static Throwable |
invalidPartitionColumnKeyInTableError(String key,
String tblName) |
static Throwable |
invalidPartitionColumnTypeError(StructField column) |
static Throwable |
invalidPartitionSpecError(String details) |
static Throwable |
invalidPartitionSpecError(String specKeys,
scala.collection.Seq<String> partitionColumnNames,
String tableName) |
static Throwable |
invalidPartitionTransformationError(org.apache.spark.sql.catalyst.expressions.Expression expr) |
static Throwable |
invalidRepartitionExpressionsError(scala.collection.Seq<Object> sortOrders) |
static Throwable |
invalidRowLevelOperationAssignments(scala.collection.Seq<org.apache.spark.sql.catalyst.plans.logical.Assignment> assignments,
scala.collection.Seq<String> errors) |
static Throwable |
invalidStarUsageError(String prettyName,
scala.collection.Seq<org.apache.spark.sql.catalyst.analysis.Star> stars) |
static Throwable |
invalidTimestampExprForTimeTravel(String errorClass,
org.apache.spark.sql.catalyst.expressions.Expression expr) |
static Throwable |
invalidTimestampProvidedForStrategyError(String strategy,
String timeString) |
static Throwable |
invalidTimeTravelSpecError() |
static Throwable |
invalidViewNameError(String viewName) |
static Throwable |
invalidViewText(String viewText,
String viewName) |
static Throwable |
joinConditionMissingOrTrivialError(org.apache.spark.sql.catalyst.plans.logical.Join join,
org.apache.spark.sql.catalyst.plans.logical.LogicalPlan left,
org.apache.spark.sql.catalyst.plans.logical.LogicalPlan right) |
static Throwable |
joinStrategyHintParameterNotSupportedError(Object unsupported) |
static Throwable |
keyValueInMapNotStringError(org.apache.spark.sql.catalyst.expressions.CreateMap m) |
static Throwable |
lateralColumnAliasInAggFuncUnsupportedError(scala.collection.Seq<String> lcaNameParts,
org.apache.spark.sql.catalyst.expressions.Expression aggExpr) |
static Throwable |
lateralColumnAliasInAggWithWindowAndHavingUnsupportedError(scala.collection.Seq<String> lcaNameParts) |
static Throwable |
lateralColumnAliasInWindowUnsupportedError(scala.collection.Seq<String> lcaNameParts,
org.apache.spark.sql.catalyst.expressions.Expression windowExpr) |
static Throwable |
legacyStoreAssignmentPolicyError() |
static Throwable |
literalTypeUnsupportedForSourceTypeError(String field,
org.apache.spark.sql.catalyst.expressions.Expression source) |
static Throwable |
loadDataInputPathNotExistError(String path) |
static Throwable |
loadDataNotSupportedForDatasourceTablesError(String tableIdentWithDB) |
static Throwable |
loadDataNotSupportedForV2TablesError() |
static Throwable |
loadDataPartitionSizeNotMatchNumPartitionColumnsError(String tableIdentWithDB,
int partitionSize,
int targetTableSize) |
static Throwable |
loadDataTargetTableNotPartitionedButPartitionSpecWasProvidedError(String tableIdentWithDB) |
static Throwable |
loadDataWithoutPartitionSpecProvidedError(String tableIdentWithDB) |
static Throwable |
logicalPlanForViewNotAnalyzedError() |
static Throwable |
mismatchedTableBucketingError(String tableName,
String specifiedBucketString,
String existingBucketString) |
static Throwable |
mismatchedTableColumnNumberError(String tableName,
org.apache.spark.sql.catalyst.catalog.CatalogTable existingTable,
org.apache.spark.sql.catalyst.plans.logical.LogicalPlan query) |
static Throwable |
mismatchedTableFormatError(String tableName,
Class<?> existingProvider,
Class<?> specifiedProvider) |
static Throwable |
mismatchedTableLocationError(org.apache.spark.sql.catalyst.TableIdentifier identifier,
org.apache.spark.sql.catalyst.catalog.CatalogTable existingTable,
org.apache.spark.sql.catalyst.catalog.CatalogTable tableDesc) |
static Throwable |
mismatchedTablePartitionColumnError(String tableName,
scala.collection.Seq<String> specifiedPartCols,
String existingPartCols) |
static Throwable |
missingCatalogAbilityError(org.apache.spark.sql.connector.catalog.CatalogPlugin plugin,
String ability) |
static Throwable |
missingFieldError(scala.collection.Seq<String> fieldName,
org.apache.spark.sql.catalyst.analysis.ResolvedTable table,
org.apache.spark.sql.catalyst.trees.Origin context) |
static Throwable |
missingStaticPartitionColumn(String staticName) |
static Throwable |
mixedRefsInAggFunc(String funcStr,
org.apache.spark.sql.catalyst.trees.Origin origin) |
static Throwable |
moreThanOneGeneratorError(scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> generators,
String clause) |
static Throwable |
multiplePartitionColumnValuesSpecifiedError(StructField field,
scala.collection.immutable.Map<String,String> potentialSpecs) |
static Throwable |
multiTimeWindowExpressionsNotSupportedError(org.apache.spark.sql.catalyst.trees.TreeNode<?> t) |
static Throwable |
namedArgumentsNotEnabledError(String functionName,
String argumentName) |
static Throwable |
namedArgumentsNotSupported(String functionName) |
static Throwable |
namespaceAlreadyExistsError(String[] namespace) |
static Throwable |
nestedDatabaseUnsupportedByV1SessionCatalogError(String catalog) |
static Throwable |
nestedGeneratorError(org.apache.spark.sql.catalyst.expressions.Expression trimmedNestedGenerator) |
static Throwable |
noHandlerForUDAFError(String name) |
static Throwable |
nonBooleanFilterInAggregateError() |
static Throwable |
nonDeterministicFilterInAggregateError() |
static Throwable |
nonDeterministicMergeCondition(String condName,
org.apache.spark.sql.catalyst.expressions.Expression cond) |
static Throwable |
nonLiteralPivotValError(org.apache.spark.sql.catalyst.expressions.Expression pivotVal) |
static Throwable |
nonMapFunctionNotAllowedError() |
static Throwable |
nonPartitionColError(String partitionName) |
static Throwable |
nonPartitionPruningPredicatesNotExpectedError(scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> nonPartitionPruningPredicates) |
static Throwable |
noSuchFunctionError(org.apache.spark.sql.catalyst.FunctionIdentifier identifier) |
static Throwable |
noSuchNamespaceError(String[] namespace) |
static Throwable |
noSuchPartitionError(String db,
String table,
scala.collection.immutable.Map<String,String> partition) |
static Throwable |
noSuchStructFieldInGivenFieldsError(String fieldName,
StructField[] fields) |
static org.apache.spark.sql.catalyst.analysis.NoSuchTableException |
noSuchTableError(org.apache.spark.sql.connector.catalog.Identifier ident) |
static Throwable |
noSuchTableError(scala.collection.Seq<String> nameParts) |
static Throwable |
noSuchTableError(String db,
String table) |
static Throwable |
notAllowedToCreatePermanentViewByReferencingTempFuncError(org.apache.spark.sql.catalyst.TableIdentifier name,
String funcName) |
static Throwable |
notAllowedToCreatePermanentViewByReferencingTempViewError(org.apache.spark.sql.catalyst.TableIdentifier name,
String nameParts) |
static Throwable |
notAllowedToCreatePermanentViewWithoutAssigningAliasForExpressionError(org.apache.spark.sql.catalyst.TableIdentifier name,
org.apache.spark.sql.catalyst.expressions.Attribute attr) |
static Throwable |
notNullConstraintViolationArrayElementError(scala.collection.Seq<String> path) |
static Throwable |
notNullConstraintViolationMapValueError(scala.collection.Seq<String> path) |
static Throwable |
nullableColumnOrFieldError(scala.collection.Seq<String> name) |
static Throwable |
nullableRowIdError(scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.AttributeReference> nullableRowIdAttrs) |
static Throwable |
numberAndSizeOfPartitionsNotAllowedTogether() |
static Throwable |
numberOfPartitionsNotAllowedWithUnspecifiedDistributionError() |
static Throwable |
operationNotSupportPartitioningError(String operation) |
static Throwable |
optionMustBeConstant(String key,
scala.Option<Throwable> cause) |
static Throwable |
optionMustBeLiteralString(String key) |
static Throwable |
orcNotUsedWithHiveEnabledError() |
static Throwable |
orderByPositionRangeError(int index,
int size,
org.apache.spark.sql.catalyst.trees.TreeNode<?> t) |
static Throwable |
outerScopeFailureForNewInstanceError(String className) |
static Throwable |
outputPathAlreadyExistsError(org.apache.hadoop.fs.Path outputPath) |
static Throwable |
pandasUDFAggregateNotSupportedInPivotError() |
static Throwable |
parquetTypeUnsupportedYetError(String parquetType) |
static Throwable |
parseModeUnsupportedError(String funcName,
org.apache.spark.sql.catalyst.util.ParseMode mode) |
static Throwable |
partitionByDoesNotAllowedWhenUsingInsertIntoError() |
static Throwable |
partitionColumnNotFoundInSchemaError(String col,
String schemaCatalog) |
static Throwable |
partitionColumnNotSpecifiedError(String format,
String partitionColumn) |
static Throwable |
partitionNotSpecifyLocationUriError(String specString) |
static Throwable |
partitionSizeNotAllowedWithUnspecifiedDistributionError() |
static Throwable |
pathOptionNotSetCorrectlyWhenReadingError() |
static Throwable |
pathOptionNotSetCorrectlyWhenWritingError() |
static Throwable |
permanentViewNotSupportedByStreamingReadingAPIError(String quoted) |
static Throwable |
pivotValDataTypeMismatchError(org.apache.spark.sql.catalyst.expressions.Expression pivotVal,
org.apache.spark.sql.catalyst.expressions.Expression pivotCol) |
static Throwable |
portOptionNotSetError() |
static Throwable |
positionalAndNamedArgumentDoubleReference(String functionName,
String parameterName) |
static Throwable |
protobufClassLoadError(String protobufClassName,
String explanation,
Throwable cause) |
static Throwable |
protobufDescriptorDependencyError(String dependencyName) |
static Throwable |
protobufFieldMatchError(String field,
String protobufSchema,
String matchSize,
String matches) |
static Throwable |
protobufFieldTypeMismatchError(String field) |
static Throwable |
protobufTypeUnsupportedYetError(String protobufType) |
static Throwable |
queryFromRawFilesIncludeCorruptRecordColumnError() |
static Throwable |
queryNameNotSpecifiedForMemorySinkError() |
static Throwable |
readNonStreamingTempViewError(String quoted) |
static Throwable |
recoverQueryFromCheckpointUnsupportedError(org.apache.hadoop.fs.Path checkpointPath) |
static Throwable |
recursiveViewDetectedError(org.apache.spark.sql.catalyst.TableIdentifier viewIdent,
scala.collection.Seq<org.apache.spark.sql.catalyst.TableIdentifier> newPath) |
static Throwable |
referenceColNotFoundForAlterTableChangesError(String fieldName,
String[] fields) |
static Throwable |
renameTableSourceAndDestinationMismatchError(String db,
String newDb) |
static Throwable |
renameTempViewToExistingViewError(String newName) |
static Throwable |
repairTableNotSupportedForV2TablesError() |
static Throwable |
requestedPartitionsMismatchTablePartitionsError(String tableName,
scala.collection.immutable.Map<String,scala.Option<String>> normalizedPartSpec,
StructType partColNames) |
static Throwable |
requiredParameterNotFound(String functionName,
String parameterName,
int index) |
static Throwable |
requireLiteralParameter(String funcName,
String argName,
String requiredType) |
static Throwable |
requiresSinglePartNamespaceError(scala.collection.Seq<String> namespace) |
static AnalysisException |
resolveException(String colName,
String[] fields) |
static Throwable |
resourceTypeNotSupportedError(String resourceType) |
static Throwable |
saveDataIntoViewNotAllowedError() |
static Throwable |
schemaIsNotStructTypeError(org.apache.spark.sql.catalyst.expressions.Expression exp,
DataType dataType) |
static Throwable |
schemaNotSpecifiedForSchemaRelationProviderError(String className) |
static Throwable |
secondArgumentInFunctionIsNotBooleanLiteralError(String funcName) |
static Throwable |
secondArgumentNotDoubleLiteralError() |
static Throwable |
secondArgumentOfFunctionIsNotIntegerError(String function,
NumberFormatException e) |
static Throwable |
selectExprNotInGroupByError(org.apache.spark.sql.catalyst.expressions.Expression expr,
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Alias> groupByAliases) |
static Throwable |
sessionWindowGapDurationDataTypeError(DataType dt) |
static Throwable |
setPathOptionAndCallWithPathParameterError(String method) |
static Throwable |
showColumnsNotSupportedForV2TablesError() |
static Throwable |
showColumnsWithConflictDatabasesError(scala.collection.Seq<String> db,
org.apache.spark.sql.catalyst.TableIdentifier v1TableName) |
static Throwable |
showCreateTableAsSerdeNotAllowedOnSparkDataSourceTableError(org.apache.spark.sql.catalyst.TableIdentifier table) |
static Throwable |
showCreateTableAsSerdeNotSupportedForV2TablesError() |
static Throwable |
showCreateTableFailToExecuteUnsupportedConfError(org.apache.spark.sql.catalyst.TableIdentifier table,
scala.collection.mutable.StringBuilder builder) |
static Throwable |
showCreateTableFailToExecuteUnsupportedFeatureError(org.apache.spark.sql.catalyst.catalog.CatalogTable table) |
static Throwable |
showCreateTableNotSupportedOnTempView(String table) |
static Throwable |
showCreateTableNotSupportTransactionalHiveTableError(org.apache.spark.sql.catalyst.catalog.CatalogTable table) |
static Throwable |
showCreateTableOrViewFailToExecuteUnsupportedFeatureError(org.apache.spark.sql.catalyst.catalog.CatalogTable table,
scala.collection.Seq<String> features) |
static Throwable |
showPartitionNotAllowedOnTableNotPartitionedError(String tableIdentWithDB) |
static Throwable |
singleTableStarInCountNotAllowedError(String targetString) |
static Throwable |
sortByWithoutBucketingError() |
static Throwable |
sourceNotSupportedWithContinuousTriggerError(String source) |
static Throwable |
specifyPartitionNotAllowedWhenTableSchemaNotDefinedError() |
static Throwable |
starExpandDataTypeNotSupportedError(scala.collection.Seq<String> attributes) |
static Throwable |
starNotAllowedWhenGroupByOrdinalPositionUsedError() |
static Throwable |
staticPartitionInUserSpecifiedColumnsError(String staticName) |
static Throwable |
streamingIntoViewNotSupportedError(String viewName) |
static Throwable |
streamingSourcesDoNotSupportCommonExecutionModeError(scala.collection.Seq<String> microBatchSources,
scala.collection.Seq<String> continuousSources) |
static Throwable |
streamJoinStreamWithoutEqualityPredicateUnsupportedError(org.apache.spark.sql.catalyst.plans.logical.LogicalPlan plan) |
static Throwable |
subqueryNotAllowedInMergeCondition(String condName,
org.apache.spark.sql.catalyst.expressions.Expression cond) |
static Throwable |
tableAlreadyExistsError(org.apache.spark.sql.connector.catalog.Identifier ident) |
static Throwable |
tableAlreadyExistsError(String table) |
static Throwable |
tableAlreadyExistsError(org.apache.spark.sql.catalyst.TableIdentifier tableIdent) |
static Throwable |
tableDoesNotSupportAtomicPartitionManagementError(org.apache.spark.sql.connector.catalog.Table table) |
static Throwable |
tableDoesNotSupportDeletesError(org.apache.spark.sql.connector.catalog.Table table) |
static Throwable |
tableDoesNotSupportPartitionManagementError(org.apache.spark.sql.connector.catalog.Table table) |
static Throwable |
tableDoesNotSupportReadsError(org.apache.spark.sql.connector.catalog.Table table) |
static Throwable |
tableDoesNotSupportTruncatesError(org.apache.spark.sql.connector.catalog.Table table) |
static Throwable |
tableDoesNotSupportWritesError(org.apache.spark.sql.connector.catalog.Table table) |
static Throwable |
tableIdentifierExistsError(org.apache.spark.sql.catalyst.TableIdentifier tableIdentifier) |
static Throwable |
tableIdentifierNotConvertedToHadoopFsRelationError(org.apache.spark.sql.catalyst.TableIdentifier tableIdentifier) |
static Throwable |
tableIndexNotSupportedError(String errorMessage) |
static Throwable |
tableIsNotRowLevelOperationTableError(org.apache.spark.sql.connector.catalog.Table table) |
static Throwable |
tableIsNotViewError(org.apache.spark.sql.catalyst.TableIdentifier name) |
static Throwable |
tableNotSpecifyDatabaseError(org.apache.spark.sql.catalyst.TableIdentifier identifier) |
static Throwable |
tableNotSpecifyLocationUriError(org.apache.spark.sql.catalyst.TableIdentifier identifier) |
static Throwable |
tableNotSupportStreamingWriteError(String tableName,
org.apache.spark.sql.connector.catalog.Table t) |
static Throwable |
tableOrViewAlreadyExistsError(String name) |
static Throwable |
tableOrViewNotFound(scala.collection.Seq<String> ident) |
static Throwable |
tableValuedFunctionTooManyTableArgumentsError(int num) |
static Throwable |
tempViewNotCachedForAnalyzingColumnsError(org.apache.spark.sql.catalyst.TableIdentifier tableIdent) |
static Throwable |
tempViewNotSupportStreamingWriteError(String viewName) |
static Throwable |
textDataSourceWithMultiColumnsError(StructType schema) |
static Throwable |
timeTravelUnsupportedError(String relationId) |
static String |
toDSOption(String option) |
static String |
toSQLConf(String conf) |
static String |
toSQLConfVal(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 |
toSQLSchema(String schema) |
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(Object v,
DataType t) |
static String |
toSQLValue(short value) |
static String |
toSQLValue(String value) |
static String |
toSQLValue(org.apache.spark.unsafe.types.UTF8String value) |
static Throwable |
truncateTableOnExternalTablesError(String tableIdentWithDB) |
static Throwable |
truncateTablePartitionNotSupportedForNotPartitionedTablesError(String tableIdentWithDB) |
static Throwable |
udfClassDoesNotImplementAnyUDFInterfaceError(String className) |
static Throwable |
udfClassImplementMultiUDFInterfacesError(String className) |
static Throwable |
udfClassWithTooManyTypeArgumentsError(int n) |
static Throwable |
unableToLocateProtobufMessageError(String messageName) |
static Throwable |
unexpectedInputDataTypeError(String functionName,
int paramIndex,
DataType dataType,
org.apache.spark.sql.catalyst.expressions.Expression expression) |
static Throwable |
unexpectedPartitionColumnPrefixError(String table,
String database,
String schemaColumns,
String specColumns) |
static Throwable |
unexpectedPositionalArgument(String functionName,
String precedingNamedArgument) |
static Throwable |
unexpectedRequiredParameterInFunctionSignature(String functionName,
org.apache.spark.sql.catalyst.plans.logical.FunctionSignature functionSignature) |
static Throwable |
unexpectedSchemaTypeError(org.apache.spark.sql.catalyst.expressions.Expression exp) |
static Throwable |
unknownHiveResourceTypeError(String resourceType) |
static Throwable |
unknownProtobufMessageTypeError(String descriptorName,
String containingType) |
static Throwable |
unorderablePivotColError(org.apache.spark.sql.catalyst.expressions.Expression pivotCol) |
static Throwable |
unpivotRequiresAttributes(String given,
String empty,
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.NamedExpression> expressions) |
static Throwable |
unpivotRequiresValueColumns() |
static Throwable |
unpivotValueDataTypeMismatchError(scala.collection.Seq<scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.NamedExpression>> values) |
static Throwable |
unpivotValueSizeMismatchError(int names) |
static Throwable |
unrecognizedParameterName(String functionName,
String argumentName,
scala.collection.Seq<String> candidates) |
static Throwable |
unrecognizedParquetTypeError(String field) |
static Throwable |
unresolvedAttributeError(String errorClass,
String colName,
scala.collection.Seq<String> candidates,
org.apache.spark.sql.catalyst.trees.Origin origin) |
static Throwable |
unresolvedColumnError(String columnName,
scala.collection.Seq<String> proposal) |
static AnalysisException |
unresolvedColumnWithSuggestionError(String objectName,
String suggestion) |
static Throwable |
unresolvedFieldError(String fieldName,
scala.collection.Seq<String> columnPath,
scala.collection.Seq<String> proposal) |
static Throwable |
unresolvedRoutineError(org.apache.spark.sql.catalyst.FunctionIdentifier name,
scala.collection.Seq<String> searchPath) |
static Throwable |
unresolvedRoutineError(scala.collection.Seq<String> nameParts,
scala.collection.Seq<String> searchPath,
org.apache.spark.sql.catalyst.trees.Origin context) |
static Throwable |
unresolvedUsingColForJoinError(String colName,
String suggestion,
String side) |
static Throwable |
unsetNonExistentPropertiesError(scala.collection.Seq<String> properties,
org.apache.spark.sql.catalyst.TableIdentifier table) |
static Throwable |
unsupportedAppendInBatchModeError(org.apache.spark.sql.connector.catalog.Table table) |
static Throwable |
unsupportedBatchReadError(org.apache.spark.sql.connector.catalog.Table table) |
static Throwable |
unsupportedCorrelatedReferenceDataTypeError(org.apache.spark.sql.catalyst.expressions.Expression expr,
DataType dataType,
org.apache.spark.sql.catalyst.trees.Origin origin) |
static Throwable |
unsupportedDeleteByConditionWithSubqueryError(org.apache.spark.sql.catalyst.expressions.Expression condition) |
static Throwable |
unsupportedDynamicOverwriteInBatchModeError(org.apache.spark.sql.connector.catalog.Table table) |
static Throwable |
unsupportedIfNotExistsError(String tableName) |
static Throwable |
unsupportedJDBCNamespaceChangeInCatalogError(scala.collection.Seq<org.apache.spark.sql.connector.catalog.NamespaceChange> changes) |
static Throwable |
unsupportedMicroBatchOrContinuousScanError(org.apache.spark.sql.connector.catalog.Table table) |
static Throwable |
unsupportedOverwriteByFilterInBatchModeError(org.apache.spark.sql.connector.catalog.Table table) |
static Throwable |
unsupportedTableChangeInJDBCCatalogError(org.apache.spark.sql.connector.catalog.TableChange change) |
static Throwable |
unsupportedTableOperationError(org.apache.spark.sql.connector.catalog.CatalogPlugin catalog,
org.apache.spark.sql.connector.catalog.Identifier ident,
String operation) |
static Throwable |
unsupportedTableOperationError(org.apache.spark.sql.catalyst.TableIdentifier ident,
String operation) |
static Throwable |
unsupportedTruncateInBatchModeError(org.apache.spark.sql.connector.catalog.Table table) |
static Throwable |
upCastFailureError(String fromStr,
org.apache.spark.sql.catalyst.expressions.Expression from,
DataType to,
scala.collection.Seq<String> walkedTypePath) |
static Throwable |
usePythonUDFInJoinConditionUnsupportedError(org.apache.spark.sql.catalyst.plans.JoinType joinType) |
static Throwable |
userDefinedPartitionNotFoundInJDBCRelationError(String columnName,
String schema) |
static Throwable |
userSpecifiedSchemaMismatchActualSchemaError(StructType schema,
StructType actualSchema) |
static Throwable |
userSpecifiedSchemaUnsupportedError(String operation) |
static Throwable |
usingUntypedScalaUDFError() |
static Throwable |
v2FunctionInvalidInputTypeLengthError(org.apache.spark.sql.connector.catalog.functions.BoundFunction bound,
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> args) |
static Throwable |
viewAlreadyExistsError(org.apache.spark.sql.catalyst.TableIdentifier name) |
static Throwable |
viewDepthExceedsMaxResolutionDepthError(org.apache.spark.sql.catalyst.TableIdentifier identifier,
int maxNestedViewDepth,
org.apache.spark.sql.catalyst.trees.TreeNode<?> t) |
static Throwable |
windowAggregateFunctionWithFilterNotSupportedError() |
static Throwable |
windowFrameNotMatchRequiredFrameError(org.apache.spark.sql.catalyst.expressions.SpecifiedWindowFrame f,
org.apache.spark.sql.catalyst.expressions.WindowFrame required) |
static Throwable |
windowFunctionInAggregateFilterError() |
static Throwable |
windowFunctionInsideAggregateFunctionNotAllowedError() |
static Throwable |
windowFunctionNotAllowedError(String clauseName) |
static Throwable |
windowFunctionWithWindowFrameNotOrderedError(org.apache.spark.sql.catalyst.expressions.WindowFunction wf) |
static Throwable |
windowSpecificationNotDefinedError(String windowName) |
static Throwable |
writeDistributionAndOrderingNotSupportedInContinuousExecution() |
static Throwable |
writeEmptySchemasUnsupportedByDataSourceError() |
static Throwable |
writeIntoTempViewNotAllowedError(String quoted) |
static Throwable |
writeIntoV1TableNotAllowedError(org.apache.spark.sql.catalyst.TableIdentifier identifier,
org.apache.spark.sql.catalyst.trees.TreeNode<?> t) |
static Throwable |
writeIntoViewNotAllowedError(org.apache.spark.sql.catalyst.TableIdentifier identifier,
org.apache.spark.sql.catalyst.trees.TreeNode<?> t) |
static Throwable |
writeWithSaveModeUnsupportedBySourceError(String source,
String createMode) |
static Throwable |
wrongCommandForObjectTypeError(String operation,
String requiredType,
String objectName,
String foundType,
String alternative) |
static Throwable |
wrongNumArgsError(String name,
scala.collection.Seq<Object> validParametersCount,
int actualNumber,
String legacyNum,
String legacyConfKey,
String legacyConfValue) |
static Throwable |
zeroArgumentIndexError() |
public static Throwable unexpectedRequiredParameterInFunctionSignature(String functionName, org.apache.spark.sql.catalyst.plans.logical.FunctionSignature functionSignature)
public static Throwable namedArgumentsNotSupported(String functionName)
public static Throwable positionalAndNamedArgumentDoubleReference(String functionName, String parameterName)
public static Throwable doubleNamedArgumentReference(String functionName, String parameterName)
public static Throwable requiredParameterNotFound(String functionName, String parameterName, int index)
public static Throwable unrecognizedParameterName(String functionName, String argumentName, scala.collection.Seq<String> candidates)
public static Throwable unexpectedPositionalArgument(String functionName, String precedingNamedArgument)
public static Throwable groupingIDMismatchError(org.apache.spark.sql.catalyst.expressions.GroupingID groupingID, scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> groupByExprs)
public static Throwable groupingColInvalidError(org.apache.spark.sql.catalyst.expressions.Expression groupingCol, scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> groupByExprs)
public static Throwable groupingSizeTooLargeError(int sizeLimit)
public static Throwable zeroArgumentIndexError()
public static Throwable unorderablePivotColError(org.apache.spark.sql.catalyst.expressions.Expression pivotCol)
public static Throwable nonLiteralPivotValError(org.apache.spark.sql.catalyst.expressions.Expression pivotVal)
public static Throwable pivotValDataTypeMismatchError(org.apache.spark.sql.catalyst.expressions.Expression pivotVal, org.apache.spark.sql.catalyst.expressions.Expression pivotCol)
public static Throwable unpivotRequiresAttributes(String given, String empty, scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.NamedExpression> expressions)
public static Throwable unpivotRequiresValueColumns()
public static Throwable unpivotValueSizeMismatchError(int names)
public static Throwable unpivotValueDataTypeMismatchError(scala.collection.Seq<scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.NamedExpression>> values)
public static Throwable unsupportedIfNotExistsError(String tableName)
public static Throwable nonPartitionColError(String partitionName)
public static Throwable missingStaticPartitionColumn(String staticName)
public static Throwable staticPartitionInUserSpecifiedColumnsError(String staticName)
public static Throwable nestedGeneratorError(org.apache.spark.sql.catalyst.expressions.Expression trimmedNestedGenerator)
public static Throwable moreThanOneGeneratorError(scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> generators, String clause)
public static Throwable generatorOutsideSelectError(org.apache.spark.sql.catalyst.plans.logical.LogicalPlan plan)
public static Throwable legacyStoreAssignmentPolicyError()
public static Throwable namedArgumentsNotEnabledError(String functionName, String argumentName)
public static Throwable unresolvedUsingColForJoinError(String colName, String suggestion, String side)
public static Throwable unresolvedAttributeError(String errorClass, String colName, scala.collection.Seq<String> candidates, org.apache.spark.sql.catalyst.trees.Origin origin)
public static Throwable unresolvedColumnError(String columnName, scala.collection.Seq<String> proposal)
public static Throwable unresolvedFieldError(String fieldName, scala.collection.Seq<String> columnPath, scala.collection.Seq<String> proposal)
public static Throwable dataTypeMismatchForDeserializerError(DataType dataType, String desiredType)
public static Throwable fieldNumberMismatchForDeserializerError(StructType schema, int maxOrdinal)
public static Throwable upCastFailureError(String fromStr, org.apache.spark.sql.catalyst.expressions.Expression from, DataType to, scala.collection.Seq<String> walkedTypePath)
public static Throwable outerScopeFailureForNewInstanceError(String className)
public static Throwable referenceColNotFoundForAlterTableChangesError(String fieldName, String[] fields)
public static Throwable windowSpecificationNotDefinedError(String windowName)
public static Throwable selectExprNotInGroupByError(org.apache.spark.sql.catalyst.expressions.Expression expr, scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Alias> groupByAliases)
public static Throwable groupingMustWithGroupingSetsOrCubeOrRollupError()
public static Throwable pandasUDFAggregateNotSupportedInPivotError()
public static Throwable aggregateExpressionRequiredForPivotError(String sql)
public static Throwable writeIntoTempViewNotAllowedError(String quoted)
public static Throwable readNonStreamingTempViewError(String quoted)
public static Throwable viewDepthExceedsMaxResolutionDepthError(org.apache.spark.sql.catalyst.TableIdentifier identifier, int maxNestedViewDepth, org.apache.spark.sql.catalyst.trees.TreeNode<?> t)
public static Throwable insertIntoViewNotAllowedError(org.apache.spark.sql.catalyst.TableIdentifier identifier, org.apache.spark.sql.catalyst.trees.TreeNode<?> t)
public static Throwable writeIntoViewNotAllowedError(org.apache.spark.sql.catalyst.TableIdentifier identifier, org.apache.spark.sql.catalyst.trees.TreeNode<?> t)
public static Throwable writeIntoV1TableNotAllowedError(org.apache.spark.sql.catalyst.TableIdentifier identifier, org.apache.spark.sql.catalyst.trees.TreeNode<?> t)
public static Throwable expectTableNotViewError(scala.collection.Seq<String> nameParts, boolean isTemp, String cmd, scala.Option<String> mismatchHint, org.apache.spark.sql.catalyst.trees.TreeNode<?> t)
public static Throwable expectViewNotTempViewError(scala.collection.Seq<String> nameParts, String cmd, org.apache.spark.sql.catalyst.trees.TreeNode<?> t)
public static Throwable expectViewNotTableError(org.apache.spark.sql.catalyst.analysis.ResolvedTable v, String cmd, scala.Option<String> mismatchHint, org.apache.spark.sql.catalyst.trees.TreeNode<?> t)
public static Throwable expectTableOrPermanentViewNotTempViewError(scala.collection.Seq<String> nameParts, String cmd, org.apache.spark.sql.catalyst.trees.TreeNode<?> t)
public static Throwable expectPersistentFuncError(String name, String cmd, scala.Option<String> mismatchHint, org.apache.spark.sql.catalyst.trees.TreeNode<?> t)
public static Throwable permanentViewNotSupportedByStreamingReadingAPIError(String quoted)
public static Throwable starNotAllowedWhenGroupByOrdinalPositionUsedError()
public static Throwable invalidStarUsageError(String prettyName, scala.collection.Seq<org.apache.spark.sql.catalyst.analysis.Star> stars)
public static Throwable singleTableStarInCountNotAllowedError(String targetString)
public static Throwable orderByPositionRangeError(int index, int size, org.apache.spark.sql.catalyst.trees.TreeNode<?> t)
public static Throwable groupByPositionRefersToAggregateFunctionError(int index, org.apache.spark.sql.catalyst.expressions.Expression expr)
public static Throwable groupByPositionRangeError(int index, int size)
public static Throwable generatorNotExpectedError(org.apache.spark.sql.catalyst.FunctionIdentifier name, String classCanonicalName)
public static Throwable functionWithUnsupportedSyntaxError(String prettyName, String syntax)
public static Throwable nonDeterministicFilterInAggregateError()
public static Throwable nonBooleanFilterInAggregateError()
public static Throwable aggregateInAggregateFilterError()
public static Throwable windowFunctionInAggregateFilterError()
public static Throwable aliasNumberNotMatchColumnNumberError(int columnSize, int outputSize, org.apache.spark.sql.catalyst.trees.TreeNode<?> t)
public static Throwable aliasesNumberNotMatchUDTFOutputError(int aliasesSize, String aliasesNames)
public static Throwable windowAggregateFunctionWithFilterNotSupportedError()
public static Throwable windowFunctionInsideAggregateFunctionNotAllowedError()
public static Throwable expressionWithoutWindowExpressionError(org.apache.spark.sql.catalyst.expressions.NamedExpression expr)
public static Throwable expressionWithMultiWindowExpressionsError(org.apache.spark.sql.catalyst.expressions.NamedExpression expr, scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.WindowSpecDefinition> distinctWindowSpec)
public static Throwable windowFunctionNotAllowedError(String clauseName)
public static Throwable cannotSpecifyWindowFrameError(String prettyName)
public static Throwable windowFrameNotMatchRequiredFrameError(org.apache.spark.sql.catalyst.expressions.SpecifiedWindowFrame f, org.apache.spark.sql.catalyst.expressions.WindowFrame required)
public static Throwable windowFunctionWithWindowFrameNotOrderedError(org.apache.spark.sql.catalyst.expressions.WindowFunction wf)
public static Throwable multiTimeWindowExpressionsNotSupportedError(org.apache.spark.sql.catalyst.trees.TreeNode<?> t)
public static Throwable sessionWindowGapDurationDataTypeError(DataType dt)
public static Throwable unresolvedRoutineError(org.apache.spark.sql.catalyst.FunctionIdentifier name, scala.collection.Seq<String> searchPath)
public static Throwable unresolvedRoutineError(scala.collection.Seq<String> nameParts, scala.collection.Seq<String> searchPath, org.apache.spark.sql.catalyst.trees.Origin context)
public static Throwable wrongNumArgsError(String name, scala.collection.Seq<Object> validParametersCount, int actualNumber, String legacyNum, String legacyConfKey, String legacyConfValue)
public static Throwable alterV2TableSetLocationWithPartitionNotSupportedError()
public static Throwable joinStrategyHintParameterNotSupportedError(Object unsupported)
public static Throwable invalidHintParameterError(String hintName, scala.collection.Seq<Object> invalidParams)
public static Throwable invalidCoalesceHintParameterError(String hintName)
public static Throwable attributeNameSyntaxError(String name)
public static Throwable starExpandDataTypeNotSupportedError(scala.collection.Seq<String> attributes)
public static Throwable cannotResolveStarExpandGivenInputColumnsError(String targetString, String columns)
public static Throwable addColumnWithV1TableCannotSpecifyNotNullError()
public static Throwable unsupportedTableOperationError(org.apache.spark.sql.connector.catalog.CatalogPlugin catalog, org.apache.spark.sql.connector.catalog.Identifier ident, String operation)
public static Throwable unsupportedTableOperationError(org.apache.spark.sql.catalyst.TableIdentifier ident, String operation)
public static Throwable catalogOperationNotSupported(org.apache.spark.sql.connector.catalog.CatalogPlugin catalog, String operation)
public static Throwable alterColumnWithV1TableCannotSpecifyNotNullError()
public static Throwable alterColumnCannotFindColumnInV1TableError(String colName, org.apache.spark.sql.connector.catalog.V1Table v1Table)
public static Throwable invalidDatabaseNameError(String quoted)
public static Throwable wrongCommandForObjectTypeError(String operation, String requiredType, String objectName, String foundType, String alternative)
public static Throwable showColumnsWithConflictDatabasesError(scala.collection.Seq<String> db, org.apache.spark.sql.catalyst.TableIdentifier v1TableName)
public static Throwable cannotCreateTableWithBothProviderAndSerdeError(scala.Option<String> provider, scala.Option<org.apache.spark.sql.catalyst.plans.logical.SerdeInfo> maybeSerdeInfo)
public static Throwable invalidFileFormatForStoredAsError(org.apache.spark.sql.catalyst.plans.logical.SerdeInfo serdeInfo)
public static Throwable commandNotSupportNestedColumnError(String command, String quoted)
public static Throwable renameTempViewToExistingViewError(String newName)
public static Throwable cannotDropNonemptyDatabaseError(String db)
public static Throwable cannotDropNonemptyNamespaceError(scala.collection.Seq<String> namespace)
public static Throwable invalidNameForTableOrDatabaseError(String name)
public static Throwable cannotCreateDatabaseWithSameNameAsPreservedDatabaseError(String database)
public static Throwable cannotDropDefaultDatabaseError(String database)
public static Throwable cannotUsePreservedDatabaseAsCurrentDatabaseError(String database)
public static Throwable createExternalTableWithoutLocationError()
public static Throwable dropNonExistentColumnsNotSupportedError(scala.collection.Seq<String> nonExistentColumnNames)
public static Throwable cannotRetrieveTableOrViewNotInSameDatabaseError(scala.collection.Seq<org.apache.spark.sql.catalyst.QualifiedTableName> qualifiedTableNames)
public static Throwable renameTableSourceAndDestinationMismatchError(String db, String newDb)
public static Throwable cannotRenameTempViewWithDatabaseSpecifiedError(org.apache.spark.sql.catalyst.TableIdentifier oldName, org.apache.spark.sql.catalyst.TableIdentifier newName)
public static Throwable cannotRenameTempViewToExistingTableError(org.apache.spark.sql.catalyst.TableIdentifier newName)
public static Throwable invalidPartitionSpecError(String details)
public static Throwable functionAlreadyExistsError(org.apache.spark.sql.catalyst.FunctionIdentifier func)
public static Throwable cannotLoadClassWhenRegisteringFunctionError(String className, org.apache.spark.sql.catalyst.FunctionIdentifier func)
public static Throwable resourceTypeNotSupportedError(String resourceType)
public static Throwable tableNotSpecifyDatabaseError(org.apache.spark.sql.catalyst.TableIdentifier identifier)
public static Throwable tableNotSpecifyLocationUriError(org.apache.spark.sql.catalyst.TableIdentifier identifier)
public static Throwable partitionNotSpecifyLocationUriError(String specString)
public static Throwable invalidBucketNumberError(int bucketingMaxBuckets, int numBuckets)
public static Throwable corruptedTableNameContextInCatalogError(int numParts, int index)
public static Throwable corruptedViewSQLConfigsInCatalogError(Exception e)
public static Throwable corruptedViewQueryOutputColumnsInCatalogError(String numCols, int index)
public static Throwable corruptedViewReferredTempViewInCatalogError(Exception e)
public static Throwable corruptedViewReferredTempFunctionsInCatalogError(Exception e)
public static Throwable columnStatisticsDeserializationNotSupportedError(String name, DataType dataType)
public static Throwable columnStatisticsSerializationNotSupportedError(String colName, DataType dataType)
public static Throwable insufficientTablePropertyError(String key)
public static Throwable insufficientTablePropertyPartError(String key, String totalAmountOfParts)
public static Throwable unexpectedSchemaTypeError(org.apache.spark.sql.catalyst.expressions.Expression exp)
public static Throwable schemaIsNotStructTypeError(org.apache.spark.sql.catalyst.expressions.Expression exp, DataType dataType)
public static Throwable keyValueInMapNotStringError(org.apache.spark.sql.catalyst.expressions.CreateMap m)
public static Throwable nonMapFunctionNotAllowedError()
public static Throwable invalidFieldTypeForCorruptRecordError()
public static Throwable dataTypeUnsupportedByClassError(DataType x, String className)
public static Throwable parseModeUnsupportedError(String funcName, org.apache.spark.sql.catalyst.util.ParseMode mode)
public static Throwable requireLiteralParameter(String funcName, String argName, String requiredType)
public static Throwable literalTypeUnsupportedForSourceTypeError(String field, org.apache.spark.sql.catalyst.expressions.Expression source)
public static Throwable arrayComponentTypeUnsupportedError(Class<?> clz)
public static Throwable secondArgumentNotDoubleLiteralError()
public static Throwable dataTypeUnsupportedByExtractValueError(DataType dataType, org.apache.spark.sql.catalyst.expressions.Expression extraction, org.apache.spark.sql.catalyst.expressions.Expression child)
public static Throwable noHandlerForUDAFError(String name)
public static Throwable batchWriteCapabilityError(org.apache.spark.sql.connector.catalog.Table table, String v2WriteClassName, String v1WriteClassName)
public static Throwable unsupportedDeleteByConditionWithSubqueryError(org.apache.spark.sql.catalyst.expressions.Expression condition)
public static Throwable cannotTranslateExpressionToSourceFilterError(org.apache.spark.sql.catalyst.expressions.Expression f)
public static Throwable cannotDeleteTableWhereFiltersError(org.apache.spark.sql.connector.catalog.Table table, org.apache.spark.sql.connector.expressions.filter.Predicate[] filters)
public static Throwable describeDoesNotSupportPartitionForV2TablesError()
public static Throwable cannotReplaceMissingTableError(org.apache.spark.sql.connector.catalog.Identifier tableIdentifier)
public static Throwable cannotReplaceMissingTableError(org.apache.spark.sql.connector.catalog.Identifier tableIdentifier, scala.Option<Throwable> cause)
public static Throwable unsupportedBatchReadError(org.apache.spark.sql.connector.catalog.Table table)
public static Throwable unsupportedMicroBatchOrContinuousScanError(org.apache.spark.sql.connector.catalog.Table table)
public static Throwable unsupportedAppendInBatchModeError(org.apache.spark.sql.connector.catalog.Table table)
public static Throwable unsupportedDynamicOverwriteInBatchModeError(org.apache.spark.sql.connector.catalog.Table table)
public static Throwable unsupportedTruncateInBatchModeError(org.apache.spark.sql.connector.catalog.Table table)
public static Throwable unsupportedOverwriteByFilterInBatchModeError(org.apache.spark.sql.connector.catalog.Table table)
public static Throwable streamingSourcesDoNotSupportCommonExecutionModeError(scala.collection.Seq<String> microBatchSources, scala.collection.Seq<String> continuousSources)
public static org.apache.spark.sql.catalyst.analysis.NoSuchTableException noSuchTableError(org.apache.spark.sql.connector.catalog.Identifier ident)
public static Throwable noSuchTableError(scala.collection.Seq<String> nameParts)
public static Throwable noSuchNamespaceError(String[] namespace)
public static Throwable tableAlreadyExistsError(org.apache.spark.sql.connector.catalog.Identifier ident)
public static Throwable requiresSinglePartNamespaceError(scala.collection.Seq<String> namespace)
public static Throwable namespaceAlreadyExistsError(String[] namespace)
public static Throwable cannotCreateJDBCTableUsingProviderError()
public static Throwable cannotCreateJDBCTableUsingLocationError()
public static Throwable cannotCreateJDBCNamespaceUsingProviderError()
public static Throwable cannotCreateJDBCNamespaceWithPropertyError(String property)
public static Throwable cannotSetJDBCNamespaceWithPropertyError(String property)
public static Throwable cannotUnsetJDBCNamespaceWithPropertyError(String property)
public static Throwable unsupportedJDBCNamespaceChangeInCatalogError(scala.collection.Seq<org.apache.spark.sql.connector.catalog.NamespaceChange> changes)
public static Throwable tableDoesNotSupportReadsError(org.apache.spark.sql.connector.catalog.Table table)
public static Throwable tableDoesNotSupportWritesError(org.apache.spark.sql.connector.catalog.Table table)
public static Throwable tableDoesNotSupportDeletesError(org.apache.spark.sql.connector.catalog.Table table)
public static Throwable tableDoesNotSupportTruncatesError(org.apache.spark.sql.connector.catalog.Table table)
public static Throwable tableDoesNotSupportPartitionManagementError(org.apache.spark.sql.connector.catalog.Table table)
public static Throwable tableDoesNotSupportAtomicPartitionManagementError(org.apache.spark.sql.connector.catalog.Table table)
public static Throwable tableIsNotRowLevelOperationTableError(org.apache.spark.sql.connector.catalog.Table table)
public static Throwable cannotRenameTableWithAlterViewError()
public static Throwable analyzeTableNotSupportedForV2TablesError()
public static Throwable alterTableRecoverPartitionsNotSupportedForV2TablesError()
public static Throwable alterTableSerDePropertiesNotSupportedForV2TablesError()
public static Throwable loadDataNotSupportedForV2TablesError()
public static Throwable showCreateTableAsSerdeNotSupportedForV2TablesError()
public static Throwable showColumnsNotSupportedForV2TablesError()
public static Throwable repairTableNotSupportedForV2TablesError()
public static Throwable databaseFromV1SessionCatalogNotSpecifiedError()
public static Throwable nestedDatabaseUnsupportedByV1SessionCatalogError(String catalog)
public static Throwable invalidRepartitionExpressionsError(scala.collection.Seq<Object> sortOrders)
public static Throwable partitionColumnNotSpecifiedError(String format, String partitionColumn)
public static Throwable dataSchemaNotSpecifiedError(String format)
public static Throwable dataPathNotExistError(String path)
public static Throwable dataSourceOutputModeUnsupportedError(String className, OutputMode outputMode)
public static Throwable schemaNotSpecifiedForSchemaRelationProviderError(String className)
public static Throwable userSpecifiedSchemaMismatchActualSchemaError(StructType schema, StructType actualSchema)
public static Throwable dataSchemaNotSpecifiedError(String format, String fileCatalog)
public static Throwable invalidDataSourceError(String className)
public static Throwable cannotSaveIntervalIntoExternalStorageError()
public static Throwable cannotResolveAttributeError(String name, String outputStr)
public static Throwable orcNotUsedWithHiveEnabledError()
public static Throwable failedToFindAvroDataSourceError(String provider)
public static Throwable failedToFindKafkaDataSourceError(String provider)
public static Throwable findMultipleDataSourceError(String provider, scala.collection.Seq<String> sourceNames)
public static Throwable writeEmptySchemasUnsupportedByDataSourceError()
public static Throwable insertMismatchedColumnNumberError(scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> targetAttributes, scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> sourceAttributes, int staticPartitionsSize)
public static Throwable insertMismatchedPartitionNumberError(StructType targetPartitionSchema, int providedPartitionsSize)
public static Throwable invalidPartitionColumnError(String partKey, StructType targetPartitionSchema)
public static Throwable multiplePartitionColumnValuesSpecifiedError(StructField field, scala.collection.immutable.Map<String,String> potentialSpecs)
public static Throwable invalidOrderingForConstantValuePartitionColumnError(StructType targetPartitionSchema)
public static Throwable cannotWriteDataToRelationsWithMultiplePathsError()
public static Throwable failedToRebuildExpressionError(Filter filter)
public static Throwable dataTypeUnsupportedByDataSourceError(String format, StructField column)
public static Throwable failToResolveDataSourceForTableError(org.apache.spark.sql.catalyst.catalog.CatalogTable table, String key)
public static Throwable outputPathAlreadyExistsError(org.apache.hadoop.fs.Path outputPath)
public static Throwable cannotUseDataTypeForPartitionColumnError(StructField field)
public static Throwable cannotUseAllColumnsForPartitionColumnsError()
public static Throwable partitionColumnNotFoundInSchemaError(String col, String schemaCatalog)
public static Throwable columnNotFoundInSchemaError(StructField col, scala.Option<StructType> tableSchema)
public static Throwable saveDataIntoViewNotAllowedError()
public static Throwable mismatchedTableFormatError(String tableName, Class<?> existingProvider, Class<?> specifiedProvider)
public static Throwable mismatchedTableLocationError(org.apache.spark.sql.catalyst.TableIdentifier identifier, org.apache.spark.sql.catalyst.catalog.CatalogTable existingTable, org.apache.spark.sql.catalyst.catalog.CatalogTable tableDesc)
public static Throwable mismatchedTableColumnNumberError(String tableName, org.apache.spark.sql.catalyst.catalog.CatalogTable existingTable, org.apache.spark.sql.catalyst.plans.logical.LogicalPlan query)
public static Throwable cannotResolveColumnGivenInputColumnsError(String col, String inputColumns)
public static Throwable mismatchedTablePartitionColumnError(String tableName, scala.collection.Seq<String> specifiedPartCols, String existingPartCols)
public static Throwable mismatchedTableBucketingError(String tableName, String specifiedBucketString, String existingBucketString)
public static Throwable specifyPartitionNotAllowedWhenTableSchemaNotDefinedError()
public static Throwable bucketingColumnCannotBePartOfPartitionColumnsError(String bucketCol, scala.collection.Seq<String> normalizedPartCols)
public static Throwable bucketSortingColumnCannotBePartOfPartitionColumnsError(String sortCol, scala.collection.Seq<String> normalizedPartCols)
public static Throwable requestedPartitionsMismatchTablePartitionsError(String tableName, scala.collection.immutable.Map<String,scala.Option<String>> normalizedPartSpec, StructType partColNames)
public static Throwable ddlWithoutHiveSupportEnabledError(String cmd)
public static Throwable createTableColumnTypesOptionColumnNotFoundInSchemaError(String col, StructType schema)
public static Throwable parquetTypeUnsupportedYetError(String parquetType)
public static Throwable illegalParquetTypeError(String parquetType)
public static Throwable unrecognizedParquetTypeError(String field)
public static Throwable cannotConvertDataTypeToParquetTypeError(StructField field)
public static Throwable incompatibleViewSchemaChangeError(String viewName, String colName, int expectedNum, scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> actualCols, scala.Option<String> viewDDL)
public static Throwable numberOfPartitionsNotAllowedWithUnspecifiedDistributionError()
public static Throwable partitionSizeNotAllowedWithUnspecifiedDistributionError()
public static Throwable numberAndSizeOfPartitionsNotAllowedTogether()
public static Throwable unexpectedInputDataTypeError(String functionName, int paramIndex, DataType dataType, org.apache.spark.sql.catalyst.expressions.Expression expression)
public static Throwable streamJoinStreamWithoutEqualityPredicateUnsupportedError(org.apache.spark.sql.catalyst.plans.logical.LogicalPlan plan)
public static Throwable invalidPandasUDFPlacementError(scala.collection.Seq<String> groupAggPandasUDFNames)
public static Throwable ambiguousAttributesInSelfJoinError(scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.AttributeReference> ambiguousAttrs)
public static Throwable ambiguousColumnOrFieldError(scala.collection.Seq<String> name, int numMatches, org.apache.spark.sql.catalyst.trees.Origin context)
public static Throwable ambiguousReferenceError(String name, scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> ambiguousReferences)
public static Throwable cannotUseIntervalTypeInTableSchemaError()
public static Throwable missingCatalogAbilityError(org.apache.spark.sql.connector.catalog.CatalogPlugin plugin, String ability)
public static Throwable tableValuedFunctionTooManyTableArgumentsError(int num)
public static Throwable identifierTooManyNamePartsError(String originalIdentifier)
public static Throwable emptyMultipartIdentifierError()
public static Throwable cannotOperateOnHiveDataSourceFilesError(String operation)
public static Throwable setPathOptionAndCallWithPathParameterError(String method)
public static Throwable userSpecifiedSchemaUnsupportedError(String operation)
public static Throwable tempViewNotSupportStreamingWriteError(String viewName)
public static Throwable streamingIntoViewNotSupportedError(String viewName)
public static Throwable inputSourceDiffersFromDataSourceProviderError(String source, String tableName, org.apache.spark.sql.catalyst.catalog.CatalogTable table)
public static Throwable tableNotSupportStreamingWriteError(String tableName, org.apache.spark.sql.connector.catalog.Table t)
public static Throwable queryNameNotSpecifiedForMemorySinkError()
public static Throwable sourceNotSupportedWithContinuousTriggerError(String source)
public static Throwable columnNotFoundInExistingColumnsError(String columnType, String columnName, scala.collection.Seq<String> validColumnNames)
public static Throwable operationNotSupportPartitioningError(String operation)
public static Throwable mixedRefsInAggFunc(String funcStr, org.apache.spark.sql.catalyst.trees.Origin origin)
public static Throwable unsupportedCorrelatedReferenceDataTypeError(org.apache.spark.sql.catalyst.expressions.Expression expr, DataType dataType, org.apache.spark.sql.catalyst.trees.Origin origin)
public static Throwable functionCannotProcessInputError(org.apache.spark.sql.connector.catalog.functions.UnboundFunction unbound, scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> arguments, UnsupportedOperationException unsupported)
public static Throwable v2FunctionInvalidInputTypeLengthError(org.apache.spark.sql.connector.catalog.functions.BoundFunction bound, scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> args)
public static Throwable commandUnsupportedInV2TableError(String name)
public static Throwable cannotResolveColumnNameAmongAttributesError(String colName, String fieldNames)
public static Throwable cannotWriteTooManyColumnsToTableError(String tableName, scala.collection.Seq<String> expected, scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> queryOutput)
public static Throwable cannotWriteNotEnoughColumnsToTableError(String tableName, scala.collection.Seq<String> expected, scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> queryOutput)
public static Throwable incompatibleDataToTableCannotFindDataError(String tableName, String colName)
public static Throwable incompatibleDataToTableAmbiguousColumnNameError(String tableName, String colName)
public static Throwable incompatibleDataToTableExtraColumnsError(String tableName, String extraColumns)
public static Throwable incompatibleDataToTableExtraStructFieldsError(String tableName, String colName, String extraFields)
public static Throwable incompatibleDataToTableNullableColumnError(String tableName, String colName)
public static Throwable incompatibleDataToTableNullableArrayElementsError(String tableName, String colName)
public static Throwable incompatibleDataToTableNullableMapValuesError(String tableName, String colName)
public static Throwable incompatibleDataToTableCannotSafelyCastError(String tableName, String colName, String srcType, String targetType)
public static Throwable incompatibleDataToTableStructMissingFieldsError(String tableName, String colName, String missingFields)
public static Throwable incompatibleDataToTableUnexpectedColumnNameError(String tableName, String colName, int order, String expected, String found)
public static Throwable invalidRowLevelOperationAssignments(scala.collection.Seq<org.apache.spark.sql.catalyst.plans.logical.Assignment> assignments, scala.collection.Seq<String> errors)
public static Throwable invalidEscapeChar(org.apache.spark.sql.catalyst.expressions.Expression sqlExpr)
public static Throwable secondArgumentOfFunctionIsNotIntegerError(String function, NumberFormatException e)
public static Throwable nonPartitionPruningPredicatesNotExpectedError(scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> nonPartitionPruningPredicates)
public static Throwable columnNotDefinedInTableError(String colType, String colName, String tableName, scala.collection.Seq<String> tableCols)
public static Throwable invalidLiteralForWindowDurationError()
public static Throwable noSuchStructFieldInGivenFieldsError(String fieldName, StructField[] fields)
public static Throwable ambiguousReferenceToFieldsError(String field, int numberOfAppearance)
public static Throwable secondArgumentInFunctionIsNotBooleanLiteralError(String funcName)
public static Throwable joinConditionMissingOrTrivialError(org.apache.spark.sql.catalyst.plans.logical.Join join, org.apache.spark.sql.catalyst.plans.logical.LogicalPlan left, org.apache.spark.sql.catalyst.plans.logical.LogicalPlan right)
public static Throwable usePythonUDFInJoinConditionUnsupportedError(org.apache.spark.sql.catalyst.plans.JoinType joinType)
public static Throwable conflictingAttributesInJoinConditionError(org.apache.spark.sql.catalyst.expressions.AttributeSet conflictingAttrs, org.apache.spark.sql.catalyst.plans.logical.LogicalPlan outerPlan, org.apache.spark.sql.catalyst.plans.logical.LogicalPlan subplan)
public static Throwable emptyWindowExpressionError(org.apache.spark.sql.catalyst.plans.logical.Window expr)
public static Throwable foundDifferentWindowFunctionTypeError(scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.NamedExpression> windowExpressions)
public static Throwable charOrVarcharTypeAsStringUnsupportedError()
public static Throwable escapeCharacterInTheMiddleError(String pattern, String char_)
public static Throwable escapeCharacterAtTheEndError(String pattern)
public static Throwable tableIdentifierExistsError(org.apache.spark.sql.catalyst.TableIdentifier tableIdentifier)
public static Throwable tableIdentifierNotConvertedToHadoopFsRelationError(org.apache.spark.sql.catalyst.TableIdentifier tableIdentifier)
public static Throwable alterDatabaseLocationUnsupportedError()
public static Throwable hiveTableTypeUnsupportedError(String tableName, String tableType)
public static Throwable hiveCreatePermanentFunctionsUnsupportedError()
public static Throwable unknownHiveResourceTypeError(String resourceType)
public static Throwable configRemovedInVersionError(String configName, String version, String comment)
public static Throwable invalidPartitionColumnKeyInTableError(String key, String tblName)
public static Throwable invalidPartitionSpecError(String specKeys, scala.collection.Seq<String> partitionColumnNames, String tableName)
public static Throwable columnAlreadyExistsError(String columnName)
public static Throwable noSuchTableError(String db, String table)
public static Throwable tempViewNotCachedForAnalyzingColumnsError(org.apache.spark.sql.catalyst.TableIdentifier tableIdent)
public static Throwable columnTypeNotSupportStatisticsCollectionError(String name, org.apache.spark.sql.catalyst.TableIdentifier tableIdent, DataType dataType)
public static Throwable analyzeTableNotSupportedOnViewsError()
public static Throwable unexpectedPartitionColumnPrefixError(String table, String database, String schemaColumns, String specColumns)
public static Throwable noSuchPartitionError(String db, String table, scala.collection.immutable.Map<String,String> partition)
public static Throwable analyzingColumnStatisticsNotSupportedForColumnTypeError(String name, DataType dataType)
public static Throwable tableAlreadyExistsError(String table)
public static Throwable createTableAsSelectWithNonEmptyDirectoryError(String tablePath)
public static Throwable unsetNonExistentPropertiesError(scala.collection.Seq<String> properties, org.apache.spark.sql.catalyst.TableIdentifier table)
public static Throwable alterTableChangeColumnNotSupportedForColumnTypeError(String tableName, StructField originColumn, StructField newColumn)
public static Throwable cannotFindColumnError(String name, String[] fieldNames)
public static Throwable alterTableSetSerdeForSpecificPartitionNotSupportedError()
public static Throwable alterTableSetSerdeNotSupportedError()
public static Throwable cmdOnlyWorksOnPartitionedTablesError(String operation, String tableIdentWithDB)
public static Throwable cmdOnlyWorksOnTableWithLocationError(String cmd, String tableIdentWithDB)
public static Throwable actionNotAllowedOnTableWithFilesourcePartitionManagementDisabledError(String action, String tableName)
public static Throwable actionNotAllowedOnTableSincePartitionMetadataNotStoredError(String action, String tableName)
public static Throwable cannotAlterViewWithAlterTableError()
public static Throwable cannotAlterTableWithAlterViewError()
public static Throwable cannotOverwritePathBeingReadFromError(String path)
public static Throwable cannotOverwriteTableThatIsBeingReadFromError(org.apache.spark.sql.catalyst.TableIdentifier tableIdent)
public static Throwable cannotDropBuiltinFuncError(String functionName)
public static Throwable cannotRefreshBuiltInFuncError(String functionName)
public static Throwable cannotRefreshTempFuncError(String functionName)
public static Throwable noSuchFunctionError(org.apache.spark.sql.catalyst.FunctionIdentifier identifier)
public static Throwable alterAddColNotSupportViewError(org.apache.spark.sql.catalyst.TableIdentifier table)
public static Throwable alterAddColNotSupportDatasourceTableError(Object tableType, org.apache.spark.sql.catalyst.TableIdentifier table)
public static Throwable loadDataNotSupportedForDatasourceTablesError(String tableIdentWithDB)
public static Throwable loadDataWithoutPartitionSpecProvidedError(String tableIdentWithDB)
public static Throwable loadDataPartitionSizeNotMatchNumPartitionColumnsError(String tableIdentWithDB, int partitionSize, int targetTableSize)
public static Throwable loadDataTargetTableNotPartitionedButPartitionSpecWasProvidedError(String tableIdentWithDB)
public static Throwable loadDataInputPathNotExistError(String path)
public static Throwable truncateTableOnExternalTablesError(String tableIdentWithDB)
public static Throwable truncateTablePartitionNotSupportedForNotPartitionedTablesError(String tableIdentWithDB)
public static Throwable failToTruncateTableWhenRemovingDataError(String tableIdentWithDB, org.apache.hadoop.fs.Path path, Throwable e)
public static Throwable descPartitionNotAllowedOnTempView(String table)
public static Throwable descPartitionNotAllowedOnView(String table)
public static Throwable showPartitionNotAllowedOnTableNotPartitionedError(String tableIdentWithDB)
public static Throwable showCreateTableNotSupportedOnTempView(String table)
public static Throwable showCreateTableFailToExecuteUnsupportedFeatureError(org.apache.spark.sql.catalyst.catalog.CatalogTable table)
public static Throwable showCreateTableNotSupportTransactionalHiveTableError(org.apache.spark.sql.catalyst.catalog.CatalogTable table)
public static Throwable showCreateTableFailToExecuteUnsupportedConfError(org.apache.spark.sql.catalyst.TableIdentifier table, scala.collection.mutable.StringBuilder builder)
public static Throwable showCreateTableAsSerdeNotAllowedOnSparkDataSourceTableError(org.apache.spark.sql.catalyst.TableIdentifier table)
public static Throwable showCreateTableOrViewFailToExecuteUnsupportedFeatureError(org.apache.spark.sql.catalyst.catalog.CatalogTable table, scala.collection.Seq<String> features)
public static Throwable logicalPlanForViewNotAnalyzedError()
public static Throwable cannotCreateViewTooManyColumnsError(org.apache.spark.sql.catalyst.TableIdentifier viewIdent, scala.collection.Seq<String> expected, org.apache.spark.sql.catalyst.plans.logical.LogicalPlan query)
public static Throwable cannotCreateViewNotEnoughColumnsError(org.apache.spark.sql.catalyst.TableIdentifier viewIdent, scala.collection.Seq<String> expected, org.apache.spark.sql.catalyst.plans.logical.LogicalPlan query)
public static Throwable tableIsNotViewError(org.apache.spark.sql.catalyst.TableIdentifier name)
public static Throwable viewAlreadyExistsError(org.apache.spark.sql.catalyst.TableIdentifier name)
public static Throwable createPersistedViewFromDatasetAPINotAllowedError()
public static Throwable recursiveViewDetectedError(org.apache.spark.sql.catalyst.TableIdentifier viewIdent, scala.collection.Seq<org.apache.spark.sql.catalyst.TableIdentifier> newPath)
public static Throwable notAllowedToCreatePermanentViewWithoutAssigningAliasForExpressionError(org.apache.spark.sql.catalyst.TableIdentifier name, org.apache.spark.sql.catalyst.expressions.Attribute attr)
public static Throwable notAllowedToCreatePermanentViewByReferencingTempViewError(org.apache.spark.sql.catalyst.TableIdentifier name, String nameParts)
public static Throwable notAllowedToCreatePermanentViewByReferencingTempFuncError(org.apache.spark.sql.catalyst.TableIdentifier name, String funcName)
public static Throwable queryFromRawFilesIncludeCorruptRecordColumnError()
public static Throwable userDefinedPartitionNotFoundInJDBCRelationError(String columnName, String schema)
public static Throwable invalidPartitionColumnTypeError(StructField column)
public static Throwable tableOrViewAlreadyExistsError(String name)
public static Throwable invalidColumnNameAsPathError(String datasource, String columnName)
public static Throwable textDataSourceWithMultiColumnsError(StructType schema)
public static Throwable cannotFindPartitionColumnInPartitionSchemaError(StructField readField, StructType partitionSchema)
public static Throwable cannotSpecifyDatabaseForTempViewError(org.apache.spark.sql.catalyst.TableIdentifier tableIdent)
public static Throwable cannotCreateTempViewUsingHiveDataSourceError()
public static Throwable invalidTimestampProvidedForStrategyError(String strategy, String timeString)
public static Throwable hostOptionNotSetError()
public static Throwable portOptionNotSetError()
public static Throwable invalidIncludeTimestampValueError()
public static Throwable checkpointLocationNotSpecifiedError()
public static Throwable recoverQueryFromCheckpointUnsupportedError(org.apache.hadoop.fs.Path checkpointPath)
public static Throwable cannotFindColumnInRelationOutputError(String colName, org.apache.spark.sql.catalyst.plans.logical.LogicalPlan relation)
public static Throwable invalidBoundaryStartError(long start)
public static Throwable invalidBoundaryEndError(long end)
public static Throwable tableOrViewNotFound(scala.collection.Seq<String> ident)
public static Throwable unsupportedTableChangeInJDBCCatalogError(org.apache.spark.sql.connector.catalog.TableChange change)
public static Throwable pathOptionNotSetCorrectlyWhenReadingError()
public static Throwable pathOptionNotSetCorrectlyWhenWritingError()
public static Throwable writeWithSaveModeUnsupportedBySourceError(String source, String createMode)
public static Throwable partitionByDoesNotAllowedWhenUsingInsertIntoError()
public static Throwable cannotFindCatalogToHandleIdentifierError(String quote)
public static Throwable sortByWithoutBucketingError()
public static Throwable bucketByUnsupportedByOperationError(String operation)
public static Throwable bucketByAndSortByUnsupportedByOperationError(String operation)
public static Throwable tableAlreadyExistsError(org.apache.spark.sql.catalyst.TableIdentifier tableIdent)
public static Throwable invalidPartitionTransformationError(org.apache.spark.sql.catalyst.expressions.Expression expr)
public static AnalysisException unresolvedColumnWithSuggestionError(String objectName, String suggestion)
public static AnalysisException resolveException(String colName, String[] fields)
public static Throwable cannotParseIntervalError(String delayThreshold, Throwable e)
public static Throwable invalidJoinTypeInJoinWithError(org.apache.spark.sql.catalyst.plans.JoinType joinType)
public static Throwable cannotPassTypedColumnInUntypedSelectError(String typedCol)
public static Throwable invalidViewNameError(String viewName)
public static Throwable invalidBucketsNumberError(String numBuckets, String e)
public static Throwable usingUntypedScalaUDFError()
public static Throwable aggregationFunctionAppliedOnNonNumericColumnError(String colName)
public static Throwable aggregationFunctionAppliedOnNonNumericColumnError(String pivotColumn, int maxValues)
public static Throwable cannotModifyValueOfStaticConfigError(String key)
public static Throwable cannotModifyValueOfSparkConfigError(String key, String docroot)
public static Throwable commandExecutionInRunnerUnsupportedError(String runner)
public static Throwable udfClassDoesNotImplementAnyUDFInterfaceError(String className)
public static Throwable udfClassImplementMultiUDFInterfacesError(String className)
public static Throwable udfClassWithTooManyTypeArgumentsError(int n)
public static Throwable classWithoutPublicNonArgumentConstructorError(String className)
public static Throwable cannotLoadClassNotOnClassPathError(String className)
public static Throwable classDoesNotImplementUserDefinedAggregateFunctionError(String className)
public static Throwable missingFieldError(scala.collection.Seq<String> fieldName, org.apache.spark.sql.catalyst.analysis.ResolvedTable table, org.apache.spark.sql.catalyst.trees.Origin context)
public static Throwable invalidFieldName(scala.collection.Seq<String> fieldName, scala.collection.Seq<String> path, org.apache.spark.sql.catalyst.trees.Origin context)
public static Throwable invalidJsonSchema(DataType schema)
public static Throwable tableIndexNotSupportedError(String errorMessage)
public static Throwable invalidViewText(String viewText, String viewName)
public static Throwable invalidTimeTravelSpecError()
public static Throwable invalidTimestampExprForTimeTravel(String errorClass, org.apache.spark.sql.catalyst.expressions.Expression expr)
public static Throwable timeTravelUnsupportedError(String relationId)
public static Throwable writeDistributionAndOrderingNotSupportedInContinuousExecution()
public static Throwable defaultReferencesNotAllowedInComplexExpressionsInInsertValuesList()
public static Throwable defaultReferencesNotAllowedInComplexExpressionsInUpdateSetClause()
public static Throwable defaultReferencesNotAllowedInComplexExpressionsInMergeInsertsOrUpdates()
public static Throwable nonDeterministicMergeCondition(String condName, org.apache.spark.sql.catalyst.expressions.Expression cond)
public static Throwable subqueryNotAllowedInMergeCondition(String condName, org.apache.spark.sql.catalyst.expressions.Expression cond)
public static Throwable aggregationNotAllowedInMergeCondition(String condName, org.apache.spark.sql.catalyst.expressions.Expression cond)
public static Throwable failedToParseExistenceDefaultAsLiteral(String fieldName, String defaultValue)
public static Throwable defaultReferencesNotAllowedInDataSource(String statementType, String dataSource)
public static Throwable addNewDefaultColumnToExistingTableNotAllowed(String statementType, String dataSource)
public static Throwable defaultValuesDataTypeError(String statement, String colName, String defaultValue, DataType expectedType, DataType actualType)
public static Throwable defaultValuesUnresolvedExprError(String statement, String colName, String defaultValue, Throwable cause)
public static Throwable defaultValuesMayNotContainSubQueryExpressions(String statement, String colName, String defaultValue)
public static Throwable nullableColumnOrFieldError(scala.collection.Seq<String> name)
public static Throwable notNullConstraintViolationArrayElementError(scala.collection.Seq<String> path)
public static Throwable notNullConstraintViolationMapValueError(scala.collection.Seq<String> path)
public static Throwable invalidColumnOrFieldDataTypeError(scala.collection.Seq<String> name, DataType dt, DataType expected)
public static Throwable columnNotInGroupByClauseError(org.apache.spark.sql.catalyst.expressions.Expression expression)
public static Throwable cannotConvertProtobufTypeToSqlTypeError(String protobufColumn, scala.collection.Seq<String> sqlColumn, String protobufType, DataType sqlType)
public static Throwable cannotConvertCatalystTypeToProtobufTypeError(scala.collection.Seq<String> sqlColumn, String protobufColumn, DataType sqlType, String protobufType)
public static Throwable cannotConvertProtobufTypeToCatalystTypeError(String protobufType, DataType sqlType, Throwable cause)
public static Throwable cannotConvertSqlTypeToProtobufError(String protobufType, DataType sqlType, Throwable cause)
public static Throwable protobufTypeUnsupportedYetError(String protobufType)
public static Throwable unknownProtobufMessageTypeError(String descriptorName, String containingType)
public static Throwable cannotFindCatalystTypeInProtobufSchemaError(String catalystFieldPath)
public static Throwable cannotFindProtobufFieldInCatalystError(String field)
public static Throwable protobufFieldMatchError(String field, String protobufSchema, String matchSize, String matches)
public static Throwable unableToLocateProtobufMessageError(String messageName)
public static Throwable foundRecursionInProtobufSchema(String fieldDescriptor)
public static Throwable protobufFieldTypeMismatchError(String field)
public static Throwable protobufClassLoadError(String protobufClassName, String explanation, Throwable cause)
public static Throwable protobufDescriptorDependencyError(String dependencyName)
public static Throwable invalidByteStringFormatError(Object unsupported)
public static Throwable funcBuildError(String funcName, Exception cause)
public static Throwable ambiguousRelationAliasNameInNestedCTEError(String name)
public static Throwable ambiguousLateralColumnAliasError(String name, int numOfMatches)
public static Throwable ambiguousLateralColumnAliasError(scala.collection.Seq<String> nameParts, int numOfMatches)
public static Throwable lateralColumnAliasInAggFuncUnsupportedError(scala.collection.Seq<String> lcaNameParts, org.apache.spark.sql.catalyst.expressions.Expression aggExpr)
public static Throwable lateralColumnAliasInWindowUnsupportedError(scala.collection.Seq<String> lcaNameParts, org.apache.spark.sql.catalyst.expressions.Expression windowExpr)
public static Throwable lateralColumnAliasInAggWithWindowAndHavingUnsupportedError(scala.collection.Seq<String> lcaNameParts)
public static Throwable dataTypeOperationUnsupportedError()
public static Throwable nullableRowIdError(scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.AttributeReference> nullableRowIdAttrs)
public static Throwable cannotRenameTableAcrossSchemaError()
public static Throwable optionMustBeLiteralString(String key)
public static Throwable optionMustBeConstant(String key, scala.Option<Throwable> cause)
public static String toSQLId(String parts)
public static String toSQLId(scala.collection.Seq<String> parts)
public static String toSQLStmt(String text)
public static String toSQLConf(String conf)
public static String toSQLType(String text)
public static String toSQLType(org.apache.spark.sql.types.AbstractDataType t)
public static String toSQLValue(String value)
public static String toSQLValue(org.apache.spark.unsafe.types.UTF8String value)
public static String toSQLValue(short value)
public static String toSQLValue(int value)
public static String toSQLValue(long value)
public static String toSQLValue(float value)
public static String toSQLValue(double value)
public static String getSummary(org.apache.spark.sql.catalyst.trees.SQLQueryContext sqlContext)
public static QueryContext[] getQueryContext(org.apache.spark.sql.catalyst.trees.SQLQueryContext sqlContext)
public static String toSQLConfVal(String conf)
public static String toDSOption(String option)
public static String toSQLExpr(org.apache.spark.sql.catalyst.expressions.Expression e)
public static String toSQLSchema(String schema)
public static String toSQLValue(Object v, DataType t)
public static AnalysisException columnNotFoundError(String colName)
public static AnalysisException descriptorParseError(Throwable cause)
public static AnalysisException cannotFindDescriptorFileError(String filePath, Throwable cause)