Github user kayousterhout commented on a diff in the pull request:
https://github.com/apache/spark/pull/962#discussion_r14308126
--- Diff: core/src/main/scala/org/apache/spark/executor/TaskMetrics.scala
---
@@ -87,6 +93,29 @@ private[spark] object TaskMetrics {
def empty: TaskMetrics = new TaskMetrics
}
+/**
+ * :: DeveloperApi ::
+ * Method by which input data was read. Network means that the data was
read over the network
+ * from a remote block manager (which may have stored the data on-disk or
in-memory).
+ */
+@DeveloperApi
+private[spark] object DataReadMethod extends Enumeration with Serializable
{
--- End diff --
Oh oops I think the mistake here was making it private[spark] -- weird for
it to be private[spark] when it's publicly exposed via InputMetrics. Fixed!
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
