Class ActionRouter

java.lang.Object
io.deephaven.server.session.ActionRouter

public final class ActionRouter extends Object
  • Constructor Details

  • Method Details

    • listActions

      public void listActions(@Nullable @Nullable SessionState session, Consumer<org.apache.arrow.flight.ActionType> visitor)
      Invokes visitor for all of the resolvers. Used as the basis for implementing FlightService ListActions.
      Parameters:
      session - the session
      visitor - the visitor
    • doAction

      public void doAction(@Nullable @Nullable SessionState session, org.apache.arrow.flight.Action action, io.grpc.stub.StreamObserver<org.apache.arrow.flight.Result> observer)
      Routes action to the appropriate ActionResolver. Used as the basis for implementing FlightService DoAction.
      Parameters:
      session - the session
      action - the action
      observer - the observer
      Throws:
      io.grpc.StatusRuntimeException - if zero or more than one resolver is found