scheduler.computeSchedule ();
    public void run()    {        setupOperator ();        // setup the scheduler        {            SchedStream stream;            stream = (SchedStream) constructSchedule ();            ASSERT (stream);            scheduler = new SimpleHierarchicalScheduler (stream);        }        ASSERT (streamInput == null);        ASSERT (streamOutput == null);        // execute the stream here        while (true)        {            runSinks ();            drainChannels ();        }    }