ARROW-8229: [Java] Move ArrowBuf into the Arrow package

java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/BinaryConsumer.java

@@ -22,10 +22,10 @@
 import java.sql.ResultSet;
 import java.sql.SQLException;
 
+import org.apache.arrow.memory.ArrowBuf;
 import org.apache.arrow.vector.BitVectorHelper;
 import org.apache.arrow.vector.VarBinaryVector;
 
-import io.netty.buffer.ArrowBuf;
 import io.netty.util.internal.PlatformDependent;
 
 /**

java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/ClobConsumer.java

@@ -22,10 +22,10 @@
 import java.sql.ResultSet;
 import java.sql.SQLException;
 
+import org.apache.arrow.memory.ArrowBuf;
 import org.apache.arrow.vector.BitVectorHelper;
 import org.apache.arrow.vector.VarCharVector;
 
-import io.netty.buffer.ArrowBuf;
 import io.netty.util.internal.PlatformDependent;
 
 /**

java/adapter/jdbc/src/test/java/org/apache/arrow/adapter/jdbc/h2/JdbcToArrowArrayTest.java

@@ -36,6 +36,7 @@
 import org.apache.arrow.adapter.jdbc.JdbcToArrowConfig;
 import org.apache.arrow.adapter.jdbc.JdbcToArrowConfigBuilder;
 import org.apache.arrow.adapter.jdbc.JdbcToArrowUtils;
+import org.apache.arrow.memory.ArrowBuf;
 import org.apache.arrow.memory.RootAllocator;
 import org.apache.arrow.vector.Float4Vector;
 import org.apache.arrow.vector.IntVector;
@@ -46,8 +47,6 @@
 import org.junit.Before;
 import org.junit.Test;
 
-import io.netty.buffer.ArrowBuf;
-
 public class JdbcToArrowArrayTest {
   private Connection conn = null;
 

java/adapter/orc/src/main/java/org/apache/arrow/adapter/orc/OrcReferenceManager.java

@@ -19,13 +19,12 @@
 
 import java.util.concurrent.atomic.AtomicInteger;
 
+import org.apache.arrow.memory.ArrowBuf;
 import org.apache.arrow.memory.BufferAllocator;
 import org.apache.arrow.memory.OwnershipTransferResult;
 import org.apache.arrow.memory.ReferenceManager;
 import org.apache.arrow.util.Preconditions;
 
-import io.netty.buffer.ArrowBuf;
-
 /**
  * A simple reference manager implementation for memory allocated by native code.
  * The underlying memory will be released when reference count reach zero.

java/adapter/orc/src/main/java/org/apache/arrow/adapter/orc/OrcStripeReader.java

@@ -21,6 +21,7 @@
 import java.util.ArrayList;
 import java.util.stream.Collectors;
 
+import org.apache.arrow.memory.ArrowBuf;
 import org.apache.arrow.memory.BufferAllocator;
 import org.apache.arrow.vector.ipc.ArrowReader;
 import org.apache.arrow.vector.ipc.ReadChannel;
@@ -32,8 +33,6 @@
 import org.apache.arrow.vector.types.pojo.Schema;
 import org.apache.arrow.vector.util.ByteArrayReadableSeekableByteChannel;
 
-import io.netty.buffer.ArrowBuf;
-
 /**
  * Orc stripe that load data into ArrowRecordBatch.
  */

java/algorithm/src/main/java/org/apache/arrow/algorithm/deduplicate/DeduplicationUtils.java

@@ -17,6 +17,7 @@
 
 package org.apache.arrow.algorithm.deduplicate;
 
+import org.apache.arrow.memory.ArrowBuf;
 import org.apache.arrow.util.DataSizeRoundingUtil;
 import org.apache.arrow.util.Preconditions;
 import org.apache.arrow.vector.BitVectorHelper;
@@ -25,8 +26,6 @@
 import org.apache.arrow.vector.compare.Range;
 import org.apache.arrow.vector.compare.RangeEqualsVisitor;
 
-import io.netty.buffer.ArrowBuf;
-
 /**
  * Utilities for vector deduplication.
  */

java/algorithm/src/main/java/org/apache/arrow/algorithm/deduplicate/VectorRunDeduplicator.java

@@ -17,15 +17,14 @@
 
 package org.apache.arrow.algorithm.deduplicate;
 
+import org.apache.arrow.memory.ArrowBuf;
 import org.apache.arrow.memory.BufferAllocator;
 import org.apache.arrow.util.DataSizeRoundingUtil;
 import org.apache.arrow.util.Preconditions;
 import org.apache.arrow.vector.BitVectorHelper;
 import org.apache.arrow.vector.IntVector;
 import org.apache.arrow.vector.ValueVector;
 
