def concat(self, streams):
        if self._execution_plan:
            self._execution_plan.append('concat', 'transform')

        return pd.concat(streams)
takes two input streams (pandas data frames) and concats them, assuming they have the same structure
dataset/ETHPy150Open Convertro/Hydro/src/hydro/transformers.py/Transformers.concat