python/src/pywayang/operator/source.py

from pywayang.operator.base import WyOperator

class SourceUnaryOperator(WyOperator):

    def __init__(self, name:str):
        super().__init__(name, None, str, 0, 1)

    def __str__(self):
        return super().__str__()

    def __repr__(self):
        return super().__repr__()



class TextFileSource(SourceUnaryOperator):

    path: str

    def __init__(self, path: str):
        super().__init__('TextFileSource')
        self.path = path

    def __str__(self):
        return super().__str__()

    def __repr__(self):
        return super().__repr__()