You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by ja...@apache.org on 2023/06/07 23:48:23 UTC
[pinot] branch master updated (03c49e43b4 -> c704147d3e)
This is an automated email from the ASF dual-hosted git repository.
jackie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
from 03c49e43b4 [multistage] register opChain finish callback for pipeline breaker to continue (#10870)
add c704147d3e PinotBufferFactory and a buffer implementation that uses Unsafe (#10528)
No new revisions were added by this update.
Summary of changes:
.github/workflows/pinot_tests.yml | 60 ++-
.github/workflows/scripts/.pinot_quickstart.sh | 5 +-
.github/workflows/scripts/.pinot_test.sh | 18 +-
config/suppressions.xml | 3 +
.../scalar/ArrayAwareJacksonJsonProviderTest.java | 6 +-
.../pinot-segment-spi-jdk8/pom.xml | 8 +
.../MultiNodesOfflineClusterIntegrationTest.java | 10 +-
.../pinot/perf/BenchmarkPinotDataBuffer.java | 157 ++++---
.../rel/rules/PinotSortExchangeCopyRuleTest.java | 14 +-
.../forward/VarByteChunkSVForwardIndexTest.java | 19 +-
pinot-segment-spi/pom.xml | 8 +
.../pinot/segment/spi/memory/BasePinotLBuffer.java | 15 +-
.../spi/memory/ByteBufferPinotBufferFactory.java | 50 +++
.../pinot/segment/spi/memory/ByteBufferUtil.java | 117 ++++++
.../spi/memory/LArrayPinotBufferFactory.java | 29 +-
.../spi/memory/NonNativePinotDataBuffer.java | 253 ++++++++++++
.../segment/spi/memory/PinotBufferFactory.java | 76 ++++
.../pinot/segment/spi/memory/PinotDataBuffer.java | 349 +++++++++++++---
.../SmallWithFallbackPinotBufferFactory.java | 72 ++++
.../segment/spi/memory/unsafe/DirectMemory.java | 79 ++++
.../unsafe/Memory.java} | 50 ++-
.../segment/spi/memory/unsafe/MmapMemory.java | 377 +++++++++++++++++
.../spi/memory/unsafe/UnsafePinotBuffer.java | 184 +++++++++
.../memory/unsafe/UnsafePinotBufferFactory.java | 57 +++
.../pinot/segment/spi/memory/unsafe/Unsafer.java | 27 +-
.../pinot/segment/spi/utils/JavaVersion.java | 22 +-
.../segment/spi/memory/PinotByteBufferTest.java | 9 +-
.../memory/PinotDataBufferInstanceTestBase.java | 366 +++++++++++++++++
.../segment/spi/memory/PinotDataBufferTest.java | 449 ++++-----------------
.../spi/memory/PinotDataBufferTestBase.java | 115 ++++++
.../spi/memory/PinotDefaultByteBufferTest.java | 13 +-
.../spi/memory/PinotLArrayByteBufferTest.java | 24 +-
.../unsafe/UnsafeMemoryPinotDataBufferTest.java | 15 +-
.../server/starter/helix/BaseServerStarter.java | 3 +
.../src/main/resources/appAssemblerScriptTemplate | 32 ++
pom.xml | 70 +++-
36 files changed, 2501 insertions(+), 660 deletions(-)
create mode 100644 pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/memory/ByteBufferPinotBufferFactory.java
create mode 100644 pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/memory/ByteBufferUtil.java
copy pinot-common/src/main/java/org/apache/pinot/common/utils/log/DummyLogFileServer.java => pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/memory/LArrayPinotBufferFactory.java (54%)
create mode 100644 pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/memory/NonNativePinotDataBuffer.java
create mode 100644 pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/memory/PinotBufferFactory.java
create mode 100644 pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/memory/SmallWithFallbackPinotBufferFactory.java
create mode 100644 pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/memory/unsafe/DirectMemory.java
copy pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/{index/creator/JsonIndexCreator.java => memory/unsafe/Memory.java} (52%)
create mode 100644 pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/memory/unsafe/MmapMemory.java
create mode 100644 pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/memory/unsafe/UnsafePinotBuffer.java
create mode 100644 pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/memory/unsafe/UnsafePinotBufferFactory.java
copy pinot-segment-local/src/main/java/org/apache/pinot/segment/local/utils/SegmentLocks.java => pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/memory/unsafe/Unsafer.java (58%)
copy pinot-segment-local/src/main/java/org/apache/pinot/segment/local/startree/v2/builder/SingleTreeBuilder.java => pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/utils/JavaVersion.java (73%)
copy pinot-common/src/main/java/org/apache/pinot/common/exception/SchemaBackwardIncompatibleException.java => pinot-segment-spi/src/test/java/org/apache/pinot/segment/spi/memory/PinotByteBufferTest.java (80%)
create mode 100644 pinot-segment-spi/src/test/java/org/apache/pinot/segment/spi/memory/PinotDataBufferInstanceTestBase.java
create mode 100644 pinot-segment-spi/src/test/java/org/apache/pinot/segment/spi/memory/PinotDataBufferTestBase.java
copy pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/HLCRealtimeClusterIntegrationTest.java => pinot-segment-spi/src/test/java/org/apache/pinot/segment/spi/memory/PinotDefaultByteBufferTest.java (76%)
copy pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/HLCRealtimeClusterIntegrationTest.java => pinot-segment-spi/src/test/java/org/apache/pinot/segment/spi/memory/PinotLArrayByteBufferTest.java (59%)
copy pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/HLCRealtimeClusterIntegrationTest.java => pinot-segment-spi/src/test/java/org/apache/pinot/segment/spi/memory/unsafe/UnsafeMemoryPinotDataBufferTest.java (71%)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org