http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/136ab3dc/content/releases/0.7.0/api/java/index-all.html ---------------------------------------------------------------------- diff --git a/content/releases/0.7.0/api/java/index-all.html b/content/releases/0.7.0/api/java/index-all.html deleted file mode 100644 index 12a3704..0000000 --- a/content/releases/0.7.0/api/java/index-all.html +++ /dev/null @@ -1,3757 +0,0 @@ -<!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 Sat Nov 28 01:44:51 CST 2015 --> -<title>Index</title> -<meta name="date" content="2015-11-28"> -<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="Index"; - } -//--> -</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>Package</li> -<li>Class</li> -<li><a href="./overview-tree.html">Tree</a></li> -<li><a href="./deprecated-list.html">Deprecated</a></li> -<li class="navBarCell1Rev">Index</li> -<li><a href="./help-doc.html">Help</a></li> -</ul> -</div> -<div class="subNav"> -<ul class="navList"> -<li>PREV</li> -<li>NEXT</li> -</ul> -<ul class="navList"> -<li><a href="./index.html?index-all.html" target="_top">FRAMES</a></li> -<li><a href="index-all.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="contentContainer"><a href="#_A_">A</a> <a href="#_B_">B</a> <a href="#_C_">C</a> <a href="#_D_">D</a> <a href="#_E_">E</a> <a href="#_F_">F</a> <a href="#_G_">G</a> <a href="#_H_">H</a> <a href="#_I_">I</a> <a href="#_J_">J</a> <a href="#_K_">K</a> <a href="#_L_">L</a> <a href="#_M_">M</a> <a href="#_N_">N</a> <a href="#_O_">O</a> <a href="#_P_">P</a> <a href="#_Q_">Q</a> <a href="#_R_">R</a> <a href="#_S_">S</a> <a href="#_T_">T</a> <a href="#_U_">U</a> <a href="#_V_">V</a> <a href="#_W_">W</a> <a href="#_Z_">Z</a> <a name="_A_"> -<!-- --> -</a> -<h2 class="title">A</h2> -<dl> -<dt><a href="./io/gearpump/streaming/task/Ack.html" title="class in io.gearpump.streaming.task"><span class="strong">Ack</span></a> - Class in <a href="./io/gearpump/streaming/task/package-summary.html">io.gearpump.streaming.task</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/task/Ack.html#Ack(io.gearpump.streaming.task.TaskId, short, short, int)">Ack(TaskId, short, short, int)</a></span> - Constructor for class io.gearpump.streaming.task.<a href="./io/gearpump/streaming/task/Ack.html" title="class in io.gearpump.streaming.task">Ack</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/task/TaskActor.SendAck.html#ack()">ack()</a></span> - Method in class io.gearpump.streaming.task.<a href="./io/gearpump/streaming/task/TaskActor.SendAck.html" title="class in io.gearpump.streaming.task">TaskActor.SendAck</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/task/Ack$.html" title="class in io.gearpump.streaming.task"><span class="strong">Ack$</span></a> - Class in <a href="./io/gearpump/streaming/task/package-summary.html">io.gearpump.streaming.task</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/task/Ack$.html#Ack$()">Ack$()</a></span> - Constructor for class io.gearpump.streaming.task.<a href="./io/gearpump/streaming/task/Ack$.html" title="class in io.gearpump.streaming.task">Ack$</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/task/AckRequest.html" title="class in io.gearpump.streaming.task"><span class="strong">AckRequest</span></a> - Class in <a href="./io/gearpump/streaming/task/package-summary.html">io.gearpump.streaming.task</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/task/AckRequest.html#AckRequest(io.gearpump.streaming.task.TaskId, short, int)">AckRequest(TaskId, short, int)</a></span> - Constructor for class io.gearpump.streaming.task.<a href="./io/gearpump/streaming/task/AckRequest.html" title="class in io.gearpump.streaming.task">AckRequest</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/task/AckRequest$.html" title="class in io.gearpump.streaming.task"><span class="strong">AckRequest$</span></a> - Class in <a href="./io/gearpump/streaming/task/package-summary.html">io.gearpump.streaming.task</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/task/AckRequest$.html#AckRequest$()">AckRequest$()</a></span> - Constructor for class io.gearpump.streaming.task.<a href="./io/gearpump/streaming/task/AckRequest$.html" title="class in io.gearpump.streaming.task">AckRequest$</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/AckRequestSerializer.html" title="class in io.gearpump.streaming"><span class="strong">AckRequestSerializer</span></a> - Class in <a href="./io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/AckRequestSerializer.html#AckRequestSerializer()">AckRequestSerializer()</a></span> - Constructor for class io.gearpump.streaming.<a href="./io/gearpump/streaming/AckRequestSerializer.html" title="class in io.gearpump.streaming">AckRequestSerializer</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/AckSerializer.html" title="class in io.gearpump.streaming"><span class="strong">AckSerializer</span></a> - Class in <a href="./io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/AckSerializer.html#AckSerializer()">AckSerializer()</a></span> - Constructor for class io.gearpump.streaming.<a href="./io/gearpump/streaming/AckSerializer.html" title="class in io.gearpump.streaming">AckSerializer</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/task/TaskContext.html#actorOf(akka.actor.Props)">actorOf(Props)</a></span> - Method in interface io.gearpump.streaming.task.<a href="./io/gearpump/streaming/task/TaskContext.html" title="interface in io.gearpump.streaming.task">TaskContext</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/task/TaskContext.html#actorOf(akka.actor.Props, java.lang.String)">actorOf(Props, String)</a></span> - Method in interface io.gearpump.streaming.task.<a href="./io/gearpump/streaming/task/TaskContext.html" title="interface in io.gearpump.streaming.task">TaskContext</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/task/TaskWrapper.html#actorOf(akka.actor.Props)">actorOf(Props)</a></span> - Method in class io.gearpump.streaming.task.<a href="./io/gearpump/streaming/task/TaskWrapper.html" title="class in io.gearpump.streaming.task">TaskWrapper</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/task/TaskWrapper.html#actorOf(akka.actor.Props, java.lang.String)">actorOf(Props, String)</a></span> - Method in class io.gearpump.streaming.task.<a href="./io/gearpump/streaming/task/TaskWrapper.html" title="class in io.gearpump.streaming.task">TaskWrapper</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/StreamAppMasterSummary.html#actorPath()">actorPath()</a></span> - Method in class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/StreamAppMasterSummary.html" title="class in io.gearpump.streaming.appmaster">StreamAppMasterSummary</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/executor/Executor.ExecutorSummary.html#actorPath()">actorPath()</a></span> - Method in class io.gearpump.streaming.executor.<a href="./io/gearpump/streaming/executor/Executor.ExecutorSummary.html" title="class in io.gearpump.streaming.executor">Executor.ExecutorSummary</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/util/ActorPathUtil.html" title="class in io.gearpump.streaming.util"><span class="strong">ActorPathUtil</span></a> - Class in <a href="./io/gearpump/streaming/util/package-summary.html">io.gearpump.streaming.util</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/util/ActorPathUtil.html#ActorPathUtil()">ActorPathUtil()</a></span> - Constructor for class io.gearpump.streaming.util.<a href="./io/gearpump/streaming/util/ActorPathUtil.html" title="class in io.gearpump.streaming.util">ActorPathUtil</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/util/ActorPathUtil$.html" title="class in io.gearpump.streaming.util"><span class="strong">ActorPathUtil$</span></a> - Class in <a href="./io/gearpump/streaming/util/package-summary.html">io.gearpump.streaming.util</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/util/ActorPathUtil$.html#ActorPathUtil$()">ActorPathUtil$()</a></span> - Constructor for class io.gearpump.streaming.util.<a href="./io/gearpump/streaming/util/ActorPathUtil$.html" title="class in io.gearpump.streaming.util">ActorPathUtil$</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/AppMaster.html#actorSystem()">actorSystem()</a></span> - Method in class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/AppMaster.html" title="class in io.gearpump.streaming.appmaster">AppMaster</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/task/Ack.html#actualReceivedNum()">actualReceivedNum()</a></span> - Method in class io.gearpump.streaming.task.<a href="./io/gearpump/streaming/task/Ack.html" title="class in io.gearpump.streaming.task">Ack</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/executor/Executor.TaskArgumentStore.html#add(io.gearpump.streaming.task.TaskId, io.gearpump.streaming.executor.TaskLauncher.TaskArgument)">add(TaskId, TaskLauncher.TaskArgument)</a></span> - Method in class io.gearpump.streaming.executor.<a href="./io/gearpump/streaming/executor/Executor.TaskArgumentStore.html" title="class in io.gearpump.streaming.executor">Executor.TaskArgumentStore</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/executor/ExecutorRestartPolicy.html#addTaskToExecutor(int, io.gearpump.streaming.task.TaskId)">addTaskToExecutor(int, TaskId)</a></span> - Method in class io.gearpump.streaming.executor.<a href="./io/gearpump/streaming/executor/ExecutorRestartPolicy.html" title="class in io.gearpump.streaming.executor">ExecutorRestartPolicy</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/TaskScheduler.TaskStatus.html#allocation()">allocation()</a></span> - Method in class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/TaskScheduler.TaskStatus.html" title="class in io.gearpump.streaming.appmaster">TaskScheduler.TaskStatus</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/executor/ExecutorRestartPolicy.html#allowRestartExecutor(int)">allowRestartExecutor(int)</a></span> - Method in class io.gearpump.streaming.executor.<a href="./io/gearpump/streaming/executor/ExecutorRestartPolicy.html" title="class in io.gearpump.streaming.executor">ExecutorRestartPolicy</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/task/Subscription.html#allowSendingMoreMessages()">allowSendingMoreMessages()</a></span> - Method in class io.gearpump.streaming.task.<a href="./io/gearpump/streaming/task/Subscription.html" title="class in io.gearpump.streaming.task">Subscription</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/dsl/plan/OpTranslator.DummyInputFunction.html#andThen(io.gearpump.streaming.dsl.plan.OpTranslator.SingleInputFunction)">andThen(OpTranslator.SingleInputFunction<T, OUTER>)</a></span> - Method in class io.gearpump.streaming.dsl.plan.<a href="./io/gearpump/streaming/dsl/plan/OpTranslator.DummyInputFunction.html" title="class in io.gearpump.streaming.dsl.plan">OpTranslator.DummyInputFunction</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/dsl/plan/OpTranslator.SingleInputFunction.html#andThen(io.gearpump.streaming.dsl.plan.OpTranslator.SingleInputFunction)">andThen(OpTranslator.SingleInputFunction<OUT, OUTER>)</a></span> - Method in interface io.gearpump.streaming.dsl.plan.<a href="./io/gearpump/streaming/dsl/plan/OpTranslator.SingleInputFunction.html" title="interface in io.gearpump.streaming.dsl.plan">OpTranslator.SingleInputFunction</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/ClockService.HealthChecker.ClockValue.html#appClock()">appClock()</a></span> - Method in class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/ClockService.HealthChecker.ClockValue.html" title="class in io.gearpump.streaming.appmaster">ClockService.HealthChecker.ClockValue</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/storage/AppDataStore.html" title="interface in io.gearpump.streaming.storage"><span class="strong">AppDataStore</span></a> - Interface in <a href="./io/gearpump/streaming/storage/package-summary.html">io.gearpump.streaming.storage</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/transaction/api/OffsetStorage.html#append(long, byte[])">append(long, byte[])</a></span> - Method in interface io.gearpump.streaming.transaction.api.<a href="./io/gearpump/streaming/transaction/api/OffsetStorage.html" title="interface in io.gearpump.streaming.transaction.api">OffsetStorage</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/util/RecreateRollingFileAppender.html#append(org.apache.log4j.spi.LoggingEvent)">append(LoggingEvent)</a></span> - Method in class io.gearpump.util.<a href="./io/gearpump/util/RecreateRollingFileAppender.html" title="class in io.gearpump.util">RecreateRollingFileAppender</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/StreamAppMasterSummary.html#appId()">appId()</a></span> - Method in class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/StreamAppMasterSummary.html" title="class in io.gearpump.streaming.appmaster">StreamAppMasterSummary</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/task/TaskContext.html#appId()">appId()</a></span> - Method in interface io.gearpump.streaming.task.<a href="./io/gearpump/streaming/task/TaskContext.html" title="interface in io.gearpump.streaming.task">TaskContext</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/task/TaskContextData.html#appId()">appId()</a></span> - Method in class io.gearpump.streaming.task.<a href="./io/gearpump/streaming/task/TaskContextData.html" title="class in io.gearpump.streaming.task">TaskContextData</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/task/TaskWrapper.html#appId()">appId()</a></span> - Method in class io.gearpump.streaming.task.<a href="./io/gearpump/streaming/task/TaskWrapper.html" title="class in io.gearpump.streaming.task">TaskWrapper</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/executor/Executor.html#applicationReady()">applicationReady()</a></span> - Method in class io.gearpump.streaming.executor.<a href="./io/gearpump/streaming/executor/Executor.html" title="class in io.gearpump.streaming.executor">Executor</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/DAG$.html#apply(io.gearpump.util.Graph, int)">apply(Graph<ProcessorDescription, PartitionerDescription>, int)</a></span> - Method in class io.gearpump.streaming.<a href="./io/gearpump/streaming/DAG$.html" title="class in io.gearpump.streaming">DAG$</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/DAG.html#apply(io.gearpump.util.Graph, int)">apply(Graph<ProcessorDescription, PartitionerDescription>, int)</a></span> - Static method in class io.gearpump.streaming.<a href="./io/gearpump/streaming/DAG.html" title="class in io.gearpump.streaming">DAG</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/dsl/Stream$.html#apply(io.gearpump.util.Graph, io.gearpump.streaming.dsl.op.Op, scala.Option, scala.reflect.ClassTag)">apply(Graph<Op, OpEdge>, Op, Option<OpEdge>, ClassTag<T>)</a></span> - Method in class io.gearpump.streaming.dsl.<a href="./io/gearpump/streaming/dsl/Stream$.html" title="class in io.gearpump.streaming.dsl">Stream$</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/dsl/Stream.html#apply(io.gearpump.util.Graph, io.gearpump.streaming.dsl.op.Op, scala.Option, scala.reflect.ClassTag)">apply(Graph<Op, OpEdge>, Op, Option<OpEdge>, ClassTag<T>)</a></span> - Static method in class io.gearpump.streaming.dsl.<a href="./io/gearpump/streaming/dsl/Stream.html" title="class in io.gearpump.streaming.dsl">Stream</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/dsl/StreamApp$.html#apply(java.lang.String, io.gearpump.cluster.client.ClientContext, io.gearpump.cluster.UserConfig)">apply(String, ClientContext, UserConfig)</a></span> - Method in class io.gearpump.streaming.dsl.<a href="./io/gearpump/streaming/dsl/StreamApp$.html" title="class in io.gearpump.streaming.dsl">StreamApp$</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/dsl/StreamApp.html#apply(java.lang.String, io.gearpump.cluster.client.ClientContext, io.gearpump.cluster.UserConfig)">apply(String, ClientContext, UserConfig)</a></span> - Static method in class io.gearpump.streaming.dsl.<a href="./io/gearpump/streaming/dsl/StreamApp.html" title="class in io.gearpump.streaming.dsl">StreamApp</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/executor/TaskLauncher$.html#apply(io.gearpump.cluster.ExecutorContext, io.gearpump.cluster.UserConfig)">apply(ExecutorContext, UserConfig)</a></span> - Method in class io.gearpump.streaming.executor.<a href="./io/gearpump/streaming/executor/TaskLauncher$.html" title="class in io.gearpump.streaming.executor">TaskLauncher$</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/executor/TaskLauncher.html#apply(io.gearpump.cluster.ExecutorContext, io.gearpump.cluster.UserConfig)">apply(ExecutorContext, UserConfig)</a></span> - Static method in class io.gearpump.streaming.executor.<a href="./io/gearpump/streaming/executor/TaskLauncher.html" title="class in io.gearpump.streaming.executor">TaskLauncher</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/Processor$.html#apply(int, java.lang.String, io.gearpump.cluster.UserConfig, scala.reflect.ClassTag)">apply(int, String, UserConfig, ClassTag<T>)</a></span> - Method in class io.gearpump.streaming.<a href="./io/gearpump/streaming/Processor$.html" title="class in io.gearpump.streaming">Processor$</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/Processor$.html#apply(java.lang.Class, int, java.lang.String, io.gearpump.cluster.UserConfig)">apply(Class<T>, int, String, UserConfig)</a></span> - Method in class io.gearpump.streaming.<a href="./io/gearpump/streaming/Processor$.html" title="class in io.gearpump.streaming">Processor$</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/sink/DataSinkProcessor$.html#apply(io.gearpump.streaming.sink.DataSink, int, java.lang.String, io.gearpump.cluster.UserConfig, akka.actor.ActorSystem)">apply(DataSink, int, String, UserConfig, ActorSystem)</a></span> - Method in class io.gearpump.streaming.sink.<a href="./io/gearpump/streaming/sink/DataSinkProcessor$.html" title="class in io.gearpump.streaming.sink">DataSinkProcessor$</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/sink/DataSinkProcessor.html#apply(io.gearpump.streaming.sink.DataSink, int, java.lang.String, io.gearpump.cluster.UserConfig, akka.actor.ActorSystem)">apply(DataSink, int, String, UserConfig, ActorSystem)</a></span> - Static method in class io.gearpump.streaming.sink.<a href="./io/gearpump/streaming/sink/DataSinkProcessor.html" title="class in io.gearpump.streaming.sink">DataSinkProcessor</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/source/DataSourceProcessor$.html#apply(io.gearpump.streaming.source.DataSource, int, java.lang.String, io.gearpump.cluster.UserConfig, akka.actor.ActorSystem)">apply(DataSource, int, String, UserConfig, ActorSystem)</a></span> - Method in class io.gearpump.streaming.source.<a href="./io/gearpump/streaming/source/DataSourceProcessor$.html" title="class in io.gearpump.streaming.source">DataSourceProcessor$</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/source/DataSourceProcessor.html#apply(io.gearpump.streaming.source.DataSource, int, java.lang.String, io.gearpump.cluster.UserConfig, akka.actor.ActorSystem)">apply(DataSource, int, String, UserConfig, ActorSystem)</a></span> - Static method in class io.gearpump.streaming.source.<a href="./io/gearpump/streaming/source/DataSourceProcessor.html" title="class in io.gearpump.streaming.source">DataSourceProcessor</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/StreamApplication$.html#apply(java.lang.String, io.gearpump.util.Graph, io.gearpump.cluster.UserConfig)">apply(String, Graph<T, P>, UserConfig)</a></span> - Method in class io.gearpump.streaming.<a href="./io/gearpump/streaming/StreamApplication$.html" title="class in io.gearpump.streaming">StreamApplication$</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/StreamApplication.html#apply(java.lang.String, io.gearpump.util.Graph, io.gearpump.cluster.UserConfig)">apply(String, Graph<T, P>, UserConfig)</a></span> - Static method in class io.gearpump.streaming.<a href="./io/gearpump/streaming/StreamApplication.html" title="class in io.gearpump.streaming">StreamApplication</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/appmaster/AppMaster.html" title="class in io.gearpump.streaming.appmaster"><span class="strong">AppMaster</span></a> - Class in <a href="./io/gearpump/streaming/appmaster/package-summary.html">io.gearpump.streaming.appmaster</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/AppMaster.html#AppMaster(io.gearpump.cluster.AppMasterContext, io.gearpump.cluster.AppDescription)">AppMaster(AppMasterContext, AppDescription)</a></span> - Constructor for class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/AppMaster.html" title="class in io.gearpump.streaming.appmaster">AppMaster</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/javaapi/StreamApplication.html#appMaster()">appMaster()</a></span> - Method in class io.gearpump.streaming.javaapi.<a href="./io/gearpump/streaming/javaapi/StreamApplication.html" title="class in io.gearpump.streaming.javaapi">StreamApplication</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/StreamApplication.html#appMaster()">appMaster()</a></span> - Method in class io.gearpump.streaming.<a href="./io/gearpump/streaming/StreamApplication.html" title="class in io.gearpump.streaming">StreamApplication</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/task/TaskContext.html#appMaster()">appMaster()</a></span> - Method in interface io.gearpump.streaming.task.<a href="./io/gearpump/streaming/task/TaskContext.html" title="interface in io.gearpump.streaming.task">TaskContext</a></dt> -<dd> -<div class="block">The actorRef of AppMaster</div> -</dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/task/TaskContextData.html#appMaster()">appMaster()</a></span> - Method in class io.gearpump.streaming.task.<a href="./io/gearpump/streaming/task/TaskContextData.html" title="class in io.gearpump.streaming.task">TaskContextData</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/task/TaskWrapper.html#appMaster()">appMaster()</a></span> - Method in class io.gearpump.streaming.task.<a href="./io/gearpump/streaming/task/TaskWrapper.html" title="class in io.gearpump.streaming.task">TaskWrapper</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/appmaster/AppMaster$.html" title="class in io.gearpump.streaming.appmaster"><span class="strong">AppMaster$</span></a> - Class in <a href="./io/gearpump/streaming/appmaster/package-summary.html">io.gearpump.streaming.appmaster</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/AppMaster$.html#AppMaster$()">AppMaster$()</a></span> - Constructor for class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/AppMaster$.html" title="class in io.gearpump.streaming.appmaster">AppMaster$</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/appmaster/AppMaster.AllocateResourceTimeOut$.html" title="class in io.gearpump.streaming.appmaster"><span class="strong">AppMaster.AllocateResourceTimeOut$</span></a> - Class in <a href="./io/gearpump/streaming/appmaster/package-summary.html">io.gearpump.streaming.appmaster</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/AppMaster.AllocateResourceTimeOut$.html#AppMaster.AllocateResourceTimeOut$()">AppMaster.AllocateResourceTimeOut$()</a></span> - Constructor for class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/AppMaster.AllocateResourceTimeOut$.html" title="class in io.gearpump.streaming.appmaster">AppMaster.AllocateResourceTimeOut$</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/appmaster/AppMaster.ExecutorBrief.html" title="class in io.gearpump.streaming.appmaster"><span class="strong">AppMaster.ExecutorBrief</span></a> - Class in <a href="./io/gearpump/streaming/appmaster/package-summary.html">io.gearpump.streaming.appmaster</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/AppMaster.ExecutorBrief.html#AppMaster.ExecutorBrief(int, java.lang.String, int, java.lang.String)">AppMaster.ExecutorBrief(int, String, int, String)</a></span> - Constructor for class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/AppMaster.ExecutorBrief.html" title="class in io.gearpump.streaming.appmaster">AppMaster.ExecutorBrief</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/appmaster/AppMaster.ExecutorBrief$.html" title="class in io.gearpump.streaming.appmaster"><span class="strong">AppMaster.ExecutorBrief$</span></a> - Class in <a href="./io/gearpump/streaming/appmaster/package-summary.html">io.gearpump.streaming.appmaster</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/AppMaster.ExecutorBrief$.html#AppMaster.ExecutorBrief$()">AppMaster.ExecutorBrief$()</a></span> - Constructor for class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/AppMaster.ExecutorBrief$.html" title="class in io.gearpump.streaming.appmaster">AppMaster.ExecutorBrief$</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/appmaster/AppMaster.LookupTaskActorRef.html" title="class in io.gearpump.streaming.appmaster"><span class="strong">AppMaster.LookupTaskActorRef</span></a> - Class in <a href="./io/gearpump/streaming/appmaster/package-summary.html">io.gearpump.streaming.appmaster</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/AppMaster.LookupTaskActorRef.html#AppMaster.LookupTaskActorRef(io.gearpump.streaming.task.TaskId)">AppMaster.LookupTaskActorRef(TaskId)</a></span> - Constructor for class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/AppMaster.LookupTaskActorRef.html" title="class in io.gearpump.streaming.appmaster">AppMaster.LookupTaskActorRef</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/appmaster/AppMaster.LookupTaskActorRef$.html" title="class in io.gearpump.streaming.appmaster"><span class="strong">AppMaster.LookupTaskActorRef$</span></a> - Class in <a href="./io/gearpump/streaming/appmaster/package-summary.html">io.gearpump.streaming.appmaster</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/AppMaster.LookupTaskActorRef$.html#AppMaster.LookupTaskActorRef$()">AppMaster.LookupTaskActorRef$()</a></span> - Constructor for class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/AppMaster.LookupTaskActorRef$.html" title="class in io.gearpump.streaming.appmaster">AppMaster.LookupTaskActorRef$</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/appmaster/AppMaster.ServiceNotAvailableException.html" title="class in io.gearpump.streaming.appmaster"><span class="strong">AppMaster.ServiceNotAvailableException</span></a> - Exception in <a href="./io/gearpump/streaming/appmaster/package-summary.html">io.gearpump.streaming.appmaster</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/AppMaster.ServiceNotAvailableException.html#AppMaster.ServiceNotAvailableException(java.lang.String)">AppMaster.ServiceNotAvailableException(String)</a></span> - Constructor for exception io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/AppMaster.ServiceNotAvailableException.html" title="class in io.gearpump.streaming.appmaster">AppMaster.ServiceNotAvailableException</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/appmaster/AppMaster.TaskActorRef.html" title="class in io.gearpump.streaming.appmaster"><span class="strong">AppMaster.TaskActorRef</span></a> - Class in <a href="./io/gearpump/streaming/appmaster/package-summary.html">io.gearpump.streaming.appmaster</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/AppMaster.TaskActorRef.html#AppMaster.TaskActorRef(akka.actor.ActorRef)">AppMaster.TaskActorRef(ActorRef)</a></span> - Constructor for class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/AppMaster.TaskActorRef.html" title="class in io.gearpump.streaming.appmaster">AppMaster.TaskActorRef</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/appmaster/AppMaster.TaskActorRef$.html" title="class in io.gearpump.streaming.appmaster"><span class="strong">AppMaster.TaskActorRef$</span></a> - Class in <a href="./io/gearpump/streaming/appmaster/package-summary.html">io.gearpump.streaming.appmaster</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/AppMaster.TaskActorRef$.html#AppMaster.TaskActorRef$()">AppMaster.TaskActorRef$()</a></span> - Constructor for class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/AppMaster.TaskActorRef$.html" title="class in io.gearpump.streaming.appmaster">AppMaster.TaskActorRef$</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/AppMaster.html#appMasterService()">appMasterService()</a></span> - Method in class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/AppMaster.html" title="class in io.gearpump.streaming.appmaster">AppMaster</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/appmaster/AppMasterTaskDetail.html" title="class in io.gearpump.streaming.appmaster"><span class="strong">AppMasterTaskDetail</span></a> - Class in <a href="./io/gearpump/streaming/appmaster/package-summary.html">io.gearpump.streaming.appmaster</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/AppMasterTaskDetail.html#AppMasterTaskDetail(scala.collection.immutable.Map)">AppMasterTaskDetail(Map<TaskId, Object>)</a></span> - Constructor for class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/AppMasterTaskDetail.html" title="class in io.gearpump.streaming.appmaster">AppMasterTaskDetail</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/appmaster/AppMasterTaskDetail$.html" title="class in io.gearpump.streaming.appmaster"><span class="strong">AppMasterTaskDetail$</span></a> - Class in <a href="./io/gearpump/streaming/appmaster/package-summary.html">io.gearpump.streaming.appmaster</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/AppMasterTaskDetail$.html#AppMasterTaskDetail$()">AppMasterTaskDetail$()</a></span> - Constructor for class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/AppMasterTaskDetail$.html" title="class in io.gearpump.streaming.appmaster">AppMasterTaskDetail$</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/AppMasterToExecutor.html" title="class in io.gearpump.streaming"><span class="strong">AppMasterToExecutor</span></a> - Class in <a href="./io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/AppMasterToExecutor.html#AppMasterToExecutor()">AppMasterToExecutor()</a></span> - Constructor for class io.gearpump.streaming.<a href="./io/gearpump/streaming/AppMasterToExecutor.html" title="class in io.gearpump.streaming">AppMasterToExecutor</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/AppMasterToExecutor$.html" title="class in io.gearpump.streaming"><span class="strong">AppMasterToExecutor$</span></a> - Class in <a href="./io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/AppMasterToExecutor$.html#AppMasterToExecutor$()">AppMasterToExecutor$()</a></span> - Constructor for class io.gearpump.streaming.<a href="./io/gearpump/streaming/AppMasterToExecutor$.html" title="class in io.gearpump.streaming">AppMasterToExecutor$</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/AppMasterToExecutor.ChangeTask.html" title="class in io.gearpump.streaming"><span class="strong">AppMasterToExecutor.ChangeTask</span></a> - Class in <a href="./io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/AppMasterToExecutor.ChangeTask.html#AppMasterToExecutor.ChangeTask(io.gearpump.streaming.task.TaskId, int, io.gearpump.streaming.LifeTime, scala.collection.immutable.List)">AppMasterToExecutor.ChangeTask(TaskId, int, LifeTime, List<Subscriber>)</a></span> - Constructor for class io.gearpump.streaming.<a href="./io/gearpump/streaming/AppMasterToExecutor.ChangeTask.html" title="class in io.gearpump.streaming">AppMasterToExecutor.ChangeTask</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/AppMasterToExecutor.ChangeTask$.html" title="class in io.gearpump.streaming"><span class="strong">AppMasterToExecutor.ChangeTask$</span></a> - Class in <a href="./io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/AppMasterToExecutor.ChangeTask$.html#AppMasterToExecutor.ChangeTask$()">AppMasterToExecutor.ChangeTask$()</a></span> - Constructor for class io.gearpump.streaming.<a href="./io/gearpump/streaming/AppMasterToExecutor.ChangeTask$.html" title="class in io.gearpump.streaming">AppMasterToExecutor.ChangeTask$</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/AppMasterToExecutor.ChangeTasks.html" title="class in io.gearpump.streaming"><span class="strong">AppMasterToExecutor.ChangeTasks</span></a> - Class in <a href="./io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt> -<dd> -<div class="block">dagVersion, life, and subscribers will be changed on target task list.</div> -</dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/AppMasterToExecutor.ChangeTasks.html#AppMasterToExecutor.ChangeTasks(scala.collection.immutable.List, int, io.gearpump.streaming.LifeTime, scala.collection.immutable.List)">AppMasterToExecutor.ChangeTasks(List<TaskId>, int, LifeTime, List<Subscriber>)</a></span> - Constructor for class io.gearpump.streaming.<a href="./io/gearpump/streaming/AppMasterToExecutor.ChangeTasks.html" title="class in io.gearpump.streaming">AppMasterToExecutor.ChangeTasks</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/AppMasterToExecutor.ChangeTasks$.html" title="class in io.gearpump.streaming"><span class="strong">AppMasterToExecutor.ChangeTasks$</span></a> - Class in <a href="./io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/AppMasterToExecutor.ChangeTasks$.html#AppMasterToExecutor.ChangeTasks$()">AppMasterToExecutor.ChangeTasks$()</a></span> - Constructor for class io.gearpump.streaming.<a href="./io/gearpump/streaming/AppMasterToExecutor.ChangeTasks$.html" title="class in io.gearpump.streaming">AppMasterToExecutor.ChangeTasks$</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/AppMasterToExecutor.LaunchTasks.html" title="class in io.gearpump.streaming"><span class="strong">AppMasterToExecutor.LaunchTasks</span></a> - Class in <a href="./io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/AppMasterToExecutor.LaunchTasks.html#AppMasterToExecutor.LaunchTasks(scala.collection.immutable.List, int, io.gearpump.streaming.ProcessorDescription, scala.collection.immutable.List)">AppMasterToExecutor.LaunchTasks(List<TaskId>, int, ProcessorDescription, List<Subscriber>)</a></span> - Constructor for class io.gearpump.streaming.<a href="./io/gearpump/streaming/AppMasterToExecutor.LaunchTasks.html" title="class in io.gearpump.streaming">AppMasterToExecutor.LaunchTasks</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/AppMasterToExecutor.LaunchTasks$.html" title="class in io.gearpump.streaming"><span class="strong">AppMasterToExecutor.LaunchTasks$</span></a> - Class in <a href="./io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/AppMasterToExecutor.LaunchTasks$.html#AppMasterToExecutor.LaunchTasks$()">AppMasterToExecutor.LaunchTasks$()</a></span> - Constructor for class io.gearpump.streaming.<a href="./io/gearpump/streaming/AppMasterToExecutor.LaunchTasks$.html" title="class in io.gearpump.streaming">AppMasterToExecutor.LaunchTasks$</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/AppMasterToExecutor.MsgLostException.html" title="class in io.gearpump.streaming"><span class="strong">AppMasterToExecutor.MsgLostException</span></a> - Exception in <a href="./io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/AppMasterToExecutor.MsgLostException.html#AppMasterToExecutor.MsgLostException()">AppMasterToExecutor.MsgLostException()</a></span> - Constructor for exception io.gearpump.streaming.<a href="./io/gearpump/streaming/AppMasterToExecutor.MsgLostException.html" title="class in io.gearpump.streaming">AppMasterToExecutor.MsgLostException</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/AppMasterToExecutor.RestartClockService$.html" title="class in io.gearpump.streaming"><span class="strong">AppMasterToExecutor.RestartClockService$</span></a> - Class in <a href="./io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/AppMasterToExecutor.RestartClockService$.html#AppMasterToExecutor.RestartClockService$()">AppMasterToExecutor.RestartClockService$()</a></span> - Constructor for class io.gearpump.streaming.<a href="./io/gearpump/streaming/AppMasterToExecutor.RestartClockService$.html" title="class in io.gearpump.streaming">AppMasterToExecutor.RestartClockService$</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/AppMasterToExecutor.Start.html" title="class in io.gearpump.streaming"><span class="strong">AppMasterToExecutor.Start</span></a> - Class in <a href="./io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/AppMasterToExecutor.Start.html#AppMasterToExecutor.Start(long, int)">AppMasterToExecutor.Start(long, int)</a></span> - Constructor for class io.gearpump.streaming.<a href="./io/gearpump/streaming/AppMasterToExecutor.Start.html" title="class in io.gearpump.streaming">AppMasterToExecutor.Start</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/AppMasterToExecutor.Start$.html" title="class in io.gearpump.streaming"><span class="strong">AppMasterToExecutor.Start$</span></a> - Class in <a href="./io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/AppMasterToExecutor.Start$.html#AppMasterToExecutor.Start$()">AppMasterToExecutor.Start$()</a></span> - Constructor for class io.gearpump.streaming.<a href="./io/gearpump/streaming/AppMasterToExecutor.Start$.html" title="class in io.gearpump.streaming">AppMasterToExecutor.Start$</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/AppMasterToExecutor.StartAllTasks.html" title="class in io.gearpump.streaming"><span class="strong">AppMasterToExecutor.StartAllTasks</span></a> - Class in <a href="./io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/AppMasterToExecutor.StartAllTasks.html#AppMasterToExecutor.StartAllTasks(io.gearpump.streaming.appmaster.TaskRegistry.TaskLocations, long, int)">AppMasterToExecutor.StartAllTasks(TaskRegistry.TaskLocations, long, int)</a></span> - Constructor for class io.gearpump.streaming.<a href="./io/gearpump/streaming/AppMasterToExecutor.StartAllTasks.html" title="class in io.gearpump.streaming">AppMasterToExecutor.StartAllTasks</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/AppMasterToExecutor.StartAllTasks$.html" title="class in io.gearpump.streaming"><span class="strong">AppMasterToExecutor.StartAllTasks$</span></a> - Class in <a href="./io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/AppMasterToExecutor.StartAllTasks$.html#AppMasterToExecutor.StartAllTasks$()">AppMasterToExecutor.StartAllTasks$()</a></span> - Constructor for class io.gearpump.streaming.<a href="./io/gearpump/streaming/AppMasterToExecutor.StartAllTasks$.html" title="class in io.gearpump.streaming">AppMasterToExecutor.StartAllTasks$</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/AppMasterToExecutor.TaskChanged.html" title="class in io.gearpump.streaming"><span class="strong">AppMasterToExecutor.TaskChanged</span></a> - Class in <a href="./io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/AppMasterToExecutor.TaskChanged.html#AppMasterToExecutor.TaskChanged(io.gearpump.streaming.task.TaskId, int)">AppMasterToExecutor.TaskChanged(TaskId, int)</a></span> - Constructor for class io.gearpump.streaming.<a href="./io/gearpump/streaming/AppMasterToExecutor.TaskChanged.html" title="class in io.gearpump.streaming">AppMasterToExecutor.TaskChanged</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/AppMasterToExecutor.TaskChanged$.html" title="class in io.gearpump.streaming"><span class="strong">AppMasterToExecutor.TaskChanged$</span></a> - Class in <a href="./io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/AppMasterToExecutor.TaskChanged$.html#AppMasterToExecutor.TaskChanged$()">AppMasterToExecutor.TaskChanged$()</a></span> - Constructor for class io.gearpump.streaming.<a href="./io/gearpump/streaming/AppMasterToExecutor.TaskChanged$.html" title="class in io.gearpump.streaming">AppMasterToExecutor.TaskChanged$</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/AppMasterToExecutor.TaskRegistered.html" title="class in io.gearpump.streaming"><span class="strong">AppMasterToExecutor.TaskRegistered</span></a> - Class in <a href="./io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/AppMasterToExecutor.TaskRegistered.html#AppMasterToExecutor.TaskRegistered(io.gearpump.streaming.task.TaskId, int)">AppMasterToExecutor.TaskRegistered(TaskId, int)</a></span> - Constructor for class io.gearpump.streaming.<a href="./io/gearpump/streaming/AppMasterToExecutor.TaskRegistered.html" title="class in io.gearpump.streaming">AppMasterToExecutor.TaskRegistered</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/AppMasterToExecutor.TaskRegistered$.html" title="class in io.gearpump.streaming"><span class="strong">AppMasterToExecutor.TaskRegistered$</span></a> - Class in <a href="./io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/AppMasterToExecutor.TaskRegistered$.html#AppMasterToExecutor.TaskRegistered$()">AppMasterToExecutor.TaskRegistered$()</a></span> - Constructor for class io.gearpump.streaming.<a href="./io/gearpump/streaming/AppMasterToExecutor.TaskRegistered$.html" title="class in io.gearpump.streaming">AppMasterToExecutor.TaskRegistered$</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/AppMasterToExecutor.TaskRejected.html" title="class in io.gearpump.streaming"><span class="strong">AppMasterToExecutor.TaskRejected</span></a> - Class in <a href="./io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/AppMasterToExecutor.TaskRejected.html#AppMasterToExecutor.TaskRejected(io.gearpump.streaming.task.TaskId)">AppMasterToExecutor.TaskRejected(TaskId)</a></span> - Constructor for class io.gearpump.streaming.<a href="./io/gearpump/streaming/AppMasterToExecutor.TaskRejected.html" title="class in io.gearpump.streaming">AppMasterToExecutor.TaskRejected</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/AppMasterToExecutor.TaskRejected$.html" title="class in io.gearpump.streaming"><span class="strong">AppMasterToExecutor.TaskRejected$</span></a> - Class in <a href="./io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/AppMasterToExecutor.TaskRejected$.html#AppMasterToExecutor.TaskRejected$()">AppMasterToExecutor.TaskRejected$()</a></span> - Constructor for class io.gearpump.streaming.<a href="./io/gearpump/streaming/AppMasterToExecutor.TaskRejected$.html" title="class in io.gearpump.streaming">AppMasterToExecutor.TaskRejected$</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/AppMasterToExecutor.TasksChanged$.html" title="class in io.gearpump.streaming"><span class="strong">AppMasterToExecutor.TasksChanged$</span></a> - Class in <a href="./io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/AppMasterToExecutor.TasksChanged$.html#AppMasterToExecutor.TasksChanged$()">AppMasterToExecutor.TasksChanged$()</a></span> - Constructor for class io.gearpump.streaming.<a href="./io/gearpump/streaming/AppMasterToExecutor.TasksChanged$.html" title="class in io.gearpump.streaming">AppMasterToExecutor.TasksChanged$</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/AppMasterToExecutor.TasksLaunched$.html" title="class in io.gearpump.streaming"><span class="strong">AppMasterToExecutor.TasksLaunched$</span></a> - Class in <a href="./io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/AppMasterToExecutor.TasksLaunched$.html#AppMasterToExecutor.TasksLaunched$()">AppMasterToExecutor.TasksLaunched$()</a></span> - Constructor for class io.gearpump.streaming.<a href="./io/gearpump/streaming/AppMasterToExecutor.TasksLaunched$.html" title="class in io.gearpump.streaming">AppMasterToExecutor.TasksLaunched$</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/AppMasterToMaster.html" title="class in io.gearpump.streaming"><span class="strong">AppMasterToMaster</span></a> - Class in <a href="./io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/AppMasterToMaster.html#AppMasterToMaster()">AppMasterToMaster()</a></span> - Constructor for class io.gearpump.streaming.<a href="./io/gearpump/streaming/AppMasterToMaster.html" title="class in io.gearpump.streaming">AppMasterToMaster</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/AppMasterToMaster$.html" title="class in io.gearpump.streaming"><span class="strong">AppMasterToMaster$</span></a> - Class in <a href="./io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/AppMasterToMaster$.html#AppMasterToMaster$()">AppMasterToMaster$()</a></span> - Constructor for class io.gearpump.streaming.<a href="./io/gearpump/streaming/AppMasterToMaster$.html" title="class in io.gearpump.streaming">AppMasterToMaster$</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/AppMasterToMaster.StallingTasks.html" title="class in io.gearpump.streaming"><span class="strong">AppMasterToMaster.StallingTasks</span></a> - Class in <a href="./io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/AppMasterToMaster.StallingTasks.html#AppMasterToMaster.StallingTasks(scala.collection.immutable.List)">AppMasterToMaster.StallingTasks(List<TaskId>)</a></span> - Constructor for class io.gearpump.streaming.<a href="./io/gearpump/streaming/AppMasterToMaster.StallingTasks.html" title="class in io.gearpump.streaming">AppMasterToMaster.StallingTasks</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/AppMasterToMaster.StallingTasks$.html" title="class in io.gearpump.streaming"><span class="strong">AppMasterToMaster.StallingTasks$</span></a> - Class in <a href="./io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/AppMasterToMaster.StallingTasks$.html#AppMasterToMaster.StallingTasks$()">AppMasterToMaster.StallingTasks$()</a></span> - Constructor for class io.gearpump.streaming.<a href="./io/gearpump/streaming/AppMasterToMaster.StallingTasks$.html" title="class in io.gearpump.streaming">AppMasterToMaster.StallingTasks$</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/StreamAppMasterSummary.html#appName()">appName()</a></span> - Method in class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/StreamAppMasterSummary.html" title="class in io.gearpump.streaming.appmaster">StreamAppMasterSummary</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/SubmitApplicationRequest.html#appName()">appName()</a></span> - Method in class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/SubmitApplicationRequest.html" title="class in io.gearpump.streaming.appmaster">SubmitApplicationRequest</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/task/TaskContext.html#appName()">appName()</a></span> - Method in interface io.gearpump.streaming.task.<a href="./io/gearpump/streaming/task/TaskContext.html" title="interface in io.gearpump.streaming.task">TaskContext</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/task/TaskContextData.html#appName()">appName()</a></span> - Method in class io.gearpump.streaming.task.<a href="./io/gearpump/streaming/task/TaskContextData.html" title="class in io.gearpump.streaming.task">TaskContextData</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/task/TaskWrapper.html#appName()">appName()</a></span> - Method in class io.gearpump.streaming.task.<a href="./io/gearpump/streaming/task/TaskWrapper.html" title="class in io.gearpump.streaming.task">TaskWrapper</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/StreamAppMasterSummary.html#appType()">appType()</a></span> - Method in class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/StreamAppMasterSummary.html" title="class in io.gearpump.streaming.appmaster">StreamAppMasterSummary</a></dt> -<dd> </dd> -</dl> -<a name="_B_"> -<!-- --> -</a> -<h2 class="title">B</h2> -<dl> -<dt><span class="strong"><a href="./io/gearpump/streaming/LifeTime.html#birth()">birth()</a></span> - Method in class io.gearpump.streaming.<a href="./io/gearpump/streaming/LifeTime.html" title="class in io.gearpump.streaming">LifeTime</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/task/SerializedMessage.html#bytes()">bytes()</a></span> - Method in class io.gearpump.streaming.task.<a href="./io/gearpump/streaming/task/SerializedMessage.html" title="class in io.gearpump.streaming.task">SerializedMessage</a></dt> -<dd> </dd> -</dl> -<a name="_C_"> -<!-- --> -</a> -<h2 class="title">C</h2> -<dl> -<dt><span class="strong"><a href="./io/gearpump/streaming/ExecutorToAppMaster.MessageLoss.html#cause()">cause()</a></span> - Method in class io.gearpump.streaming.<a href="./io/gearpump/streaming/ExecutorToAppMaster.MessageLoss.html" title="class in io.gearpump.streaming">ExecutorToAppMaster.MessageLoss</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/task/Subscription.html#changeLife(io.gearpump.streaming.LifeTime)">changeLife(LifeTime)</a></span> - Method in class io.gearpump.streaming.task.<a href="./io/gearpump/streaming/task/Subscription.html" title="class in io.gearpump.streaming.task">Subscription</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/ClockService.HealthChecker.html#check(long, scala.collection.immutable.Map, io.gearpump.streaming.DAG, long)">check(long, Map<Object, ClockService.ProcessorClock>, DAG, long)</a></span> - Method in class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/ClockService.HealthChecker.html" title="class in io.gearpump.streaming.appmaster">ClockService.HealthChecker</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/util/RecreateRollingFileAppender.html#checkFileInterval">checkFileInterval</a></span> - Variable in class io.gearpump.util.<a href="./io/gearpump/util/RecreateRollingFileAppender.html" title="class in io.gearpump.util">RecreateRollingFileAppender</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/task/TaskActor.SecurityChecker.html#checkMessage(io.gearpump.Message, akka.actor.ActorRef)">checkMessage(Message, ActorRef)</a></span> - Method in class io.gearpump.streaming.task.<a href="./io/gearpump/streaming/task/TaskActor.SecurityChecker.html" title="class in io.gearpump.streaming.task">TaskActor.SecurityChecker</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/state/api/PersistentState.html#checkpoint()">checkpoint()</a></span> - Method in interface io.gearpump.streaming.state.api.<a href="./io/gearpump/streaming/state/api/PersistentState.html" title="interface in io.gearpump.streaming.state.api">PersistentState</a></dt> -<dd> -<div class="block">get a binary snapshot of state - usually invoked by the framework</div> -</dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/state/impl/CheckpointManager.html#checkpoint(long, byte[])">checkpoint(long, byte[])</a></span> - Method in class io.gearpump.streaming.state.impl.<a href="./io/gearpump/streaming/state/impl/CheckpointManager.html" title="class in io.gearpump.streaming.state.impl">CheckpointManager</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/state/impl/NonWindowState.html#checkpoint()">checkpoint()</a></span> - Method in class io.gearpump.streaming.state.impl.<a href="./io/gearpump/streaming/state/impl/NonWindowState.html" title="class in io.gearpump.streaming.state.impl">NonWindowState</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/state/impl/WindowState.html#checkpoint()">checkpoint()</a></span> - Method in class io.gearpump.streaming.state.impl.<a href="./io/gearpump/streaming/state/impl/WindowState.html" title="class in io.gearpump.streaming.state.impl">WindowState</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/task/CheckpointClock.html" title="class in io.gearpump.streaming.task"><span class="strong">CheckpointClock</span></a> - Class in <a href="./io/gearpump/streaming/task/package-summary.html">io.gearpump.streaming.task</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/task/CheckpointClock.html#CheckpointClock(scala.Option)">CheckpointClock(Option<Object>)</a></span> - Constructor for class io.gearpump.streaming.task.<a href="./io/gearpump/streaming/task/CheckpointClock.html" title="class in io.gearpump.streaming.task">CheckpointClock</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/task/CheckpointClock$.html" title="class in io.gearpump.streaming.task"><span class="strong">CheckpointClock$</span></a> - Class in <a href="./io/gearpump/streaming/task/package-summary.html">io.gearpump.streaming.task</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/task/CheckpointClock$.html#CheckpointClock$()">CheckpointClock$()</a></span> - Constructor for class io.gearpump.streaming.task.<a href="./io/gearpump/streaming/task/CheckpointClock$.html" title="class in io.gearpump.streaming.task">CheckpointClock$</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/state/api/PersistentTask.html#checkpointInterval()">checkpointInterval()</a></span> - Method in class io.gearpump.streaming.state.api.<a href="./io/gearpump/streaming/state/api/PersistentTask.html" title="class in io.gearpump.streaming.state.api">PersistentTask</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/state/api/PersistentTask.html#checkpointManager()">checkpointManager()</a></span> - Method in class io.gearpump.streaming.state.api.<a href="./io/gearpump/streaming/state/api/PersistentTask.html" title="class in io.gearpump.streaming.state.api">PersistentTask</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/state/impl/CheckpointManager.html" title="class in io.gearpump.streaming.state.impl"><span class="strong">CheckpointManager</span></a> - Class in <a href="./io/gearpump/streaming/state/impl/package-summary.html">io.gearpump.streaming.state.impl</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/state/impl/CheckpointManager.html#CheckpointManager(long, io.gearpump.streaming.transaction.api.CheckpointStore)">CheckpointManager(long, CheckpointStore)</a></span> - Constructor for class io.gearpump.streaming.state.impl.<a href="./io/gearpump/streaming/state/impl/CheckpointManager.html" title="class in io.gearpump.streaming.state.impl">CheckpointManager</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/state/api/PersistentTask.html#checkpointStore()">checkpointStore()</a></span> - Method in class io.gearpump.streaming.state.api.<a href="./io/gearpump/streaming/state/api/PersistentTask.html" title="class in io.gearpump.streaming.state.api">PersistentTask</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/transaction/api/CheckpointStore.html" title="interface in io.gearpump.streaming.transaction.api"><span class="strong">CheckpointStore</span></a> - Interface in <a href="./io/gearpump/streaming/transaction/api/package-summary.html">io.gearpump.streaming.transaction.api</a></dt> -<dd> -<div class="block">CheckpointStore persistently stores mapping of timestamp to checkpoint - it's possible that two checkpoints have the same timestamp - CheckpointStore needs to handle this either during write or read</div> -</dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/state/api/PersistentTask.html#checkpointStoreFactory()">checkpointStoreFactory()</a></span> - Method in class io.gearpump.streaming.state.api.<a href="./io/gearpump/streaming/state/api/PersistentTask.html" title="class in io.gearpump.streaming.state.api">PersistentTask</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/transaction/api/CheckpointStoreFactory.html" title="interface in io.gearpump.streaming.transaction.api"><span class="strong">CheckpointStoreFactory</span></a> - Interface in <a href="./io/gearpump/streaming/transaction/api/package-summary.html">io.gearpump.streaming.transaction.api</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/state/api/MonoidState.html#checkpointTime()">checkpointTime()</a></span> - Method in class io.gearpump.streaming.state.api.<a href="./io/gearpump/streaming/state/api/MonoidState.html" title="class in io.gearpump.streaming.state.api">MonoidState</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/ClockService.StoredStartClock.html#clock()">clock()</a></span> - Method in class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/ClockService.StoredStartClock.html" title="class in io.gearpump.streaming.appmaster">ClockService.StoredStartClock</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/StreamAppMasterSummary.html#clock()">clock()</a></span> - Method in class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/StreamAppMasterSummary.html" title="class in io.gearpump.streaming.appmaster">StreamAppMasterSummary</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/task/CheckpointClock.html#clock()">clock()</a></span> - Method in class io.gearpump.streaming.task.<a href="./io/gearpump/streaming/task/CheckpointClock.html" title="class in io.gearpump.streaming.task">CheckpointClock</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/task/LatestMinClock.html#clock()">clock()</a></span> - Method in class io.gearpump.streaming.task.<a href="./io/gearpump/streaming/task/LatestMinClock.html" title="class in io.gearpump.streaming.task">LatestMinClock</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/task/ReportCheckpointClock.html#clock()">clock()</a></span> - Method in class io.gearpump.streaming.task.<a href="./io/gearpump/streaming/task/ReportCheckpointClock.html" title="class in io.gearpump.streaming.task">ReportCheckpointClock</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/task/StartClock.html#clock()">clock()</a></span> - Method in class io.gearpump.streaming.task.<a href="./io/gearpump/streaming/task/StartClock.html" title="class in io.gearpump.streaming.task">StartClock</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/task/TaskActor.html#CLOCK_REPORT_INTERVAL()">CLOCK_REPORT_INTERVAL()</a></span> - Method in class io.gearpump.streaming.task.<a href="./io/gearpump/streaming/task/TaskActor.html" title="class in io.gearpump.streaming.task">TaskActor</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/task/TaskActor$.html#CLOCK_SYNC_TIMEOUT_INTERVAL()">CLOCK_SYNC_TIMEOUT_INTERVAL()</a></span> - Method in class io.gearpump.streaming.task.<a href="./io/gearpump/streaming/task/TaskActor$.html" title="class in io.gearpump.streaming.task">TaskActor$</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/task/TaskActor.html#CLOCK_SYNC_TIMEOUT_INTERVAL()">CLOCK_SYNC_TIMEOUT_INTERVAL()</a></span> - Static method in class io.gearpump.streaming.task.<a href="./io/gearpump/streaming/task/TaskActor.html" title="class in io.gearpump.streaming.task">TaskActor</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/task/ClockEvent.html" title="interface in io.gearpump.streaming.task"><span class="strong">ClockEvent</span></a> - Interface in <a href="./io/gearpump/streaming/task/package-summary.html">io.gearpump.streaming.task</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/ClockService.ChangeToNewDAGSuccess.html#clocks()">clocks()</a></span> - Method in class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/ClockService.ChangeToNewDAGSuccess.html" title="class in io.gearpump.streaming.appmaster">ClockService.ChangeToNewDAGSuccess</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/ClockService.html#clocks()">clocks()</a></span> - Method in class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/ClockService.html" title="class in io.gearpump.streaming.appmaster">ClockService</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/appmaster/ClockService.html" title="class in io.gearpump.streaming.appmaster"><span class="strong">ClockService</span></a> - Class in <a href="./io/gearpump/streaming/appmaster/package-summary.html">io.gearpump.streaming.appmaster</a></dt> -<dd> -<div class="block">The clockService will maintain a global view of message timestamp in the application</div> -</dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/ClockService.html#ClockService(io.gearpump.streaming.DAG, io.gearpump.streaming.storage.AppDataStore)">ClockService(DAG, AppDataStore)</a></span> - Constructor for class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/ClockService.html" title="class in io.gearpump.streaming.appmaster">ClockService</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/ClockService.html#clockService()">clockService()</a></span> - Method in class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/ClockService.html" title="class in io.gearpump.streaming.appmaster">ClockService</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/appmaster/ClockService$.html" title="class in io.gearpump.streaming.appmaster"><span class="strong">ClockService$</span></a> - Class in <a href="./io/gearpump/streaming/appmaster/package-summary.html">io.gearpump.streaming.appmaster</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/ClockService$.html#ClockService$()">ClockService$()</a></span> - Constructor for class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/ClockService$.html" title="class in io.gearpump.streaming.appmaster">ClockService$</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/appmaster/ClockService.ChangeToNewDAG.html" title="class in io.gearpump.streaming.appmaster"><span class="strong">ClockService.ChangeToNewDAG</span></a> - Class in <a href="./io/gearpump/streaming/appmaster/package-summary.html">io.gearpump.streaming.appmaster</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/ClockService.ChangeToNewDAG.html#ClockService.ChangeToNewDAG(io.gearpump.streaming.DAG)">ClockService.ChangeToNewDAG(DAG)</a></span> - Constructor for class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/ClockService.ChangeToNewDAG.html" title="class in io.gearpump.streaming.appmaster">ClockService.ChangeToNewDAG</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/appmaster/ClockService.ChangeToNewDAG$.html" title="class in io.gearpump.streaming.appmaster"><span class="strong">ClockService.ChangeToNewDAG$</span></a> - Class in <a href="./io/gearpump/streaming/appmaster/package-summary.html">io.gearpump.streaming.appmaster</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/ClockService.ChangeToNewDAG$.html#ClockService.ChangeToNewDAG$()">ClockService.ChangeToNewDAG$()</a></span> - Constructor for class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/ClockService.ChangeToNewDAG$.html" title="class in io.gearpump.streaming.appmaster">ClockService.ChangeToNewDAG$</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/appmaster/ClockService.ChangeToNewDAGSuccess.html" title="class in io.gearpump.streaming.appmaster"><span class="strong">ClockService.ChangeToNewDAGSuccess</span></a> - Class in <a href="./io/gearpump/streaming/appmaster/package-summary.html">io.gearpump.streaming.appmaster</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/ClockService.ChangeToNewDAGSuccess.html#ClockService.ChangeToNewDAGSuccess(scala.collection.immutable.Map)">ClockService.ChangeToNewDAGSuccess(Map<Object, Object>)</a></span> - Constructor for class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/ClockService.ChangeToNewDAGSuccess.html" title="class in io.gearpump.streaming.appmaster">ClockService.ChangeToNewDAGSuccess</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/appmaster/ClockService.ChangeToNewDAGSuccess$.html" title="class in io.gearpump.streaming.appmaster"><span class="strong">ClockService.ChangeToNewDAGSuccess$</span></a> - Class in <a href="./io/gearpump/streaming/appmaster/package-summary.html">io.gearpump.streaming.appmaster</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/ClockService.ChangeToNewDAGSuccess$.html#ClockService.ChangeToNewDAGSuccess$()">ClockService.ChangeToNewDAGSuccess$()</a></span> - Constructor for class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/ClockService.ChangeToNewDAGSuccess$.html" title="class in io.gearpump.streaming.appmaster">ClockService.ChangeToNewDAGSuccess$</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/appmaster/ClockService.HealthCheck$.html" title="class in io.gearpump.streaming.appmaster"><span class="strong">ClockService.HealthCheck$</span></a> - Class in <a href="./io/gearpump/streaming/appmaster/package-summary.html">io.gearpump.streaming.appmaster</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/ClockService.HealthCheck$.html#ClockService.HealthCheck$()">ClockService.HealthCheck$()</a></span> - Constructor for class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/ClockService.HealthCheck$.html" title="class in io.gearpump.streaming.appmaster">ClockService.HealthCheck$</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/appmaster/ClockService.HealthChecker.html" title="class in io.gearpump.streaming.appmaster"><span class="strong">ClockService.HealthChecker</span></a> - Class in <a href="./io/gearpump/streaming/appmaster/package-summary.html">io.gearpump.streaming.appmaster</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/ClockService.HealthChecker.html#ClockService.HealthChecker(int)">ClockService.HealthChecker(int)</a></span> - Constructor for class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/ClockService.HealthChecker.html" title="class in io.gearpump.streaming.appmaster">ClockService.HealthChecker</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/appmaster/ClockService.HealthChecker$.html" title="class in io.gearpump.streaming.appmaster"><span class="strong">ClockService.HealthChecker$</span></a> - Class in <a href="./io/gearpump/streaming/appmaster/package-summary.html">io.gearpump.streaming.appmaster</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/ClockService.HealthChecker$.html#ClockService.HealthChecker$()">ClockService.HealthChecker$()</a></span> - Constructor for class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/ClockService.HealthChecker$.html" title="class in io.gearpump.streaming.appmaster">ClockService.HealthChecker$</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/appmaster/ClockService.HealthChecker.ClockValue.html" title="class in io.gearpump.streaming.appmaster"><span class="strong">ClockService.HealthChecker.ClockValue</span></a> - Class in <a href="./io/gearpump/streaming/appmaster/package-summary.html">io.gearpump.streaming.appmaster</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/ClockService.HealthChecker.ClockValue.html#ClockService.HealthChecker.ClockValue(long, long)">ClockService.HealthChecker.ClockValue(long, long)</a></span> - Constructor for class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/ClockService.HealthChecker.ClockValue.html" title="class in io.gearpump.streaming.appmaster">ClockService.HealthChecker.ClockValue</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/appmaster/ClockService.HealthChecker.ClockValue$.html" title="class in io.gearpump.streaming.appmaster"><span class="strong">ClockService.HealthChecker.ClockValue$</span></a> - Class in <a href="./io/gearpump/streaming/appmaster/package-summary.html">io.gearpump.streaming.appmaster</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/ClockService.HealthChecker.ClockValue$.html#ClockService.HealthChecker.ClockValue$()">ClockService.HealthChecker.ClockValue$()</a></span> - Constructor for class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/ClockService.HealthChecker.ClockValue$.html" title="class in io.gearpump.streaming.appmaster">ClockService.HealthChecker.ClockValue$</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/appmaster/ClockService.ProcessorClock.html" title="class in io.gearpump.streaming.appmaster"><span class="strong">ClockService.ProcessorClock</span></a> - Class in <a href="./io/gearpump/streaming/appmaster/package-summary.html">io.gearpump.streaming.appmaster</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/ClockService.ProcessorClock.html#ClockService.ProcessorClock(int, int)">ClockService.ProcessorClock(int, int)</a></span> - Constructor for class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/ClockService.ProcessorClock.html" title="class in io.gearpump.streaming.appmaster">ClockService.ProcessorClock</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/appmaster/ClockService.ProcessorClocks$.html" title="class in io.gearpump.streaming.appmaster"><span class="strong">ClockService.ProcessorClocks$</span></a> - Class in <a href="./io/gearpump/streaming/appmaster/package-summary.html">io.gearpump.streaming.appmaster</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/ClockService.ProcessorClocks$.html#ClockService.ProcessorClocks$()">ClockService.ProcessorClocks$()</a></span> - Constructor for class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/ClockService.ProcessorClocks$.html" title="class in io.gearpump.streaming.appmaster">ClockService.ProcessorClocks$</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/appmaster/ClockService.Report.html" title="class in io.gearpump.streaming.appmaster"><span class="strong">ClockService.Report</span></a> - Class in <a href="./io/gearpump/streaming/appmaster/package-summary.html">io.gearpump.streaming.appmaster</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/ClockService.Report.html#ClockService.Report(scala.collection.immutable.List)">ClockService.Report(List<TaskId>)</a></span> - Constructor for class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/ClockService.Report.html" title="class in io.gearpump.streaming.appmaster">ClockService.Report</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/appmaster/ClockService.Report$.html" title="class in io.gearpump.streaming.appmaster"><span class="strong">ClockService.Report$</span></a> - Class in <a href="./io/gearpump/streaming/appmaster/package-summary.html">io.gearpump.streaming.appmaster</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/ClockService.Report$.html#ClockService.Report$()">ClockService.Report$()</a></span> - Constructor for class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/ClockService.Report$.html" title="class in io.gearpump.streaming.appmaster">ClockService.Report$</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/appmaster/ClockService.SnapshotStartClock$.html" title="class in io.gearpump.streaming.appmaster"><span class="strong">ClockService.SnapshotStartClock$</span></a> - Class in <a href="./io/gearpump/streaming/appmaster/package-summary.html">io.gearpump.streaming.appmaster</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/ClockService.SnapshotStartClock$.html#ClockService.SnapshotStartClock$()">ClockService.SnapshotStartClock$()</a></span> - Constructor for class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/ClockService.SnapshotStartClock$.html" title="class in io.gearpump.streaming.appmaster">ClockService.SnapshotStartClock$</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/appmaster/ClockService.StoredStartClock.html" title="class in io.gearpump.streaming.appmaster"><span class="strong">ClockService.StoredStartClock</span></a> - Class in <a href="./io/gearpump/streaming/appmaster/package-summary.html">io.gearpump.streaming.appmaster</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/ClockService.StoredStartClock.html#ClockService.StoredStartClock(long)">ClockService.StoredStartClock(long)</a></span> - Constructor for class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/ClockService.StoredStartClock.html" title="class in io.gearpump.streaming.appmaster">ClockService.StoredStartClock</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/appmaster/ClockService.StoredStartClock$.html" title="class in io.gearpump.streaming.appmaster"><span class="strong">ClockService.StoredStartClock$</span></a> - Class in <a href="./io/gearpump/streaming/appmaster/package-summary.html">io.gearpump.streaming.appmaster</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/ClockService.StoredStartClock$.html#ClockService.StoredStartClock$()">ClockService.StoredStartClock$()</a></span> - Constructor for class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/ClockService.StoredStartClock$.html" title="class in io.gearpump.streaming.appmaster">ClockService.StoredStartClock$</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/dsl/CollectionDataSource.html#close()">close()</a></span> - Method in class io.gearpump.streaming.dsl.<a href="./io/gearpump/streaming/dsl/CollectionDataSource.html" title="class in io.gearpump.streaming.dsl">CollectionDataSource</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/sink/DataSink.html#close()">close()</a></span> - Method in interface io.gearpump.streaming.sink.<a href="./io/gearpump/streaming/sink/DataSink.html" title="interface in io.gearpump.streaming.sink">DataSink</a></dt> -<dd> -<div class="block">close connection to data sink - invoked at onClose() method of <a href="./io/gearpump/streaming/task/Task.html" title="class in io.gearpump.streaming.task"><code>Task</code></a></div> -</dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/source/DataSource.html#close()">close()</a></span> - Method in interface io.gearpump.streaming.source.<a href="./io/gearpump/streaming/source/DataSource.html" title="interface in io.gearpump.streaming.source">DataSource</a></dt> -<dd> -<div class="block">close connection to data source.</div> -</dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/state/impl/CheckpointManager.html#close()">close()</a></span> - Method in class io.gearpump.streaming.state.impl.<a href="./io/gearpump/streaming/state/impl/CheckpointManager.html" title="class in io.gearpump.streaming.state.impl">CheckpointManager</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/state/impl/InMemoryCheckpointStore.html#close()">close()</a></span> - Method in class io.gearpump.streaming.state.impl.<a href="./io/gearpump/streaming/state/impl/InMemoryCheckpointStore.html" title="class in io.gearpump.streaming.state.impl">InMemoryCheckpointStore</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/transaction/api/CheckpointStore.html#close()">close()</a></span> - Method in interface io.gearpump.streaming.transaction.api.<a href="./io/gearpump/streaming/transaction/api/CheckpointStore.html" title="interface in io.gearpump.streaming.transaction.api">CheckpointStore</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/transaction/api/OffsetManager.html#close()">close()</a></span> - Method in interface io.gearpump.streaming.transaction.api.<a href="./io/gearpump/streaming/transaction/api/OffsetManager.html" title="interface in io.gearpump.streaming.transaction.api">OffsetManager</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/transaction/api/OffsetStorage.html#close()">close()</a></span> - Method in interface io.gearpump.streaming.transaction.api.<a href="./io/gearpump/streaming/transaction/api/OffsetStorage.html" title="interface in io.gearpump.streaming.transaction.api">OffsetStorage</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/dsl/CollectionDataSource.html" title="class in io.gearpump.streaming.dsl"><span class="strong">CollectionDataSource</span></a><<a href="./io/gearpump/streaming/dsl/CollectionDataSource.html" title="type parameter in CollectionDataSource">T</a>> - Class in <a href="./io/gearpump/streaming/dsl/package-summary.html">io.gearpump.streaming.dsl</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/dsl/CollectionDataSource.html#CollectionDataSource(scala.collection.Seq)">CollectionDataSource(Seq<T>)</a></span> - Constructor for class io.gearpump.streaming.dsl.<a href="./io/gearpump/streaming/dsl/CollectionDataSource.html" title="class in io.gearpump.streaming.dsl">CollectionDataSource</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/state/impl/Interval.html#compare(io.gearpump.streaming.state.impl.Interval)">compare(Interval)</a></span> - Method in class io.gearpump.streaming.state.impl.<a href="./io/gearpump/streaming/state/impl/Interval.html" title="class in io.gearpump.streaming.state.impl">Interval</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/executor/Executor.ExecutorConfig.html#config()">config()</a></span> - Method in class io.gearpump.streaming.executor.<a href="./io/gearpump/streaming/executor/Executor.ExecutorConfig.html" title="class in io.gearpump.streaming.executor">Executor.ExecutorConfig</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/task/TaskActor.html#config()">config()</a></span> - Method in class io.gearpump.streaming.task.<a href="./io/gearpump/streaming/task/TaskActor.html" title="class in io.gearpump.streaming.task">TaskActor</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/Constants.html" title="class in io.gearpump.streaming"><span class="strong">Constants</span></a> - Class in <a href="./io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/Constants.html#Constants()">Constants()</a></span> - Constructor for class io.gearpump.streaming.<a href="./io/gearpump/streaming/Constants.html" title="class in io.gearpump.streaming">Constants</a></dt> -<dd> </dd> -<dt><a href="./io/gearpump/streaming/Constants$.html" title="class in io.gearpump.streaming"><span class="strong">Constants$</span></a> - Class in <a href="./io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/Constants$.html#Constants$()">Constants$()</a></span> - Constructor for class io.gearpump.streaming.<a href="./io/gearpump/streaming/Constants$.html" title="class in io.gearpump.streaming">Constants$</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/LifeTime.html#contains(long)">contains(long)</a></span> - Method in class io.gearpump.streaming.<a href="./io/gearpump/streaming/LifeTime.html" title="class in io.gearpump.streaming">LifeTime</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/DagManager.GetTaskLaunchData.html#context()">context()</a></span> - Method in class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/DagManager.GetTaskLaunchData.html" title="class in io.gearpump.streaming.appmaster">DagManager.GetTaskLaunchData</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/DagManager.TaskLaunchData.html#context()">context()</a></span> - Method in class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/DagManager.TaskLaunchData.html" title="class in io.gearpump.streaming.appmaster">DagManager.TaskLaunchData</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/javaapi/Task.html#context">context</a></span> - Variable in class io.gearpump.streaming.javaapi.<a href="./io/gearpump/streaming/javaapi/Task.html" title="class in io.gearpump.streaming.javaapi">Task</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/TaskCount.html#count()">count()</a></span> - Method in class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/TaskCount.html" title="class in io.gearpump.streaming.appmaster">TaskCount</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/LifeTime.html#cross(io.gearpump.streaming.LifeTime)">cross(LifeTime)</a></span> - Method in class io.gearpump.streaming.<a href="./io/gearpump/streaming/LifeTime.html" title="class in io.gearpump.streaming">LifeTime</a></dt> -<dd> </dd> -</dl> -<a name="_D_"> -<!-- --> -</a> -<h2 class="title">D</h2> -<dl> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/ClockService.ChangeToNewDAG.html#dag()">dag()</a></span> - Method in class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/ClockService.ChangeToNewDAG.html" title="class in io.gearpump.streaming.appmaster">ClockService.ChangeToNewDAG</a></dt> -<dd> </dd> -<dt><span class="strong"><a href="./io/gearpump/streaming/appmaster/DagManager.LatestDAG.html#dag()">dag()</a></span> - Method in class io.gearpump.streaming.appmaster.<a href="./io/gearpump/streaming/appmaster/DagManager.LatestDAG.html" title="class in io.gearpump.strea
<TRUNCATED>
