| <!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd"> |
| <!-- NewPage --> |
| <html lang="en"> |
| <head> |
| <!-- Generated by javadoc (version 1.6.0_36) on Wed Jan 13 23:44:29 CST 2016 --> |
| <title>io.gearpump.streaming</title> |
| <meta name="date" content="2016-01-13"> |
| <link rel="stylesheet" type="text/css" href="../../../stylesheet.css" title="Style"> |
| </head> |
| <body> |
| <script type="text/javascript"><!-- |
| if (location.href.indexOf('is-external=true') == -1) { |
| parent.document.title="io.gearpump.streaming"; |
| } |
| //--> |
| </script> |
| <noscript> |
| <div>JavaScript is disabled on your browser.</div> |
| </noscript> |
| <!-- ========= START OF TOP NAVBAR ======= --> |
| <div class="topNav"><a name="navbar_top"> |
| <!-- --> |
| </a><a href="#skip-navbar_top" title="Skip navigation links"></a><a name="navbar_top_firstrow"> |
| <!-- --> |
| </a> |
| <ul class="navList" title="Navigation"> |
| <li><a href="../../../overview-summary.html">Overview</a></li> |
| <li class="navBarCell1Rev">Package</li> |
| <li>Class</li> |
| <li><a href="package-tree.html">Tree</a></li> |
| <li><a href="../../../deprecated-list.html">Deprecated</a></li> |
| <li><a href="../../../index-all.html">Index</a></li> |
| <li><a href="../../../help-doc.html">Help</a></li> |
| </ul> |
| </div> |
| <div class="subNav"> |
| <ul class="navList"> |
| <li>PREV PACKAGE</li> |
| <li><a href="../../../io/gearpump/streaming/appmaster/package-summary.html">NEXT PACKAGE</a></li> |
| </ul> |
| <ul class="navList"> |
| <li><a href="../../../index.html?io/gearpump/streaming/package-summary.html" target="_top">FRAMES</a></li> |
| <li><a href="package-summary.html" target="_top">NO FRAMES</a></li> |
| </ul> |
| <ul class="navList" id="allclasses_navbar_top"> |
| <li><a href="../../../allclasses-noframe.html">All Classes</a></li> |
| </ul> |
| <div> |
| <script type="text/javascript"><!-- |
| allClassesLink = document.getElementById("allclasses_navbar_top"); |
| if(window==top) { |
| allClassesLink.style.display = "block"; |
| } |
| else { |
| allClassesLink.style.display = "none"; |
| } |
| //--> |
| </script> |
| </div> |
| <a name="skip-navbar_top"> |
| <!-- --> |
| </a></div> |
| <!-- ========= END OF TOP NAVBAR ========= --> |
| <div class="header"> |
| <h1 title="Package" class="title">Package io.gearpump.streaming</h1> |
| </div> |
| <div class="contentContainer"> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <table class="packageSummary" border="0" cellpadding="3" cellspacing="0" summary="Interface Summary table, listing interfaces, and an explanation"> |
| <caption><span>Interface Summary</span><span class="tabEnd"> </span></caption> |
| <tr> |
| <th class="colFirst" scope="col">Interface</th> |
| <th class="colLast" scope="col">Description</th> |
| </tr> |
| <tbody> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/Processor.html" title="interface in io.gearpump.streaming">Processor<T extends Task></a></td> |
| <td class="colLast"> |
| <div class="block">Processor is the blueprint for tasks.</div> |
| </td> |
| </tr> |
| </tbody> |
| </table> |
| </li> |
| <li class="blockList"> |
| <table class="packageSummary" border="0" cellpadding="3" cellspacing="0" summary="Class Summary table, listing classes, and an explanation"> |
| <caption><span>Class Summary</span><span class="tabEnd"> </span></caption> |
| <tr> |
| <th class="colFirst" scope="col">Class</th> |
| <th class="colLast" scope="col">Description</th> |
| </tr> |
| <tbody> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/AckRequestSerializer.html" title="class in io.gearpump.streaming">AckRequestSerializer</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/AckSerializer.html" title="class in io.gearpump.streaming">AckSerializer</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/AppMasterToExecutor.html" title="class in io.gearpump.streaming">AppMasterToExecutor</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/AppMasterToExecutor.ChangeTask.html" title="class in io.gearpump.streaming">AppMasterToExecutor.ChangeTask</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/AppMasterToExecutor.ChangeTask$.html" title="class in io.gearpump.streaming">AppMasterToExecutor.ChangeTask$</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/AppMasterToExecutor.ChangeTasks.html" title="class in io.gearpump.streaming">AppMasterToExecutor.ChangeTasks</a></td> |
| <td class="colLast"> |
| <div class="block">dagVersion, life, and subscribers will be changed on target task list.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/AppMasterToExecutor.ChangeTasks$.html" title="class in io.gearpump.streaming">AppMasterToExecutor.ChangeTasks$</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/AppMasterToExecutor.LaunchTasks.html" title="class in io.gearpump.streaming">AppMasterToExecutor.LaunchTasks</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/AppMasterToExecutor.LaunchTasks$.html" title="class in io.gearpump.streaming">AppMasterToExecutor.LaunchTasks$</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/AppMasterToExecutor.RestartClockService$.html" title="class in io.gearpump.streaming">AppMasterToExecutor.RestartClockService$</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/AppMasterToExecutor.StartAllTasks.html" title="class in io.gearpump.streaming">AppMasterToExecutor.StartAllTasks</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/AppMasterToExecutor.StartAllTasks$.html" title="class in io.gearpump.streaming">AppMasterToExecutor.StartAllTasks$</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/AppMasterToExecutor.StartDynamicDag.html" title="class in io.gearpump.streaming">AppMasterToExecutor.StartDynamicDag</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/AppMasterToExecutor.StartDynamicDag$.html" title="class in io.gearpump.streaming">AppMasterToExecutor.StartDynamicDag$</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/AppMasterToExecutor.StartTask.html" title="class in io.gearpump.streaming">AppMasterToExecutor.StartTask</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/AppMasterToExecutor.StartTask$.html" title="class in io.gearpump.streaming">AppMasterToExecutor.StartTask$</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/AppMasterToExecutor.TaskChanged.html" title="class in io.gearpump.streaming">AppMasterToExecutor.TaskChanged</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/AppMasterToExecutor.TaskChanged$.html" title="class in io.gearpump.streaming">AppMasterToExecutor.TaskChanged$</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/AppMasterToExecutor.TaskLocationsReady.html" title="class in io.gearpump.streaming">AppMasterToExecutor.TaskLocationsReady</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/AppMasterToExecutor.TaskLocationsReady$.html" title="class in io.gearpump.streaming">AppMasterToExecutor.TaskLocationsReady$</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/AppMasterToExecutor.TaskLocationsReceived.html" title="class in io.gearpump.streaming">AppMasterToExecutor.TaskLocationsReceived</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/AppMasterToExecutor.TaskLocationsReceived$.html" title="class in io.gearpump.streaming">AppMasterToExecutor.TaskLocationsReceived$</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/AppMasterToExecutor.TaskLocationsRejected.html" title="class in io.gearpump.streaming">AppMasterToExecutor.TaskLocationsRejected</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/AppMasterToExecutor.TaskLocationsRejected$.html" title="class in io.gearpump.streaming">AppMasterToExecutor.TaskLocationsRejected$</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/AppMasterToExecutor.TaskRegistered.html" title="class in io.gearpump.streaming">AppMasterToExecutor.TaskRegistered</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/AppMasterToExecutor.TaskRegistered$.html" title="class in io.gearpump.streaming">AppMasterToExecutor.TaskRegistered$</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/AppMasterToExecutor.TaskRejected.html" title="class in io.gearpump.streaming">AppMasterToExecutor.TaskRejected</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/AppMasterToExecutor.TaskRejected$.html" title="class in io.gearpump.streaming">AppMasterToExecutor.TaskRejected$</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/AppMasterToExecutor.TasksChanged.html" title="class in io.gearpump.streaming">AppMasterToExecutor.TasksChanged</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/AppMasterToExecutor.TasksChanged$.html" title="class in io.gearpump.streaming">AppMasterToExecutor.TasksChanged$</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/AppMasterToExecutor.TasksLaunched$.html" title="class in io.gearpump.streaming">AppMasterToExecutor.TasksLaunched$</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/AppMasterToExecutor$.html" title="class in io.gearpump.streaming">AppMasterToExecutor$</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/AppMasterToMaster.html" title="class in io.gearpump.streaming">AppMasterToMaster</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/AppMasterToMaster.StallingTasks.html" title="class in io.gearpump.streaming">AppMasterToMaster.StallingTasks</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/AppMasterToMaster.StallingTasks$.html" title="class in io.gearpump.streaming">AppMasterToMaster.StallingTasks$</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/AppMasterToMaster$.html" title="class in io.gearpump.streaming">AppMasterToMaster$</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/Constants.html" title="class in io.gearpump.streaming">Constants</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/Constants$.html" title="class in io.gearpump.streaming">Constants$</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/DAG.html" title="class in io.gearpump.streaming">DAG</a></td> |
| <td class="colLast"> |
| <div class="block">DAG is wrapper for <code>Graph</code> for streaming applications.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/DAG$.html" title="class in io.gearpump.streaming">DAG$</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/ExecutorToAppMaster.html" title="class in io.gearpump.streaming">ExecutorToAppMaster</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/ExecutorToAppMaster.MessageLoss.html" title="class in io.gearpump.streaming">ExecutorToAppMaster.MessageLoss</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/ExecutorToAppMaster.MessageLoss$.html" title="class in io.gearpump.streaming">ExecutorToAppMaster.MessageLoss$</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/ExecutorToAppMaster.RegisterExecutor.html" title="class in io.gearpump.streaming">ExecutorToAppMaster.RegisterExecutor</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/ExecutorToAppMaster.RegisterExecutor$.html" title="class in io.gearpump.streaming">ExecutorToAppMaster.RegisterExecutor$</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/ExecutorToAppMaster.RegisterTask.html" title="class in io.gearpump.streaming">ExecutorToAppMaster.RegisterTask</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/ExecutorToAppMaster.RegisterTask$.html" title="class in io.gearpump.streaming">ExecutorToAppMaster.RegisterTask$</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/ExecutorToAppMaster$.html" title="class in io.gearpump.streaming">ExecutorToAppMaster$</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/InitialAckRequestSerializer.html" title="class in io.gearpump.streaming">InitialAckRequestSerializer</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/LatencyProbeSerializer.html" title="class in io.gearpump.streaming">LatencyProbeSerializer</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/LifeTime.html" title="class in io.gearpump.streaming">LifeTime</a></td> |
| <td class="colLast"> |
| <div class="block">Each processor has a LifeTime.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/LifeTime$.html" title="class in io.gearpump.streaming">LifeTime$</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/Processor.DefaultProcessor.html" title="class in io.gearpump.streaming">Processor.DefaultProcessor<T extends Task></a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/Processor.DefaultProcessor$.html" title="class in io.gearpump.streaming">Processor.DefaultProcessor$</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/Processor$.html" title="class in io.gearpump.streaming">Processor$</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/ProcessorDescription.html" title="class in io.gearpump.streaming">ProcessorDescription</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/ProcessorDescription$.html" title="class in io.gearpump.streaming">ProcessorDescription$</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/StreamApplication.html" title="class in io.gearpump.streaming">StreamApplication</a></td> |
| <td class="colLast"> |
| <div class="block">Represent a streaming application</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/StreamApplication$.html" title="class in io.gearpump.streaming">StreamApplication$</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/TaskIdSerializer.html" title="class in io.gearpump.streaming">TaskIdSerializer</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| </tbody> |
| </table> |
| </li> |
| <li class="blockList"> |
| <table class="packageSummary" border="0" cellpadding="3" cellspacing="0" summary="Exception Summary table, listing exceptions, and an explanation"> |
| <caption><span>Exception Summary</span><span class="tabEnd"> </span></caption> |
| <tr> |
| <th class="colFirst" scope="col">Exception</th> |
| <th class="colLast" scope="col">Description</th> |
| </tr> |
| <tbody> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../io/gearpump/streaming/AppMasterToExecutor.MsgLostException.html" title="class in io.gearpump.streaming">AppMasterToExecutor.MsgLostException</a></td> |
| <td class="colLast"> </td> |
| </tr> |
| </tbody> |
| </table> |
| </li> |
| </ul> |
| </div> |
| <!-- ======= START OF BOTTOM NAVBAR ====== --> |
| <div class="bottomNav"><a name="navbar_bottom"> |
| <!-- --> |
| </a><a href="#skip-navbar_bottom" title="Skip navigation links"></a><a name="navbar_bottom_firstrow"> |
| <!-- --> |
| </a> |
| <ul class="navList" title="Navigation"> |
| <li><a href="../../../overview-summary.html">Overview</a></li> |
| <li class="navBarCell1Rev">Package</li> |
| <li>Class</li> |
| <li><a href="package-tree.html">Tree</a></li> |
| <li><a href="../../../deprecated-list.html">Deprecated</a></li> |
| <li><a href="../../../index-all.html">Index</a></li> |
| <li><a href="../../../help-doc.html">Help</a></li> |
| </ul> |
| </div> |
| <div class="subNav"> |
| <ul class="navList"> |
| <li>PREV PACKAGE</li> |
| <li><a href="../../../io/gearpump/streaming/appmaster/package-summary.html">NEXT PACKAGE</a></li> |
| </ul> |
| <ul class="navList"> |
| <li><a href="../../../index.html?io/gearpump/streaming/package-summary.html" target="_top">FRAMES</a></li> |
| <li><a href="package-summary.html" target="_top">NO FRAMES</a></li> |
| </ul> |
| <ul class="navList" id="allclasses_navbar_bottom"> |
| <li><a href="../../../allclasses-noframe.html">All Classes</a></li> |
| </ul> |
| <div> |
| <script type="text/javascript"><!-- |
| allClassesLink = document.getElementById("allclasses_navbar_bottom"); |
| if(window==top) { |
| allClassesLink.style.display = "block"; |
| } |
| else { |
| allClassesLink.style.display = "none"; |
| } |
| //--> |
| </script> |
| </div> |
| <a name="skip-navbar_bottom"> |
| <!-- --> |
| </a></div> |
| <!-- ======== END OF BOTTOM NAVBAR ======= --> |
| </body> |
| </html> |