This is an automated email from the ASF dual-hosted git repository.
mhubail pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/asterixdb.git
from 0f41f171d2 [NO ISSUE][*DB] Refactoring AssignRuntime Factory
new f30653bcb1 [ASTERIXDB-3368][EXT] Abort S3 streams before closing
new a89fb40334 Merge branch 'gerrit/neo' into 'gerrit/trinity'
new d904a246a7 [ASTERIXDB-3362][MISC] Update formatter language versions
new e76b460b35 [ASTERIXDB-3343][API] Add servlet to get completed requests
new f805cfc4c6 [ASTERIXDB-3343][API] Include job details in
active/completed requests
new 19cf53341e [ASTERIXDB-3369][FUN] Implement SQL median()
new 40cfb8705b [ASTERIXDB-3369][FUN] Add tests for SQL median()
new ed4bd17f06 [ASTERIXDB-3388][DOC]: Add ARRAY_MEDIAN() Function
new 8b076b8f72 Merge branch 'gerrit/neo' into 'gerrit/trinity'
new 83b614a85a [NO ISSUE][HYR] Fix LSMBTreeMergeFailTest on Java 17
new 61524a6711 [NO ISSUE][OTH] Change mvn Java ver. to 17
new 8ffe8eedca [ASTERIXDB-3396][CONF] Tweak memory, '-add-opens' flags
new 8b6b3be27f Merge branch 'gerrit/trinity' into 'master'
The 13 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../apache/asterix/translator/ClientRequest.java | 5 +-
.../SqlppExpressionToPlanTranslator.java | 12 +-
asterixdb/asterix-app/pom.xml | 1 +
.../apache/asterix/api/common/APIFramework.java | 2 +-
.../app/resource/OperatorResourcesComputer.java | 71 +++-
.../org/apache/asterix/utils/ResourceUtils.java | 25 +-
.../app/resource/PlanStagesGeneratorTest.java | 2 +-
.../asterix/runtime/PartitionManagerTest.java | 2 +-
.../aggregate-sql/median/median.01.ddl.sqlpp | 17 +-
.../aggregate-sql/median/median.02.update.sqlpp | 34 +-
.../aggregate-sql/median/median.03.query.sqlpp | 10 +-
.../aggregate-sql/median/median.04.query.sqlpp | 10 +-
.../aggregate-sql/median/median.05.query.sqlpp | 11 +-
.../aggregate-sql/median/median.06.query.sqlpp | 11 +-
.../aggregate-sql/median/median.07.query.sqlpp | 11 +-
.../aggregate-sql/median/median.08.query.sqlpp | 11 +-
.../aggregate-sql/median/median.09.query.sqlpp | 11 +-
.../aggregate-sql/median/median.10.query.sqlpp | 13 +-
.../aggregate-sql/median/median.11.query.sqlpp | 13 +-
.../median/median.99.ddl.sqlpp} | 0
.../results/aggregate-sql/median/median.03.adm | 1 +
.../results/aggregate-sql/median/median.04.adm | 1 +
.../results/aggregate-sql/median/median.05.adm | 1 +
.../results/aggregate-sql/median/median.06.adm | 1 +
.../results/aggregate-sql/median/median.07.adm | 1 +
.../results/aggregate-sql/median/median.08.adm | 1 +
.../results/aggregate-sql/median/median.09.adm | 1 +
.../results/aggregate-sql/median/median.10.adm | 15 +
.../results/aggregate-sql/median/median.11.adm | 1 +
.../asterix/common/config/CompilerProperties.java | 5 +
.../common/config/OptimizationConfUtil.java | 2 +-
.../src/main/markdown/builtins/9_aggregate_sql.md | 91 +++--
.../asterix-doc/src/main/markdown/sqlpp/3_query.md | 13 +-
.../src/main/markdown/sqlpp/4_windowfunctions.md | 4 +-
.../input/record/reader/aws/AwsS3InputStream.java | 8 +-
.../asterix/om/functions/BuiltinFunctions.java | 47 +++
.../typecomputer/impl/LocalMedianTypeComputer.java | 44 +++
.../test/om/typecomputer/TypeComputerTest.java | 2 +
.../scalar/ScalarSqlMedianAggregateDescriptor.java | 60 ++++
.../std/AbstractLocalMedianAggregateFunction.java | 176 ++++++++++
.../std/AbstractMedianAggregateFunction.java | 380 +++++++++++++++++++++
.../std/GlobalSqlMedianAggregateDescriptor.java | 54 +++
.../std/GlobalSqlMedianAggregateFunction.java | 51 +++
.../IntermediateSqlMedianAggregateDescriptor.java | 54 +++
.../IntermediateSqlMedianAggregateFunction.java | 50 +++
.../std/LocalSqlMedianAggregateDescriptor.java | 75 ++++
.../std/LocalSqlMedianAggregateFunction.java | 50 +++
.../std/SqlMedianAggregateDescriptor.java | 77 +++++
.../aggregates/std/SqlMedianAggregateFunction.java | 85 +++++
.../runtime/functions/FunctionCollection.java | 10 +
.../runtime/functions/FunctionTypeInferers.java | 3 +
asterixdb/pom.xml | 1 +
.../hyracks/api/context/IHyracksJobletContext.java | 2 +
...utChannel.java => FileNetworkInputChannel.java} | 57 ++--
.../hyracks/comm/channels/NetworkInputChannel.java | 4 +-
.../java/org/apache/hyracks/control/nc/Joblet.java | 7 +
.../hyracks/control/nc/net/NetworkManager.java | 45 ++-
.../control/nc/partitions/JobFileState.java | 92 +++++
.../nc/partitions/MaterializedPartition.java | 43 +--
.../control/nc/partitions/PartitionFileReader.java | 91 +++++
.../nc/partitions/PartitionFileReaderUtil.java | 58 ++++
.../control/nc/partitions/PartitionManager.java | 23 ++
.../hyracks/control/nc/service/NCService.java | 17 +-
.../hyracks/control/nc/service/NCServiceTest.java | 4 +-
.../hyracks/dataflow/common/io/RunFileReader.java | 4 +
.../storage/common/buffercache/IRateLimiter.java | 2 +-
.../common/buffercache/NoOpRateLimiter.java | 2 +-
.../common/buffercache/SleepRateLimiter.java | 5 +-
.../hyracks/test/support/TestJobletContext.java | 7 +
.../am/lsm/btree/LSMBTreeMergeFailTest.java | 4 -
.../lsm/btree/LSMBTreePageWriteCallbackTest.java | 4 +-
.../storage/am/lsm/btree/impl/TestLsmBtree.java | 16 +-
hyracks-fullstack/pom.xml | 3 +-
73 files changed, 1868 insertions(+), 259 deletions(-)
copy
hyracks-fullstack/hyracks/hyracks-storage-common/src/main/java/org/apache/hyracks/storage/common/buffercache/IRateLimiter.java
=>
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/aggregate-sql/median/median.01.ddl.sqlpp
(69%)
copy
hyracks-fullstack/hyracks/hyracks-storage-common/src/main/java/org/apache/hyracks/storage/common/buffercache/NoOpRateLimiter.java
=>
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/aggregate-sql/median/median.02.update.sqlpp
(61%)
copy
hyracks-fullstack/hyracks/hyracks-storage-common/src/main/java/org/apache/hyracks/storage/common/buffercache/IRateLimiter.java
=>
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/aggregate-sql/median/median.03.query.sqlpp
(76%)
copy
hyracks-fullstack/hyracks/hyracks-storage-common/src/main/java/org/apache/hyracks/storage/common/buffercache/IRateLimiter.java
=>
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/aggregate-sql/median/median.04.query.sqlpp
(76%)
copy
hyracks-fullstack/hyracks/hyracks-storage-common/src/main/java/org/apache/hyracks/storage/common/buffercache/IRateLimiter.java
=>
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/aggregate-sql/median/median.05.query.sqlpp
(76%)
copy
hyracks-fullstack/hyracks/hyracks-storage-common/src/main/java/org/apache/hyracks/storage/common/buffercache/IRateLimiter.java
=>
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/aggregate-sql/median/median.06.query.sqlpp
(76%)
copy
hyracks-fullstack/hyracks/hyracks-storage-common/src/main/java/org/apache/hyracks/storage/common/buffercache/IRateLimiter.java
=>
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/aggregate-sql/median/median.07.query.sqlpp
(76%)
copy
hyracks-fullstack/hyracks/hyracks-storage-common/src/main/java/org/apache/hyracks/storage/common/buffercache/IRateLimiter.java
=>
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/aggregate-sql/median/median.08.query.sqlpp
(76%)
copy
hyracks-fullstack/hyracks/hyracks-storage-common/src/main/java/org/apache/hyracks/storage/common/buffercache/IRateLimiter.java
=>
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/aggregate-sql/median/median.09.query.sqlpp
(76%)
copy
hyracks-fullstack/hyracks/hyracks-storage-common/src/main/java/org/apache/hyracks/storage/common/buffercache/IRateLimiter.java
=>
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/aggregate-sql/median/median.10.query.sqlpp
(76%)
copy
hyracks-fullstack/hyracks/hyracks-storage-common/src/main/java/org/apache/hyracks/storage/common/buffercache/IRateLimiter.java
=>
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/aggregate-sql/median/median.11.query.sqlpp
(76%)
copy
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/{ddl/analyze-dataset-with-indexes/analyze-dataset-with-indexes.99.ddl.sqlpp
=> aggregate-sql/median/median.99.ddl.sqlpp} (100%)
create mode 100644
asterixdb/asterix-app/src/test/resources/runtimets/results/aggregate-sql/median/median.03.adm
create mode 100644
asterixdb/asterix-app/src/test/resources/runtimets/results/aggregate-sql/median/median.04.adm
create mode 100644
asterixdb/asterix-app/src/test/resources/runtimets/results/aggregate-sql/median/median.05.adm
create mode 100644
asterixdb/asterix-app/src/test/resources/runtimets/results/aggregate-sql/median/median.06.adm
create mode 100644
asterixdb/asterix-app/src/test/resources/runtimets/results/aggregate-sql/median/median.07.adm
create mode 100644
asterixdb/asterix-app/src/test/resources/runtimets/results/aggregate-sql/median/median.08.adm
create mode 100644
asterixdb/asterix-app/src/test/resources/runtimets/results/aggregate-sql/median/median.09.adm
create mode 100644
asterixdb/asterix-app/src/test/resources/runtimets/results/aggregate-sql/median/median.10.adm
create mode 100644
asterixdb/asterix-app/src/test/resources/runtimets/results/aggregate-sql/median/median.11.adm
create mode 100644
asterixdb/asterix-om/src/main/java/org/apache/asterix/om/typecomputer/impl/LocalMedianTypeComputer.java
create mode 100644
asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/scalar/ScalarSqlMedianAggregateDescriptor.java
create mode 100644
asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/std/AbstractLocalMedianAggregateFunction.java
create mode 100644
asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/std/AbstractMedianAggregateFunction.java
create mode 100644
asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/std/GlobalSqlMedianAggregateDescriptor.java
create mode 100644
asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/std/GlobalSqlMedianAggregateFunction.java
create mode 100644
asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/std/IntermediateSqlMedianAggregateDescriptor.java
create mode 100644
asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/std/IntermediateSqlMedianAggregateFunction.java
create mode 100644
asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/std/LocalSqlMedianAggregateDescriptor.java
create mode 100644
asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/std/LocalSqlMedianAggregateFunction.java
create mode 100644
asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/std/SqlMedianAggregateDescriptor.java
create mode 100644
asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/std/SqlMedianAggregateFunction.java
copy
hyracks-fullstack/hyracks/hyracks-comm/src/main/java/org/apache/hyracks/comm/channels/{NetworkInputChannel.java
=> FileNetworkInputChannel.java} (70%)
create mode 100644
hyracks-fullstack/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/partitions/JobFileState.java
create mode 100644
hyracks-fullstack/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/partitions/PartitionFileReader.java
create mode 100644
hyracks-fullstack/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/partitions/PartitionFileReaderUtil.java
