Class DistributedRPCInvocations.Processor<I extends DistributedRPCInvocations.Iface>

java.lang.Object
org.apache.storm.thrift.TBaseProcessor<I>
org.apache.storm.generated.DistributedRPCInvocations.Processor<I>
All Implemented Interfaces:
org.apache.storm.thrift.TProcessor
Enclosing class:
DistributedRPCInvocations

public static class DistributedRPCInvocations.Processor<I extends DistributedRPCInvocations.Iface> extends org.apache.storm.thrift.TBaseProcessor<I> implements org.apache.storm.thrift.TProcessor
  • Constructor Details

    • Processor

      public Processor(I iface)
    • Processor

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