Package org.apache.storm.generated
Class Supervisor.AsyncProcessor<I extends Supervisor.AsyncIface>
- java.lang.Object
-
- org.apache.storm.thrift.TBaseAsyncProcessor<I>
-
- org.apache.storm.generated.Supervisor.AsyncProcessor<I>
-
- All Implemented Interfaces:
org.apache.storm.thrift.TAsyncProcessor,org.apache.storm.thrift.TProcessor
- Enclosing class:
- Supervisor
public static class Supervisor.AsyncProcessor<I extends Supervisor.AsyncIface> extends org.apache.storm.thrift.TBaseAsyncProcessor<I>
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classSupervisor.AsyncProcessor.getLocalAssignmentForStorm<I extends Supervisor.AsyncIface>static classSupervisor.AsyncProcessor.sendSupervisorAssignments<I extends Supervisor.AsyncIface>static classSupervisor.AsyncProcessor.sendSupervisorWorkerHeartbeat<I extends Supervisor.AsyncIface>
-
Constructor Summary
Constructors Modifier Constructor Description AsyncProcessor(I iface)protectedAsyncProcessor(I iface, Map<String,org.apache.storm.thrift.AsyncProcessFunction<I,? extends org.apache.storm.thrift.TBase,?>> processMap)
-