added statistics info for etl (#3)

Author: ivanmarchenko83

src/AbstractEtl.php

@@ -7,6 +7,9 @@ abstract class AbstractEtl
     abstract public function extractor(): AbstractExtractor;
     abstract public function loader(): AbstractLoader;
 
+    protected $statistics = [
+    ];
+
     /**
      * @param array $data
      * @return array|Iterator|null
@@ -15,4 +18,9 @@ public function transform(array $data)
     {
         return $data;
     }
+
+    public function getStatistics()
+    {
+        return $this->statistics;
+    }
 }

src/EtlExecutor.php

@@ -13,7 +13,7 @@ public function execute(AbstractEtl $etl, $incremental = false)
 
         foreach ($extractor->extract($incremental) as $data) {
             $transformed = $etl->transform($data);
-            
+
             if ($transformed instanceof \Iterator) {
                 foreach ($transformed as $transformedData) {
                     $loader->load($transformedData);
@@ -26,7 +26,8 @@ public function execute(AbstractEtl $etl, $incremental = false)
         $loader->cleanup();
 
         return [
-            'loader' => $loader->getStatistics()
+            'loader' => $loader->getStatistics(),
+            'etl' => $etl->getStatistics()
         ];
     }
 }