public class IndependentIterationsThreadPoolStage<T> extends AbstractEStage<List<T>>
Constructor and Description |
---|
IndependentIterationsThreadPoolStage(EventHandler<T> handler,
int numThreads,
int granularity) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
onNext(List<T> iterations)
Handles an event
|
getInMeter, getOutMeter
public IndependentIterationsThreadPoolStage(EventHandler<T> handler, int numThreads, int granularity)
Copyright © 2015 The Apache Software Foundation. All rights reserved.