File tree Expand file tree Collapse file tree 3 files changed +12
-13
lines changed Expand file tree Collapse file tree 3 files changed +12
-13
lines changed Original file line number Diff line number Diff line change 2
2
3
3
namespace Marquine \Etl \Extractors ;
4
4
5
- use IteratorAggregate ;
6
5
use Marquine \Etl \Step ;
7
6
8
- abstract class Extractor extends Step implements IteratorAggregate
7
+ abstract class Extractor extends Step
9
8
{
10
9
/**
11
- * Set up the extraction from the given source .
10
+ * Extract data from an input .
12
11
*
13
- * @param mixed $source
14
- * @return void
12
+ * @return \Generator
15
13
*/
16
- abstract public function extract ($ source );
14
+ abstract public function extract ();
17
15
};
Original file line number Diff line number Diff line change 7
7
abstract class Loader extends Step
8
8
{
9
9
/**
10
- * Get the loader handler .
10
+ * Load the given row .
11
11
*
12
- * @param mixed $destination
13
- * @return callable
12
+ * @param \Marquine\Etl\Row $row
13
+ * @return void
14
14
*/
15
- abstract public function load ($ destination );
15
+ abstract public function load ($ row );
16
16
}
Original file line number Diff line number Diff line change 7
7
abstract class Transformer extends Step
8
8
{
9
9
/**
10
- * Get the transformer handler .
10
+ * Transform the given row .
11
11
*
12
- * @return callable
12
+ * @param \Marquine\Etl\Row $row
13
+ * @return void
13
14
*/
14
- abstract public function transform ();
15
+ abstract public function transform ($ row );
15
16
}
You can’t perform that action at this time.
0 commit comments