Skip to content

Commit

Permalink
Use processedInput* metrics in PipelineContext#getInput*
Browse files Browse the repository at this point in the history
This makes it compatible with PipelineContext#getOutput*
methods as they don't use raw driver metrics.
Additionally, PipelineContext#GetInput* metrics
were merging rawInput* with processedInput* from driver.
  • Loading branch information
sopel39 committed Jan 29, 2019
1 parent 0c7d4ed commit 23f8793
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -272,7 +272,7 @@ public boolean isCpuTimerEnabled()
public CounterStat getInputDataSize()
{
CounterStat stat = new CounterStat();
stat.merge(rawInputDataSize);
stat.merge(processedInputDataSize);
for (DriverContext driver : drivers) {
stat.merge(driver.getInputDataSize());
}
Expand All @@ -282,7 +282,7 @@ public CounterStat getInputDataSize()
public CounterStat getInputPositions()
{
CounterStat stat = new CounterStat();
stat.merge(rawInputPositions);
stat.merge(processedInputPositions);
for (DriverContext driver : drivers) {
stat.merge(driver.getInputPositions());
}
Expand Down

0 comments on commit 23f8793

Please sign in to comment.