diff --git a/java/flight/src/main/java/org/apache/arrow/flight/FlightClient.java b/java/flight/src/main/java/org/apache/arrow/flight/FlightClient.java index bd126b5ea203..78005b61cc64 100644 --- a/java/flight/src/main/java/org/apache/arrow/flight/FlightClient.java +++ b/java/flight/src/main/java/org/apache/arrow/flight/FlightClient.java @@ -80,7 +80,7 @@ public FlightClient(BufferAllocator incomingAllocator, Location location) { /** * Get a list of available flights. - * @param criteria Critera for selecting flights + * @param criteria Criteria for selecting flights * @return FlightInfo Iterable */ public Iterable listFlights(Criteria criteria) { diff --git a/java/flight/src/main/java/org/apache/arrow/flight/FlightProducer.java b/java/flight/src/main/java/org/apache/arrow/flight/FlightProducer.java index fc320f54ba24..f2415f24a134 100644 --- a/java/flight/src/main/java/org/apache/arrow/flight/FlightProducer.java +++ b/java/flight/src/main/java/org/apache/arrow/flight/FlightProducer.java @@ -23,7 +23,7 @@ import org.apache.arrow.vector.VectorSchemaRoot; /** - * API to Implement an Arrow Flight server. + * API to Implement an Arrow Flight producer. */ public interface FlightProducer { diff --git a/java/flight/src/main/java/org/apache/arrow/flight/example/FlightHolder.java b/java/flight/src/main/java/org/apache/arrow/flight/example/FlightHolder.java index fff6ab338924..de4d94e66e1d 100644 --- a/java/flight/src/main/java/org/apache/arrow/flight/example/FlightHolder.java +++ b/java/flight/src/main/java/org/apache/arrow/flight/example/FlightHolder.java @@ -56,7 +56,7 @@ public Stream getStream(ExampleTicket ticket) { } public Stream.StreamCreator addStream(Schema schema) { - Preconditions.checkArgument(schema.equals(schema), "Stream schema inconsitent with existing schema."); + Preconditions.checkArgument(schema.equals(schema), "Stream schema inconsistent with existing schema."); return new Stream.StreamCreator(schema, allocator, t -> { synchronized (streams) { streams.add(t); diff --git a/java/flight/src/main/java/org/apache/arrow/flight/example/InMemoryStore.java b/java/flight/src/main/java/org/apache/arrow/flight/example/InMemoryStore.java index dd06f7947906..c95ee9509abb 100644 --- a/java/flight/src/main/java/org/apache/arrow/flight/example/InMemoryStore.java +++ b/java/flight/src/main/java/org/apache/arrow/flight/example/InMemoryStore.java @@ -143,7 +143,7 @@ public Result doAction(Action action) { @Override public void listActions(StreamListener listener) { listener.onNext(new ActionType("get", "pull a stream. Action must be done via standard get mechanism")); - listener.onNext(new ActionType("put", "push a stream. Action must be done via standard get mechanism")); + listener.onNext(new ActionType("put", "push a stream. Action must be done via standard put mechanism")); listener.onNext(new ActionType("drop", "delete a flight. Action body is a JSON encoded path.")); listener.onCompleted(); } diff --git a/java/flight/src/main/java/org/apache/arrow/flight/grpc/AddWritableBuffer.java b/java/flight/src/main/java/org/apache/arrow/flight/grpc/AddWritableBuffer.java index 80158d7babce..07b19c273800 100644 --- a/java/flight/src/main/java/org/apache/arrow/flight/grpc/AddWritableBuffer.java +++ b/java/flight/src/main/java/org/apache/arrow/flight/grpc/AddWritableBuffer.java @@ -30,7 +30,7 @@ /** * Allow a user to add a ByteBuf based InputStream directly into GRPC WritableBuffer to avoid an * extra copy. This could be solved in GRPC by adding a ByteBufListable interface on InputStream and - * letting BufferChainOutputStream take adavantage of it. + * letting BufferChainOutputStream take advantage of it. */ public class AddWritableBuffer { diff --git a/java/flight/src/test/java/org/apache/arrow/flight/perf/PerformanceTestServer.java b/java/flight/src/test/java/org/apache/arrow/flight/perf/PerformanceTestServer.java index 6bd83ae924b7..fe631474d535 100644 --- a/java/flight/src/test/java/org/apache/arrow/flight/perf/PerformanceTestServer.java +++ b/java/flight/src/test/java/org/apache/arrow/flight/perf/PerformanceTestServer.java @@ -36,7 +36,6 @@ import org.apache.arrow.flight.Result; import org.apache.arrow.flight.Ticket; import org.apache.arrow.flight.auth.ServerAuthHandler; -import org.apache.arrow.flight.example.ExampleFlightServer; import org.apache.arrow.flight.impl.Flight.PutResult; import org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf; import org.apache.arrow.flight.perf.impl.PerfOuterClass.Token; @@ -54,7 +53,7 @@ public class PerformanceTestServer implements AutoCloseable { - private static final org.slf4j.Logger logger = org.slf4j.LoggerFactory.getLogger(ExampleFlightServer.class); + private static final org.slf4j.Logger logger = org.slf4j.LoggerFactory.getLogger(PerformanceTestServer.class); private final FlightServer flightServer; private final Location location;