Searched defs:processMap (Results 1 – 2 of 2) sorted by relevance
33 final Map<String, AsyncProcessFunction<I, ? extends TBase, ?>> processMap; field in TBaseAsyncProcessor36 I iface, Map<String, AsyncProcessFunction<I, ? extends TBase, ?>> processMap) { in TBaseAsyncProcessor()
13 private final Map<String, ProcessFunction<I, ? extends TBase>> processMap; field in TBaseProcessor