public static final class ProfilingAware.ProfiledBarrier extends Object implements Barrier
Barrier
and it's related ProfileStep
so that the latter can have
its timer started and stopped appropriately.Constructor and Description |
---|
ProfiledBarrier(Barrier barrier,
ProfileStep profileStep) |
Modifier and Type | Method and Description |
---|---|
void |
addBarrier(Object barrier)
Add a barrier to the step.
|
void |
done()
A way to hard set that the barrier is complete.
|
MemoryComputeKey |
getMemoryComputeKey()
The
MemoryComputeKey that will be used by this step. |
boolean |
hasNextBarrier()
Whether or not the step has an accessible barrier.
|
Object |
nextBarrier()
Get the next barrier within this step.
|
void |
processAllStarts()
Process all left traversers by do not yield the resultant output.
|
public ProfiledBarrier(Barrier barrier, ProfileStep profileStep)
public void processAllStarts()
Barrier
ReducingBarrierStep
, where traversers can be processed "on the fly" and thus, reduce memory consumption.processAllStarts
in interface Barrier
public boolean hasNextBarrier()
Barrier
hasNextBarrier
in interface Barrier
public Object nextBarrier() throws NoSuchElementException
Barrier
nextBarrier
in interface Barrier
NoSuchElementException
public void addBarrier(Object barrier)
Barrier
addBarrier
in interface Barrier
barrier
- the barrier to merge inpublic MemoryComputeKey getMemoryComputeKey()
MemoryComputing
MemoryComputeKey
that will be used by this step.getMemoryComputeKey
in interface MemoryComputing
Copyright © 2013–2022 Apache Software Foundation. All rights reserved.