-import io.netty.buffer.ArrowBuf;
-
 /**
  * Remove adjacent equal elements from a vector.
  * If the vector is sorted, it removes all duplicated values in the vector.

java/algorithm/src/main/java/org/apache/arrow/algorithm/sort/FixedWidthOutOfPlaceVectorSorter.java

@@ -17,11 +17,11 @@
 
 package org.apache.arrow.algorithm.sort;
 
+import org.apache.arrow.memory.ArrowBuf;
 import org.apache.arrow.vector.BaseFixedWidthVector;
 import org.apache.arrow.vector.BitVectorHelper;
 import org.apache.arrow.vector.IntVector;
 
-import io.netty.buffer.ArrowBuf;
 import io.netty.util.internal.PlatformDependent;
 
 /**

java/algorithm/src/main/java/org/apache/arrow/algorithm/sort/VariableWidthOutOfPlaceVectorSorter.java

@@ -17,11 +17,11 @@
 
 package org.apache.arrow.algorithm.sort;
 
+import org.apache.arrow.memory.ArrowBuf;
 import org.apache.arrow.vector.BaseVariableWidthVector;
 import org.apache.arrow.vector.BitVectorHelper;
 import org.apache.arrow.vector.IntVector;
 
-import io.netty.buffer.ArrowBuf;
 import io.netty.util.internal.PlatformDependent;
 
 /**

java/algorithm/src/test/java/org/apache/arrow/algorithm/deduplicate/TestDeduplicationUtils.java

@@ -20,6 +20,7 @@
 import static org.junit.Assert.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertArrayEquals;
 
+import org.apache.arrow.memory.ArrowBuf;
 import org.apache.arrow.memory.BufferAllocator;
 import org.apache.arrow.memory.RootAllocator;
 import org.apache.arrow.util.DataSizeRoundingUtil;
@@ -30,8 +31,6 @@
 import org.junit.Before;
 import org.junit.Test;
 
-import io.netty.buffer.ArrowBuf;
-
 /**
  * Test cases for {@link DeduplicationUtils}.
  */

java/flight/flight-core/src/main/java/org/apache/arrow/flight/ArrowMessage.java

@@ -31,6 +31,7 @@
 import org.apache.arrow.flight.grpc.GetReadableBuffer;
 import org.apache.arrow.flight.impl.Flight.FlightData;
 import org.apache.arrow.flight.impl.Flight.FlightDescriptor;
+import org.apache.arrow.memory.ArrowBuf;
 import org.apache.arrow.memory.BufferAllocator;
 import org.apache.arrow.util.AutoCloseables;
 import org.apache.arrow.util.Preconditions;
@@ -52,7 +53,6 @@
 import io.grpc.MethodDescriptor;
 import io.grpc.MethodDescriptor.Marshaller;
 import io.grpc.protobuf.ProtoUtils;
-import io.netty.buffer.ArrowBuf;
 import io.netty.buffer.ByteBuf;
 import io.netty.buffer.ByteBufInputStream;
 import io.netty.buffer.CompositeByteBuf;

java/flight/flight-core/src/main/java/org/apache/arrow/flight/FlightClient.java

@@ -38,6 +38,7 @@
 import org.apache.arrow.flight.impl.FlightServiceGrpc;
 import org.apache.arrow.flight.impl.FlightServiceGrpc.FlightServiceBlockingStub;
 import org.apache.arrow.flight.impl.FlightServiceGrpc.FlightServiceStub;
+import org.apache.arrow.memory.ArrowBuf;
 import org.apache.arrow.memory.BufferAllocator;
 import org.apache.arrow.util.Preconditions;
 import org.apache.arrow.vector.VectorSchemaRoot;
@@ -59,7 +60,6 @@
 import io.grpc.stub.ClientCalls;
 import io.grpc.stub.ClientResponseObserver;
 import io.grpc.stub.StreamObserver;
-import io.netty.buffer.ArrowBuf;
 import io.netty.channel.EventLoopGroup;
 import io.netty.channel.ServerChannel;
 import io.netty.handler.ssl.SslContextBuilder;

java/flight/flight-core/src/main/java/org/apache/arrow/flight/FlightProducer.java

@@ -19,11 +19,10 @@
 
 import java.util.Map;
 
+import org.apache.arrow.memory.ArrowBuf;
 import org.apache.arrow.vector.VectorSchemaRoot;
 import org.apache.arrow.vector.dictionary.DictionaryProvider;
 
-import io.netty.buffer.ArrowBuf;
-
 /**
  * API to Implement an Arrow Flight producer.
  */

java/flight/flight-core/src/main/java/org/apache/arrow/flight/FlightService.java

