File tree
741 files changed
+18042
-13964
lines changed- .devcontainer/Sleeper
- .github
- config
- workflows
- .vscode
- code-style
- checkstyle-idea
- docs
- design
- development
- usage
- example/full
- java
- athena
- src
- main/java/sleeper/athena/record
- test/java/sleeper/athena
- metadata
- record
- build-uptime-lambda
- src/test/java/sleeper/build/uptime/lambda
- build
- src/test/java/sleeper/build/notices
- bulk-export
- bulk-export-core
- src
- main/java/sleeper/bulkexport/core
- model
- recordretrieval
- test/java/sleeper/bulkexport/core
- model
- recordretrieval
- bulk-export-runner
- bulk-export-starter
- bulk-import
- bulk-import-core
- bulk-import-eks
- bulk-import-runner
- src
- main/java/sleeper/bulkimport/runner
- test/java/sleeper/bulkimport/runner
- bulk-import-starter
- src
- main/java/sleeper/bulkimport/starter
- executor
- test/java/sleeper/bulkimport/starter
- executor
- cdk-custom-resources
- src/test/java/sleeper/cdk/custom
- cdk-environment
- cdk
- src
- main/java/sleeper/cdk
- stack
- compaction
- core
- ingest
- query
- test/java/sleeper/cdk
- jars
- testutils
- util
- clients
- src
- main/java/sleeper/clients
- admin
- deploy
- docker/stack
- status
- report
- compaction
- job
- task
- ingest
- job
- task
- job
- query
- partitions
- update
- test
- java/sleeper/clients
- admin
- testutils
- deploy
- docker
- status
- report
- compaction
- job
- task
- ingest
- job
- task
- job
- partitions
- update
- teardown
- testutil
- resources/reports
- compaction/job/json
- ingest/job
- json
- bulkImport
- standard
- all/bulkImport
- detailed/bulkImport
- common
- common-invoke-tables
- src/test/java/sleeper/invoke/tables
- common-job
- src/test/java/sleeper/job/common/action
- common-task
- src
- main/java/sleeper/task/common
- test/java/sleeper/task/common
- dynamodb-test
- src/main/java/sleeper/dynamodb/test
- dynamodb-tools
- localstack-test
- src
- main/java/sleeper/localstack/test
- test/java/sleeper/localstack/test
- compaction
- compaction-core
- src
- main/java/sleeper/compaction/core
- job
- commit
- creation
- task
- test/java/sleeper/compaction/core
- job
- commit
- creation
- task
- compaction-job-creation-lambda
- src
- main/java/sleeper/compaction/job/creation/lambda
- test/java/sleeper/compaction/job/creation/lambda
- compaction-job-creation
- src
- main/java/sleeper/compaction/job/creation
- test/java/sleeper/compaction/job/creation
- compaction-job-execution
- src
- main/java/sleeper/compaction/job/execution
- test/java/sleeper/compaction/job/execution
- testutils
- compaction-rust
- src
- main/java/sleeper/compaction/rust
- test/java/sleeper/compaction/rust
- compaction-task-creation
- compaction-tracker
- src
- main/java/sleeper/compaction/tracker
- job
- task
- test/java/sleeper/compaction/tracker
- job
- task
- testutils
- configuration
- src/test/java/sleeper/configuration
- jars
- properties
- table/index
- core
- src
- main/java/sleeper/core
- deploy
- iterator
- properties
- instance
- table
- validation
- range
- record/process/status
- statestore
- commit
- transactionlog
- transactions
- tracker
- compaction
- job
- query
- update
- task
- ingest
- job
- query
- update
- task
- job
- run
- status
- util
- test/java/sleeper/core
- iterator
- properties
- instance
- testutils
- record/process/status
- statestore
- commit
- testutils
- transactionlog
- transactions
- testutils
- tracker
- compaction
- job
- task
- ingest
- job
- task
- job
- run
- status
- distribution
- src/main/assembly
- example-iterators
- src
- main/java/sleeper/example/iterator
- test/java/sleeper/example/iterator
- garbage-collector
- src
- main/java/sleeper/garbagecollector
- test/java/sleeper/garbagecollector
- ingest
- ingest-batcher-core
- ingest-batcher-job-creator
- src/test/java/sleeper/ingest/batcher/job/creator
- ingest-batcher-store
- ingest-batcher-submitter
- src/test/java/sleeper/ingest/batcher/submitter
- ingest-core
- src
- main/java/sleeper/ingest/core
- job
- commit
- test/java/sleeper/ingest/core
- job
- commit
- status
- ingest-runner
- src
- main/java/sleeper/ingest/runner
- impl/commit
- task
- test/java/sleeper/ingest/runner
- impl
- commit
- task
- ingest-starter
- ingest-tracker
- src
- main/java/sleeper/ingest/tracker
- job
- task
- test/java/sleeper/ingest/tracker
- job
- task
- testutils
- metrics
- parquet
- src/main/java/sleeper/parquet/record
- query
- query-core
- src
- main/java/sleeper/query/core/recordretrieval
- test/java/sleeper/query/core/recordretrieval
- query-lambda
- src
- main/java/sleeper/query/lambda
- test/java/sleeper/query/lambda
- query-runner
- src
- main/java/sleeper/query/runner/recordretrieval
- test/java/sleeper/query/runner/recordretrieval
- sketches
- splitter
- splitter-core
- src
- main/java/sleeper/splitter/core/split
- test/java/sleeper/splitter/core/split
- splitter-lambda
- src
- main/java/sleeper/splitter/lambda
- test/java/sleeper/splitter/lambda
- statestore-committer-core
- src
- main/java/sleeper/statestore/committer
- test/java/sleeper/statestore/committer
- statestore-lambda
- src
- main/java/sleeper/statestore/lambda/committer
- test/java/sleeper/statestore/lambda/committer
- statestore
- src
- main/java/sleeper/statestore
- commit
- dynamodb
- s3
- transactionlog
- snapshots
- test/java/sleeper/statestore
- commit
- dynamodb
- s3
- transactionlog
- snapshots
- system-test
- system-test-cdk
- system-test-configuration
- system-test-data-generation
- src/main/java/sleeper/systemtest/datageneration
- system-test-drivers
- src
- main/java/sleeper/systemtest/drivers
- compaction
- ingest
- instance
- query
- statestore
- util
- test/java/sleeper/systemtest/drivers
- nightly
- statestore
- testutil
- system-test-dsl
- src
- main/java/sleeper/systemtest/dsl
- compaction
- ingest
- query
- reporting
- statestore
- util
- test/java/sleeper/systemtest/dsl
- testutil
- drivers
- util
- system-test-suite
- src
- main/java/sleeper/systemtest/suite/fixtures
- test/java/sleeper/systemtest/suite
- trino
- src
- main/java/sleeper/trino/remotesleeperconnection
- test/java/sleeper/trino
- testutils
- python
- src/sleeper
- rust
- compaction
- src
- datafusion
- readahead
- compactor
- src/bin
- rust_sketch
- src
- scripts
- build
- cli/environment
- templates
- test/nightly
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
741 files changed
+18042
-13964
lines changedLines changed: 1 addition & 0 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
48 | 48 |
| |
49 | 49 |
| |
50 | 50 |
| |
| 51 | + | |
51 | 52 |
| |
52 | 53 |
| |
53 | 54 |
| |
|
Lines changed: 4 additions & 2 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
28 | 28 |
| |
29 | 29 |
| |
30 | 30 |
| |
| 31 | + | |
31 | 32 |
| |
32 | 33 |
| |
33 | 34 |
| |
34 | 35 |
| |
35 | 36 |
| |
| 37 | + | |
36 | 38 |
| |
37 | 39 |
| |
38 | 40 |
| |
| |||
41 | 43 |
| |
42 | 44 |
| |
43 | 45 |
| |
44 |
| - | |
| 46 | + | |
45 | 47 |
| |
46 | 48 |
| |
47 | 49 |
| |
| |||
64 | 66 |
| |
65 | 67 |
| |
66 | 68 |
| |
67 |
| - | |
| 69 | + | |
68 | 70 |
| |
69 | 71 |
| |
70 | 72 |
| |
|
Lines changed: 8 additions & 6 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
22 | 22 |
| |
23 | 23 |
| |
24 | 24 |
| |
| 25 | + | |
25 | 26 |
| |
| 27 | + | |
26 | 28 |
| |
27 | 29 |
| |
28 | 30 |
| |
29 |
| - | |
30 | 31 |
| |
31 | 32 |
| |
32 | 33 |
| |
33 | 34 |
| |
34 |
| - | |
| 35 | + | |
35 | 36 |
| |
36 |
| - | |
| 37 | + | |
37 | 38 |
| |
38 |
| - | |
39 | 39 |
| |
40 | 40 |
| |
41 | 41 |
| |
42 | 42 |
| |
43 |
| - | |
| 43 | + | |
44 | 44 |
| |
45 | 45 |
| |
46 |
| - | |
47 | 46 |
| |
| 47 | + | |
48 | 48 |
| |
| 49 | + | |
49 | 50 |
| |
| 51 | + | |
50 | 52 |
| |
51 | 53 |
| |
52 | 54 |
| |
|
Lines changed: 11 additions & 8 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
10 | 10 |
| |
11 | 11 |
| |
12 | 12 |
| |
| 13 | + | |
13 | 14 |
| |
14 | 15 |
| |
15 | 16 |
| |
16 |
| - | |
17 |
| - | |
18 |
| - | |
19 |
| - | |
20 |
| - | |
21 |
| - | |
22 |
| - | |
23 |
| - | |
24 | 17 |
| |
25 | 18 |
| |
26 | 19 |
| |
27 | 20 |
| |
28 | 21 |
| |
29 | 22 |
| |
| 23 | + | |
| 24 | + | |
| 25 | + | |
| 26 | + | |
| 27 | + | |
| 28 | + | |
| 29 | + | |
| 30 | + | |
| 31 | + | |
| 32 | + | |
30 | 33 |
| |
31 | 34 |
| |
32 | 35 |
| |
|
Lines changed: 13 additions & 11 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
10 | 10 |
| |
11 | 11 |
| |
12 | 12 |
| |
| 13 | + | |
13 | 14 |
| |
14 | 15 |
| |
15 | 16 |
| |
16 | 17 |
| |
17 | 18 |
| |
18 | 19 |
| |
19 |
| - | |
| 20 | + | |
20 | 21 |
| |
21 | 22 |
| |
22 | 23 |
| |
23 |
| - | |
24 | 24 |
| |
| 25 | + | |
| 26 | + | |
| 27 | + | |
| 28 | + | |
25 | 29 |
| |
26 |
| - | |
27 | 30 |
| |
28 | 31 |
| |
29 |
| - | |
30 |
| - | |
| 32 | + | |
31 | 33 |
| |
| 34 | + | |
32 | 35 |
| |
33 |
| - | |
| 36 | + | |
34 | 37 |
| |
35 | 38 |
| |
36 |
| - | |
37 | 39 |
| |
38 |
| - | |
39 |
| - | |
40 |
| - | |
41 |
| - | |
| 40 | + | |
| 41 | + | |
| 42 | + | |
| 43 | + | |
42 | 44 |
| |
43 | 45 |
| |
44 | 46 |
| |
|
Lines changed: 9 additions & 7 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
9 | 9 |
| |
10 | 10 |
| |
11 | 11 |
| |
| 12 | + | |
12 | 13 |
| |
13 |
| - | |
| 14 | + | |
14 | 15 |
| |
15 | 16 |
| |
16 | 17 |
| |
17 | 18 |
| |
18 | 19 |
| |
19 |
| - | |
20 |
| - | |
21 | 20 |
| |
22 | 21 |
| |
23 | 22 |
| |
| 23 | + | |
24 | 24 |
| |
25 |
| - | |
26 |
| - | |
27 | 25 |
| |
28 |
| - | |
| 26 | + | |
29 | 27 |
| |
30 | 28 |
| |
31 |
| - | |
32 | 29 |
| |
| 30 | + | |
| 31 | + | |
| 32 | + | |
| 33 | + | |
| 34 | + | |
33 | 35 |
| |
34 | 36 |
| |
35 | 37 |
| |
|
Lines changed: 7 additions & 5 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
8 | 8 |
| |
9 | 9 |
| |
10 | 10 |
| |
11 |
| - | |
12 |
| - | |
13 | 11 |
| |
14 | 12 |
| |
15 | 13 |
| |
16 | 14 |
| |
| 15 | + | |
| 16 | + | |
17 | 17 |
| |
18 | 18 |
| |
| 19 | + | |
19 | 20 |
| |
20 |
| - | |
| 21 | + | |
21 | 22 |
| |
22 |
| - | |
23 |
| - | |
24 | 23 |
| |
25 | 24 |
| |
| 25 | + | |
26 | 26 |
| |
| 27 | + | |
27 | 28 |
| |
28 | 29 |
| |
| 30 | + | |
29 | 31 |
| |
30 | 32 |
| |
31 | 33 |
| |
|
Lines changed: 2 additions & 6 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
12 | 12 |
| |
13 | 13 |
| |
14 | 14 |
| |
15 |
| - | |
16 |
| - | |
17 |
| - | |
18 | 15 |
| |
19 |
| - | |
20 |
| - | |
21 | 16 |
| |
22 |
| - | |
23 | 17 |
| |
24 | 18 |
| |
| 19 | + | |
25 | 20 |
| |
| 21 | + | |
26 | 22 |
| |
27 | 23 |
| |
28 | 24 |
| |
|
Lines changed: 18 additions & 22 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
31 | 31 |
| |
32 | 32 |
| |
33 | 33 |
| |
34 |
| - | |
35 |
| - | |
36 |
| - | |
37 |
| - | |
38 |
| - | |
39 |
| - | |
40 |
| - | |
41 |
| - | |
42 |
| - | |
43 |
| - | |
44 |
| - | |
45 |
| - | |
46 |
| - | |
47 |
| - | |
48 |
| - | |
49 |
| - | |
50 |
| - | |
51 |
| - | |
52 |
| - | |
53 |
| - | |
54 |
| - | |
55 |
| - | |
| 34 | + | |
| 35 | + | |
| 36 | + | |
| 37 | + | |
| 38 | + | |
| 39 | + | |
| 40 | + | |
| 41 | + | |
| 42 | + | |
| 43 | + | |
| 44 | + | |
| 45 | + | |
| 46 | + | |
| 47 | + | |
| 48 | + | |
| 49 | + | |
| 50 | + | |
| 51 | + |
Lines changed: 1 addition & 0 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
31 | 31 |
| |
32 | 32 |
| |
33 | 33 |
| |
| 34 | + |
0 commit comments