META-INF/MANIFEST.MF
org/apache/spark/sql/execution/ui/static/spark-sql-viz.css
org/apache/spark/sql/execution/ui/static/spark-sql-viz.js
META-INF/services/org.apache.spark.sql.sources.DataSourceRegister
META-INF/services/org.apache.spark.scheduler.SparkHistoryListenerFactory
org/apache/spark/sql/execution/SparkPlanInfo.scala
org/apache/spark/sql/execution/SparkOptimizer.scala
org/apache/spark/sql/execution/package.scala
org/apache/spark/sql/execution/SQLExecution.scala
org/apache/spark/sql/execution/SparkPlan.scala
org/apache/spark/sql/execution/CacheManager.scala
org/apache/spark/sql/execution/objects.scala
org/apache/spark/sql/execution/SortExec.scala
org/apache/spark/sql/execution/UnsafeRowSerializer.scala
org/apache/spark/sql/execution/aggregate/AggregationIterator.scala
org/apache/spark/sql/execution/aggregate/HashMapGenerator.scala
org/apache/spark/sql/execution/aggregate/SortAggregateExec.scala
org/apache/spark/sql/execution/aggregate/HashAggregateExec.scala
org/apache/spark/sql/execution/aggregate/udaf.scala
org/apache/spark/sql/execution/aggregate/VectorizedHashMapGenerator.scala
org/apache/spark/sql/execution/aggregate/typedaggregators.scala
org/apache/spark/sql/execution/aggregate/AggUtils.scala
org/apache/spark/sql/execution/aggregate/SortBasedAggregationIterator.scala
org/apache/spark/sql/execution/aggregate/RowBasedHashMapGenerator.scala
org/apache/spark/sql/execution/aggregate/TungstenAggregationIterator.scala
org/apache/spark/sql/execution/aggregate/TypedAggregateExpression.scala
org/apache/spark/sql/execution/GenerateExec.scala
org/apache/spark/sql/execution/basicPhysicalOperators.scala
org/apache/spark/sql/execution/FileRelation.scala
org/apache/spark/sql/execution/datasources/HadoopFsRelation.scala
org/apache/spark/sql/execution/datasources/SQLHadoopMapReduceCommitProtocol.scala
org/apache/spark/sql/execution/datasources/DataSource.scala
org/apache/spark/sql/execution/datasources/json/InferSchema.scala
org/apache/spark/sql/execution/datasources/json/JsonFileFormat.scala
org/apache/spark/sql/execution/datasources/jdbc/JDBCRelation.scala
org/apache/spark/sql/execution/datasources/jdbc/DriverRegistry.scala
org/apache/spark/sql/execution/datasources/jdbc/JDBCRDD.scala
org/apache/spark/sql/execution/datasources/jdbc/JdbcUtils.scala
org/apache/spark/sql/execution/datasources/jdbc/DriverWrapper.scala
org/apache/spark/sql/execution/datasources/jdbc/JDBCOptions.scala
org/apache/spark/sql/execution/datasources/jdbc/JdbcRelationProvider.scala
org/apache/spark/sql/execution/datasources/parquet/ParquetFilters.scala
org/apache/spark/sql/execution/datasources/parquet/ParquetFileFormat.scala
org/apache/spark/sql/execution/datasources/parquet/ParquetOutputWriter.scala
org/apache/spark/sql/execution/datasources/parquet/ParquetRowConverter.scala
org/apache/spark/sql/execution/datasources/parquet/ParquetReadSupport.scala
org/apache/spark/sql/execution/datasources/parquet/ParquetSchemaConverter.scala
org/apache/spark/sql/execution/datasources/parquet/ParquetOptions.scala
org/apache/spark/sql/execution/datasources/parquet/ParquetWriteSupport.scala
org/apache/spark/sql/execution/datasources/parquet/ParquetRecordMaterializer.scala
org/apache/spark/sql/execution/datasources/BucketingUtils.scala
org/apache/spark/sql/execution/datasources/CatalogFileIndex.scala
org/apache/spark/sql/execution/datasources/RecordReaderIterator.scala
org/apache/spark/sql/execution/datasources/PartitioningAwareFileIndex.scala
org/apache/spark/sql/execution/datasources/FileScanRDD.scala
org/apache/spark/sql/execution/datasources/rules.scala
org/apache/spark/sql/execution/datasources/csv/CSVFileFormat.scala
org/apache/spark/sql/execution/datasources/csv/CSVOptions.scala
org/apache/spark/sql/execution/datasources/csv/CSVInferSchema.scala
org/apache/spark/sql/execution/datasources/csv/CSVParser.scala
org/apache/spark/sql/execution/datasources/csv/CSVRelation.scala
org/apache/spark/sql/execution/datasources/FileFormatWriter.scala
org/apache/spark/sql/execution/datasources/InsertIntoDataSourceCommand.scala
org/apache/spark/sql/execution/datasources/InsertIntoHadoopFsRelationCommand.scala
org/apache/spark/sql/execution/datasources/HadoopFileLinesReader.scala
org/apache/spark/sql/execution/datasources/ddl.scala
org/apache/spark/sql/execution/datasources/PartitioningUtils.scala
org/apache/spark/sql/execution/datasources/text/TextFileFormat.scala
org/apache/spark/sql/execution/datasources/FileStatusCache.scala
org/apache/spark/sql/execution/datasources/OutputWriter.scala
org/apache/spark/sql/execution/datasources/FileFormat.scala
org/apache/spark/sql/execution/datasources/FileIndex.scala
org/apache/spark/sql/execution/datasources/PruneFileSourcePartitions.scala
org/apache/spark/sql/execution/datasources/InMemoryFileIndex.scala
org/apache/spark/sql/execution/datasources/LogicalRelation.scala
org/apache/spark/sql/execution/datasources/DataSourceStrategy.scala
org/apache/spark/sql/execution/datasources/FileSourceStrategy.scala
org/apache/spark/sql/execution/RowIterator.scala
org/apache/spark/sql/execution/LocalTableScanExec.scala
org/apache/spark/sql/execution/debug/package.scala
org/apache/spark/sql/execution/SparkPlanner.scala
org/apache/spark/sql/execution/QueryExecutionException.scala
org/apache/spark/sql/execution/GroupedIterator.scala
org/apache/spark/sql/execution/metric/SQLMetricInfo.scala
org/apache/spark/sql/execution/metric/SQLMetrics.scala
org/apache/spark/sql/execution/r/MapPartitionsRWrapper.scala
org/apache/spark/sql/execution/CoGroupedIterator.scala
org/apache/spark/sql/execution/WholeStageCodegenExec.scala
org/apache/spark/sql/execution/limit.scala
org/apache/spark/sql/execution/stat/StatFunctions.scala
org/apache/spark/sql/execution/stat/FrequentItems.scala
org/apache/spark/sql/execution/DataSourceScanExec.scala
org/apache/spark/sql/execution/ExpandExec.scala
org/apache/spark/sql/execution/SparkSqlParser.scala
org/apache/spark/sql/execution/ui/SQLListener.scala
org/apache/spark/sql/execution/ui/SQLTab.scala
org/apache/spark/sql/execution/ui/AllExecutionsPage.scala
org/apache/spark/sql/execution/ui/ExecutionPage.scala
org/apache/spark/sql/execution/ui/SparkPlanGraph.scala
org/apache/spark/sql/execution/streaming/IncrementalExecution.scala
org/apache/spark/sql/execution/streaming/CompactibleFileStreamLog.scala
org/apache/spark/sql/execution/streaming/EventTimeWatermarkExec.scala
org/apache/spark/sql/execution/streaming/StatefulAggregate.scala
org/apache/spark/sql/execution/streaming/FileStreamOptions.scala
org/apache/spark/sql/execution/streaming/TriggerExecutor.scala
org/apache/spark/sql/execution/streaming/MetadataLog.scala
org/apache/spark/sql/execution/streaming/StreamingQueryListenerBus.scala
org/apache/spark/sql/execution/streaming/FileStreamSource.scala
org/apache/spark/sql/execution/streaming/ProgressReporter.scala
org/apache/spark/sql/execution/streaming/OffsetSeq.scala
org/apache/spark/sql/execution/streaming/Offset.scala
org/apache/spark/sql/execution/streaming/FileStreamSink.scala
org/apache/spark/sql/execution/streaming/StreamExecution.scala
org/apache/spark/sql/execution/streaming/HDFSMetadataLog.scala
org/apache/spark/sql/execution/streaming/socket.scala
org/apache/spark/sql/execution/streaming/FileStreamSinkLog.scala
org/apache/spark/sql/execution/streaming/console.scala
org/apache/spark/sql/execution/streaming/ForeachSink.scala
org/apache/spark/sql/execution/streaming/FileStreamSourceOffset.scala
org/apache/spark/sql/execution/streaming/StreamProgress.scala
org/apache/spark/sql/execution/streaming/state/StateStoreConf.scala
org/apache/spark/sql/execution/streaming/state/package.scala
org/apache/spark/sql/execution/streaming/state/StateStore.scala
org/apache/spark/sql/execution/streaming/state/HDFSBackedStateStoreProvider.scala
org/apache/spark/sql/execution/streaming/state/StateStoreRDD.scala
org/apache/spark/sql/execution/streaming/state/StateStoreCoordinator.scala
org/apache/spark/sql/execution/streaming/Sink.scala
org/apache/spark/sql/execution/streaming/MetricsReporter.scala
org/apache/spark/sql/execution/streaming/MetadataLogFileIndex.scala
org/apache/spark/sql/execution/streaming/memory.scala
org/apache/spark/sql/execution/streaming/StreamingRelation.scala
org/apache/spark/sql/execution/streaming/ManifestFileCommitProtocol.scala
org/apache/spark/sql/execution/streaming/OffsetSeqLog.scala
org/apache/spark/sql/execution/streaming/LongOffset.scala
org/apache/spark/sql/execution/streaming/StreamMetadata.scala
org/apache/spark/sql/execution/streaming/FileStreamSourceLog.scala
org/apache/spark/sql/execution/streaming/StreamingQueryWrapper.scala
org/apache/spark/sql/execution/streaming/Source.scala
org/apache/spark/sql/execution/window/AggregateProcessor.scala
org/apache/spark/sql/execution/window/RowBuffer.scala
org/apache/spark/sql/execution/window/BoundOrdering.scala
org/apache/spark/sql/execution/window/WindowFunctionFrame.scala
org/apache/spark/sql/execution/window/WindowExec.scala
org/apache/spark/sql/execution/python/PythonUDF.scala
org/apache/spark/sql/execution/python/ExtractPythonUDFs.scala
org/apache/spark/sql/execution/python/UserDefinedPythonFunction.scala
org/apache/spark/sql/execution/python/RowQueue.scala
org/apache/spark/sql/execution/python/EvaluatePython.scala
org/apache/spark/sql/execution/python/BatchEvalPythonExec.scala
org/apache/spark/sql/execution/joins/package.scala
org/apache/spark/sql/execution/joins/CartesianProductExec.scala
org/apache/spark/sql/execution/joins/HashedRelation.scala
org/apache/spark/sql/execution/joins/BroadcastNestedLoopJoinExec.scala
org/apache/spark/sql/execution/joins/SortMergeJoinExec.scala
org/apache/spark/sql/execution/joins/BroadcastHashJoinExec.scala
org/apache/spark/sql/execution/joins/HashJoin.scala
org/apache/spark/sql/execution/joins/ShuffledHashJoinExec.scala
org/apache/spark/sql/execution/OptimizeMetadataOnlyQuery.scala
org/apache/spark/sql/execution/SparkStrategies.scala
org/apache/spark/sql/execution/exchange/ShuffleExchange.scala
org/apache/spark/sql/execution/exchange/Exchange.scala
org/apache/spark/sql/execution/exchange/BroadcastExchangeExec.scala
org/apache/spark/sql/execution/exchange/EnsureRequirements.scala
org/apache/spark/sql/execution/exchange/ExchangeCoordinator.scala
org/apache/spark/sql/execution/ShuffledRowRDD.scala
org/apache/spark/sql/execution/subquery.scala
org/apache/spark/sql/execution/ExistingRDD.scala
org/apache/spark/sql/execution/command/databases.scala
org/apache/spark/sql/execution/command/AnalyzeTableCommand.scala
org/apache/spark/sql/execution/command/resources.scala
org/apache/spark/sql/execution/command/views.scala
org/apache/spark/sql/execution/command/AnalyzeColumnCommand.scala
org/apache/spark/sql/execution/command/commands.scala
org/apache/spark/sql/execution/command/ddl.scala
org/apache/spark/sql/execution/command/cache.scala
org/apache/spark/sql/execution/command/functions.scala
org/apache/spark/sql/execution/command/SetCommand.scala
org/apache/spark/sql/execution/command/tables.scala
org/apache/spark/sql/execution/command/createDataSourceTables.scala
org/apache/spark/sql/execution/SortPrefixUtils.scala
org/apache/spark/sql/execution/columnar/GenerateColumnAccessor.scala
org/apache/spark/sql/execution/columnar/ColumnBuilder.scala
org/apache/spark/sql/execution/columnar/ColumnType.scala
org/apache/spark/sql/execution/columnar/NullableColumnBuilder.scala
org/apache/spark/sql/execution/columnar/ColumnAccessor.scala
org/apache/spark/sql/execution/columnar/compression/CompressibleColumnBuilder.scala
org/apache/spark/sql/execution/columnar/compression/CompressionScheme.scala
org/apache/spark/sql/execution/columnar/compression/compressionSchemes.scala
org/apache/spark/sql/execution/columnar/compression/CompressibleColumnAccessor.scala
org/apache/spark/sql/execution/columnar/InMemoryTableScanExec.scala
org/apache/spark/sql/execution/columnar/ColumnStats.scala
org/apache/spark/sql/execution/columnar/NullableColumnAccessor.scala
org/apache/spark/sql/execution/columnar/InMemoryRelation.scala
org/apache/spark/sql/execution/QueryExecution.scala
org/apache/spark/sql/DataFrameStatFunctions.scala
org/apache/spark/sql/package.scala
org/apache/spark/sql/jdbc/OracleDialect.scala
org/apache/spark/sql/jdbc/MsSqlServerDialect.scala
org/apache/spark/sql/jdbc/PostgresDialect.scala
org/apache/spark/sql/jdbc/DerbyDialect.scala
org/apache/spark/sql/jdbc/MySQLDialect.scala
org/apache/spark/sql/jdbc/DB2Dialect.scala
org/apache/spark/sql/jdbc/AggregatedDialect.scala
org/apache/spark/sql/jdbc/JdbcDialects.scala
org/apache/spark/sql/DataFrameNaFunctions.scala
org/apache/spark/sql/catalyst/SQLBuilder.scala
org/apache/spark/sql/catalog/Catalog.scala
org/apache/spark/sql/catalog/interface.scala
org/apache/spark/sql/Dataset.scala
org/apache/spark/sql/api/package.scala
org/apache/spark/sql/api/r/SQLUtils.scala
org/apache/spark/sql/api/python/PythonSQLUtils.scala
org/apache/spark/sql/Column.scala
org/apache/spark/sql/RelationalGroupedDataset.scala
org/apache/spark/sql/RuntimeConfig.scala
org/apache/spark/sql/sources/package.scala
org/apache/spark/sql/sources/filters.scala
org/apache/spark/sql/sources/interfaces.scala
org/apache/spark/sql/test/README.md
org/apache/spark/sql/test/ExamplePointUDT.scala
org/apache/spark/sql/internal/package.scala
org/apache/spark/sql/internal/SessionState.scala
org/apache/spark/sql/internal/package-info.java
org/apache/spark/sql/internal/HiveSerDe.scala
org/apache/spark/sql/internal/VariableSubstitution.scala
org/apache/spark/sql/internal/CatalogImpl.scala
org/apache/spark/sql/internal/SharedState.scala
org/apache/spark/sql/DataFrameReader.scala
org/apache/spark/sql/DatasetHolder.scala
org/apache/spark/sql/DataFrameWriter.scala
#内容未全部加载,请点击展开加载全部代码(NowJava.com)
|