Path Lines of Code sql/api/src/main/antlr4/org/apache/spark/sql/catalyst/parser/SqlBaseLexer.g4 607 sql/api/src/main/antlr4/org/apache/spark/sql/catalyst/parser/SqlBaseParser.g4 2122 sql/api/src/main/java/org/apache/spark/api/java/function/FlatMapGroupsWithStateFunction.java 9 sql/api/src/main/java/org/apache/spark/api/java/function/MapGroupsWithStateFunction.java 9 sql/api/src/main/java/org/apache/spark/sql/RowFactory.java 9 sql/api/src/main/java/org/apache/spark/sql/SaveMode.java 9 sql/api/src/main/java/org/apache/spark/sql/api/java/UDF0.java 7 sql/api/src/main/java/org/apache/spark/sql/api/java/UDF1.java 7 sql/api/src/main/java/org/apache/spark/sql/api/java/UDF10.java 7 sql/api/src/main/java/org/apache/spark/sql/api/java/UDF11.java 7 sql/api/src/main/java/org/apache/spark/sql/api/java/UDF12.java 7 sql/api/src/main/java/org/apache/spark/sql/api/java/UDF13.java 7 sql/api/src/main/java/org/apache/spark/sql/api/java/UDF14.java 7 sql/api/src/main/java/org/apache/spark/sql/api/java/UDF15.java 7 sql/api/src/main/java/org/apache/spark/sql/api/java/UDF16.java 7 sql/api/src/main/java/org/apache/spark/sql/api/java/UDF17.java 7 sql/api/src/main/java/org/apache/spark/sql/api/java/UDF18.java 7 sql/api/src/main/java/org/apache/spark/sql/api/java/UDF19.java 7 sql/api/src/main/java/org/apache/spark/sql/api/java/UDF2.java 7 sql/api/src/main/java/org/apache/spark/sql/api/java/UDF20.java 7 sql/api/src/main/java/org/apache/spark/sql/api/java/UDF21.java 7 sql/api/src/main/java/org/apache/spark/sql/api/java/UDF22.java 7 sql/api/src/main/java/org/apache/spark/sql/api/java/UDF3.java 7 sql/api/src/main/java/org/apache/spark/sql/api/java/UDF4.java 7 sql/api/src/main/java/org/apache/spark/sql/api/java/UDF5.java 7 sql/api/src/main/java/org/apache/spark/sql/api/java/UDF6.java 7 sql/api/src/main/java/org/apache/spark/sql/api/java/UDF7.java 7 sql/api/src/main/java/org/apache/spark/sql/api/java/UDF8.java 7 sql/api/src/main/java/org/apache/spark/sql/api/java/UDF9.java 7 sql/api/src/main/java/org/apache/spark/sql/api/java/package-info.java 1 sql/api/src/main/java/org/apache/spark/sql/connector/catalog/Identifier.java 10 sql/api/src/main/java/org/apache/spark/sql/connector/catalog/IdentifierImpl.java 47 sql/api/src/main/java/org/apache/spark/sql/connector/catalog/IdentityColumnSpec.java 44 sql/api/src/main/java/org/apache/spark/sql/expressions/javalang/typed.java 22 sql/api/src/main/java/org/apache/spark/sql/streaming/GroupStateTimeout.java 11 sql/api/src/main/java/org/apache/spark/sql/streaming/OutputMode.java 15 sql/api/src/main/java/org/apache/spark/sql/streaming/TimeMode.java 11 sql/api/src/main/java/org/apache/spark/sql/streaming/Trigger.java 42 sql/api/src/main/java/org/apache/spark/sql/types/DataTypes.java 117 sql/api/src/main/java/org/apache/spark/sql/types/SQLUserDefinedType.java 9 sql/api/src/main/scala/org/apache/spark/sql/AnalysisException.scala 106 sql/api/src/main/scala/org/apache/spark/sql/Artifact.scala 105 sql/api/src/main/scala/org/apache/spark/sql/Column.scala 274 sql/api/src/main/scala/org/apache/spark/sql/DataFrameNaFunctions.scala 53 sql/api/src/main/scala/org/apache/spark/sql/DataFrameReader.scala 133 sql/api/src/main/scala/org/apache/spark/sql/DataFrameStatFunctions.scala 80 sql/api/src/main/scala/org/apache/spark/sql/DataFrameWriter.scala 139 sql/api/src/main/scala/org/apache/spark/sql/DataFrameWriterV2.scala 46 sql/api/src/main/scala/org/apache/spark/sql/Dataset.scala 412 sql/api/src/main/scala/org/apache/spark/sql/DatasetHolder.scala 8 sql/api/src/main/scala/org/apache/spark/sql/Encoder.scala 12 sql/api/src/main/scala/org/apache/spark/sql/Encoders.scala 79 sql/api/src/main/scala/org/apache/spark/sql/ForeachWriter.scala 6 sql/api/src/main/scala/org/apache/spark/sql/KeyValueGroupedDataset.scala 228 sql/api/src/main/scala/org/apache/spark/sql/MergeIntoWriter.scala 72 sql/api/src/main/scala/org/apache/spark/sql/Observation.scala 36 sql/api/src/main/scala/org/apache/spark/sql/RelationalGroupedDataset.scala 53 sql/api/src/main/scala/org/apache/spark/sql/Row.scala 242 sql/api/src/main/scala/org/apache/spark/sql/RuntimeConfig.scala 26 sql/api/src/main/scala/org/apache/spark/sql/SQLContext.scala 296 sql/api/src/main/scala/org/apache/spark/sql/SQLImplicits.scala 102 sql/api/src/main/scala/org/apache/spark/sql/SparkSession.scala 313 sql/api/src/main/scala/org/apache/spark/sql/TableValuedFunction.scala 22 sql/api/src/main/scala/org/apache/spark/sql/UDFRegistration.scala 51 sql/api/src/main/scala/org/apache/spark/sql/avro/functions.scala 34 sql/api/src/main/scala/org/apache/spark/sql/catalog/Catalog.scala 156 sql/api/src/main/scala/org/apache/spark/sql/catalog/interface.scala 134 sql/api/src/main/scala/org/apache/spark/sql/catalyst/DefinedByConstructorParams.scala 2 sql/api/src/main/scala/org/apache/spark/sql/catalyst/JavaTypeInference.scala 120 sql/api/src/main/scala/org/apache/spark/sql/catalyst/ScalaReflection.scala 324 sql/api/src/main/scala/org/apache/spark/sql/catalyst/WalkedTypePath.scala 26 sql/api/src/main/scala/org/apache/spark/sql/catalyst/analysis/NonEmptyException.scala 12 sql/api/src/main/scala/org/apache/spark/sql/catalyst/analysis/SqlApiAnalysis.scala 4 sql/api/src/main/scala/org/apache/spark/sql/catalyst/analysis/alreadyExistException.scala 151 sql/api/src/main/scala/org/apache/spark/sql/catalyst/analysis/noSuchItemsExceptions.scala 171 sql/api/src/main/scala/org/apache/spark/sql/catalyst/encoders/AgnosticEncoder.scala 213 sql/api/src/main/scala/org/apache/spark/sql/catalyst/encoders/OuterScopes.scala 99 sql/api/src/main/scala/org/apache/spark/sql/catalyst/encoders/RowEncoder.scala 81 sql/api/src/main/scala/org/apache/spark/sql/catalyst/encoders/codecs.scala 30 sql/api/src/main/scala/org/apache/spark/sql/catalyst/expressions/OrderUtils.scala 13 sql/api/src/main/scala/org/apache/spark/sql/catalyst/expressions/rows.scala 17 sql/api/src/main/scala/org/apache/spark/sql/catalyst/parser/DataTypeAstBuilder.scala 201 sql/api/src/main/scala/org/apache/spark/sql/catalyst/parser/DataTypeParserInterface.scala 8 sql/api/src/main/scala/org/apache/spark/sql/catalyst/parser/LegacyTypeStringParser.scala 60 sql/api/src/main/scala/org/apache/spark/sql/catalyst/parser/SparkParserErrorStrategy.scala 91 sql/api/src/main/scala/org/apache/spark/sql/catalyst/parser/parsers.scala 313 sql/api/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/LogicalGroupState.scala 2 sql/api/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/TimeMode.scala 23 sql/api/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/groupStateTimeouts.scala 5 sql/api/src/main/scala/org/apache/spark/sql/catalyst/streaming/InternalOutputModes.scala 23 sql/api/src/main/scala/org/apache/spark/sql/catalyst/trees/QueryContexts.scala 126 sql/api/src/main/scala/org/apache/spark/sql/catalyst/trees/origin.scala 84 sql/api/src/main/scala/org/apache/spark/sql/catalyst/util/AttributeNameParser.scala 43 sql/api/src/main/scala/org/apache/spark/sql/catalyst/util/CaseInsensitiveMap.scala 28 sql/api/src/main/scala/org/apache/spark/sql/catalyst/util/DataTypeJsonUtils.scala 26 sql/api/src/main/scala/org/apache/spark/sql/catalyst/util/DateFormatter.scala 140 sql/api/src/main/scala/org/apache/spark/sql/catalyst/util/DateTimeFormatterHelper.scala 248 sql/api/src/main/scala/org/apache/spark/sql/catalyst/util/MathUtils.scala 65 sql/api/src/main/scala/org/apache/spark/sql/catalyst/util/QuotingUtils.scala 52 sql/api/src/main/scala/org/apache/spark/sql/catalyst/util/RebaseDateTime.scala 209 sql/api/src/main/scala/org/apache/spark/sql/catalyst/util/ResolveDefaultColumnsUtils.scala 6 sql/api/src/main/scala/org/apache/spark/sql/catalyst/util/SparkCharVarcharUtils.scala 29 sql/api/src/main/scala/org/apache/spark/sql/catalyst/util/SparkDateTimeUtils.scala 426 sql/api/src/main/scala/org/apache/spark/sql/catalyst/util/SparkIntervalUtils.scala 430 sql/api/src/main/scala/org/apache/spark/sql/catalyst/util/SparkParserUtils.scala 144 sql/api/src/main/scala/org/apache/spark/sql/catalyst/util/StringUtils.scala 80 sql/api/src/main/scala/org/apache/spark/sql/catalyst/util/TimeFormatter.scala 77 sql/api/src/main/scala/org/apache/spark/sql/catalyst/util/TimestampFormatter.scala 432 sql/api/src/main/scala/org/apache/spark/sql/catalyst/util/UDTUtils.scala 24 sql/api/src/main/scala/org/apache/spark/sql/errors/CompilationErrors.scala 101 sql/api/src/main/scala/org/apache/spark/sql/errors/DataTypeErrors.scala 224 sql/api/src/main/scala/org/apache/spark/sql/errors/DataTypeErrorsBase.scala 68 sql/api/src/main/scala/org/apache/spark/sql/errors/ExecutionErrors.scala 210 sql/api/src/main/scala/org/apache/spark/sql/errors/QueryParsingErrors.scala 681 sql/api/src/main/scala/org/apache/spark/sql/execution/streaming/Triggers.scala 64 sql/api/src/main/scala/org/apache/spark/sql/expressions/Aggregator.scala 15 sql/api/src/main/scala/org/apache/spark/sql/expressions/ReduceAggregator.scala 49 sql/api/src/main/scala/org/apache/spark/sql/expressions/UserDefinedFunction.scala 113 sql/api/src/main/scala/org/apache/spark/sql/expressions/Window.scala 36 sql/api/src/main/scala/org/apache/spark/sql/expressions/WindowSpec.scala 66 sql/api/src/main/scala/org/apache/spark/sql/expressions/scalalang/typed.scala 10 sql/api/src/main/scala/org/apache/spark/sql/expressions/udaf.scala 32 sql/api/src/main/scala/org/apache/spark/sql/functions.scala 1882 sql/api/src/main/scala/org/apache/spark/sql/internal/LegacyBehaviorPolicy.scala 4 sql/api/src/main/scala/org/apache/spark/sql/internal/SqlApiConf.scala 56 sql/api/src/main/scala/org/apache/spark/sql/internal/SqlApiConfHelper.scala 17 sql/api/src/main/scala/org/apache/spark/sql/internal/TableValuedFunctionArgument.scala 2 sql/api/src/main/scala/org/apache/spark/sql/internal/ToScalaUDF.scala 31 sql/api/src/main/scala/org/apache/spark/sql/internal/columnNodes.scala 408 sql/api/src/main/scala/org/apache/spark/sql/internal/typedaggregators.scala 57 sql/api/src/main/scala/org/apache/spark/sql/internal/types/AbstractArrayType.scala 11 sql/api/src/main/scala/org/apache/spark/sql/internal/types/AbstractMapType.scala 14 sql/api/src/main/scala/org/apache/spark/sql/internal/types/AbstractStringType.scala 68 sql/api/src/main/scala/org/apache/spark/sql/package.scala 8 sql/api/src/main/scala/org/apache/spark/sql/protobuf/functions.scala 97 sql/api/src/main/scala/org/apache/spark/sql/streaming/DataStreamReader.scala 48 sql/api/src/main/scala/org/apache/spark/sql/streaming/DataStreamWriter.scala 36 sql/api/src/main/scala/org/apache/spark/sql/streaming/ExpiredTimerInfo.scala 7 sql/api/src/main/scala/org/apache/spark/sql/streaming/GroupState.scala 43 sql/api/src/main/scala/org/apache/spark/sql/streaming/ListState.scala 11 sql/api/src/main/scala/org/apache/spark/sql/streaming/MapState.scala 14 sql/api/src/main/scala/org/apache/spark/sql/streaming/QueryInfo.scala 11 sql/api/src/main/scala/org/apache/spark/sql/streaming/StatefulProcessor.scala 30 sql/api/src/main/scala/org/apache/spark/sql/streaming/StatefulProcessorHandle.scala 28 sql/api/src/main/scala/org/apache/spark/sql/streaming/StreamingQuery.scala 26 sql/api/src/main/scala/org/apache/spark/sql/streaming/StreamingQueryListener.scala 142 sql/api/src/main/scala/org/apache/spark/sql/streaming/StreamingQueryManager.scala 17 sql/api/src/main/scala/org/apache/spark/sql/streaming/StreamingQueryStatus.scala 30 sql/api/src/main/scala/org/apache/spark/sql/streaming/TTLConfig.scala 6 sql/api/src/main/scala/org/apache/spark/sql/streaming/TimerValues.scala 8 sql/api/src/main/scala/org/apache/spark/sql/streaming/ValueState.scala 10 sql/api/src/main/scala/org/apache/spark/sql/streaming/progress.scala 192 sql/api/src/main/scala/org/apache/spark/sql/types/AbstractDataType.scala 68 sql/api/src/main/scala/org/apache/spark/sql/types/ArrayType.scala 50 sql/api/src/main/scala/org/apache/spark/sql/types/BinaryType.scala 9 sql/api/src/main/scala/org/apache/spark/sql/types/BooleanType.scala 9 sql/api/src/main/scala/org/apache/spark/sql/types/ByteType.scala 10 sql/api/src/main/scala/org/apache/spark/sql/types/CalendarIntervalType.scala 10 sql/api/src/main/scala/org/apache/spark/sql/types/CharType.scala 14 sql/api/src/main/scala/org/apache/spark/sql/types/DataType.scala 369 sql/api/src/main/scala/org/apache/spark/sql/types/DateType.scala 9 sql/api/src/main/scala/org/apache/spark/sql/types/DayTimeIntervalType.scala 47 sql/api/src/main/scala/org/apache/spark/sql/types/Decimal.scala 495 sql/api/src/main/scala/org/apache/spark/sql/types/DecimalType.scala 131 sql/api/src/main/scala/org/apache/spark/sql/types/DoubleType.scala 32 sql/api/src/main/scala/org/apache/spark/sql/types/FloatType.scala 36 sql/api/src/main/scala/org/apache/spark/sql/types/IntegerType.scala 10 sql/api/src/main/scala/org/apache/spark/sql/types/LongType.scala 10 sql/api/src/main/scala/org/apache/spark/sql/types/MapType.scala 59 sql/api/src/main/scala/org/apache/spark/sql/types/Metadata.scala 183 sql/api/src/main/scala/org/apache/spark/sql/types/NullType.scala 10 sql/api/src/main/scala/org/apache/spark/sql/types/ObjectType.scala 20 sql/api/src/main/scala/org/apache/spark/sql/types/ShortType.scala 10 sql/api/src/main/scala/org/apache/spark/sql/types/StringType.scala 108 sql/api/src/main/scala/org/apache/spark/sql/types/StructField.scala 148 sql/api/src/main/scala/org/apache/spark/sql/types/StructType.scala 406 sql/api/src/main/scala/org/apache/spark/sql/types/TimeType.scala 18 sql/api/src/main/scala/org/apache/spark/sql/types/TimestampNTZType.scala 10 sql/api/src/main/scala/org/apache/spark/sql/types/TimestampType.scala 9 sql/api/src/main/scala/org/apache/spark/sql/types/UDTRegistration.scala 41 sql/api/src/main/scala/org/apache/spark/sql/types/UpCastRule.scala 41 sql/api/src/main/scala/org/apache/spark/sql/types/UserDefinedType.scala 66 sql/api/src/main/scala/org/apache/spark/sql/types/VarcharType.scala 14 sql/api/src/main/scala/org/apache/spark/sql/types/VariantType.scala 9 sql/api/src/main/scala/org/apache/spark/sql/types/YearMonthIntervalType.scala 43 sql/api/src/main/scala/org/apache/spark/sql/util/ArrowUtils.scala 221 sql/api/src/main/scala/org/apache/spark/sql/util/ArtifactUtils.scala 14 sql/api/src/main/scala/org/apache/spark/sql/util/ProtobufUtils.scala 19 sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/ArrayExpressionUtils.java 134 sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/BitmapExpressionUtils.java 29 sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/ExpressionDescription.java 18 sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/ExpressionImplUtils.java 259 sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/ExpressionInfo.java 160 sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/FixedLengthRowBasedKeyValueBatch.java 110 sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/RowBasedKeyValueBatch.java 96 sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/SpecializedGetters.java 28 sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/SpecializedGettersReader.java 69 sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/ToJavaArrayUtils.java 57 sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/UnsafeArrayData.java 400 sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/UnsafeDataUtils.java 17 sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/UnsafeMapData.java 101 sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/UnsafeRow.java 471 sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/VariableLengthRowBasedKeyValueBatch.java 118 sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/XXH64.java 148 sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/codegen/BufferHolder.java 71 sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/codegen/UnsafeArrayWriter.java 137 sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/codegen/UnsafeRowWriter.java 137 sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/codegen/UnsafeWriter.java 168 sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/json/JsonExpressionUtils.java 46 sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/xml/UDFXPathUtil.java 164 sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/util/CharVarcharCodegenUtils.java 44 sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/util/HadoopCompressionCodec.java 37 sql/catalyst/src/main/java/org/apache/spark/sql/connector/ExternalCommandRunner.java 7 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/CatalogExtension.java 7 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/CatalogPlugin.java 12 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/Column.java 67 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/ColumnDefaultValue.java 42 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/DefaultValue.java 50 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/DelegatingCatalogExtension.java 147 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/FunctionCatalog.java 18 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/MetadataColumn.java 27 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/NamespaceChange.java 34 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/ProcedureCatalog.java 8 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/SessionConfigSupport.java 6 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/StagedTable.java 16 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/StagingTableCatalog.java 83 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/SupportsAtomicPartitionManagement.java 41 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/SupportsCatalogOptions.java 17 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/SupportsDelete.java 30 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/SupportsDeleteV2.java 20 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/SupportsMetadataColumns.java 10 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/SupportsNamespaces.java 32 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/SupportsPartitionManagement.java 48 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/SupportsRead.java 9 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/SupportsRowLevelOperations.java 9 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/SupportsWrite.java 9 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/Table.java 26 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/TableCapability.java 15 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/TableCatalog.java 78 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/TableCatalogCapability.java 9 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/TableChange.java 490 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/TableInfo.java 58 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/TableProvider.java 17 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/TableWritePrivilege.java 6 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/TruncatableTable.java 6 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/View.java 16 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/ViewCatalog.java 51 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/ViewChange.java 34 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/ViewInfo.java 117 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/constraints/BaseConstraint.java 94 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/constraints/Check.java 75 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/constraints/Constraint.java 31 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/constraints/ForeignKey.java 92 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/constraints/PrimaryKey.java 57 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/constraints/Unique.java 56 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/functions/AggregateFunction.java 12 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/functions/BoundFunction.java 20 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/functions/Function.java 7 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/functions/Reducer.java 6 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/functions/ReducibleFunction.java 14 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/functions/ScalarFunction.java 17 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/functions/UnboundFunction.java 8 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/index/SupportsIndex.java 19 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/index/TableIndex.java 31 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/procedures/BoundProcedure.java 12 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/procedures/Procedure.java 9 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/procedures/ProcedureParameter.java 58 sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/procedures/UnboundProcedure.java 7 sql/catalyst/src/main/java/org/apache/spark/sql/connector/distributions/ClusteredDistribution.java 7 sql/catalyst/src/main/java/org/apache/spark/sql/connector/distributions/Distribution.java 4 sql/catalyst/src/main/java/org/apache/spark/sql/connector/distributions/Distributions.java 18 sql/catalyst/src/main/java/org/apache/spark/sql/connector/distributions/OrderedDistribution.java 7 sql/catalyst/src/main/java/org/apache/spark/sql/connector/distributions/UnspecifiedDistribution.java 4 sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/Cast.java 38 sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/Expression.java 19 sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/Expressions.java 47 sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/Extract.java 16 sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/GeneralScalarExpression.java 31 sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/Literal.java 10 sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/NamedReference.java 10 sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/NullOrdering.java 13 sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/SortDirection.java 22 sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/SortOrder.java 10 sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/Transform.java 9 sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/UserDefinedScalarFunc.java 35 sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/aggregate/AggregateFunc.java 7 sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/aggregate/Aggregation.java 9 sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/aggregate/Avg.java 17 sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/aggregate/Count.java 17 sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/aggregate/CountStar.java 11 sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/aggregate/GeneralAggregateFunc.java 49 sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/aggregate/Max.java 12 sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/aggregate/Min.java 12 sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/aggregate/Sum.java 17 sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/aggregate/UserDefinedAggregateFunc.java 42 sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/filter/AlwaysFalse.java 21 sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/filter/AlwaysTrue.java 21 sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/filter/And.java 10 sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/filter/Not.java 9 sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/filter/Or.java 10 sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/filter/Predicate.java 10 sql/catalyst/src/main/java/org/apache/spark/sql/connector/metric/CustomAvgMetric.java 19 sql/catalyst/src/main/java/org/apache/spark/sql/connector/metric/CustomMetric.java 9 sql/catalyst/src/main/java/org/apache/spark/sql/connector/metric/CustomSumMetric.java 13 sql/catalyst/src/main/java/org/apache/spark/sql/connector/metric/CustomTaskMetric.java 8 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/Batch.java 7 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/HasPartitionKey.java 5 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/HasPartitionStatistics.java 7 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/InputPartition.java 9 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/LocalScan.java 7 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/PartitionReader.java 14 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/PartitionReaderFactory.java 16 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/Scan.java 44 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/ScanBuilder.java 6 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/Statistics.java 15 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/SupportsPushDownAggregates.java 8 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/SupportsPushDownFilters.java 8 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/SupportsPushDownLimit.java 7 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/SupportsPushDownOffset.java 6 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/SupportsPushDownRequiredColumns.java 7 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/SupportsPushDownTableSample.java 10 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/SupportsPushDownTopN.java 8 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/SupportsPushDownV2Filters.java 8 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/SupportsReportOrdering.java 7 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/SupportsReportPartitioning.java 7 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/SupportsReportStatistics.java 6 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/SupportsRuntimeFiltering.java 14 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/SupportsRuntimeV2Filtering.java 10 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/colstats/ColumnStatistics.java 29 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/colstats/Histogram.java 7 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/colstats/HistogramBin.java 8 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/partitioning/KeyGroupedPartitioning.java 19 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/partitioning/Partitioning.java 7 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/partitioning/UnknownPartitioning.java 13 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/streaming/AcceptsLatestSeenOffset.java 4 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/streaming/CompositeReadLimit.java 26 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/streaming/ContinuousPartitionReader.java 7 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/streaming/ContinuousPartitionReaderFactory.java 17 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/streaming/ContinuousStream.java 13 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/streaming/MicroBatchStream.java 12 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/streaming/Offset.java 22 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/streaming/PartitionOffset.java 6 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/streaming/ReadAllAvailable.java 11 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/streaming/ReadLimit.java 15 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/streaming/ReadMaxBytes.java 23 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/streaming/ReadMaxFiles.java 23 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/streaming/ReadMaxRows.java 23 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/streaming/ReadMinRows.java 30 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/streaming/ReportsSinkMetrics.java 7 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/streaming/ReportsSourceMetrics.java 8 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/streaming/SparkDataStream.java 9 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/streaming/SupportsAdmissionControl.java 8 sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/streaming/SupportsTriggerAvailableNow.java 6 sql/catalyst/src/main/java/org/apache/spark/sql/connector/util/V2ExpressionSQLBuilder.java 313 sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/BatchWrite.java 12 sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/DataWriter.java 23 sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/DataWriterFactory.java 9 sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/DeltaBatchWrite.java 7 sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/DeltaWrite.java 12 sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/DeltaWriteBuilder.java 12 sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/DeltaWriter.java 16 sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/DeltaWriterFactory.java 8 sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/LogicalWriteInfo.java 21 sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/PhysicalWriteInfo.java 7 sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/RequiresDistributionAndOrdering.java 13 sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/RowLevelOperation.java 22 sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/RowLevelOperationBuilder.java 6 sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/RowLevelOperationInfo.java 9 sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/SupportsDelta.java 12 sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/SupportsDynamicOverwrite.java 6 sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/SupportsOverwrite.java 25 sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/SupportsOverwriteV2.java 15 sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/SupportsTruncate.java 6 sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/Write.java 29 sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/WriteBuilder.java 30 sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/WriterCommitMessage.java 6 sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/streaming/StreamingDataWriterFactory.java 11 sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/streaming/StreamingWrite.java 14 sql/catalyst/src/main/java/org/apache/spark/sql/util/CaseInsensitiveStringMap.java 130 sql/catalyst/src/main/java/org/apache/spark/sql/util/NumericHistogram.java 140 sql/catalyst/src/main/java/org/apache/spark/sql/vectorized/ArrowColumnVector.java 481 sql/catalyst/src/main/java/org/apache/spark/sql/vectorized/ColumnVector.java 105 sql/catalyst/src/main/java/org/apache/spark/sql/vectorized/ColumnarArray.java 154 sql/catalyst/src/main/java/org/apache/spark/sql/vectorized/ColumnarBatch.java 59 sql/catalyst/src/main/java/org/apache/spark/sql/vectorized/ColumnarBatchRow.java 164 sql/catalyst/src/main/java/org/apache/spark/sql/vectorized/ColumnarMap.java 27 sql/catalyst/src/main/java/org/apache/spark/sql/vectorized/ColumnarRow.java 166 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/CatalystTypeConverters.scala 464 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/CurrentUserContext.scala 9 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/DataSourceOptions.scala 48 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/DeserializerBuildHelper.scala 407 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/ExtendedAnalysisException.scala 60 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/FileSourceOptions.scala 27 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/InternalRow.scala 113 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/OrderedFilters.scala 38 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/ProjectingInternalRow.scala 78 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/QueryPlanningTracker.scala 91 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/SQLConfHelper.scala 31 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/SerializerBuildHelper.scala 418 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/SqlScriptingLocalVariableManager.scala 6 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/StructFilters.scala 95 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/AliasResolution.scala 53 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/AlreadyExistException.scala 71 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala 2889 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/AnsiGetDateFieldOperationsTypeCoercion.scala 10 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/AnsiStringPromotionTypeCoercion.scala 83 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/AnsiTypeCoercion.scala 125 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ApplyCharTypePaddingHelper.scala 168 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ApplyDefaultCollationToStringType.scala 135 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/AssignmentUtils.scala 148 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/BinaryArithmeticWithDatetimeResolver.scala 127 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/BooleanEqualityTypeCoercion.scala 56 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/CTESubstitution.scala 261 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/CheckAnalysis.scala 920 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/CollationRulesRunner.scala 10 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/CollationTypeCasts.scala 8 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/CollationTypeCoercion.scala 339 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ColumnResolutionHelper.scala 476 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/DecimalPrecision.scala 8 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/DecimalPrecisionTypeCoercion.scala 131 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/DeduplicateRelations.scala 394 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/DivisionTypeCoercion.scala 15 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/EliminateLazyExpression.scala 11 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ExtractDistributedSequenceID.scala 18 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/FunctionRegistry.scala 961 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/FunctionResolution.scala 303 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/HintErrorLogger.scala 38 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/IntegralDivisionTypeCoercion.scala 14 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/KeepLegacyOutputs.scala 26 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/LiteralFunctionResolution.scala 23 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/MultiInstanceRelation.scala 5 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/NamedRelation.scala 6 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/NaturalAndUsingJoinResolution.scala 127 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/NoSuchItemException.scala 66 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/NondeterministicExpressionCollection.scala 25 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/NormalizeableRelation.scala 5 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/PlanToString.scala 13 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/PullOutNondeterministic.scala 30 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/RelationResolution.scala 196 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/RelationTimeTravel.scala 10 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveCatalogs.scala 112 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveCollationName.scala 13 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveColumnDefaultInCommandInputQuery.scala 100 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveCommandsWithIfExists.scala 13 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveDataFrameDropColumns.scala 23 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveHints.scala 198 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveIdentifierClause.scala 100 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveInlineTables.scala 14 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveInsertionBase.scala 53 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveLateralColumnAliasReference.scala 140 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolvePartitionSpec.scala 67 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveReferencesInAggregate.scala 101 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveReferencesInSort.scala 39 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveReferencesInUpdate.scala 42 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveRowLevelCommandAssignments.scala 89 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveSetVariable.scala 46 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveTableSpec.scala 84 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveTimeWindows.scala 232 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveUnion.scala 138 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveUpdateEventTimeWatermarkColumn.scala 19 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveWithCTE.scala 258 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/RewriteCollationJoin.scala 55 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/RewriteDeleteFromTable.scala 60 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/RewriteMergeIntoTable.scala 369 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/RewriteRowLevelCommand.scala 249 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/RewriteUpdateTable.scala 142 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/SQLFunctionExpression.scala 49 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/SQLFunctionNode.scala 30 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/StackTypeCoercion.scala 15 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/StreamingJoinHelper.scala 180 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/StringLiteralTypeCoercion.scala 25 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/StringPromotionTypeCoercion.scala 51 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/TableOutputResolver.scala 549 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/TimeTravelSpec.scala 80 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/TypeCheckResult.scala 25 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/TypeCoercion.scala 249 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/TypeCoercionBase.scala 228 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/TypeCoercionHelper.scala 535 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/TypeCoercionValidation.scala 95 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/UnsupportedOperationChecker.scala 439 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/UpCastResolution.scala 40 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/UpdateAttributeNullability.scala 20 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ValidateSubqueryExpression.scala 301 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ViewResolution.scala 29 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/executeImmediate.scala 136 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/higherOrderFunctions.scala 86 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/package.scala 63 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/parameters.scala 121 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver.scala 5 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/AggregateExpressionResolver.scala 154 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/AggregateResolver.scala 192 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/AliasResolver.scala 48 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/AnalyzerBridgeState.scala 22 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/AttributeScopeStack.scala 48 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/AutoGeneratedAliasProvider.scala 40 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/BinaryArithmeticResolver.scala 90 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/BridgedRelationId.scala 6 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/BridgedRelationMetadataProvider.scala 48 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/ConditionalExpressionResolver.scala 34 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/CreateNamedStructResolver.scala 22 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/CteScope.scala 90 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/DelegatesResolutionToExtensions.scala 31 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/ExplicitlyUnsupportedResolverFeature.scala 16 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/ExpressionIdAssigner.scala 210 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/ExpressionResolutionContext.scala 34 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/ExpressionResolutionValidator.scala 150 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/ExpressionResolver.scala 527 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/ExpressionTreeTraversal.scala 28 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/FilterResolver.scala 62 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/FunctionResolver.scala 102 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/HybridAnalyzer.scala 161 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/IdentifierAndCteSubstituor.scala 100 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/IdentifierMap.scala 5 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/JoinResolver.scala 180 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/KeyTransformingMap.scala 22 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/LateralColumnAliasProhibitedRegistry.scala 14 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/LateralColumnAliasRegistry.scala 14 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/LateralColumnAliasRegistryImpl.scala 77 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/LimitExpressionResolver.scala 64 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/LimitLikeExpressionValidator.scala 101 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/MetadataResolver.scala 87 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/NameScope.scala 406 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/NameTarget.scala 36 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/PlanLogger.scala 49 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/PlanRewriter.scala 28 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/PredicateResolver.scala 69 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/ProducesUnresolvedSubtree.scala 30 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/ProhibitedResolver.scala 8 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/ProjectResolver.scala 119 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/PruneMetadataColumns.scala 77 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/PullOutNondeterministicExpressionInExpressionTree.scala 20 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/RelationId.scala 7 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/RelationMetadataProvider.scala 37 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/ResolutionValidator.scala 239 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/ResolvedAggregateExpressions.scala 10 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/ResolvedProjectList.scala 6 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/ResolvedSubqueryExpressionPlan.scala 7 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/Resolver.scala 421 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/ResolverExtension.scala 7 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/ResolverGuard.scala 369 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/ResolverMetricTracker.scala 38 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/ResolverRunner.scala 35 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/ResolvesExpressionChildren.scala 69 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/ResolvesNameByHiddenOutput.scala 48 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/ResolvesOperatorChildren.scala 10 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/SemanticComparator.scala 31 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/SetOperationLikeResolver.scala 283 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/SortResolver.scala 211 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/SubqueryExpressionResolver.scala 104 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/SubqueryScope.scala 37 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/TimeAddResolver.scala 44 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/TimezoneAwareExpressionResolver.scala 23 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/TreeNodeResolver.scala 9 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/TryExtractOrdinal.scala 11 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/TypeCoercionResolver.scala 87 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/UnaryMinusResolver.scala 32 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/UnresolvedCteRelationRef.scala 5 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/UnsupportedExpressionInOperatorValidation.scala 43 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/ViewResolver.scala 91 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/timeZoneAnalysis.scala 25 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/unresolved.scala 641 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/v2ResolutionPlans.scala 164 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/view.scala 30 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/ExternalCatalog.scala 118 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/ExternalCatalogUtils.scala 242 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/ExternalCatalogWithListener.scala 227 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/FunctionExpressionBuilder.scala 11 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/GlobalTempViewManager.scala 54 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/InMemoryCatalog.scala 533 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/InvalidUDFClassException.scala 15 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/RoutineLanguage.scala 7 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/SQLFunction.scala 204 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/SessionCatalog.scala 1490 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/UserDefinedFunction.scala 80 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/UserDefinedFunctionErrors.scala 83 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/VariableManager.scala 64 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/events.scala 64 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/functionResources.scala 28 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/interface.scala 813 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/csv/CSVExprUtils.scala 75 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/csv/CSVHeaderChecker.scala 86 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/csv/CSVInferSchema.scala 209 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/csv/CSVOptions.scala 284 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/csv/UnivocityGenerator.scala 175 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/csv/UnivocityParser.scala 456 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/dsl/package.scala 399 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/encoders/EncoderUtils.scala 114 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/encoders/ExpressionEncoder.scala 189 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/encoders/KryoSerializationCodecImpl.scala 10 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/encoders/package.scala 12 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/AliasHelper.scala 66 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/AnalysisAwareExpression.scala 4 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/ApplyFunctionExpression.scala 30 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/AttributeMap.scala 26 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/AttributeSet.scala 69 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/Between.scala 40 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/BloomFilterMightContain.scala 83 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/BoundAttribute.scala 62 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/CallMethodViaReflection.scala 167 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/Cast.scala 1905 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/CodeGeneratorWithInterpretedFallback.scala 28 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/CollationKey.scala 24 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/DistributedSequenceID.scala 12 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/DynamicPruning.scala 61 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/EquivalentExpressions.scala 142 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/EvalHelper.scala 9 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/EvalMode.scala 15 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/ExpectsInputTypes.scala 30 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/ExprUtils.scala 166 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/Expression.scala 827 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/ExpressionSet.scala 109 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/ExpressionsEvaluator.scala 23 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/FunctionTableSubqueryArgumentExpression.scala 99 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/GetStructFieldObject.scala 8 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/InterpretedMutableProjection.scala 68 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/InterpretedSafeProjection.scala 89 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/InterpretedUnsafeProjection.scala 215 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/JoinedRow.scala 114 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/MonotonicallyIncreasingID.scala 52 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/NamedArgumentExpression.scala 10 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/PartitionTransforms.scala 53 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/Projection.scala 89 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/ProjectionOverSchema.scala 51 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/PythonUDF.scala 206 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/ScalaUDF.scala 1053 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/SchemaPruning.scala 91 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/SelectedField.scala 74 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/SessionWindow.scala 64 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/SortOrder.scala 172 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/SparkPartitionID.scala 31 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/SpecificInternalRow.scala 221 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/SubExprEvaluationRuntime.scala 75 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/TimeWindow.scala 214 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/ToJavaArray.scala 70 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/ToPrettyString.scala 42 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/ToStringBase.scala 422 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/TransformExpression.scala 70 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/TryEval.scala 239 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/UnwrapUDT.scala 28 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/V2ExpressionUtils.scala 319 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/VariableReference.scala 27 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/WindowTime.scala 34 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/With.scala 94 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/AnyValue.scala 37 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/ApproxCountDistinctForIntervals.scala 194 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/ApproximatePercentile.scala 268 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/Average.scala 123 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/BloomFilterAggregate.scala 194 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/CentralMomentAgg.scala 290 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/Corr.scala 89 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/Count.scala 71 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/CountIf.scala 28 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/CountMinSketchAgg.scala 173 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/Covariance.scala 119 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/First.scala 81 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/HistogramNumeric.scala 196 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/HyperLogLogPlusPlus.scala 83 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/Last.scala 73 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/Max.scala 37 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/MaxByAndMinBy.scala 95 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/Min.scala 37 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/Mode.scala 268 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/PandasAggregate.scala 16 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/PivotFirst.scala 98 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/Product.scala 124 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/Sum.scala 150 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/SupportsOrderingWithinGroup.scala 8 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/V2Aggregator.scala 38 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/bitwiseAggregates.scala 75 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/boolAggregates.scala 46 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/collect.scala 399 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/datasketchesAggregates.scala 217 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/interfaces.scala 255 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/linearRegression.scala 307 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/percentiles.scala 388 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/arithmetic.scala 1071 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/avroSqlFunctions.scala 221 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/bitmapExpressions.scala 244 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/bitwiseExpressions.scala 223 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/CodeFormatter.scala 111 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/CodeGenerator.scala 1210 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/CodegenFallback.scala 41 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/GenerateMutableProjection.scala 102 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/GenerateOrdering.scala 151 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/GeneratePredicate.scala 41 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/GenerateSafeProjection.scala 156 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/GenerateUnsafeProjection.scala 298 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/GenerateUnsafeRowJoiner.scala 155 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/javaCode.scala 195 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/package.scala 37 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/collationExpressions.scala 111 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/collectionOperations.scala 4533 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/complexTypeCreator.scala 592 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/complexTypeExtractors.scala 368 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/conditionalExpressions.scala 308 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/constraintExpressions.scala 38 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/constraints.scala 174 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/csv/CsvExpressionEvalUtils.scala 80 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/csvExpressions.scala 211 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/datasketchesExpressions.scala 93 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/datetimeExpressions.scala 3066 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/decimalExpressions.scala 226 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/generators.scala 562 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/grouping.scala 175 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/hash.scala 827 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/higherOrderFunctions.scala 989 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/inputFileBlock.scala 78 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/intervalExpressions.scala 749 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/json/JsonExpressionEvalUtils.scala 409 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/jsonExpressions.scala 458 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/literals.scala 486 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/maskExpressions.scala 262 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/mathExpressions.scala 1531 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/misc.scala 436 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/namedExpressions.scala 441 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/nullExpressions.scala 426 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/numberFormatExpressions.scala 280 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/objects/objects.scala 1547 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/ordering.scala 77 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/package.scala 223 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/pipeOperators.scala 67 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/predicates.scala 1057 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/randomExpressions.scala 315 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/regexpExpressions.scala 975 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/rows.scala 135 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/stringExpressions.scala 2968 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/subquery.scala 347 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/timeExpressions.scala 458 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/toFromProtobufSqlFunctions.scala 252 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/url/UrlExpressionEvalUtils.scala 101 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/urlExpressions.scala 205 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/variant/VariantExpressionEvalUtils.scala 118 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/variant/variantExpressions.scala 743 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/windowExpressions.scala 803 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/xml/XmlExpressionEvalUtils.scala 159 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/xml/xpath.scala 176 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/xmlExpressions.scala 204 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/identifiers.scala 86 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/json/CreateJacksonParser.scala 50 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/json/JSONOptions.scala 190 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/json/JacksonGenerator.scala 228 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/json/JacksonParser.scala 518 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/json/JacksonUtils.scala 32 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/json/JsonFilters.scala 50 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/json/JsonInferSchema.scala 323 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/ComplexTypes.scala 34 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/CostBasedJoinReorder.scala 255 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/DecorrelateInnerQuery.scala 529 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/EliminateResolvedHint.scala 57 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/EliminateSQLFunctionNode.scala 21 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/EliminateWindowPartitions.scala 19 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/InferWindowGroupLimit.scala 72 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/InjectRuntimeFilter.scala 235 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/InlineCTE.scala 167 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/InsertMapSortExpression.scala 102 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/LimitPushDownThroughWindow.scala 26 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/MergeScalarSubqueries.scala 257 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/NestedColumnAliasing.scala 256 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/NormalizeFloatingNumbers.scala 139 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/OptimizeCsvJsonExprs.scala 70 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/OptimizeJoinCondition.scala 22 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/OptimizeOneRowPlan.scala 29 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/OptimizeRand.scala 32 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/Optimizer.scala 1683 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/PropagateEmptyRelation.scala 138 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/PullOutGroupingExpressions.scala 39 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/PullOutNestedDataOuterRefExpressions.scala 54 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/PushDownLeftSemiAntiJoin.scala 170 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/PushExtraPredicateThroughJoin.scala 51 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/PushProjectionThroughLimitAndOffset.scala 18 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/PushdownPredicatesAndPruneColumnsForCTEDef.scala 110 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/RemoveRedundantAggregates.scala 36 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/RemoveRedundantSorts.scala 32 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/ReplaceCTERefWithRepartition.scala 56 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/ReplaceExceptWithFilter.scala 69 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/ReplaceNullWithFalseInPredicate.scala 103 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/RewriteAsOfJoin.scala 42 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/RewriteDistinctAggregates.scala 168 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/RewriteWithExpression.scala 139 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/StarSchemaDetection.scala 190 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/UnwrapCastInBinaryComparison.scala 302 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/UpdateFields.scala 50 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/expressions.scala 783 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/finishAnalysis.scala 133 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/joins.scala 393 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/objects.scala 178 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/subquery.scala 757 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/package.scala 3 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/parser/AbstractSqlParser.scala 85 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/parser/AstBuilder.scala 4715 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/parser/CatalystSqlParser.scala 5 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/parser/ParserInterface.scala 23 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/parser/ParserUtils.scala 217 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/parser/package.scala 20 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/planning/QueryPlanner.scala 37 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/planning/package.scala 2 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/planning/patterns.scala 272 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/AliasAwareOutputExpression.scala 76 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/DescribeCommandSchema.scala 23 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/NormalizePlan.scala 145 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/QueryPlan.scala 424 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/ReferenceAllColumns.scala 6 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/joinTypes.scala 132 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/AnalysisHelper.scala 210 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/ColumnDefinition.scala 177 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/Command.scala 25 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/DistinctKeyVisitor.scala 104 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/EmptyRelation.scala 11 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/EventTimeWatermark.scala 67 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/ExecutableDuringAnalysis.scala 4 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/FunctionBuilderBase.scala 105 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/IgnoreCachedData.scala 2 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/LocalRelation.scala 77 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/LogicalPlan.scala 269 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/LogicalPlanDistinctKeys.scala 8 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/LogicalPlanVisitor.scala 53 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/MergeRows.scala 78 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/MultiResult.scala 9 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/PlanHelper.scala 30 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/QueryPlanConstraints.scala 68 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/ScriptTransformation.scala 21 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/SqlScriptingLogicalPlans.scala 227 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/Statistics.scala 136 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/StreamSourceAwareLogicalPlan.scala 6 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicLogicalOperators.scala 1503 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/cteOperators.scala 108 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/hints.scala 100 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/object.scala 682 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/pythonLogicalOperators.scala 190 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/statements.scala 114 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/statsEstimation/AggregateEstimation.scala 41 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/statsEstimation/BasicStatsPlanVisitor.scala 64 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/statsEstimation/EstimationUtils.scala 273 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/statsEstimation/FilterEstimation.scala 514 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/statsEstimation/JoinEstimation.scala 242 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/statsEstimation/LogicalPlanStats.scala 17 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/statsEstimation/ProjectEstimation.scala 20 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/statsEstimation/SizeInBytesOnlyStatsPlanVisitor.scala 116 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/statsEstimation/UnionEstimation.scala 96 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/statsEstimation/ValueInterval.scala 55 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/v2AlterTableCommands.scala 223 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/v2Commands.scala 1148 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/package.scala 2 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/physical/broadcastMode.scala 14 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/physical/partitioning.scala 497 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/rules/QueryExecutionMetering.scala 87 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/rules/Rule.scala 12 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/rules/RuleExecutor.scala 202 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/rules/RuleIdCollection.scala 187 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/rules/package.scala 2 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/streaming/StreamingRelationV2.scala 42 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/streaming/WriteToStream.scala 21 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/streaming/WriteToStreamStatement.scala 25 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/trees/TreeNode.scala 847 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/trees/TreePatternBits.scala 38 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/trees/TreePatterns.scala 150 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/trees/package.scala 12 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/types/DataTypeUtils.scala 153 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/types/PhysicalDataType.scala 323 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/ArrayBasedMapBuilder.scala 96 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/ArrayBasedMapData.scala 68 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/ArrayData.scala 152 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/BadRecordException.scala 51 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/CharVarcharUtils.scala 231 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/CharsetProvider.scala 56 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/CompressionCodecs.scala 36 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/DateTimeUtils.scala 432 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/EvaluateUnresolvedInlineTable.scala 72 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/FailureSafeParser.scala 65 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/GeneratedColumn.scala 130 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/GenericArrayData.scala 123 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/IdentityColumn.scala 39 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/InternalRowComparableWrapper.scala 70 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/IntervalMathUtils.scala 21 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/IntervalUtils.scala 750 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/MapData.scala 18 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/NumberConverter.scala 141 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/ParseMode.scala 27 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/QuantileSummaries.scala 196 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/RandomIndicesGenerator.scala 18 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/RandomUUIDGenerator.scala 13 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/ReplaceDataProjections.scala 5 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/ResolveDefaultColumnsUtil.scala 406 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/ResolveTableConstraints.scala 31 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/RowDeltaUtils.scala 11 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/SQLKeywordUtils.scala 22 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/SQLOrderingUtil.scala 9 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/StringKeyHashMap.scala 18 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/StringUtils.scala 90 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/ToNumberParser.scala 640 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/TypeUtils.scala 102 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/UDTUtilsImpl.scala 8 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/UTF8StringUtils.scala 27 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/UnsafeRowUtils.scala 117 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/V2ExpressionBuilder.scala 402 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/WriteDeltaProjections.scala 6 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/package.scala 179 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/xml/CreateXmlParser.scala 70 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/xml/IndentingXMLStreamWriter.scala 138 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/xml/StaxXmlGenerator.scala 289 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/xml/StaxXmlParser.scala 873 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/xml/StaxXmlParserUtils.scala 152 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/xml/ValidatorUtil.scala 43 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/xml/XmlInferSchema.scala 432 sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/xml/XmlOptions.scala 167 sql/catalyst/src/main/scala/org/apache/spark/sql/connector/catalog/CatalogManager.scala 103 sql/catalyst/src/main/scala/org/apache/spark/sql/connector/catalog/CatalogNotFoundException.scala 12 sql/catalyst/src/main/scala/org/apache/spark/sql/connector/catalog/CatalogV2Implicits.scala 180 sql/catalyst/src/main/scala/org/apache/spark/sql/connector/catalog/CatalogV2Util.scala 516 sql/catalyst/src/main/scala/org/apache/spark/sql/connector/catalog/Catalogs.scala 61 sql/catalyst/src/main/scala/org/apache/spark/sql/connector/catalog/LookupCatalog.scala 84 sql/catalyst/src/main/scala/org/apache/spark/sql/connector/catalog/V1Table.scala 61 sql/catalyst/src/main/scala/org/apache/spark/sql/connector/distributions/distributions.scala 31 sql/catalyst/src/main/scala/org/apache/spark/sql/connector/expressions/expressions.scala 304 sql/catalyst/src/main/scala/org/apache/spark/sql/connector/write/LogicalWriteInfoImpl.scala 27 sql/catalyst/src/main/scala/org/apache/spark/sql/connector/write/PhysicalWriteInfoImpl.scala 2 sql/catalyst/src/main/scala/org/apache/spark/sql/connector/write/RowLevelOperationInfoImpl.scala 6 sql/catalyst/src/main/scala/org/apache/spark/sql/connector/write/RowLevelOperationTable.scala 21 sql/catalyst/src/main/scala/org/apache/spark/sql/errors/QueryCompilationErrors.scala 3781 sql/catalyst/src/main/scala/org/apache/spark/sql/errors/QueryErrorsBase.scala 32 sql/catalyst/src/main/scala/org/apache/spark/sql/errors/QueryExecutionErrors.scala 2609 sql/catalyst/src/main/scala/org/apache/spark/sql/errors/SqlScriptingErrors.scala 216 sql/catalyst/src/main/scala/org/apache/spark/sql/exceptions/SqlScriptingException.scala 26 sql/catalyst/src/main/scala/org/apache/spark/sql/execution/QueryExecutionException.scala 3 sql/catalyst/src/main/scala/org/apache/spark/sql/execution/RowIterator.scala 46 sql/catalyst/src/main/scala/org/apache/spark/sql/execution/arrow/ArrowWriter.scala 399 sql/catalyst/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DataSourceV2Implicits.scala 100 sql/catalyst/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DataSourceV2Relation.scala 209 sql/catalyst/src/main/scala/org/apache/spark/sql/internal/ReadOnlySQLConf.scala 34 sql/catalyst/src/main/scala/org/apache/spark/sql/internal/SQLConf.scala 5815 sql/catalyst/src/main/scala/org/apache/spark/sql/internal/StaticSQLConf.scala 250 sql/catalyst/src/main/scala/org/apache/spark/sql/internal/connector/ColumnImpl.scala 12 sql/catalyst/src/main/scala/org/apache/spark/sql/internal/connector/ExpressionWithToString.scala 6 sql/catalyst/src/main/scala/org/apache/spark/sql/internal/connector/PredicateUtils.scala 110 sql/catalyst/src/main/scala/org/apache/spark/sql/internal/connector/ProcedureParameterImpl.scala 11 sql/catalyst/src/main/scala/org/apache/spark/sql/internal/connector/SimpleTableProvider.scala 25 sql/catalyst/src/main/scala/org/apache/spark/sql/internal/connector/SupportsMetadata.scala 4 sql/catalyst/src/main/scala/org/apache/spark/sql/internal/connector/SupportsPushDownCatalystFilters.scala 7 sql/catalyst/src/main/scala/org/apache/spark/sql/internal/connector/SupportsStreamingUpdateAsAppend.scala 4 sql/catalyst/src/main/scala/org/apache/spark/sql/internal/connector/ToStringSQLBuilder.scala 15 sql/catalyst/src/main/scala/org/apache/spark/sql/internal/connector/V1Function.scala 12 sql/catalyst/src/main/scala/org/apache/spark/sql/sources/filters.scala 231 sql/catalyst/src/main/scala/org/apache/spark/sql/types/DataTypeExpression.scala 39 sql/catalyst/src/main/scala/org/apache/spark/sql/types/numerics.scala 127 sql/catalyst/src/main/scala/org/apache/spark/sql/types/package.scala 2 sql/catalyst/src/main/scala/org/apache/spark/sql/util/PartitioningUtils.scala 97 sql/catalyst/src/main/scala/org/apache/spark/sql/util/SQLOpenHashSet.scala 129 sql/catalyst/src/main/scala/org/apache/spark/sql/util/SchemaUtils.scala 250 sql/connect/client/jvm/src/main/scala/org/apache/spark/sql/application/ConnectRepl.scala 145 sql/connect/client/jvm/src/main/scala/org/apache/spark/sql/connect/client/AmmoniteClassFinder.scala 21 sql/connect/common/src/main/buf.gen.yaml 18 sql/connect/common/src/main/buf.work.yaml 3 sql/connect/common/src/main/protobuf/buf.yaml 9 sql/connect/common/src/main/protobuf/spark/connect/base.proto 921 sql/connect/common/src/main/protobuf/spark/connect/catalog.proto 211 sql/connect/common/src/main/protobuf/spark/connect/commands.proto 448 sql/connect/common/src/main/protobuf/spark/connect/common.proto 135 sql/connect/common/src/main/protobuf/spark/connect/example_plugins.proto 34 sql/connect/common/src/main/protobuf/spark/connect/expressions.proto 412 sql/connect/common/src/main/protobuf/spark/connect/ml.proto 114 sql/connect/common/src/main/protobuf/spark/connect/ml_common.proto 54 sql/connect/common/src/main/protobuf/spark/connect/relations.proto 984 sql/connect/common/src/main/protobuf/spark/connect/types.proto 165 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/Catalog.scala 304 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/ConnectClientUnsupportedErrors.scala 26 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/ConnectConversions.scala 34 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/ConnectProtoUtils.scala 28 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/DataFrameNaFunctions.scala 125 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/DataFrameReader.scala 133 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/DataFrameStatFunctions.scala 95 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/DataFrameWriter.scala 86 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/DataFrameWriterV2.scala 71 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/DataStreamReader.scala 75 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/DataStreamWriter.scala 125 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/Dataset.scala 1025 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/KeyValueGroupedDataset.scala 581 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/MergeIntoWriter.scala 90 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/RelationalGroupedDataset.scala 108 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/RuntimeConfig.scala 103 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/SQLContext.scala 162 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/SQLImplicits.scala 17 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/SessionCleaner.scala 25 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/SparkSession.scala 598 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/StreamingQuery.scala 114 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/StreamingQueryListenerBus.scala 123 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/StreamingQueryManager.scala 81 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/TableValuedFunction.scala 53 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/UDFRegistration.scala 37 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/UdfToProtoUtils.scala 80 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/UserDefinedAggregateFunctionWrapper.scala 55 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/client/ArtifactManager.scala 267 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/client/ClassFinder.scala 24 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/client/CloseableIterator.scala 33 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/client/CustomSparkConnectBlockingStub.scala 102 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/client/CustomSparkConnectStub.scala 14 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/client/ExecutePlanResponseReattachableIterator.scala 210 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/client/GrpcExceptionConverter.scala 291 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/client/GrpcRetryHandler.scala 137 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/client/ResponseValidator.scala 80 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/client/RetriesExceeded.scala 2 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/client/RetryPolicy.scala 66 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/client/SparkConnectClient.scala 544 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/client/SparkConnectClientParser.scala 70 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/client/SparkConnectStubState.scala 9 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/client/SparkResult.scala 302 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/client/ToStub.scala 2 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/client/arrow/ArrowDeserializer.scala 496 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/client/arrow/ArrowEncoderUtils.scala 30 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/client/arrow/ArrowSerializer.scala 499 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/client/arrow/ArrowVectorReader.scala 219 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/client/arrow/ConcatenatingArrowStreamReader.scala 131 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/client/arrow/ScalaCollectionUtils.scala 15 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/client/package.scala 9 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/columnNodeSupport.scala 248 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/common/Abbreviator.scala 76 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/common/DataTypeProtoConverter.scala 257 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/common/ForeachWriterPacket.scala 5 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/common/InvalidCommandInput.scala 5 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/common/InvalidPlanInput.scala 5 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/common/LiteralValueProtoConverter.scala 316 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/common/ProtoDataTypes.scala 100 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/common/ProtoUtils.scala 43 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/common/StorageLevelProtoConverter.scala 23 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/common/StreamingListenerPacket.scala 2 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/common/UdfPacket.scala 34 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/common/UdfUtils.scala 498 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/common/config/ConnectCommon.scala 7 sql/connect/common/src/main/scala/org/apache/spark/sql/connect/package.scala 4 sql/connect/server/src/main/java/org/apache/spark/sql/connect/plugin/CommandPlugin.java 5 sql/connect/server/src/main/java/org/apache/spark/sql/connect/plugin/ExpressionPlugin.java 7 sql/connect/server/src/main/java/org/apache/spark/sql/connect/plugin/MLBackendPlugin.java 5 sql/connect/server/src/main/java/org/apache/spark/sql/connect/plugin/RelationPlugin.java 7 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/SimpleSparkConnectService.scala 29 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/SparkConnectPlugin.scala 20 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/config/Connect.scala 325 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/execution/CachedStreamResponse.scala 8 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/execution/ConnectProgressExecutionListener.scala 127 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/execution/ExecuteGrpcResponseSender.scala 253 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/execution/ExecuteResponseObserver.scala 217 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/execution/ExecuteThreadRunner.scala 242 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/execution/SparkConnectPlanExecution.scala 250 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/ml/MLCache.scala 187 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/ml/MLException.scala 28 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/ml/MLHandler.scala 323 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/ml/MLUtils.scala 514 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/ml/Serializer.scala 175 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/planner/LiteralExpressionProtoConverter.scala 78 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/planner/MockObserver.scala 8 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/planner/SaveModeConverter.scala 27 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/planner/SparkConnectPlanner.scala 3468 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/planner/SparkConnectStreamingQueryListenerHandler.scala 79 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/planner/StreamingForeachBatchHelper.scala 181 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/planner/StreamingQueryListenerHelper.scala 74 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/planner/TableSaveMethodConverter.scala 17 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/plugin/SparkConnectPluginRegistry.scala 102 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/service/ExecuteEventsManager.scala 225 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/service/ExecuteHolder.scala 216 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/service/LocalPropertiesCleanupInterceptor.scala 25 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/service/LoggingInterceptor.scala 45 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/service/PreSharedKeyAuthenticationInterceptor.scala 24 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SessionEventsManager.scala 58 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SessionHolder.scala 279 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SparkConnectAddArtifactsHandler.scala 210 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SparkConnectAnalyzeHandler.scala 186 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SparkConnectArtifactStatusesHandler.scala 48 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SparkConnectConfigHandler.scala 167 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SparkConnectExecutePlanHandler.scala 26 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SparkConnectExecutionManager.scala 181 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SparkConnectFetchErrorDetailsHandler.scala 27 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SparkConnectInterceptorRegistry.scala 61 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SparkConnectInterruptHandler.scala 43 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SparkConnectListenerBusListener.scala 103 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SparkConnectReattachExecuteHandler.scala 56 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SparkConnectReleaseExecuteHandler.scala 38 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SparkConnectReleaseSessionHandler.scala 19 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SparkConnectServer.scala 34 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SparkConnectService.scala 339 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SparkConnectSessionManager.scala 216 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SparkConnectStreamingQueryCache.scala 237 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/ui/SparkConnectServerAppStatusStore.scala 93 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/ui/SparkConnectServerHistoryServerPlugin.scala 19 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/ui/SparkConnectServerListener.scala 382 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/ui/SparkConnectServerPage.scala 428 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/ui/SparkConnectServerSessionPage.scala 97 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/ui/SparkConnectServerTab.scala 34 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/ui/ToolTips.scala 15 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/utils/ErrorUtils.scala 231 sql/connect/server/src/main/scala/org/apache/spark/sql/connect/utils/MetricGenerator.scala 50 sql/connect/shims/src/main/scala/org/apache/spark/shims.scala 28 sql/core/src/main/buf.gen.yaml 6 sql/core/src/main/buf.work.yaml 3 sql/core/src/main/java/org/apache/parquet/filter2/predicate/SparkFilterApi.java 28 sql/core/src/main/java/org/apache/spark/sql/avro/AvroCompressionCodec.java 41 sql/core/src/main/java/org/apache/spark/sql/avro/SparkAvroKeyOutputFormat.java 68 sql/core/src/main/java/org/apache/spark/sql/connector/read/V1Scan.java 9 sql/core/src/main/java/org/apache/spark/sql/connector/write/V1Write.java 8 sql/core/src/main/java/org/apache/spark/sql/execution/BufferedRowIterator.java 36 sql/core/src/main/java/org/apache/spark/sql/execution/RecordBinaryComparator.java 50 sql/core/src/main/java/org/apache/spark/sql/execution/UnsafeExternalRowSorter.java 177 sql/core/src/main/java/org/apache/spark/sql/execution/UnsafeFixedWidthAggregationMap.java 134 sql/core/src/main/java/org/apache/spark/sql/execution/UnsafeKVExternalSorter.java 215 sql/core/src/main/java/org/apache/spark/sql/execution/columnar/ColumnDictionary.java 37 sql/core/src/main/java/org/apache/spark/sql/execution/datasources/SchemaColumnConvertNotSupportedException.java 27 sql/core/src/main/java/org/apache/spark/sql/execution/datasources/orc/OrcArrayColumnVector.java 74 sql/core/src/main/java/org/apache/spark/sql/execution/datasources/orc/OrcAtomicColumnVector.java 119 sql/core/src/main/java/org/apache/spark/sql/execution/datasources/orc/OrcColumnStatistics.java 25 sql/core/src/main/java/org/apache/spark/sql/execution/datasources/orc/OrcColumnVector.java 47 sql/core/src/main/java/org/apache/spark/sql/execution/datasources/orc/OrcColumnVectorUtils.java 35 sql/core/src/main/java/org/apache/spark/sql/execution/datasources/orc/OrcColumnarBatchReader.java 152 sql/core/src/main/java/org/apache/spark/sql/execution/datasources/orc/OrcCompressionCodec.java 33 sql/core/src/main/java/org/apache/spark/sql/execution/datasources/orc/OrcFooterReader.java 31 sql/core/src/main/java/org/apache/spark/sql/execution/datasources/orc/OrcMapColumnVector.java 77 sql/core/src/main/java/org/apache/spark/sql/execution/datasources/orc/OrcStructColumnVector.java 68 sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/ParquetColumnVector.java 248 sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/ParquetCompressionCodec.java 46 sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/ParquetDictionary.java 44 sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/ParquetFooterReader.java 49 sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/ParquetReadState.java 85 sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/ParquetVectorUpdater.java 29 sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/ParquetVectorUpdaterFactory.java 1454 sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/SpecificParquetRecordReaderBase.java 216 sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedColumnReader.java 310 sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedDeltaBinaryPackedReader.java 232 sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedDeltaByteArrayReader.java 91 sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedDeltaLengthByteArrayReader.java 60 sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedParquetRecordReader.java 296 sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedPlainValuesReader.java 326 sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedReaderBase.java 109 sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedRleValuesReader.java 709 sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedValuesReader.java 56 sql/core/src/main/java/org/apache/spark/sql/execution/streaming/Offset.java 2 sql/core/src/main/java/org/apache/spark/sql/execution/vectorized/AggregateHashMap.java 62 sql/core/src/main/java/org/apache/spark/sql/execution/vectorized/ColumnVectorUtils.java 198 sql/core/src/main/java/org/apache/spark/sql/execution/vectorized/ConstantColumnVector.java 198 sql/core/src/main/java/org/apache/spark/sql/execution/vectorized/Dictionary.java 8 sql/core/src/main/java/org/apache/spark/sql/execution/vectorized/MutableColumnarRow.java 239 sql/core/src/main/java/org/apache/spark/sql/execution/vectorized/OffHeapColumnVector.java 486 sql/core/src/main/java/org/apache/spark/sql/execution/vectorized/OnHeapColumnVector.java 493 sql/core/src/main/java/org/apache/spark/sql/execution/vectorized/WritableColumnVector.java 599 sql/core/src/main/java/org/apache/spark/sql/internal/NonClosableMutableURLClassLoader.java 13 sql/core/src/main/protobuf/org/apache/spark/sql/execution/streaming/StateMessage.proto 219 sql/core/src/main/resources/org/apache/spark/sql/execution/ui/static/spark-sql-viz.css 47 sql/core/src/main/resources/org/apache/spark/sql/execution/ui/static/spark-sql-viz.js 264 sql/core/src/main/scala/org/apache/spark/sql/DataSourceRegistration.scala 38 sql/core/src/main/scala/org/apache/spark/sql/ExperimentalMethods.scala 17 sql/core/src/main/scala/org/apache/spark/sql/ExtendedExplainGenerator.scala 9 sql/core/src/main/scala/org/apache/spark/sql/SparkSessionExtensions.scala 153 sql/core/src/main/scala/org/apache/spark/sql/SparkSessionExtensionsProvider.scala 5 sql/core/src/main/scala/org/apache/spark/sql/TableArg.scala 52 sql/core/src/main/scala/org/apache/spark/sql/UDTFRegistration.scala 25 sql/core/src/main/scala/org/apache/spark/sql/api/package.scala 2 sql/core/src/main/scala/org/apache/spark/sql/api/python/PythonSQLUtils.scala 139 sql/core/src/main/scala/org/apache/spark/sql/api/r/SQLUtils.scala 188 sql/core/src/main/scala/org/apache/spark/sql/artifact/ArtifactManager.scala 377 sql/core/src/main/scala/org/apache/spark/sql/avro/AvroDeserializer.scala 404 sql/core/src/main/scala/org/apache/spark/sql/avro/AvroFileFormat.scala 135 sql/core/src/main/scala/org/apache/spark/sql/avro/AvroOptions.scala 116 sql/core/src/main/scala/org/apache/spark/sql/avro/AvroOutputWriter.scala 56 sql/core/src/main/scala/org/apache/spark/sql/avro/AvroOutputWriterFactory.scala 26 sql/core/src/main/scala/org/apache/spark/sql/avro/AvroSerializer.scala 314 sql/core/src/main/scala/org/apache/spark/sql/avro/AvroUtils.scala 265 sql/core/src/main/scala/org/apache/spark/sql/avro/CustomDecimal.scala 53 sql/core/src/main/scala/org/apache/spark/sql/avro/SchemaConverters.scala 358 sql/core/src/main/scala/org/apache/spark/sql/catalyst/analysis/EvalSubqueriesForTimeTravel.scala 37 sql/core/src/main/scala/org/apache/spark/sql/catalyst/analysis/InvokeProcedures.scala 59 sql/core/src/main/scala/org/apache/spark/sql/catalyst/analysis/ReplaceCharWithVarchar.scala 48 sql/core/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveDataSource.scala 103 sql/core/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveSessionCatalog.scala 613 sql/core/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveTranspose.scala 128 sql/core/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/CommandResult.scala 15 sql/core/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/SQLFunctionNode.scala 18 sql/core/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/UnresolvedDataSource.scala 17 sql/core/src/main/scala/org/apache/spark/sql/classic/Catalog.scala 568 sql/core/src/main/scala/org/apache/spark/sql/classic/DataFrameNaFunctions.scala 185 sql/core/src/main/scala/org/apache/spark/sql/classic/DataFrameReader.scala 224 sql/core/src/main/scala/org/apache/spark/sql/classic/DataFrameStatFunctions.scala 69 sql/core/src/main/scala/org/apache/spark/sql/classic/DataFrameWriter.scala 408 sql/core/src/main/scala/org/apache/spark/sql/classic/DataFrameWriterV2.scala 169 sql/core/src/main/scala/org/apache/spark/sql/classic/DataStreamReader.scala 86 sql/core/src/main/scala/org/apache/spark/sql/classic/DataStreamWriter.scala 323 sql/core/src/main/scala/org/apache/spark/sql/classic/Dataset.scala 1498 sql/core/src/main/scala/org/apache/spark/sql/classic/KeyValueGroupedDataset.scala 452 sql/core/src/main/scala/org/apache/spark/sql/classic/MergeIntoWriter.scala 80 sql/core/src/main/scala/org/apache/spark/sql/classic/ObservationManager.scala 42 sql/core/src/main/scala/org/apache/spark/sql/classic/RelationalGroupedDataset.scala 473 sql/core/src/main/scala/org/apache/spark/sql/classic/RuntimeConfig.scala 63 sql/core/src/main/scala/org/apache/spark/sql/classic/SQLContext.scala 232 sql/core/src/main/scala/org/apache/spark/sql/classic/SQLImplicits.scala 17 sql/core/src/main/scala/org/apache/spark/sql/classic/SparkSession.scala 665 sql/core/src/main/scala/org/apache/spark/sql/classic/StreamingQuery.scala 5 sql/core/src/main/scala/org/apache/spark/sql/classic/StreamingQueryManager.scala 259 sql/core/src/main/scala/org/apache/spark/sql/classic/TableValuedFunction.scala 49 sql/core/src/main/scala/org/apache/spark/sql/classic/TypedAggUtils.scala 39 sql/core/src/main/scala/org/apache/spark/sql/classic/UDFRegistration.scala 142 sql/core/src/main/scala/org/apache/spark/sql/classic/UserDefinedFunctionUtils.scala 20 sql/core/src/main/scala/org/apache/spark/sql/classic/columnNodeSupport.scala 265 sql/core/src/main/scala/org/apache/spark/sql/classic/conversions.scala 41 sql/core/src/main/scala/org/apache/spark/sql/classic/package.scala 9 sql/core/src/main/scala/org/apache/spark/sql/columnar/CachedBatchSerializer.scala 154 sql/core/src/main/scala/org/apache/spark/sql/execution/AggregatingAccumulator.scala 216 sql/core/src/main/scala/org/apache/spark/sql/execution/AliasAwareOutputExpression.scala 42 sql/core/src/main/scala/org/apache/spark/sql/execution/BaseScriptTransformationExec.scala 322 sql/core/src/main/scala/org/apache/spark/sql/execution/CacheManager.scala 305 sql/core/src/main/scala/org/apache/spark/sql/execution/CoGroupedIterator.scala 54 sql/core/src/main/scala/org/apache/spark/sql/execution/CollectMetricsExec.scala 67 sql/core/src/main/scala/org/apache/spark/sql/execution/Columnar.scala 388 sql/core/src/main/scala/org/apache/spark/sql/execution/ColumnarEvaluatorFactory.scala 80 sql/core/src/main/scala/org/apache/spark/sql/execution/CommandResultExec.scala 70 sql/core/src/main/scala/org/apache/spark/sql/execution/DataSourceScanExec.scala 611 sql/core/src/main/scala/org/apache/spark/sql/execution/EmptyRelationExec.scala 49 sql/core/src/main/scala/org/apache/spark/sql/execution/ExistingRDD.scala 220 sql/core/src/main/scala/org/apache/spark/sql/execution/ExpandExec.scala 150 sql/core/src/main/scala/org/apache/spark/sql/execution/ExplainMode.scala 21 sql/core/src/main/scala/org/apache/spark/sql/execution/ExplainUtils.scala 200 sql/core/src/main/scala/org/apache/spark/sql/execution/ExternalAppendOnlyUnsafeRowArray.scala 164 sql/core/src/main/scala/org/apache/spark/sql/execution/FileRelation.scala 4 sql/core/src/main/scala/org/apache/spark/sql/execution/FilterEvaluatorFactory.scala 27 sql/core/src/main/scala/org/apache/spark/sql/execution/GenerateExec.scala 231 sql/core/src/main/scala/org/apache/spark/sql/execution/GroupedIterator.scala 81 sql/core/src/main/scala/org/apache/spark/sql/execution/HiveResult.scala 110 sql/core/src/main/scala/org/apache/spark/sql/execution/InsertSortForLimitAndOffset.scala 63 sql/core/src/main/scala/org/apache/spark/sql/execution/LocalTableScanExec.scala 75 sql/core/src/main/scala/org/apache/spark/sql/execution/MultiResultExec.scala 14 sql/core/src/main/scala/org/apache/spark/sql/execution/OptimizeMetadataOnlyQuery.scala 119 sql/core/src/main/scala/org/apache/spark/sql/execution/PartitionedFileUtil.scala 60 sql/core/src/main/scala/org/apache/spark/sql/execution/ProjectEvaluatorFactory.scala 20 sql/core/src/main/scala/org/apache/spark/sql/execution/QueryExecution.scala 440 sql/core/src/main/scala/org/apache/spark/sql/execution/RemoveRedundantProjects.scala 71 sql/core/src/main/scala/org/apache/spark/sql/execution/RemoveRedundantSorts.scala 19 sql/core/src/main/scala/org/apache/spark/sql/execution/RemoveRedundantWindowGroupLimits.scala 12 sql/core/src/main/scala/org/apache/spark/sql/execution/ReplaceHashWithSortAgg.scala 59 sql/core/src/main/scala/org/apache/spark/sql/execution/SQLExecution.scala 240 sql/core/src/main/scala/org/apache/spark/sql/execution/SQLExecutionRDD.scala 25 sql/core/src/main/scala/org/apache/spark/sql/execution/ScanFileListing.scala 19 sql/core/src/main/scala/org/apache/spark/sql/execution/ShuffledRowRDD.scala 153 sql/core/src/main/scala/org/apache/spark/sql/execution/SortExec.scala 131 sql/core/src/main/scala/org/apache/spark/sql/execution/SortPrefixUtils.scala 119 sql/core/src/main/scala/org/apache/spark/sql/execution/SparkOptimizer.scala 81 sql/core/src/main/scala/org/apache/spark/sql/execution/SparkPlan.scala 378 sql/core/src/main/scala/org/apache/spark/sql/execution/SparkPlanInfo.scala 72 sql/core/src/main/scala/org/apache/spark/sql/execution/SparkPlanner.scala 60 sql/core/src/main/scala/org/apache/spark/sql/execution/SparkScriptTransformationExec.scala 51 sql/core/src/main/scala/org/apache/spark/sql/execution/SparkSqlParser.scala 1040 sql/core/src/main/scala/org/apache/spark/sql/execution/SparkStrategies.scala 806 sql/core/src/main/scala/org/apache/spark/sql/execution/StreamSourceAwareSparkPlan.scala 5 sql/core/src/main/scala/org/apache/spark/sql/execution/SubqueryAdaptiveBroadcastExec.scala 24 sql/core/src/main/scala/org/apache/spark/sql/execution/SubqueryBroadcastExec.scala 87 sql/core/src/main/scala/org/apache/spark/sql/execution/UnionLoopExec.scala 152 sql/core/src/main/scala/org/apache/spark/sql/execution/UnsafeRowSerializer.scala 118 sql/core/src/main/scala/org/apache/spark/sql/execution/WholeStageCodegenEvaluatorFactory.scala 37 sql/core/src/main/scala/org/apache/spark/sql/execution/WholeStageCodegenExec.scala 553 sql/core/src/main/scala/org/apache/spark/sql/execution/adaptive/AQEOptimizer.scala 58 sql/core/src/main/scala/org/apache/spark/sql/execution/adaptive/AQEPropagateEmptyRelation.scala 57 sql/core/src/main/scala/org/apache/spark/sql/execution/adaptive/AQEShuffleReadExec.scala 201 sql/core/src/main/scala/org/apache/spark/sql/execution/adaptive/AQEShuffleReadRule.scala 10 sql/core/src/main/scala/org/apache/spark/sql/execution/adaptive/AQEUtils.scala 31 sql/core/src/main/scala/org/apache/spark/sql/execution/adaptive/AdaptiveRulesHolder.scala 10 sql/core/src/main/scala/org/apache/spark/sql/execution/adaptive/AdaptiveSparkPlanExec.scala 637 sql/core/src/main/scala/org/apache/spark/sql/execution/adaptive/AdaptiveSparkPlanHelper.scala 59 sql/core/src/main/scala/org/apache/spark/sql/execution/adaptive/AdjustShuffleExchangePosition.scala 15 sql/core/src/main/scala/org/apache/spark/sql/execution/adaptive/CoalesceShufflePartitions.scala 141 sql/core/src/main/scala/org/apache/spark/sql/execution/adaptive/DynamicJoinSelection.scala 85 sql/core/src/main/scala/org/apache/spark/sql/execution/adaptive/InsertAdaptiveSparkPlan.scala 102 sql/core/src/main/scala/org/apache/spark/sql/execution/adaptive/InvalidAQEPlanException.scala 4 sql/core/src/main/scala/org/apache/spark/sql/execution/adaptive/LogicalQueryStage.scala 47 sql/core/src/main/scala/org/apache/spark/sql/execution/adaptive/LogicalQueryStageStrategy.scala 35 sql/core/src/main/scala/org/apache/spark/sql/execution/adaptive/OptimizeShuffleWithLocalRead.scala 98 sql/core/src/main/scala/org/apache/spark/sql/execution/adaptive/OptimizeSkewInRebalancePartitions.scala 56 sql/core/src/main/scala/org/apache/spark/sql/execution/adaptive/OptimizeSkewedJoin.scala 176 sql/core/src/main/scala/org/apache/spark/sql/execution/adaptive/PlanAdaptiveDynamicPruningFilters.scala 54 sql/core/src/main/scala/org/apache/spark/sql/execution/adaptive/PlanAdaptiveSubqueries.scala 37 sql/core/src/main/scala/org/apache/spark/sql/execution/adaptive/QueryStageExec.scala 219 sql/core/src/main/scala/org/apache/spark/sql/execution/adaptive/ReuseAdaptiveSubquery.scala 22 sql/core/src/main/scala/org/apache/spark/sql/execution/adaptive/ShufflePartitionsUtil.scala 265 sql/core/src/main/scala/org/apache/spark/sql/execution/adaptive/ValidateSparkPlan.scala 36 sql/core/src/main/scala/org/apache/spark/sql/execution/adaptive/costing.scala 23 sql/core/src/main/scala/org/apache/spark/sql/execution/adaptive/simpleCosting.scala 28 sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/AggUtils.scala 432 sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/AggregateCodegenSupport.scala 253 sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/AggregationIterator.scala 214 sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/BaseAggregateExec.scala 76 sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/HashAggregateExec.scala 695 sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/HashMapGenerator.scala 126 sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/MergingSessionsExec.scala 58 sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/MergingSessionsIterator.scala 164 sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/ObjectAggregationIterator.scala 231 sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/ObjectAggregationMap.scala 67 sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/ObjectHashAggregateExec.scala 85 sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/RowBasedHashMapGenerator.scala 139 sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/SortAggregateExec.scala 86 sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/SortBasedAggregationIterator.scala 103 sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/TungstenAggregationIterator.scala 233 sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/TypedAggregateExpression.scala 219 sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/UpdatingSessionsExec.scala 54 sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/UpdatingSessionsIterator.scala 142 sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/VectorizedHashMapGenerator.scala 120 sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/udaf.scala 429 sql/core/src/main/scala/org/apache/spark/sql/execution/analysis/DetectAmbiguousSelfJoin.scala 110 sql/core/src/main/scala/org/apache/spark/sql/execution/arrow/ArrowConverters.scala 379 sql/core/src/main/scala/org/apache/spark/sql/execution/basicPhysicalOperators.scala 642 sql/core/src/main/scala/org/apache/spark/sql/execution/bucketing/CoalesceBucketsInJoin.scala 124 sql/core/src/main/scala/org/apache/spark/sql/execution/bucketing/DisableUnnecessaryBucketedScan.scala 64 sql/core/src/main/scala/org/apache/spark/sql/execution/columnar/ColumnAccessor.scala 125 sql/core/src/main/scala/org/apache/spark/sql/execution/columnar/ColumnBuilder.scala 142 sql/core/src/main/scala/org/apache/spark/sql/execution/columnar/ColumnStats.scala 276 sql/core/src/main/scala/org/apache/spark/sql/execution/columnar/ColumnType.scala 624 sql/core/src/main/scala/org/apache/spark/sql/execution/columnar/GenerateColumnAccessor.scala 173 sql/core/src/main/scala/org/apache/spark/sql/execution/columnar/InMemoryRelation.scala 417 sql/core/src/main/scala/org/apache/spark/sql/execution/columnar/InMemoryTableScanExec.scala 126 sql/core/src/main/scala/org/apache/spark/sql/execution/columnar/NullableColumnAccessor.scala 31 sql/core/src/main/scala/org/apache/spark/sql/execution/columnar/NullableColumnBuilder.scala 47 sql/core/src/main/scala/org/apache/spark/sql/execution/columnar/compression/CompressibleColumnAccessor.scala 19 sql/core/src/main/scala/org/apache/spark/sql/execution/columnar/compression/CompressibleColumnBuilder.scala 59 sql/core/src/main/scala/org/apache/spark/sql/execution/columnar/compression/CompressionScheme.scala 49 sql/core/src/main/scala/org/apache/spark/sql/execution/columnar/compression/compressionSchemes.scala 673 sql/core/src/main/scala/org/apache/spark/sql/execution/command/AnalyzeColumnCommand.scala 106 sql/core/src/main/scala/org/apache/spark/sql/execution/command/AnalyzePartitionCommand.scala 64 sql/core/src/main/scala/org/apache/spark/sql/execution/command/AnalyzeTableCommand.scala 12 sql/core/src/main/scala/org/apache/spark/sql/execution/command/AnalyzeTablesCommand.scala 24 sql/core/src/main/scala/org/apache/spark/sql/execution/command/CommandCheck.scala 14 sql/core/src/main/scala/org/apache/spark/sql/execution/command/CommandUtils.scala 375 sql/core/src/main/scala/org/apache/spark/sql/execution/command/CreateSQLFunctionCommand.scala 279 sql/core/src/main/scala/org/apache/spark/sql/execution/command/CreateUserDefinedFunctionCommand.scala 111 sql/core/src/main/scala/org/apache/spark/sql/execution/command/DataWritingCommand.scala 60 sql/core/src/main/scala/org/apache/spark/sql/execution/command/DescribeProcedureCommand.scala 54 sql/core/src/main/scala/org/apache/spark/sql/execution/command/DescribeRelationJsonCommand.scala 262 sql/core/src/main/scala/org/apache/spark/sql/execution/command/InsertIntoDataSourceDirCommand.scala 42 sql/core/src/main/scala/org/apache/spark/sql/execution/command/SetCatalogCommand.scala 10 sql/core/src/main/scala/org/apache/spark/sql/execution/command/SetCommand.scala 157 sql/core/src/main/scala/org/apache/spark/sql/execution/command/SetNamespaceCommand.scala 10 sql/core/src/main/scala/org/apache/spark/sql/execution/command/ShowCatalogsCommand.scala 12 sql/core/src/main/scala/org/apache/spark/sql/execution/command/ShowCurrentNamespaceCommand.scala 14 sql/core/src/main/scala/org/apache/spark/sql/execution/command/ShowNamespacesCommand.scala 49 sql/core/src/main/scala/org/apache/spark/sql/execution/command/ShowProceduresCommand.scala 34 sql/core/src/main/scala/org/apache/spark/sql/execution/command/UnsetNamespacePropertiesCommand.scala 22 sql/core/src/main/scala/org/apache/spark/sql/execution/command/cache.scala 9 sql/core/src/main/scala/org/apache/spark/sql/execution/command/commands.scala 135 sql/core/src/main/scala/org/apache/spark/sql/execution/command/createDataSourceTables.scala 155 sql/core/src/main/scala/org/apache/spark/sql/execution/command/ddl.scala 734 sql/core/src/main/scala/org/apache/spark/sql/execution/command/functions.scala 133 sql/core/src/main/scala/org/apache/spark/sql/execution/command/resources.scala 79 sql/core/src/main/scala/org/apache/spark/sql/execution/command/tables.scala 992 sql/core/src/main/scala/org/apache/spark/sql/execution/command/v2/CreateVariableExec.scala 38 sql/core/src/main/scala/org/apache/spark/sql/execution/command/v2/DropVariableExec.scala 29 sql/core/src/main/scala/org/apache/spark/sql/execution/command/v2/SetVariableExec.scala 66 sql/core/src/main/scala/org/apache/spark/sql/execution/command/v2/V2CommandStrategy.scala 17 sql/core/src/main/scala/org/apache/spark/sql/execution/command/views.scala 555 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/AggregatePushDownUtils.scala 127 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/ApplyCharTypePadding.scala 35 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/BasicWriteStatsTracker.scala 160 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/BucketingUtils.scala 23 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/CatalogFileIndex.scala 57 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/CodecStreams.scala 61 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/DataSource.scala 617 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/DataSourceManager.scala 79 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/DataSourceMetricsMixin.scala 5 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/DataSourceResolver.scala 36 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/DataSourceStrategy.scala 613 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/DataSourceUtils.scala 225 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/DaysWritable.scala 43 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/ExternalEngineDatasourceRDD.scala 4 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/FallBackFileSourceV2.scala 21 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/FileFormat.scala 178 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/FileFormatDataWriter.scala 410 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/FileFormatWriter.scala 315 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/FileIndex.scala 68 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/FileIndexOptions.scala 13 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/FilePartition.scala 97 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/FileResolver.scala 21 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/FileScanRDD.scala 210 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/FileSourceStrategy.scala 237 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/FileStatusCache.scala 97 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/HadoopFileLinesReader.scala 35 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/HadoopFileWholeTextReader.scala 31 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/HadoopFsRelation.scala 30 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/InMemoryFileIndex.scala 130 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/InsertIntoDataSourceCommand.scala 25 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/InsertIntoHadoopFsRelationCommand.scala 203 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/LogicalRelation.scala 77 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/OutputWriter.scala 16 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/PartitioningAwareFileIndex.scala 173 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/PartitioningUtils.scala 400 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/PruneFileSourcePartitions.scala 65 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/PushVariantIntoScan.scala 233 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/RecordReaderIterator.scala 41 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/SQLHadoopMapReduceCommitProtocol.scala 36 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/SaveIntoDataSourceCommand.scala 51 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/SchemaMergeUtils.scala 64 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/SchemaPruning.scala 128 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/SourceOptions.scala 18 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/V1Writes.scala 140 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/WriteFiles.scala 76 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/WriteStatsTracker.scala 14 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/binaryfile/BinaryFileFormat.scala 133 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/csv/CSVDataSource.scala 239 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/csv/CSVFileFormat.scala 127 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/csv/CSVUtils.scala 114 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/csv/CsvOutputWriter.scala 23 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/ddl.scala 104 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/DriverRegistry.scala 37 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/DriverWrapper.scala 17 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JDBCOptions.scala 213 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JDBCRDD.scala 195 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JDBCRelation.scala 249 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JdbcRelationProvider.scala 60 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JdbcUtils.scala 991 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/connection/BasicConnectionProvider.scala 31 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/connection/ConnectionProvider.scala 74 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/connection/DB2ConnectionProvider.scala 29 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/connection/MSSQLConnectionProvider.scala 51 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/connection/MariaDBConnectionProvider.scala 8 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/connection/OracleConnectionProvider.scala 28 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/connection/PostgresConnectionProvider.scala 13 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/connection/SecureConnectionProvider.scala 58 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/json/JsonDataSource.scala 190 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/json/JsonFileFormat.scala 110 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/json/JsonOutputWriter.scala 36 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/json/JsonUtils.scala 39 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/noop/NoopDataSource.scala 64 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/orc/OrcDeserializer.scala 221 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/orc/OrcFileFormat.scala 181 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/orc/OrcFilters.scala 151 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/orc/OrcFiltersBase.scala 50 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/orc/OrcOptions.scala 41 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/orc/OrcOutputWriter.scala 38 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/orc/OrcSerializer.scala 159 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/orc/OrcShimUtils.scala 38 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/orc/OrcUtils.scala 403 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetColumn.scala 30 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetFileFormat.scala 374 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetFilters.scala 704 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetOptions.scala 55 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetOutputWriter.scala 18 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetReadSupport.scala 369 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetRecordMaterializer.scala 26 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetRowConverter.scala 675 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetRowIndexUtil.scala 84 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetSchemaConverter.scala 470 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetUtils.scala 366 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetWriteSupport.scala 366 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/SparkShreddingUtils.scala 672 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/pathFilters.scala 79 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/rules.scala 558 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/text/TextFileFormat.scala 107 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/text/TextOptions.scala 28 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/text/TextOutputWriter.scala 24 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/AddPartitionExec.scala 43 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/AlterNamespaceSetPropertiesExec.scala 17 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/AlterTableExec.scala 21 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/BatchScanExec.scala 224 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/CacheTableExec.scala 81 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/ContinuousScanExec.scala 43 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/CreateIndexExec.scala 40 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/CreateNamespaceExec.scala 37 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/CreateTableExec.scala 42 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DataSourceRDD.scala 140 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DataSourceV2ScanExecBase.scala 147 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DataSourceV2Strategy.scala 551 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DataSourceV2Utils.scala 152 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DeleteFromTableExec.scala 16 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DescribeColumnExec.scala 72 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DescribeNamespaceExec.scala 34 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DescribeTableExec.scala 151 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DistributionAndOrderingUtils.scala 77 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DropIndexExec.scala 22 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DropNamespaceExec.scala 30 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DropPartitionExec.scala 37 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DropTableExec.scala 24 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/EmptyPartitionReader.scala 9 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/ExplainOnlySparkPlan.scala 16 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/FileBatchWrite.scala 33 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/FileDataSourceV2.scala 90 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/FilePartitionReader.scala 70 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/FilePartitionReaderFactory.scala 31 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/FileScan.scala 147 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/FileScanBuilder.scala 69 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/FileTable.scala 99 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/FileWrite.scala 109 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/FileWriterFactory.scala 36 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/GroupBasedRowLevelOperationScanPlanning.scala 80 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/MergeRowsExec.scala 168 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/MicroBatchScanExec.scala 34 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/OptimizeMetadataOnlyDeleteFromTable.scala 55 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/PartitionReaderFromIterator.scala 16 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/PartitionReaderWithPartitionValues.scala 26 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/PartitionRecordReader.scala 9 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/PushDownUtils.scala 131 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/PushedDownOperators.scala 13 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/RefreshTableExec.scala 15 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/RenamePartitionExec.scala 18 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/RenameTableExec.scala 34 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/ReplaceTableExec.scala 89 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/SetCatalogAndNamespaceExec.scala 16 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/ShowColumnsExec.scala 12 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/ShowCreateTableExec.scala 128 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/ShowFunctionsExec.scala 40 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/ShowPartitionsExec.scala 39 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/ShowTablePropertiesExec.scala 28 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/ShowTablesExec.scala 29 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/ShowTablesExtendedExec.scala 139 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/TableCapabilityCheck.scala 61 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/TableSampleInfo.scala 6 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/TextBasedFileScan.scala 18 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/TruncatePartitionExec.scala 28 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/TruncateTableExec.scala 13 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/V1FallbackWriters.scala 49 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/V2ColumnUtils.scala 8 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/V2CommandExec.scala 27 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/V2ScanPartitioningAndOrdering.scala 48 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/V2ScanRelationPushDown.scala 441 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/V2SessionCatalog.scala 421 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/V2Writes.scala 146 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/WriteToDataSourceV2Exec.scala 528 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/csv/CSVDataSourceV2.scala 23 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/csv/CSVPartitionReaderFactory.scala 50 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/csv/CSVScan.scala 70 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/csv/CSVScanBuilder.scala 35 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/csv/CSVTable.scala 41 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/csv/CSVWrite.scala 42 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/jdbc/JDBCScan.scala 47 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/jdbc/JDBCScanBuilder.scala 137 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/jdbc/JDBCTable.scala 80 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/jdbc/JDBCTableCatalog.scala 360 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/jdbc/JDBCV1RelationFromV2Scan.scala 33 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/jdbc/JDBCWriteBuilder.scala 26 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/json/JsonDataSourceV2.scala 23 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/json/JsonPartitionReaderFactory.scala 38 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/json/JsonScan.scala 67 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/json/JsonScanBuilder.scala 35 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/json/JsonTable.scala 47 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/json/JsonWrite.scala 41 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/orc/OrcDataSourceV2.scala 23 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/orc/OrcPartitionReaderFactory.scala 174 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/orc/OrcScan.scala 75 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/orc/OrcScanBuilder.scala 62 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/orc/OrcTable.scala 39 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/orc/OrcWrite.scala 45 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/parquet/ParquetDataSourceV2.scala 24 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/parquet/ParquetPartitionReaderFactory.scala 266 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/parquet/ParquetScan.scala 103 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/parquet/ParquetScanBuilder.scala 79 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/parquet/ParquetTable.scala 39 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/parquet/ParquetWrite.scala 23 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/python/PythonBatchWriterFactory.scala 52 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/python/PythonCustomMetric.scala 26 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/python/PythonDataSourceV2.scala 55 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/python/PythonMicroBatchStream.scala 79 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/python/PythonPartitionReaderFactory.scala 37 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/python/PythonScan.scala 49 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/python/PythonScanBuilder.scala 33 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/python/PythonStreamingPartitionReaderFactory.scala 56 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/python/PythonStreamingSinkCommitRunner.scala 41 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/python/PythonStreamingWrite.scala 61 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/python/PythonTable.scala 23 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/python/PythonWrite.scala 45 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/python/PythonWriteBuilder.scala 14 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/python/UserDefinedPythonDataSource.scala 437 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/state/StateDataSource.scala 443 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/state/StateDataSourceErrors.scala 126 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/state/StatePartitionReader.scala 232 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/state/StateScanBuilder.scala 123 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/state/StateTable.scala 62 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/state/StreamStreamJoinStateHelper.scala 51 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/state/StreamStreamJoinStatePartitionReader.scala 123 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/state/metadata/StateMetadataSource.scala 213 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/state/utils/SchemaUtil.scala 396 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/text/TextDataSourceV2.scala 23 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/text/TextPartitionReaderFactory.scala 45 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/text/TextScan.scala 58 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/text/TextScanBuilder.scala 18 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/text/TextTable.scala 29 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/text/TextWrite.scala 44 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/xml/XSDToSchema.scala 205 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/xml/XmlDataSource.scala 187 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/xml/XmlFileFormat.scala 106 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/xml/XmlInputFormat.scala 231 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/xml/XmlOutputWriter.scala 27 sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/xml/XmlUtils.scala 39 sql/core/src/main/scala/org/apache/spark/sql/execution/debug/DebugEvaluatorFactory.scala 37 sql/core/src/main/scala/org/apache/spark/sql/execution/debug/package.scala 183 sql/core/src/main/scala/org/apache/spark/sql/execution/dynamicpruning/CleanupDynamicPruningFilters.scala 58 sql/core/src/main/scala/org/apache/spark/sql/execution/dynamicpruning/PartitionPruning.scala 174 sql/core/src/main/scala/org/apache/spark/sql/execution/dynamicpruning/PlanDynamicPruningFilters.scala 55 sql/core/src/main/scala/org/apache/spark/sql/execution/dynamicpruning/RowLevelOperationRuntimeGroupFiltering.scala 87 sql/core/src/main/scala/org/apache/spark/sql/execution/exchange/BroadcastExchangeExec.scala 180 sql/core/src/main/scala/org/apache/spark/sql/execution/exchange/EnsureRequirements.scala 526 sql/core/src/main/scala/org/apache/spark/sql/execution/exchange/Exchange.scala 48 sql/core/src/main/scala/org/apache/spark/sql/execution/exchange/ShuffleExchangeExec.scala 283 sql/core/src/main/scala/org/apache/spark/sql/execution/exchange/ValidateRequirements.scala 42 sql/core/src/main/scala/org/apache/spark/sql/execution/history/SQLEventFilterBuilder.scala 88 sql/core/src/main/scala/org/apache/spark/sql/execution/joins/BaseJoinExec.scala 34 sql/core/src/main/scala/org/apache/spark/sql/execution/joins/BroadcastHashJoinExec.scala 174 sql/core/src/main/scala/org/apache/spark/sql/execution/joins/BroadcastNestedLoopJoinExec.scala 471 sql/core/src/main/scala/org/apache/spark/sql/execution/joins/CartesianProductExec.scala 69 sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashJoin.scala 663 sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashedRelation.scala 795 sql/core/src/main/scala/org/apache/spark/sql/execution/joins/JoinCodegenSupport.scala 62 sql/core/src/main/scala/org/apache/spark/sql/execution/joins/ShuffledHashJoinExec.scala 505 sql/core/src/main/scala/org/apache/spark/sql/execution/joins/ShuffledJoin.scala 48 sql/core/src/main/scala/org/apache/spark/sql/execution/joins/SortMergeJoinEvaluatorFactory.scala 259 sql/core/src/main/scala/org/apache/spark/sql/execution/joins/SortMergeJoinExec.scala 1142 sql/core/src/main/scala/org/apache/spark/sql/execution/limit.scala 307 sql/core/src/main/scala/org/apache/spark/sql/execution/metric/CustomMetrics.scala 36 sql/core/src/main/scala/org/apache/spark/sql/execution/metric/SQLMetricInfo.scala 7 sql/core/src/main/scala/org/apache/spark/sql/execution/metric/SQLMetrics.scala 120 sql/core/src/main/scala/org/apache/spark/sql/execution/metric/SQLShuffleMetricsReporter.scala 191 sql/core/src/main/scala/org/apache/spark/sql/execution/objects.scala 454 sql/core/src/main/scala/org/apache/spark/sql/execution/package.scala 2 sql/core/src/main/scala/org/apache/spark/sql/execution/python/AggregateInPandasExec.scala 144 sql/core/src/main/scala/org/apache/spark/sql/execution/python/ArrowEvalPythonExec.scala 95 sql/core/src/main/scala/org/apache/spark/sql/execution/python/ArrowEvalPythonUDTFExec.scala 56 sql/core/src/main/scala/org/apache/spark/sql/execution/python/ArrowPythonRunner.scala 97 sql/core/src/main/scala/org/apache/spark/sql/execution/python/ArrowPythonUDTFRunner.scala 43 sql/core/src/main/scala/org/apache/spark/sql/execution/python/AttachDistributedSequenceExec.scala 67 sql/core/src/main/scala/org/apache/spark/sql/execution/python/BatchEvalPythonExec.scala 97 sql/core/src/main/scala/org/apache/spark/sql/execution/python/BatchEvalPythonUDTFExec.scala 93 sql/core/src/main/scala/org/apache/spark/sql/execution/python/CoGroupedArrowPythonRunner.scala 97 sql/core/src/main/scala/org/apache/spark/sql/execution/python/EvalPythonEvaluatorFactory.scala 87 sql/core/src/main/scala/org/apache/spark/sql/execution/python/EvalPythonExec.scala 25 sql/core/src/main/scala/org/apache/spark/sql/execution/python/EvalPythonUDTFExec.scala 86 sql/core/src/main/scala/org/apache/spark/sql/execution/python/EvaluatePython.scala 222 sql/core/src/main/scala/org/apache/spark/sql/execution/python/ExtractPythonUDFs.scala 243 sql/core/src/main/scala/org/apache/spark/sql/execution/python/FlatMapCoGroupsInArrowExec.scala 17 sql/core/src/main/scala/org/apache/spark/sql/execution/python/FlatMapCoGroupsInBatchExec.scala 63 sql/core/src/main/scala/org/apache/spark/sql/execution/python/FlatMapCoGroupsInPandasExec.scala 17 sql/core/src/main/scala/org/apache/spark/sql/execution/python/FlatMapGroupsInArrowExec.scala 22 sql/core/src/main/scala/org/apache/spark/sql/execution/python/FlatMapGroupsInBatchExec.scala 62 sql/core/src/main/scala/org/apache/spark/sql/execution/python/FlatMapGroupsInPandasExec.scala 14 sql/core/src/main/scala/org/apache/spark/sql/execution/python/MapInArrowExec.scala 16 sql/core/src/main/scala/org/apache/spark/sql/execution/python/MapInBatchEvaluatorFactory.scala 68 sql/core/src/main/scala/org/apache/spark/sql/execution/python/MapInBatchExec.scala 56 sql/core/src/main/scala/org/apache/spark/sql/execution/python/MapInPandasExec.scala 16 sql/core/src/main/scala/org/apache/spark/sql/execution/python/PandasGroupUtils.scala 64 sql/core/src/main/scala/org/apache/spark/sql/execution/python/PythonArrowInput.scala 138 sql/core/src/main/scala/org/apache/spark/sql/execution/python/PythonArrowOutput.scala 243 sql/core/src/main/scala/org/apache/spark/sql/execution/python/PythonPlannerRunner.scala 181 sql/core/src/main/scala/org/apache/spark/sql/execution/python/PythonSQLMetrics.scala 33 sql/core/src/main/scala/org/apache/spark/sql/execution/python/PythonUDFRunner.scala 170 sql/core/src/main/scala/org/apache/spark/sql/execution/python/RowQueue.scala 205 sql/core/src/main/scala/org/apache/spark/sql/execution/python/UserDefinedPythonFunction.scala 213 sql/core/src/main/scala/org/apache/spark/sql/execution/python/WindowInPandasEvaluatorFactory.scala 260 sql/core/src/main/scala/org/apache/spark/sql/execution/python/WindowInPandasExec.scala 38 sql/core/src/main/scala/org/apache/spark/sql/execution/python/streaming/ApplyInPandasWithStatePythonRunner.scala 182 sql/core/src/main/scala/org/apache/spark/sql/execution/python/streaming/ApplyInPandasWithStateWriter.scala 105 sql/core/src/main/scala/org/apache/spark/sql/execution/python/streaming/BaseStreamingArrowWriter.scala 36 sql/core/src/main/scala/org/apache/spark/sql/execution/python/streaming/FlatMapGroupsInPandasWithStateExec.scala 171 sql/core/src/main/scala/org/apache/spark/sql/execution/python/streaming/PythonForeachWriter.scala 131 sql/core/src/main/scala/org/apache/spark/sql/execution/python/streaming/PythonStreamingSourceRunner.scala 184 sql/core/src/main/scala/org/apache/spark/sql/execution/python/streaming/TransformWithStateInPySparkDeserializer.scala 48 sql/core/src/main/scala/org/apache/spark/sql/execution/python/streaming/TransformWithStateInPySparkExec.scala 403 sql/core/src/main/scala/org/apache/spark/sql/execution/python/streaming/TransformWithStateInPySparkPythonRunner.scala 291 sql/core/src/main/scala/org/apache/spark/sql/execution/python/streaming/TransformWithStateInPySparkStateServer.scala 754 sql/core/src/main/scala/org/apache/spark/sql/execution/r/ArrowRRunner.scala 147 sql/core/src/main/scala/org/apache/spark/sql/execution/r/MapPartitionsRWrapper.scala 37 sql/core/src/main/scala/org/apache/spark/sql/execution/reuse/ReuseExchangeAndSubquery.scala 44 sql/core/src/main/scala/org/apache/spark/sql/execution/stat/FrequentItems.scala 134 sql/core/src/main/scala/org/apache/spark/sql/execution/stat/StatFunctions.scala 166 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/AcceptsLatestSeenOffsetHandler.scala 30 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/AsyncCommitLog.scala 75 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/AsyncLogPurge.scala 62 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/AsyncOffsetSeqLog.scala 107 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/AsyncProgressTrackingMicroBatchExecution.scala 224 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/AsyncStreamingQueryCheckpointMetadata.scala 24 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/AvailableNowDataStreamWrapper.scala 49 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/AvailableNowMicroBatchStreamWrapper.scala 13 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/AvailableNowSourceWrapper.scala 12 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/CheckpointFileManager.scala 231 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/CommitLog.scala 40 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/CompactibleFileStreamLog.scala 232 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/ContinuousRecordEndpoint.scala 27 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/ErrorNotifier.scala 16 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/EventTimeWatermarkExec.scala 117 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/ExpiredTimerInfoImpl.scala 5 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/FileStreamOptions.scala 85 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/FileStreamSink.scala 133 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/FileStreamSinkLog.scala 75 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/FileStreamSource.scala 462 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/FileStreamSourceLog.scala 95 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/FileStreamSourceOffset.scala 26 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/FlatMapGroupsWithStateExec.scala 417 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/GroupStateImpl.scala 194 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/HDFSMetadataLog.scala 251 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/IncrementalExecution.scala 467 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/ListStateImpl.scala 95 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/ListStateImplWithTTL.scala 139 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/ListStateMetricsImpl.scala 39 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/LongOffset.scala 9 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/ManifestFileCommitProtocol.scala 94 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/MapStateImpl.scala 72 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/MapStateImplWithTTL.scala 136 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/MergingSortWithSessionWindowStateIterator.scala 106 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/MetadataLog.scala 8 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/MetadataLogFileIndex.scala 40 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/MetadataVersionUtil.scala 34 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/MetricsReporter.scala 42 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/MicroBatchExecution.scala 701 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/OffsetSeq.scala 95 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/OffsetSeqLog.scala 45 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/ProgressReporter.scala 446 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/RateStreamOffset.scala 10 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/ResolveWriteToStream.scala 99 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/SerializedOffset.scala 2 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/Sink.scala 17 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/Source.scala 19 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StateStoreColumnFamilySchemaUtils.scala 156 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StateTypesEncoderUtils.scala 179 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StatefulOperatorPartitioning.scala 23 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StatefulProcessorHandleImpl.scala 477 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StatefulProcessorHandleImplBase.scala 32 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamExecution.scala 483 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamExecutionContext.scala 130 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamMetadata.scala 63 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamProgress.scala 21 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamingCheckpointConstants.scala 7 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamingQueryCheckpointMetadata.scala 21 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamingQueryListenerBus.scala 70 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamingQueryWrapper.scala 61 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamingRelation.scala 79 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamingSymmetricHashJoinExec.scala 543 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamingSymmetricHashJoinHelper.scala 221 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/TTLState.scala 271 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/TimerStateImpl.scala 128 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/TimerValuesImpl.scala 8 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/TransformWithStateExec.scala 539 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/TransformWithStateVariableUtils.scala 154 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/TriggerExecutor.scala 60 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/ValueStateImpl.scala 42 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/ValueStateImplWithTTL.scala 83 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/WatermarkPropagator.scala 182 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/WatermarkTracker.scala 99 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/console.scala 54 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDD.scala 71 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousExecution.scala 345 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousQueuedDataReader.scala 130 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousRateStreamSource.scala 113 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousTaskRetryException.scala 4 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousTextSocketSource.scala 203 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousWriteRDD.scala 73 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/EpochCoordinator.scala 158 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/EpochTracker.scala 24 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/WriteToContinuousDataSource.scala 13 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/WriteToContinuousDataSourceExec.scala 40 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/memory.scala 215 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/sources/ConsoleStreamingWrite.scala 40 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/sources/ContinuousMemoryStream.scala 113 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/sources/ForeachBatchSink.scala 42 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/sources/ForeachWriterTable.scala 122 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/sources/MicroBatchWrite.scala 27 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/sources/PackedRowWriterFactory.scala 26 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/sources/RatePerMicroBatchProvider.scala 75 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/sources/RatePerMicroBatchStream.scala 134 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/sources/RateStreamMicroBatchStream.scala 147 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/sources/RateStreamProvider.scala 82 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/sources/TextSocketMicroBatchStream.scala 120 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/sources/TextSocketSourceProvider.scala 82 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/sources/WriteToMicroBatchDataSource.scala 23 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/sources/WriteToMicroBatchDataSourceV1.scala 23 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/sources/memory.scala 140 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/FlatMapGroupsWithStateExecHelper.scala 152 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/HDFSBackedStateStoreMap.scala 113 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/HDFSBackedStateStoreProvider.scala 801 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/OperatorStateMetadata.scala 348 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/RocksDB.scala 1425 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/RocksDBFileManager.scala 783 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/RocksDBLoader.scala 33 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/RocksDBMemoryManager.scala 40 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/RocksDBStateEncoder.scala 1126 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/RocksDBStateStoreProvider.scala 755 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/SchemaHelper.scala 169 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/StateSchemaCompatibilityChecker.scala 278 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/StateStore.scala 693 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/StateStoreChangelog.scala 413 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/StateStoreConf.scala 37 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/StateStoreCoordinator.scala 265 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/StateStoreErrors.scala 367 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/StateStoreRDD.scala 96 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/StreamingAggregationStateManager.scala 107 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/StreamingSessionWindowStateManager.scala 155 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/SymmetricHashJoinStateManager.scala 793 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/package.scala 99 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/statefulOperators.scala 1059 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/streamingLimits.scala 100 sql/core/src/main/scala/org/apache/spark/sql/execution/subquery.scala 140 sql/core/src/main/scala/org/apache/spark/sql/execution/ui/AllExecutionsPage.scala 495 sql/core/src/main/scala/org/apache/spark/sql/execution/ui/ExecutionPage.scala 210 sql/core/src/main/scala/org/apache/spark/sql/execution/ui/SQLAppStatusListener.scala 479 sql/core/src/main/scala/org/apache/spark/sql/execution/ui/SQLAppStatusStore.scala 115 sql/core/src/main/scala/org/apache/spark/sql/execution/ui/SQLHistoryServerPlugin.scala 17 sql/core/src/main/scala/org/apache/spark/sql/execution/ui/SQLListener.scala 68 sql/core/src/main/scala/org/apache/spark/sql/execution/ui/SQLTab.scala 18 sql/core/src/main/scala/org/apache/spark/sql/execution/ui/SparkPlanGraph.scala 166 sql/core/src/main/scala/org/apache/spark/sql/execution/ui/StreamingQueryHistoryServerPlugin.scala 21 sql/core/src/main/scala/org/apache/spark/sql/execution/ui/StreamingQueryStatusStore.scala 24 sql/core/src/main/scala/org/apache/spark/sql/execution/window/AggregateProcessor.scala 98 sql/core/src/main/scala/org/apache/spark/sql/execution/window/BoundOrdering.scala 26 sql/core/src/main/scala/org/apache/spark/sql/execution/window/WindowEvaluatorFactory.scala 106 sql/core/src/main/scala/org/apache/spark/sql/execution/window/WindowEvaluatorFactoryBase.scala 193 sql/core/src/main/scala/org/apache/spark/sql/execution/window/WindowExec.scala 35 sql/core/src/main/scala/org/apache/spark/sql/execution/window/WindowExecBase.scala 24 sql/core/src/main/scala/org/apache/spark/sql/execution/window/WindowFunctionFrame.scala 361 sql/core/src/main/scala/org/apache/spark/sql/execution/window/WindowGroupLimitEvaluatorFactory.scala 40 sql/core/src/main/scala/org/apache/spark/sql/execution/window/WindowGroupLimitExec.scala 186 sql/core/src/main/scala/org/apache/spark/sql/internal/BaseSessionStateBuilder.scala 257 sql/core/src/main/scala/org/apache/spark/sql/internal/HiveSerDe.scala 80 sql/core/src/main/scala/org/apache/spark/sql/internal/SessionState.scala 114 sql/core/src/main/scala/org/apache/spark/sql/internal/SharedState.scala 190 sql/core/src/main/scala/org/apache/spark/sql/internal/VariableSubstitution.scala 23 sql/core/src/main/scala/org/apache/spark/sql/internal/package-info.java 1 sql/core/src/main/scala/org/apache/spark/sql/internal/package.scala 2 sql/core/src/main/scala/org/apache/spark/sql/jdbc/AggregatedDialect.scala 36 sql/core/src/main/scala/org/apache/spark/sql/jdbc/DB2Dialect.scala 161 sql/core/src/main/scala/org/apache/spark/sql/jdbc/DatabricksDialect.scala 56 sql/core/src/main/scala/org/apache/spark/sql/jdbc/DerbyDialect.scala 53 sql/core/src/main/scala/org/apache/spark/sql/jdbc/H2Dialect.scala 230 sql/core/src/main/scala/org/apache/spark/sql/jdbc/JdbcConnectionProvider.scala 11 sql/core/src/main/scala/org/apache/spark/sql/jdbc/JdbcDialects.scala 474 sql/core/src/main/scala/org/apache/spark/sql/jdbc/JdbcSQLQueryBuilder.scala 74 sql/core/src/main/scala/org/apache/spark/sql/jdbc/MsSqlServerDialect.scala 191 sql/core/src/main/scala/org/apache/spark/sql/jdbc/MySQLDialect.scala 314 sql/core/src/main/scala/org/apache/spark/sql/jdbc/OracleDialect.scala 193 sql/core/src/main/scala/org/apache/spark/sql/jdbc/PostgresDialect.scala 311 sql/core/src/main/scala/org/apache/spark/sql/jdbc/SnowflakeDialect.scala 13 sql/core/src/main/scala/org/apache/spark/sql/jdbc/TeradataDialect.scala 51 sql/core/src/main/scala/org/apache/spark/sql/scripting/SqlScriptingExecution.scala 104 sql/core/src/main/scala/org/apache/spark/sql/scripting/SqlScriptingExecutionContext.scala 125 sql/core/src/main/scala/org/apache/spark/sql/scripting/SqlScriptingExecutionNode.scala 707 sql/core/src/main/scala/org/apache/spark/sql/scripting/SqlScriptingInterpreter.scala 179 sql/core/src/main/scala/org/apache/spark/sql/scripting/SqlScriptingLocalVariableManager.scala 74 sql/core/src/main/scala/org/apache/spark/sql/sources/interfaces.scala 99 sql/core/src/main/scala/org/apache/spark/sql/sources/package.scala 2 sql/core/src/main/scala/org/apache/spark/sql/streaming/TestGroupState.scala 31 sql/core/src/main/scala/org/apache/spark/sql/streaming/ui/StreamingQueryPage.scala 202 sql/core/src/main/scala/org/apache/spark/sql/streaming/ui/StreamingQueryStatisticsPage.scala 480 sql/core/src/main/scala/org/apache/spark/sql/streaming/ui/StreamingQueryStatusListener.scala 114 sql/core/src/main/scala/org/apache/spark/sql/streaming/ui/StreamingQueryTab.scala 18 sql/core/src/main/scala/org/apache/spark/sql/streaming/ui/UIUtils.scala 41 sql/core/src/main/scala/org/apache/spark/sql/util/MapperRowCounter.scala 52 sql/core/src/main/scala/org/apache/spark/sql/util/QueryExecutionListener.scala 95 sql/core/src/main/scala/org/apache/spark/status/api/v1/sql/ApiSqlRootResource.scala 12 sql/core/src/main/scala/org/apache/spark/status/api/v1/sql/SqlResource.scala 115 sql/core/src/main/scala/org/apache/spark/status/api/v1/sql/api.scala 21 sql/core/src/main/scala/org/apache/spark/status/protobuf/sql/SQLExecutionUIDataSerializer.scala 74 sql/core/src/main/scala/org/apache/spark/status/protobuf/sql/SQLPlanMetricSerializer.scala 21 sql/core/src/main/scala/org/apache/spark/status/protobuf/sql/SinkProgressSerializer.scala 22 sql/core/src/main/scala/org/apache/spark/status/protobuf/sql/SourceProgressSerializer.scala 41 sql/core/src/main/scala/org/apache/spark/status/protobuf/sql/SparkPlanGraphWrapperSerializer.scala 110 sql/core/src/main/scala/org/apache/spark/status/protobuf/sql/StateOperatorProgressSerializer.scala 53 sql/core/src/main/scala/org/apache/spark/status/protobuf/sql/StreamingQueryDataSerializer.scala 39 sql/core/src/main/scala/org/apache/spark/status/protobuf/sql/StreamingQueryProgressSerializer.scala 76 sql/core/src/main/scala/org/apache/spark/status/protobuf/sql/StreamingQueryProgressWrapperSerializer.scala 16 sql/gen-sql-api-docs.py 152 sql/gen-sql-config-docs.py 74 sql/gen-sql-functions-docs.py 109 sql/hive-thriftserver/src/main/java/org/apache/hive/service/AbstractService.java 78 sql/hive-thriftserver/src/main/java/org/apache/hive/service/BreakableService.java 74 sql/hive-thriftserver/src/main/java/org/apache/hive/service/CompositeService.java 83 sql/hive-thriftserver/src/main/java/org/apache/hive/service/CookieSigner.java 53 sql/hive-thriftserver/src/main/java/org/apache/hive/service/FilterService.java 45 sql/hive-thriftserver/src/main/java/org/apache/hive/service/Service.java 19 sql/hive-thriftserver/src/main/java/org/apache/hive/service/ServiceException.java 12 sql/hive-thriftserver/src/main/java/org/apache/hive/service/ServiceOperations.java 52 sql/hive-thriftserver/src/main/java/org/apache/hive/service/ServiceStateChangeListener.java 4 sql/hive-thriftserver/src/main/java/org/apache/hive/service/ServiceUtils.java 30 sql/hive-thriftserver/src/main/java/org/apache/hive/service/auth/AnonymousAuthenticationProviderImpl.java 7 sql/hive-thriftserver/src/main/java/org/apache/hive/service/auth/AuthenticationProviderFactory.java 42 sql/hive-thriftserver/src/main/java/org/apache/hive/service/auth/CustomAuthenticationProviderImpl.java 20 sql/hive-thriftserver/src/main/java/org/apache/hive/service/auth/HiveAuthFactory.java 280 sql/hive-thriftserver/src/main/java/org/apache/hive/service/auth/HttpAuthUtils.java 121 sql/hive-thriftserver/src/main/java/org/apache/hive/service/auth/HttpAuthenticationException.java 13 sql/hive-thriftserver/src/main/java/org/apache/hive/service/auth/KerberosSaslHelper.java 81 sql/hive-thriftserver/src/main/java/org/apache/hive/service/auth/LdapAuthenticationProviderImpl.java 74 sql/hive-thriftserver/src/main/java/org/apache/hive/service/auth/PamAuthenticationProviderImpl.java 26 sql/hive-thriftserver/src/main/java/org/apache/hive/service/auth/PasswdAuthenticationProvider.java 5 sql/hive-thriftserver/src/main/java/org/apache/hive/service/auth/PlainSaslHelper.java 115 sql/hive-thriftserver/src/main/java/org/apache/hive/service/auth/PlainSaslServer.java 125 sql/hive-thriftserver/src/main/java/org/apache/hive/service/auth/SaslQOP.java 33 sql/hive-thriftserver/src/main/java/org/apache/hive/service/auth/TSetIpAddressProcessor.java 77 sql/hive-thriftserver/src/main/java/org/apache/hive/service/auth/TSubjectAssumingTransport.java 37 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/CLIService.java 415 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/CLIServiceClient.java 24 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/CLIServiceUtils.java 39 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/ColumnBasedSet.java 148 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/ColumnDescriptor.java 53 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/ColumnValue.java 236 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/FetchOrientation.java 25 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/FetchType.java 20 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/GetInfoType.java 67 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/GetInfoValue.java 48 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/Handle.java 47 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/HandleIdentifier.java 79 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/HiveSQLException.java 143 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/ICLIService.java 69 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/OperationHandle.java 70 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/OperationState.java 80 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/OperationStatus.java 15 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/OperationType.java 29 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/RowBasedSet.java 97 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/RowSet.java 11 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/RowSetFactory.java 19 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/SessionHandle.java 36 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/TableSchema.java 64 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/TypeDescriptor.java 104 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/TypeQualifiers.java 90 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/operation/ClassicTableTypeMapping.java 65 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/operation/ExecuteStatementOperation.java 27 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/operation/GetCatalogsOperation.java 41 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/operation/GetColumnsOperation.java 204 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/operation/GetCrossReferenceOperation.java 98 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/operation/GetFunctionsOperation.java 108 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/operation/GetPrimaryKeysOperation.java 71 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/operation/GetSchemasOperation.java 61 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/operation/GetTableTypesOperation.java 58 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/operation/GetTablesOperation.java 106 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/operation/GetTypeInfoOperation.java 107 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/operation/HiveTableTypeMapping.java 22 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/operation/LogDivertAppender.java 227 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/operation/MetadataOperation.java 75 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/operation/Operation.java 253 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/operation/OperationManager.java 233 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/operation/TableTypeMapping.java 11 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/operation/TableTypeMappingFactory.java 16 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/session/HiveSession.java 51 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/session/HiveSessionBase.java 26 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/session/HiveSessionHookContext.java 7 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/session/HiveSessionHookContextImpl.java 20 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/session/HiveSessionImpl.java 778 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/session/HiveSessionImplwithUGI.java 106 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/session/HiveSessionProxy.java 55 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/session/SessionManager.java 294 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/thrift/TServlet.java 80 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/thrift/ThriftBinaryCLIService.java 105 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/thrift/ThriftCLIService.java 637 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/thrift/ThriftCLIServiceClient.java 390 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/thrift/ThriftHttpCLIService.java 154 sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/thrift/ThriftHttpServlet.java 395 sql/hive-thriftserver/src/main/java/org/apache/hive/service/server/HiveServer2.java 201 sql/hive-thriftserver/src/main/java/org/apache/hive/service/server/ThreadFactoryWithGarbageCleanup.java 21 sql/hive-thriftserver/src/main/java/org/apache/hive/service/server/ThreadWithGarbageCleanup.java 38 sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/FetchIterator.scala 50 sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/HiveThriftServer2.scala 120 sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/HiveThriftServerErrors.scala 38 sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/ReflectionUtils.scala 34 sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/RowSetUtils.scala 188 sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkExecuteStatementOperation.scala 333 sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkGetCatalogsOperation.scala 35 sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkGetColumnsOperation.scala 176 sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkGetFunctionsOperation.scala 63 sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkGetSchemasOperation.scala 54 sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkGetTableTypesOperation.scala 42 sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkGetTablesOperation.scala 91 sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkGetTypeInfoOperation.scala 72 sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkOperation.scala 67 sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkSQLCLIDriver.scala 510 sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkSQLCLIService.scala 110 sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkSQLDriver.scala 82 sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkSQLEnv.scala 54 sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkSQLSessionManager.scala 76 sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/server/SparkSQLOperationManager.scala 120 sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/ui/HiveThriftServer2AppStatusStore.scala 90 sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/ui/HiveThriftServer2EventManager.scala 76 sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/ui/HiveThriftServer2HistoryServerPlugin.scala 17 sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/ui/HiveThriftServer2Listener.scala 287 sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/ui/ThriftServerPage.scala 346 sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/ui/ThriftServerSessionPage.scala 84 sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/ui/ThriftServerTab.scala 26 sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/ui/ToolTips.scala 15 sql/hive/src/main/java/org/apache/hadoop/hive/ql/exec/HiveFunctionRegistryUtils.java 218 sql/hive/src/main/java/org/apache/hadoop/hive/ql/exec/SparkDefaultUDAFEvaluatorResolver.java 53 sql/hive/src/main/java/org/apache/hadoop/hive/ql/exec/SparkDefaultUDFMethodResolver.java 22 sql/hive/src/main/java/org/apache/hadoop/hive/ql/io/DelegateSymlinkTextInputFormat.java 76 sql/hive/src/main/java/org/apache/hadoop/hive/ql/io/orc/SparkOrcNewRecordReader.java 58 sql/hive/src/main/java/org/apache/hadoop/hive/ql/udf/generic/SparkGenericUDAFBridge.java 58 sql/hive/src/main/scala/org/apache/spark/sql/hive/DataSourceWithHiveResolver.scala 32 sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveContext.scala 20 sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveExternalCatalog.scala 998 sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveInspectors.scala 875 sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveMetastoreCatalog.scala 327 sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveSessionCatalog.scala 25 sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveSessionStateBuilder.scala 171 sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveShim.scala 139 sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveStrategies.scala 234 sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveUtils.scala 369 sql/hive/src/main/scala/org/apache/spark/sql/hive/TableReader.scala 343 sql/hive/src/main/scala/org/apache/spark/sql/hive/client/HiveClient.scala 138 sql/hive/src/main/scala/org/apache/spark/sql/hive/client/HiveClientImpl.scala 1102 sql/hive/src/main/scala/org/apache/spark/sql/hive/client/HiveShim.scala 1277 sql/hive/src/main/scala/org/apache/spark/sql/hive/client/IsolatedClientLoader.scala 229 sql/hive/src/main/scala/org/apache/spark/sql/hive/client/package.scala 74 sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/CreateHiveTableAsSelectCommand.scala 77 sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/HiveFileFormat.scala 127 sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/HiveOptions.scala 83 sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/HiveScriptTransformationExec.scala 239 sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/HiveTableScanExec.scala 178 sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/HiveTempPath.scala 119 sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/InsertIntoHiveDirCommand.scala 96 sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/InsertIntoHiveTable.scala 176 sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/PruneHiveTablePartitions.scala 79 sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/SaveAsHiveFile.scala 39 sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/V1WritesHiveUtils.scala 93 sql/hive/src/main/scala/org/apache/spark/sql/hive/hiveUDFEvaluators.scala 125 sql/hive/src/main/scala/org/apache/spark/sql/hive/hiveUDFs.scala 337 sql/hive/src/main/scala/org/apache/spark/sql/hive/orc/OrcFileFormat.scala 285 sql/hive/src/main/scala/org/apache/spark/sql/hive/orc/OrcFileOperator.scala 88 sql/hive/src/main/scala/org/apache/spark/sql/hive/package-info.java 1 sql/hive/src/main/scala/org/apache/spark/sql/hive/package.scala 2 sql/hive/src/main/scala/org/apache/spark/sql/hive/security/HiveDelegationTokenProvider.scala 95