Added app (stage 0) bytes_read and records_read

cemsbr · Aug 25, 2016 · fe8a0c0 · fe8a0c0
1 parent 2fa7a92
commit fe8a0c0
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/sparklogstats/logparser.py b/sparklogstats/logparser.py
@@ -165,6 +165,16 @@ def __init__(self):
         self.name = None
         self.filename = None
 
+    @property
+    def bytes_read(self):
+        """Input size."""
+        return self.stages[0].bytes_read
+
+    @property
+    def records_read(self):
+        """Number of lines read from input."""
+        return self.stages[0].records_read
+
 
 class Job(Timed):
     def __init__(self):