[Native] Advance Velox

prestodb · Feb 21, 2024 · 36575b0 · 36575b0
1 parent 3f42047
commit 36575b0
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/presto-native-execution/presto_cpp/main/TaskManager.cpp b/presto-native-execution/presto_cpp/main/TaskManager.cpp
@@ -117,7 +117,8 @@ void getData(
       token,
       [taskId = taskId, bufferId = destination, promiseHolder, startMs](
           std::vector<std::unique_ptr<folly::IOBuf>> pages,
-          int64_t sequence) mutable {
+          int64_t sequence,
+          std::vector<int64_t> /*remainingBytes*/) mutable {
         bool complete = pages.empty();
         int64_t nextSequence = sequence;
         std::unique_ptr<folly::IOBuf> iobuf;

diff --git a/presto-native-execution/velox b/presto-native-execution/velox
+0 −36		.circleci/dist_compile.yml
+18 −4		.github/workflows/macos.yml
+75 −0		.github/workflows/preliminary_checks.yml
+1 −1		velox/common/caching/AsyncDataCache.cpp
+0 −2		velox/common/memory/MmapArena.cpp
+4 −0		velox/connectors/hive/HiveConfig.cpp
+5 −0		velox/connectors/hive/HiveConfig.h
+1 −1		velox/connectors/hive/HiveConnector.cpp
+14 −0		velox/connectors/hive/storage_adapters/s3fs/S3FileSystem.cpp
+97 −0		velox/connectors/hive/storage_adapters/s3fs/S3Util.cpp
+26 −0		velox/connectors/hive/storage_adapters/s3fs/S3Util.h
+3 −0		velox/connectors/hive/storage_adapters/s3fs/tests/S3FileSystemTest.cpp
+136 −0		velox/connectors/hive/storage_adapters/s3fs/tests/S3UtilTest.cpp
+24 −1		velox/docs/develop/connectors.rst
+0 −1		velox/dwio/common/BitPackDecoder.cpp
+1 −1		velox/dwio/common/Reader.h
+2 −1		velox/dwio/common/ReaderFactory.cpp
+1 −1		velox/dwio/common/WriterFactory.cpp
+1 −1		velox/dwio/parquet/writer/arrow/util/CompressionZstd.cpp
+0 −2		velox/exec/ContainerRowSerde.cpp
+13 −1		velox/exec/ExchangeSource.h
+73 −10		velox/exec/OutputBuffer.cpp
+32 −4		velox/exec/OutputBuffer.h
+25 −0		velox/exec/OutputBufferManager.h
+2 −2		velox/exec/Spiller.cpp
+10 −3		velox/exec/Task.cpp
+2 −1		velox/exec/tests/LimitTest.cpp
+3 −2		velox/exec/tests/MultiFragmentTest.cpp
+130 −17		velox/exec/tests/OutputBufferManagerTest.cpp
+9 −7		velox/exec/tests/utils/LocalExchangeSource.cpp
+1 −1		velox/exec/tests/utils/TempDirectoryPath.cpp
+2 −0		velox/experimental/codegen/ast/ASTNode.h
+0 −2		velox/expression/CastExpr-inl.h
+0 −1		velox/expression/ComplexWriterTypes.h
+3 −3		velox/expression/Expr.cpp
+1 −1		velox/expression/PeeledEncoding.h
+1 −1		velox/expression/signature_parser/Scanner.h
+3 −3		velox/functions/lib/SubscriptUtil.cpp
+0 −3		velox/functions/lib/aggregates/DecimalAggregate.h
+2 −2		velox/functions/prestosql/FindFirst.cpp
+23 −0		velox/functions/prestosql/window/tests/AggregateWindowTest.cpp
+2 −0		velox/functions/prestosql/window/tests/NthValueTest.cpp
+1 −4		velox/tpch/gen/dbgen/text.cpp
+1 −1		velox/type/Subfield.cpp
+1 −1		velox/type/TimestampConversion.cpp
+4 −8		velox/type/Type.cpp
+1 −1		velox/vector/DecodedVector.cpp