Class PipeManagerMaster


  • @ThreadSafe
    public final class PipeManagerMaster
    extends Object
    Master-side pipe manager.
    • Method Detail

      • onTaskScheduled

        public void onTaskScheduled​(String edgeId,
                                    long srcIndex)