liyafan82 commented on a change in pull request #6323:
URL: https://github.com/apache/arrow/pull/6323#discussion_r415203665
##########
File path:
java/memory/src/main/java/org/apache/arrow/memory/NettyAllocationManager.java
##########
@@ -17,48 +17,97 @@
package org.apache.arrow.memory;
-import org.apache.arrow.memory.util.LargeMemoryUtil;
-
import io.netty.buffer.PooledByteBufAllocatorL;
import io.netty.buffer.UnsafeDirectLittleEndian;
+import io.netty.util.internal.PlatformDependent;
/**
- * The default implementation of AllocationManagerBase. The implementation is
responsible for managing when memory
+ * The default implementation of {@link AllocationManager}. The implementation
is responsible for managing when memory
* is allocated and returned to the Netty-based PooledByteBufAllocatorL.
*/
public class NettyAllocationManager extends AllocationManager {
public static final Factory FACTORY = new Factory();
+ /**
+ * The default cut-off value for switching allocation strategies.
+ * If the request size is not greater than the cut-off value, we will
allocate memory by
+ * {@link PooledByteBufAllocatorL} APIs,
+ * otherwise, we will use {@link PlatformDependent} APIs.
+ */
+ public static final long DEFAULT_ALLOCATION_CUTOFF_VALUE;
+
+ public static final String DEFAULT_ALLOCATION_CUTOFF_NAME =
"default.allocation.cutoff.name";
+
+ static {
+ long cutOffValue;
+ try {
+ cutOffValue =
Long.parseLong(System.getProperty(DEFAULT_ALLOCATION_CUTOFF_NAME));
+ } catch (Exception e) {
+ cutOffValue = Integer.MAX_VALUE;
+ }
+ DEFAULT_ALLOCATION_CUTOFF_VALUE = cutOffValue;
+ }
+
Review comment:
Removed. Thank you for the good suggestion.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
