Commit e8ed10e
authored
File tree
1,357 files changed
+4522
-269997
lines changed- .github/workflows
- connectors
- docs
- 0.2.0/delta-standalone/api/java
- io/delta/standalone
- actions
- data
- types
- 0.3.0/delta-standalone/api/java
- io/delta/standalone
- actions
- data
- exceptions
- expressions
- storage
- types
- util
- 0.4.0
- delta-flink/api/java
- io/delta/flink/sink
- delta-standalone/api/java
- io/delta/standalone
- actions
- data
- exceptions
- expressions
- storage
- types
- util
- 0.4.1
- delta-flink/api/java
- io/delta/flink/sink
- delta-standalone/api/java
- io/delta/standalone
- actions
- data
- exceptions
- expressions
- storage
- types
- util
- 0.5.0
- delta-flink/api/java
- io/delta/flink
- sink
- source
- delta-standalone/api/java
- io/delta/standalone
- actions
- data
- exceptions
- expressions
- types
- util
- 0.6.0
- delta-flink/api/java
- io/delta/flink
- sink
- source
- delta-standalone/api/java
- io/delta/standalone
- actions
- data
- exceptions
- expressions
- types
- util
- latest
- delta-flink/api/java
- io/delta/flink
- sink
- source
- delta-standalone/api/java
- io/delta/standalone
- actions
- data
- exceptions
- expressions
- types
- util
- examples
- build
- convert-to-delta
- src/main
- java/example
- resources
- external/sales
- flink-example
- src/main
- java/org
- example
- sink
- source
- bounded
- continuous
- sql
- insert
- select
- bounded
- continuous
- utils
- job
- bounded
- continuous
- sql
- resources
- assets/images
- data/source_table_no_partitions
- _delta_log
- hello-world
- src/main/java/example
- project
- oss-compatibility-tests/src/test/scala/io/delta/standalone/internal
- compatibility/tests
- util
- powerbi
- CustomConnector
- DeltaLake
- PowerBI_Delta.Dataset
- .pbi
- PowerBI_Delta.Report
- sql-delta-import
- src
- main/scala
- test/scala
- standalone-parquet/src/main
- java/io/delta/standalone/util
- scala/io/delta/standalone/internal/util
- standalone/src
- main
- java/io/delta/standalone
- actions
- data
- exceptions
- expressions
- internal/expressions
- types
- scala-2.11/io/delta/standalone/internal/util
- scala-2.12/io/delta/standalone/internal/util
- scala-2.13/io/delta/standalone/internal/util
- scala/io/delta/standalone/internal
- actions
- data
- exception
- logging
- scan
- sources
- storage
- util
- test
- resources
- scala/io/delta/standalone/internal
- util
- testParquetUtilsWithStandaloneCosmetic/src/test/scala/io/delta/standalone
- testStandaloneCosmetic/src/test/scala/io/delta/standalone/internal
- examples/scala
- iceberg/src/main/scala/org/apache/spark/sql/delta/icebergShaded
- kernel-spark/src
- main/java/io/delta/kernel/spark
- catalog
- read
- snapshot
- utils
- test/java/io/delta/kernel/spark
- catalog
- read
- utils
- kernel
- kernel-api/src
- main/java/io/delta/kernel
- internal
- checkpoints
- commitrange
- table
- test/scala/io/delta/kernel/internal
- kernel-defaults/src/test/scala/io/delta/kernel/defaults
- catalogManaged
- engine
- unitycatalog/src
- main/java/io/delta/kernel/unitycatalog
- test/scala/io/delta/kernel/unitycatalog
- project
- tests
- python/delta
- sharing/src
- main/scala/io/delta/sharing/spark
- test/scala/io/delta/sharing/spark
- spark-unified/src/test/scala/org/apache/spark/sql/delta
- spark/src
- main
- scala-spark-3.5/shims
- scala-spark-master/shims
- scala
- io/delta
- sql/parser
- tables
- execution
- org/apache/spark/sql/delta
- catalog
- commands
- merge
- constraints
- coordinatedcommits
- files
- logging
- metering
- perf
- schema
- serverSidePlanning
- sources
- stats
- streaming
- util
- threads
- test
- resources
- scala-spark-3.5
- org/apache/spark/sql/delta/logging
- shims
- scala-spark-master/shims
- logging
- scala
- io/delta/sql/parser
- org/apache/spark/sql/delta
- deletionvectors
- logging
- schema
- serverSidePlanning
- skipping/clustering
- stats
- test
- typewidening
- storage/src/main/java/io/delta/storage
- commit/uccommitcoordinator
- internal
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
1,357 files changed
+4522
-269997
lines changedThis file was deleted.
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | 1 | | |
2 | | - | |
| 2 | + | |
3 | 3 | | |
4 | 4 | | |
5 | 5 | | |
| |||
25 | 25 | | |
26 | 26 | | |
27 | 27 | | |
28 | | - | |
| 28 | + | |
29 | 29 | | |
30 | 30 | | |
31 | 31 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
37 | 37 | | |
38 | 38 | | |
39 | 39 | | |
| 40 | + | |
40 | 41 | | |
41 | 42 | | |
42 | 43 | | |
43 | 44 | | |
44 | | - | |
| 45 | + | |
45 | 46 | | |
46 | 47 | | |
47 | 48 | | |
| |||
59 | 60 | | |
60 | 61 | | |
61 | 62 | | |
62 | | - | |
| 63 | + | |
63 | 64 | | |
64 | 65 | | |
65 | 66 | | |
| |||
68 | 69 | | |
69 | 70 | | |
70 | 71 | | |
| 72 | + | |
71 | 73 | | |
72 | 74 | | |
73 | 75 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
22 | 22 | | |
23 | 23 | | |
24 | 24 | | |
25 | | - | |
| 25 | + | |
26 | 26 | | |
27 | 27 | | |
28 | 28 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
24 | 24 | | |
25 | 25 | | |
26 | 26 | | |
27 | | - | |
| 27 | + | |
28 | 28 | | |
29 | 29 | | |
30 | 30 | | |
| |||
This file was deleted.
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
25 | 25 | | |
26 | 26 | | |
27 | 27 | | |
28 | | - | |
| 28 | + | |
29 | 29 | | |
30 | 30 | | |
31 | 31 | | |
| |||
53 | 53 | | |
54 | 54 | | |
55 | 55 | | |
56 | | - | |
57 | | - | |
58 | | - | |
| 56 | + | |
| 57 | + | |
| 58 | + | |
59 | 59 | | |
60 | 60 | | |
61 | 61 | | |
62 | 62 | | |
63 | 63 | | |
64 | 64 | | |
65 | | - | |
66 | | - | |
67 | | - | |
68 | | - | |
69 | | - | |
| 65 | + | |
| 66 | + | |
| 67 | + | |
70 | 68 | | |
71 | | - | |
72 | | - | |
73 | 69 | | |
74 | 70 | | |
75 | 71 | | |
76 | 72 | | |
77 | 73 | | |
78 | 74 | | |
79 | 75 | | |
80 | | - | |
81 | | - | |
82 | | - | |
| 76 | + | |
| 77 | + | |
| 78 | + | |
| 79 | + | |
| 80 | + | |
| 81 | + | |
| 82 | + | |
| 83 | + | |
| 84 | + | |
| 85 | + | |
83 | 86 | | |
84 | 87 | | |
85 | 88 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
29 | 29 | | |
30 | 30 | | |
31 | 31 | | |
32 | | - | |
| 32 | + | |
33 | 33 | | |
34 | 34 | | |
35 | 35 | | |
| |||
57 | 57 | | |
58 | 58 | | |
59 | 59 | | |
60 | | - | |
61 | | - | |
62 | | - | |
| 60 | + | |
| 61 | + | |
| 62 | + | |
63 | 63 | | |
64 | 64 | | |
65 | 65 | | |
66 | 66 | | |
67 | 67 | | |
68 | 68 | | |
69 | | - | |
70 | | - | |
71 | | - | |
| 69 | + | |
| 70 | + | |
| 71 | + | |
72 | 72 | | |
73 | | - | |
| 73 | + | |
74 | 74 | | |
75 | 75 | | |
76 | 76 | | |
77 | 77 | | |
78 | 78 | | |
79 | 79 | | |
80 | | - | |
81 | | - | |
82 | | - | |
| 80 | + | |
| 81 | + | |
| 82 | + | |
| 83 | + | |
| 84 | + | |
| 85 | + | |
| 86 | + | |
| 87 | + | |
| 88 | + | |
| 89 | + | |
83 | 90 | | |
84 | 91 | | |
85 | 92 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
13 | 13 | | |
14 | 14 | | |
15 | 15 | | |
16 | | - | |
| 16 | + | |
17 | 17 | | |
18 | 18 | | |
19 | 19 | | |
0 commit comments