Commit f06534d
File tree
639 files changed
+21770
-6020
lines changed- .github/workflows
- common
- network-common/src
- main/java/org/apache/spark/network
- crypto
- util
- test/java/org/apache/spark/network/crypto
- unsafe/src
- main/java/org/apache/spark
- sql/catalyst/util
- unsafe/types
- test
- java/org/apache/spark/unsafe/types
- scala/org/apache/spark/unsafe/types
- utils/src
- main
- java/org/apache/spark
- internal
- network/util
- resources/error
- scala/org/apache/spark
- internal
- util
- test
- java/org/apache/spark/util
- scala/org/apache/spark/util
- connector
- avro/src/test/scala/org/apache/spark/sql/avro
- connect
- client/jvm/src
- main/scala/org/apache/spark/sql
- expressions
- streaming
- test/scala/org/apache/spark/sql
- connect/client
- common/src
- main
- protobuf/spark/connect
- scala/org/apache/spark/sql/connect
- client
- common/config
- test/resources/query-tests
- explain-results
- queries
- docs
- server/src
- main/scala/org/apache/spark/sql/connect
- config
- planner
- service
- utils
- test/scala/org/apache/spark/sql/connect
- planner
- service
- docker-integration-tests/src/test/scala/org/apache/spark/sql/jdbc/v2
- kafka-0-10-sql/src
- main
- resources/error
- scala/org/apache/spark/sql/kafka010
- consumer
- test/scala/org/apache/spark/sql/kafka010
- kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis
- core
- benchmarks
- src
- main
- java/org/apache/spark
- memory
- shuffle/sort/io
- resources/META-INF
- scala/org/apache/spark
- broadcast
- deploy
- history
- master/ui
- worker
- errors
- executor
- internal/config
- io
- rdd
- scheduler
- shuffle
- status/api/v1
- storage
- util
- test/scala/org/apache/spark
- deploy
- history
- internal/plugin
- io
- rdd
- scheduler
- shuffle/sort/io
- storage
- util
- dev
- create-release
- spark-rm
- deps
- sparktestsupport
- docs
- _data
- examples/src/main/python/sql
- hadoop-cloud/src/main/scala/org/apache/spark/internal/io/cloud
- launcher/src/main/java/org/apache/spark/launcher
- licenses-binary
- licenses
- mllib/src/main/scala/org/apache/spark/ml/classification
- project
- python
- docs/source
- getting_started
- migration_guide
- reference/pyspark.sql
- user_guide/sql
- pyspark
- errors
- exceptions
- pandas
- plot
- tests/connect
- plot
- sql
- classic
- connect
- client
- proto
- streaming
- functions
- pandas
- streaming
- tests
- connect
- pandas
- streaming
- typing
- worker
- testing
- test_support/sql/streaming/time
- resource-managers
- kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s
- yarn/src/main/scala/org/apache/spark
- deploy/yarn
- scheduler/cluster
- sql
- api/src/main
- antlr4/org/apache/spark/sql/catalyst/parser
- java/org/apache/spark/sql/types
- scala/org/apache/spark/sql
- catalyst
- trees
- util
- errors
- types
- util
- catalyst
- benchmarks
- src
- main
- java/org/apache/spark/sql/catalyst/expressions
- scala/org/apache/spark/sql
- catalyst
- analysis
- catalog
- csv
- encoders
- expressions
- aggregate
- codegen
- objects
- variant
- json
- optimizer
- parser
- plans
- logical
- physical
- trees
- util
- xml
- connector/catalog
- errors
- internal
- types
- test
- java/org/apache/spark/sql/catalyst/expressions
- scala/org/apache/spark/sql
- catalyst
- catalog
- csv
- encoders
- expressions
- variant
- xml
- optimizer
- parser
- plans
- trees
- util
- types
- core
- benchmarks
- src
- main/scala/org/apache/spark/sql
- execution
- adaptive
- columnar
- compression
- command
- datasources
- csv
- jdbc
- text
- v2
- jdbc
- python
- text
- xml
- python
- streaming
- continuous
- state
- expressions
- internal
- jdbc
- test
- resources
- collations
- sql-functions
- sql-tests
- analyzer-results
- ansi
- subquery/scalar-subquery
- typeCoercion/native
- udtf
- inputs
- subquery/scalar-subquery
- udtf
- results
- ansi
- subquery/scalar-subquery
- udtf
- scala/org/apache/spark/sql
- connector
- catalog/functions
- errors
- execution
- adaptive
- benchmark
- columnar
- compression
- command
- v1
- v2
- datasources
- csv
- json
- parquet
- v2
- jdbc
- xml
- python
- streaming/state
- expressions
- internal
- jdbc
- sources
- streaming
- hive-thriftserver/src
- main
- java/org/apache/hive/service/cli/operation
- scala/org/apache/spark/sql/hive/thriftserver
- test/scala/org/apache/spark/sql/hive/thriftserver
- hive/src
- main/scala/org/apache/spark/sql/hive/client
- test/scala/org/apache/spark/sql/hive
- execution
- command
- streaming/src/main/scala/org/apache/spark/streaming
- dstream
- rdd
- receiver
- scheduler
- rate
- util
- ui-test
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
639 files changed
+21770
-6020
lines changed| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
16 | 16 | | |
17 | 17 | | |
18 | 18 | | |
19 | | - | |
| 19 | + | |
20 | 20 | | |
21 | 21 | | |
22 | 22 | | |
| |||
25 | 25 | | |
26 | 26 | | |
27 | 27 | | |
28 | | - | |
| 28 | + | |
29 | 29 | | |
30 | 30 | | |
31 | 31 | | |
| |||
35 | 35 | | |
36 | 36 | | |
37 | 37 | | |
38 | | - | |
| 38 | + | |
39 | 39 | | |
40 | 40 | | |
41 | 41 | | |
| |||
50 | 50 | | |
51 | 51 | | |
52 | 52 | | |
53 | | - | |
| 53 | + | |
54 | 54 | | |
55 | 55 | | |
56 | | - | |
| 56 | + | |
57 | 57 | | |
58 | 58 | | |
59 | 59 | | |
| |||
79 | 79 | | |
80 | 80 | | |
81 | 81 | | |
82 | | - | |
| 82 | + | |
83 | 83 | | |
84 | 84 | | |
85 | 85 | | |
| |||
0 commit comments