@@ -33,6 +33,7 @@
 import org.apache.arrow.flight.grpc.StatusUtils;
 import org.apache.arrow.flight.impl.Flight;
 import org.apache.arrow.flight.impl.FlightServiceGrpc.FlightServiceImplBase;
+import org.apache.arrow.memory.ArrowBuf;
 import org.apache.arrow.memory.BufferAllocator;
 import org.apache.arrow.util.Preconditions;
 import org.apache.arrow.vector.VectorSchemaRoot;
@@ -45,7 +46,6 @@
 import io.grpc.Status;
 import io.grpc.stub.ServerCallStreamObserver;
 import io.grpc.stub.StreamObserver;
-import io.netty.buffer.ArrowBuf;
 
 /**
  * GRPC service implementation for a flight server.

java/flight/flight-core/src/main/java/org/apache/arrow/flight/FlightStream.java

@@ -27,6 +27,7 @@
 
 import org.apache.arrow.flight.ArrowMessage.HeaderType;
 import org.apache.arrow.flight.grpc.StatusUtils;
+import org.apache.arrow.memory.ArrowBuf;
 import org.apache.arrow.memory.BufferAllocator;
 import org.apache.arrow.util.AutoCloseables;
 import org.apache.arrow.vector.FieldVector;
@@ -43,7 +44,6 @@
 import com.google.common.util.concurrent.SettableFuture;
 
 import io.grpc.stub.StreamObserver;
-import io.netty.buffer.ArrowBuf;
 
 /**
  * An adaptor between protobuf streams and flight data streams.

java/flight/flight-core/src/main/java/org/apache/arrow/flight/PutResult.java

@@ -18,13 +18,12 @@
 package org.apache.arrow.flight;
 
 import org.apache.arrow.flight.impl.Flight;
+import org.apache.arrow.memory.ArrowBuf;
 import org.apache.arrow.memory.BufferAllocator;
 import org.apache.arrow.memory.ReferenceManager;
 
 import com.google.protobuf.ByteString;
 
-import io.netty.buffer.ArrowBuf;
-
 /**
  * A message from the server during a DoPut operation.
  *

java/flight/flight-core/src/main/java/org/apache/arrow/flight/SyncPutListener.java

@@ -23,8 +23,7 @@
 import java.util.concurrent.TimeUnit;
 
 import org.apache.arrow.flight.grpc.StatusUtils;
-
-import io.netty.buffer.ArrowBuf;
+import org.apache.arrow.memory.ArrowBuf;
 
 /**
  * A listener for server-sent application metadata messages during a Flight DoPut. This class wraps the messages in a

java/flight/flight-core/src/main/java/org/apache/arrow/flight/example/Stream.java

@@ -25,6 +25,7 @@
 import java.util.function.Consumer;
 
 import org.apache.arrow.flight.FlightProducer.ServerStreamListener;
+import org.apache.arrow.memory.ArrowBuf;
 import org.apache.arrow.memory.BufferAllocator;
 import org.apache.arrow.util.AutoCloseables;
 import org.apache.arrow.vector.VectorLoader;
@@ -36,8 +37,6 @@
 import com.google.common.base.Throwables;
 import com.google.common.collect.ImmutableList;
 
-import io.netty.buffer.ArrowBuf;
-
 /**
  * A collection of Arrow record batches.
  */

java/flight/flight-core/src/main/java/org/apache/arrow/flight/example/integration/IntegrationTestClient.java

@@ -33,6 +33,7 @@
 import org.apache.arrow.flight.FlightStream;
 import org.apache.arrow.flight.Location;
 import org.apache.arrow.flight.PutResult;
+import org.apache.arrow.memory.ArrowBuf;
 import org.apache.arrow.memory.BufferAllocator;
 import org.apache.arrow.memory.RootAllocator;
 import org.apache.arrow.vector.VectorLoader;
@@ -48,8 +49,6 @@
 import org.apache.commons.cli.Options;
 import org.apache.commons.cli.ParseException;
 
-import io.netty.buffer.ArrowBuf;
-
 /**
  * An Example Flight Server that provides access to the InMemoryStore.
  */

java/flight/flight-core/src/main/java/org/apache/arrow/flight/grpc/GetReadableBuffer.java

@@ -21,11 +21,12 @@
 import java.io.InputStream;
 import java.lang.reflect.Field;
 
+import org.apache.arrow.memory.ArrowBuf;
+
 import com.google.common.base.Throwables;
 import com.google.common.io.ByteStreams;
 
 import io.grpc.internal.ReadableBuffer;
