etlt.writer.Writer

Complexity

Total Complexity

6

Size/Duplication

Total Lines	57
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	Writer.__exit__()	0	2	1
A	Writer.__enter__()	0	2	1
A	Writer.fields()	0	6	1
A	Writer.writerow()	0	8	1
A	Writer.__init__()	0	7	1

import abc
import copy
from typing import Any, Dict, List


class Writer(metaclass=abc.ABCMeta):
    """
    Abstract parent class for writing rows to a destination.
    """

    # ------------------------------------------------------------------------------------------------------------------
    def __init__(self):
        """
        Object constructor.
        """

        self._fields: List[str] = []
        """
        The fields (columns) that must be written to the destination.
        """

    # ------------------------------------------------------------------------------------------------------------------
    @property
    def fields(self) -> List[str]:
        """
        Getter for fields.
        """
        return copy.copy(self._fields)

    # ------------------------------------------------------------------------------------------------------------------
    @fields.setter
    def fields(self, fields: List[str]) -> None:
        """
        Setter for fields.

        :param fields: The fields (or columns) that must be written to the destination.
        """
        self._fields = fields

    # ------------------------------------------------------------------------------------------------------------------
    @abc.abstractmethod
    def writerow(self, row: Dict[str, Any]) -> None:
        """
        Writes a row to the destination.

        :param row: The row.
        """
        raise NotImplementedError()

    # ------------------------------------------------------------------------------------------------------------------
    def __enter__(self):
        raise NotImplementedError()

    # ------------------------------------------------------------------------------------------------------------------
    def __exit__(self, exc_type, exc_value, traceback):
        raise NotImplementedError()

# ----------------------------------------------------------------------------------------------------------------------