ConnectGraph ();
SetupOperator ();
    public void Run()     {        ConnectGraph ();                // execute the stream here        while (true)        {            RunSinks ();            DrainChannels ();        }    }