Class Nimbus.AsyncProcessor<I extends Nimbus.AsyncIface>

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

public static class Nimbus.AsyncProcessor<I extends Nimbus.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)