fab2s / YaEtl

src/Extractors/PdoExtractorTrait.php

Doc Comments -1 removed lines

@@ -67,7 +67,6 @@
 
     /**
      * @param \PDO   $pdo
-     * @param string $extractQuery
      */
     public function configurePdo(\PDO $pdo)
     {

src/YaEtl.php

Doc Comments +2 added lines, -5 removed lines

@@ -86,7 +86,7 @@ 
     }
 
     /**
-     * @param ExtractorAbstract       $extractor
+     * @param ExtractorInterface       $extractor
      * @param null|ExtractorInterface $aggregateWith Use the extractore instance you want to aggregate with
      *
      * @return $this
@@ -134,7 +134,7 @@ 
     }
 
     /**
-     * @param Node $node
+     * @param NodeInterface $node
      *
      * @throws Exception
      */
@@ -147,8 +147,6 @@ 
      * @param JoinableInterface $extractor
      * @param JoinableInterface $joinFrom
      * @param OnClauseInterface $onClause
-     * @param callable          $merger
-     * @param bool              $leftJoin
      *
      * @return $this
      */
@@ -228,7 +226,6 @@ 
     /**
      * Triggered right after the flow stops
      *
-     * @param mixed $success
      *
      * @return $this
      */

Spacing +1 added lines, -1 removed lines

@@ -288,7 +288,7 @@
         $stats = \array_replace($this->statsDefault, $stats);
 
         foreach ($this->nodes as $nodeIdx => $node) {
-            $isJoining       = ($node instanceof JoinableInterface) && $node->getOnClause();
+            $isJoining = ($node instanceof JoinableInterface) && $node->getOnClause();
             if ($isJoining) {
                 $this->nodeStats[$nodeIdx]['num_join'] = $node->getNumRecords();
                 $stats['num_join'] += $this->nodeStats[$nodeIdx]['num_join'];

src/Laravel/Loaders/DbLoader.php

Spacing +1 added lines, -1 removed lines

@@ -89,7 +89,7 @@
         // btw, multi insert are not necessarily that faster in real world
         // situation where there is a lot of updates and you need ot keep
         // atomicity using transactions
-        DB::transaction(function () use ($loadQuery, $whereClause, $record) {
+        DB::transaction(function() use ($loadQuery, $whereClause, $record) {
             if ($loadQuery->where($whereClause)->sharedLock()->exists()) {
                 $update = \array_diff_key($record, $whereClause);
                 $loadQuery->update($update);