Class PipeManagerMaster


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

      • onTaskScheduled

        public void onTaskScheduled​(java.lang.String edgeId,
                                    long srcIndex)