initial dataflow implementation
initial dataflow implementation