-import io.netty.buffer.ArrowBuf;
 
 /**
  * Enable access to ReadableBuffer directly to copy data from a BufferInputStream into a target

java/flight/flight-core/src/test/java/org/apache/arrow/flight/TestApplicationMetadata.java

@@ -24,6 +24,7 @@
 import java.util.function.BiConsumer;
 
 import org.apache.arrow.flight.FlightClient.PutListener;
+import org.apache.arrow.memory.ArrowBuf;
 import org.apache.arrow.memory.BufferAllocator;
 import org.apache.arrow.memory.RootAllocator;
 import org.apache.arrow.vector.IntVector;
@@ -35,8 +36,6 @@
 import org.junit.Ignore;
 import org.junit.Test;
 
-import io.netty.buffer.ArrowBuf;
-
 /**
  * Tests for application-specific metadata support in Flight.
  */

java/gandiva/src/main/java/org/apache/arrow/gandiva/evaluator/Filter.java

@@ -25,14 +25,13 @@
 import org.apache.arrow.gandiva.expression.ArrowTypeHelper;
 import org.apache.arrow.gandiva.expression.Condition;
 import org.apache.arrow.gandiva.ipc.GandivaTypes;
+import org.apache.arrow.memory.ArrowBuf;
 import org.apache.arrow.vector.ipc.message.ArrowBuffer;
 import org.apache.arrow.vector.ipc.message.ArrowRecordBatch;
 import org.apache.arrow.vector.types.pojo.Schema;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import io.netty.buffer.ArrowBuf;
-
 /**
  * This class provides a mechanism to filter a RecordBatch by evaluating a condition expression.
  * Follow these steps to use this class: 1) Use the static method make() to create an instance of

java/gandiva/src/main/java/org/apache/arrow/gandiva/evaluator/Projector.java

@@ -27,6 +27,7 @@
 import org.apache.arrow.gandiva.expression.ExpressionTree;
 import org.apache.arrow.gandiva.ipc.GandivaTypes;
 import org.apache.arrow.gandiva.ipc.GandivaTypes.SelectionVectorType;
+import org.apache.arrow.memory.ArrowBuf;
 import org.apache.arrow.vector.BaseVariableWidthVector;
 import org.apache.arrow.vector.FixedWidthVector;
 import org.apache.arrow.vector.ValueVector;
@@ -35,8 +36,6 @@
 import org.apache.arrow.vector.ipc.message.ArrowRecordBatch;
 import org.apache.arrow.vector.types.pojo.Schema;
 
-import io.netty.buffer.ArrowBuf;
-
 /**
  * This class provides a mechanism to evaluate a set of expressions against a RecordBatch.
  * Follow these steps to use this class:

java/gandiva/src/main/java/org/apache/arrow/gandiva/evaluator/SelectionVector.java

@@ -20,8 +20,7 @@
 import static org.apache.arrow.memory.util.LargeMemoryUtil.capAtMaxInt;
 
 import org.apache.arrow.gandiva.ipc.GandivaTypes.SelectionVectorType;
-
-import io.netty.buffer.ArrowBuf;
+import org.apache.arrow.memory.ArrowBuf;
 
 /**
  * A selection vector contains the indexes of "selected" records in a row batch. It is backed by an

java/gandiva/src/main/java/org/apache/arrow/gandiva/evaluator/SelectionVectorInt16.java

@@ -18,8 +18,7 @@
 package org.apache.arrow.gandiva.evaluator;
 
 import org.apache.arrow.gandiva.ipc.GandivaTypes.SelectionVectorType;
-
-import io.netty.buffer.ArrowBuf;
+import org.apache.arrow.memory.ArrowBuf;
 
 /**
  * Selection vector with records of arrow type INT16.

java/gandiva/src/main/java/org/apache/arrow/gandiva/evaluator/SelectionVectorInt32.java

@@ -18,8 +18,7 @@
 package org.apache.arrow.gandiva.evaluator;
 
 import org.apache.arrow.gandiva.ipc.GandivaTypes.SelectionVectorType;
-
-import io.netty.buffer.ArrowBuf;
+import org.apache.arrow.memory.ArrowBuf;
 
 /**
  * Selection vector with records of arrow type INT32.

java/gandiva/src/test/java/org/apache/arrow/gandiva/evaluator/BaseEvaluatorTest.java

@@ -27,6 +27,7 @@
 import org.apache.arrow.gandiva.exceptions.GandivaException;
 import org.apache.arrow.gandiva.expression.Condition;
 import org.apache.arrow.gandiva.expression.ExpressionTree;
+import org.apache.arrow.memory.ArrowBuf;
 import org.apache.arrow.memory.BufferAllocator;
 import org.apache.arrow.memory.RootAllocator;
 import org.apache.arrow.vector.DecimalVector;
@@ -41,8 +42,6 @@
 import org.junit.After;
 import org.junit.Before;
 
-import io.netty.buffer.ArrowBuf;
-
 class BaseEvaluatorTest {
 
   interface BaseEvaluator {