Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -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<FlightInfo> listFlights(Criteria criteria) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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 {

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -143,7 +143,7 @@ public Result doAction(Action action) {
@Override
public void listActions(StreamListener<ActionType> 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();
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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 {

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand All @@ -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;
Expand Down