Class DistributedRPC.AsyncProcessor<I extends DistributedRPC.AsyncIface>

java.lang.Object
org.apache.storm.thrift.TBaseAsyncProcessor<I>
org.apache.storm.generated.DistributedRPC.AsyncProcessor<I>
All Implemented Interfaces:
org.apache.storm.thrift.TAsyncProcessor, org.apache.storm.thrift.TProcessor
Enclosing class:
DistributedRPC

public static class DistributedRPC.AsyncProcessor<I extends DistributedRPC.AsyncIface> extends org.apache.storm.thrift.TBaseAsyncProcessor<I>
  • Constructor Details

    • AsyncProcessor

      public AsyncProcessor(I iface)
    • AsyncProcessor

      protected AsyncProcessor(I iface, Map<String,org.apache.storm.thrift.AsyncProcessFunction<I,? extends org.apache.storm.thrift.TBase,?>> processMap)