APEXCORE-496 Provide way for StatsListeners to get additional information #476
Conversation
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Fix checkstyle errors. Please make sure PR is ready for review.
8663e44
to
366c018
Compare
@vrozov I have removed checkstyle errors. |
366c018
to
737c7e5
Compare
@tweise I have rebased the PR with current master |
@@ -1892,4 +1947,22 @@ public Integer getStreamCodecIdentifier(StreamCodec<?> streamCodecInfo) | |||
return null; | |||
} | |||
} | |||
|
|||
/** | |||
* A interface object for the statsListener to access the DAG, it provides methods |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
An interface for the {@link StatsListener}
... Please fix spelling and formatting of other Javadoc comments as well.
} | ||
|
||
/** | ||
* Adapter for handling deprecated StatsListener. This implementation calls {@see StatsListener.processStats(BatchedOperatorStats)} |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
The correct formatting would be {@link StatsListener#processStats(BatchedOperatorStats)}
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
will do it
@@ -2246,4 +2253,97 @@ public void testParallelPartitionForSlidingWindow() | |||
PhysicalPlan plan = new PhysicalPlan(dag, new TestPlanContext()); | |||
Assert.assertEquals("number of containers", 7, plan.getContainers().size()); | |||
} | |||
|
|||
static class NoOpStatsListener implements StatsListener |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
could this be done with mockito?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I will check with Mockito.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I have use Mockito to mock the interface in the tests, and updated the pull request
737c7e5
to
37308f3
Compare
@tweise I have handled the comments. |
No description provided.