public void invoke()

in flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/sink/api/GpssGrpc.java [811:852]
42 lines of code
10 McCabe index (conditional complexity)

    public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) {
      switch (methodId) {
        case METHODID_CONNECT:
          serviceImpl.connect((org.apache.flink.connector.jdbc.table.sink.api.ConnectRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.flink.connector.jdbc.table.sink.api.Session>) responseObserver);
          break;
        case METHODID_DISCONNECT:
          serviceImpl.disconnect((org.apache.flink.connector.jdbc.table.sink.api.Session) request,
              (io.grpc.stub.StreamObserver<com.google.protobuf.Empty>) responseObserver);
          break;
        case METHODID_OPEN:
          serviceImpl.open((org.apache.flink.connector.jdbc.table.sink.api.OpenRequest) request,
              (io.grpc.stub.StreamObserver<com.google.protobuf.Empty>) responseObserver);
          break;
        case METHODID_WRITE:
          serviceImpl.write((org.apache.flink.connector.jdbc.table.sink.api.WriteRequest) request,
              (io.grpc.stub.StreamObserver<com.google.protobuf.Empty>) responseObserver);
          break;
        case METHODID_CLOSE:
          serviceImpl.close((org.apache.flink.connector.jdbc.table.sink.api.CloseRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.flink.connector.jdbc.table.sink.api.TransferStats>) responseObserver);
          break;
        case METHODID_LIST_SCHEMA:
          serviceImpl.listSchema((org.apache.flink.connector.jdbc.table.sink.api.ListSchemaRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.flink.connector.jdbc.table.sink.api.Schemas>) responseObserver);
          break;
        case METHODID_LIST_TABLE:
          serviceImpl.listTable((org.apache.flink.connector.jdbc.table.sink.api.ListTableRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.flink.connector.jdbc.table.sink.api.Tables>) responseObserver);
          break;
        case METHODID_DESCRIBE_TABLE:
          serviceImpl.describeTable((org.apache.flink.connector.jdbc.table.sink.api.DescribeTableRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.flink.connector.jdbc.table.sink.api.Columns>) responseObserver);
          break;
        case METHODID_READ:
          serviceImpl.read((org.apache.flink.connector.jdbc.table.sink.api.ReadRequest) request,
              (io.grpc.stub.StreamObserver<org.apache.flink.connector.jdbc.table.sink.api.ReadResponse>) responseObserver);
          break;
        default:
          throw new AssertionError();
      }
    }