blob: 6c9337c29e4b919c4ad0469949925696088c4448 [file] [log] [blame]
<!DOCTYPE html >
<html>
<head>
<title>task - org.apache.gearpump.streaming.task</title>
<meta name="description" content="task - org.apache.gearpump.streaming.task" />
<meta name="keywords" content="task org.apache.gearpump.streaming.task" />
<meta http-equiv="content-type" content="text/html; charset=UTF-8" />
<link href="../../../../../lib/template.css" media="screen" type="text/css" rel="stylesheet" />
<link href="../../../../../lib/diagrams.css" media="screen" type="text/css" rel="stylesheet" id="diagrams-css" />
<script type="text/javascript" src="../../../../../lib/jquery.js" id="jquery-js"></script>
<script type="text/javascript" src="../../../../../lib/jquery-ui.js"></script>
<script type="text/javascript" src="../../../../../lib/template.js"></script>
<script type="text/javascript" src="../../../../../lib/tools.tooltip.js"></script>
<script type="text/javascript">
if(top === self) {
var url = '../../../../../index.html';
var hash = 'org.apache.gearpump.streaming.task.package';
var anchor = window.location.hash;
var anchor_opt = '';
if (anchor.length >= 1)
anchor_opt = '@' + anchor.substring(1);
window.location.href = url + '#' + hash + anchor_opt;
}
</script>
</head>
<body class="value">
<div id="definition">
<img alt="Package" src="../../../../../lib/package_big.png" />
<p id="owner"><a href="../../../../package.html" class="extype" name="org">org</a>.<a href="../../../package.html" class="extype" name="org.apache">apache</a>.<a href="../../package.html" class="extype" name="org.apache.gearpump">gearpump</a>.<a href="../package.html" class="extype" name="org.apache.gearpump.streaming">streaming</a></p>
<h1>task</h1><span class="permalink">
<a href="../../../../../index.html#org.apache.gearpump.streaming.task.package" title="Permalink" target="_top">
<img src="../../../../../lib/permalink.png" alt="Permalink" />
</a>
</span>
</div>
<h4 id="signature" class="signature">
<span class="modifier_kind">
<span class="modifier"></span>
<span class="kind">package</span>
</span>
<span class="symbol">
<span class="name">task</span>
</span>
</h4>
<div id="comment" class="fullcommenttop"></div>
<div id="mbrsel">
<div id="textfilter"><span class="pre"></span><span class="input"><input id="mbrsel-input" type="text" accesskey="/" /></span><span class="post"></span></div>
<div id="visbl">
<span class="filtertype">Visibility</span>
<ol><li class="public in"><span>Public</span></li><li class="all out"><span>All</span></li></ol>
</div>
</div>
<div id="template">
<div id="allMembers">
<div id="types" class="types members">
<h3>Type Members</h3>
<ol><li name="org.apache.gearpump.streaming.task.Ack" visbl="pub" data-isabs="false" fullComment="yes" group="Ungrouped">
<a id="AckextendsProductwithSerializable"></a>
<a id="Ack:Ack"></a>
<h4 class="signature">
<span class="modifier_kind">
<span class="modifier"></span>
<span class="kind">case class</span>
</span>
<span class="symbol">
<a href="Ack.html"><span class="name">Ack</span></a><span class="params">(<span name="taskId">taskId: <a href="TaskId.html" class="extype" name="org.apache.gearpump.streaming.task.TaskId">TaskId</a></span>, <span name="seq">seq: <span class="extype" name="scala.Short">Short</span></span>, <span name="actualReceivedNum">actualReceivedNum: <span class="extype" name="scala.Short">Short</span></span>, <span name="sessionId">sessionId: <span class="extype" name="scala.Int">Int</span></span>)</span><span class="result"> extends <span class="extype" name="scala.Product">Product</span> with <span class="extype" name="scala.Serializable">Serializable</span></span>
</span>
</h4><span class="permalink">
<a href="../../../../../index.html#org.apache.gearpump.streaming.task.package@AckextendsProductwithSerializable" title="Permalink" target="_top">
<img src="../../../../../lib/permalink.png" alt="Permalink" />
</a>
</span>
<p class="shortcomment cmt">Ack back to sender task actor.</p><div class="fullcomment"><div class="comment cmt"><p>Ack back to sender task actor.
</p></div><dl class="paramcmts block"><dt class="param">seq</dt><dd class="cmt"><p>The seq field represents the expected number of received messages and the
actualReceivedNum field means the actual received number since start.</p></dd></dl></div>
</li><li name="org.apache.gearpump.streaming.task.AckRequest" visbl="pub" data-isabs="false" fullComment="no" group="Ungrouped">
<a id="AckRequestextendsProductwithSerializable"></a>
<a id="AckRequest:AckRequest"></a>
<h4 class="signature">
<span class="modifier_kind">
<span class="modifier"></span>
<span class="kind">case class</span>
</span>
<span class="symbol">
<a href="AckRequest.html"><span class="name">AckRequest</span></a><span class="params">(<span name="taskId">taskId: <a href="TaskId.html" class="extype" name="org.apache.gearpump.streaming.task.TaskId">TaskId</a></span>, <span name="seq">seq: <span class="extype" name="scala.Short">Short</span></span>, <span name="sessionId">sessionId: <span class="extype" name="scala.Int">Int</span></span>)</span><span class="result"> extends <span class="extype" name="scala.Product">Product</span> with <span class="extype" name="scala.Serializable">Serializable</span></span>
</span>
</h4><span class="permalink">
<a href="../../../../../index.html#org.apache.gearpump.streaming.task.package@AckRequestextendsProductwithSerializable" title="Permalink" target="_top">
<img src="../../../../../lib/permalink.png" alt="Permalink" />
</a>
</span>
</li><li name="org.apache.gearpump.streaming.task.CheckProcessorDeath" visbl="pub" data-isabs="false" fullComment="no" group="Ungrouped">
<a id="CheckProcessorDeathextendsProductwithSerializable"></a>
<a id="CheckProcessorDeath:CheckProcessorDeath"></a>
<h4 class="signature">
<span class="modifier_kind">
<span class="modifier"></span>
<span class="kind">case class</span>
</span>
<span class="symbol">
<a href="CheckProcessorDeath.html"><span class="name">CheckProcessorDeath</span></a><span class="params">(<span name="processorId">processorId: <a href="../package.html#ProcessorId=Int" class="extmbr" name="org.apache.gearpump.streaming.ProcessorId">ProcessorId</a></span>)</span><span class="result"> extends <span class="extype" name="scala.Product">Product</span> with <span class="extype" name="scala.Serializable">Serializable</span></span>
</span>
</h4><span class="permalink">
<a href="../../../../../index.html#org.apache.gearpump.streaming.task.package@CheckProcessorDeathextendsProductwithSerializable" title="Permalink" target="_top">
<img src="../../../../../lib/permalink.png" alt="Permalink" />
</a>
</span>
</li><li name="org.apache.gearpump.streaming.task.CheckpointClock" visbl="pub" data-isabs="false" fullComment="no" group="Ungrouped">
<a id="CheckpointClockextendsProductwithSerializable"></a>
<a id="CheckpointClock:CheckpointClock"></a>
<h4 class="signature">
<span class="modifier_kind">
<span class="modifier"></span>
<span class="kind">case class</span>
</span>
<span class="symbol">
<a href="CheckpointClock.html"><span class="name">CheckpointClock</span></a><span class="params">(<span name="clock">clock: <span class="extype" name="scala.Option">Option</span>[<a href="../../package.html#TimeStamp=Long" class="extmbr" name="org.apache.gearpump.TimeStamp">TimeStamp</a>]</span>)</span><span class="result"> extends <span class="extype" name="scala.Product">Product</span> with <span class="extype" name="scala.Serializable">Serializable</span></span>
</span>
</h4><span class="permalink">
<a href="../../../../../index.html#org.apache.gearpump.streaming.task.package@CheckpointClockextendsProductwithSerializable" title="Permalink" target="_top">
<img src="../../../../../lib/permalink.png" alt="Permalink" />
</a>
</span>
</li><li name="org.apache.gearpump.streaming.task.ClockEvent" visbl="pub" data-isabs="true" fullComment="no" group="Ungrouped">
<a id="ClockEventextendsAnyRef"></a>
<a id="ClockEvent:ClockEvent"></a>
<h4 class="signature">
<span class="modifier_kind">
<span class="modifier">sealed </span>
<span class="kind">trait</span>
</span>
<span class="symbol">
<a href="ClockEvent.html"><span class="name">ClockEvent</span></a><span class="result"> extends <span class="extype" name="scala.AnyRef">AnyRef</span></span>
</span>
</h4><span class="permalink">
<a href="../../../../../index.html#org.apache.gearpump.streaming.task.package@ClockEventextendsAnyRef" title="Permalink" target="_top">
<img src="../../../../../lib/permalink.png" alt="Permalink" />
</a>
</span>
</li><li name="org.apache.gearpump.streaming.task.ExpressTransport" visbl="pub" data-isabs="true" fullComment="yes" group="Ungrouped">
<a id="ExpressTransportextendsAnyRef"></a>
<a id="ExpressTransport:ExpressTransport"></a>
<h4 class="signature">
<span class="modifier_kind">
<span class="modifier"></span>
<span class="kind">trait</span>
</span>
<span class="symbol">
<a href="ExpressTransport.html"><span class="name">ExpressTransport</span></a><span class="result"> extends <span class="extype" name="scala.AnyRef">AnyRef</span></span>
</span>
</h4><span class="permalink">
<a href="../../../../../index.html#org.apache.gearpump.streaming.task.package@ExpressTransportextendsAnyRef" title="Permalink" target="_top">
<img src="../../../../../lib/permalink.png" alt="Permalink" />
</a>
</span>
<p class="shortcomment cmt">ExpressTransport wire the networking function from default akka
networking to customized implementation <a href="../../transport/Express.html" class="extype" name="org.apache.gearpump.transport.Express">org.apache.gearpump.transport.Express</a>.</p><div class="fullcomment"><div class="comment cmt"><p>ExpressTransport wire the networking function from default akka
networking to customized implementation <a href="../../transport/Express.html" class="extype" name="org.apache.gearpump.transport.Express">org.apache.gearpump.transport.Express</a>.</p><p>See <a href="../../transport/Express.html" class="extype" name="org.apache.gearpump.transport.Express">org.apache.gearpump.transport.Express</a> for more information.
</p></div></div>
</li><li name="org.apache.gearpump.streaming.task.GetUpstreamMinClock" visbl="pub" data-isabs="false" fullComment="no" group="Ungrouped">
<a id="GetUpstreamMinClockextendsClockEventwithProductwithSerializable"></a>
<a id="GetUpstreamMinClock:GetUpstreamMinClock"></a>
<h4 class="signature">
<span class="modifier_kind">
<span class="modifier"></span>
<span class="kind">case class</span>
</span>
<span class="symbol">
<a href="GetUpstreamMinClock.html"><span class="name">GetUpstreamMinClock</span></a><span class="params">(<span name="taskId">taskId: <a href="TaskId.html" class="extype" name="org.apache.gearpump.streaming.task.TaskId">TaskId</a></span>)</span><span class="result"> extends <a href="ClockEvent.html" class="extype" name="org.apache.gearpump.streaming.task.ClockEvent">ClockEvent</a> with <span class="extype" name="scala.Product">Product</span> with <span class="extype" name="scala.Serializable">Serializable</span></span>
</span>
</h4><span class="permalink">
<a href="../../../../../index.html#org.apache.gearpump.streaming.task.package@GetUpstreamMinClockextendsClockEventwithProductwithSerializable" title="Permalink" target="_top">
<img src="../../../../../lib/permalink.png" alt="Permalink" />
</a>
</span>
</li><li name="org.apache.gearpump.streaming.task.InitialAckRequest" visbl="pub" data-isabs="false" fullComment="no" group="Ungrouped">
<a id="InitialAckRequestextendsProductwithSerializable"></a>
<a id="InitialAckRequest:InitialAckRequest"></a>
<h4 class="signature">
<span class="modifier_kind">
<span class="modifier"></span>
<span class="kind">case class</span>
</span>
<span class="symbol">
<a href="InitialAckRequest.html"><span class="name">InitialAckRequest</span></a><span class="params">(<span name="taskId">taskId: <a href="TaskId.html" class="extype" name="org.apache.gearpump.streaming.task.TaskId">TaskId</a></span>, <span name="sessionId">sessionId: <span class="extype" name="scala.Int">Int</span></span>)</span><span class="result"> extends <span class="extype" name="scala.Product">Product</span> with <span class="extype" name="scala.Serializable">Serializable</span></span>
</span>
</h4><span class="permalink">
<a href="../../../../../index.html#org.apache.gearpump.streaming.task.package@InitialAckRequestextendsProductwithSerializable" title="Permalink" target="_top">
<img src="../../../../../lib/permalink.png" alt="Permalink" />
</a>
</span>
</li><li name="org.apache.gearpump.streaming.task.LatencyProbe" visbl="pub" data-isabs="false" fullComment="no" group="Ungrouped">
<a id="LatencyProbeextendsProductwithSerializable"></a>
<a id="LatencyProbe:LatencyProbe"></a>
<h4 class="signature">
<span class="modifier_kind">
<span class="modifier"></span>
<span class="kind">case class</span>
</span>
<span class="symbol">
<a href="LatencyProbe.html"><span class="name">LatencyProbe</span></a><span class="params">(<span name="timestamp">timestamp: <span class="extype" name="scala.Long">Long</span></span>)</span><span class="result"> extends <span class="extype" name="scala.Product">Product</span> with <span class="extype" name="scala.Serializable">Serializable</span></span>
</span>
</h4><span class="permalink">
<a href="../../../../../index.html#org.apache.gearpump.streaming.task.package@LatencyProbeextendsProductwithSerializable" title="Permalink" target="_top">
<img src="../../../../../lib/permalink.png" alt="Permalink" />
</a>
</span>
<p class="shortcomment cmt">Probe the latency between two upstream to downstream tasks.</p>
</li><li name="org.apache.gearpump.streaming.task.LatestMinClock" visbl="pub" data-isabs="false" fullComment="no" group="Ungrouped">
<a id="LatestMinClockextendsProductwithSerializable"></a>
<a id="LatestMinClock:LatestMinClock"></a>
<h4 class="signature">
<span class="modifier_kind">
<span class="modifier"></span>
<span class="kind">case class</span>
</span>
<span class="symbol">
<a href="LatestMinClock.html"><span class="name">LatestMinClock</span></a><span class="params">(<span name="clock">clock: <a href="../../package.html#TimeStamp=Long" class="extmbr" name="org.apache.gearpump.TimeStamp">TimeStamp</a></span>)</span><span class="result"> extends <span class="extype" name="scala.Product">Product</span> with <span class="extype" name="scala.Serializable">Serializable</span></span>
</span>
</h4><span class="permalink">
<a href="../../../../../index.html#org.apache.gearpump.streaming.task.package@LatestMinClockextendsProductwithSerializable" title="Permalink" target="_top">
<img src="../../../../../lib/permalink.png" alt="Permalink" />
</a>
</span>
</li><li name="org.apache.gearpump.streaming.task.SerializedMessage" visbl="pub" data-isabs="false" fullComment="no" group="Ungrouped">
<a id="SerializedMessageextendsProductwithSerializable"></a>
<a id="SerializedMessage:SerializedMessage"></a>
<h4 class="signature">
<span class="modifier_kind">
<span class="modifier"></span>
<span class="kind">case class</span>
</span>
<span class="symbol">
<a href="SerializedMessage.html"><span class="name">SerializedMessage</span></a><span class="params">(<span name="timeStamp">timeStamp: <a href="../../package.html#TimeStamp=Long" class="extmbr" name="org.apache.gearpump.TimeStamp">TimeStamp</a></span>, <span name="bytes">bytes: <span class="extype" name="scala.Array">Array</span>[<span class="extype" name="scala.Byte">Byte</span>]</span>)</span><span class="result"> extends <span class="extype" name="scala.Product">Product</span> with <span class="extype" name="scala.Serializable">Serializable</span></span>
</span>
</h4><span class="permalink">
<a href="../../../../../index.html#org.apache.gearpump.streaming.task.package@SerializedMessageextendsProductwithSerializable" title="Permalink" target="_top">
<img src="../../../../../lib/permalink.png" alt="Permalink" />
</a>
</span>
</li><li name="org.apache.gearpump.streaming.task.SerializedMessageSerializer" visbl="pub" data-isabs="false" fullComment="no" group="Ungrouped">
<a id="SerializedMessageSerializerextendsTaskMessageSerializer[org.apache.gearpump.streaming.task.SerializedMessage]"></a>
<a id="SerializedMessageSerializer:SerializedMessageSerializer"></a>
<h4 class="signature">
<span class="modifier_kind">
<span class="modifier"></span>
<span class="kind">class</span>
</span>
<span class="symbol">
<a href="SerializedMessageSerializer.html"><span class="name">SerializedMessageSerializer</span></a><span class="result"> extends <a href="TaskMessageSerializer.html" class="extype" name="org.apache.gearpump.streaming.task.TaskMessageSerializer">TaskMessageSerializer</a>[<a href="SerializedMessage.html" class="extype" name="org.apache.gearpump.streaming.task.SerializedMessage">SerializedMessage</a>]</span>
</span>
</h4><span class="permalink">
<a href="../../../../../index.html#org.apache.gearpump.streaming.task.package@SerializedMessageSerializerextendsTaskMessageSerializer[org.apache.gearpump.streaming.task.SerializedMessage]" title="Permalink" target="_top">
<img src="../../../../../lib/permalink.png" alt="Permalink" />
</a>
</span>
</li><li name="org.apache.gearpump.streaming.task.StartClock" visbl="pub" data-isabs="false" fullComment="no" group="Ungrouped">
<a id="StartClockextendsProductwithSerializable"></a>
<a id="StartClock:StartClock"></a>
<h4 class="signature">
<span class="modifier_kind">
<span class="modifier"></span>
<span class="kind">case class</span>
</span>
<span class="symbol">
<a href="StartClock.html"><span class="name">StartClock</span></a><span class="params">(<span name="clock">clock: <a href="../../package.html#TimeStamp=Long" class="extmbr" name="org.apache.gearpump.TimeStamp">TimeStamp</a></span>)</span><span class="result"> extends <span class="extype" name="scala.Product">Product</span> with <span class="extype" name="scala.Serializable">Serializable</span></span>
</span>
</h4><span class="permalink">
<a href="../../../../../index.html#org.apache.gearpump.streaming.task.package@StartClockextendsProductwithSerializable" title="Permalink" target="_top">
<img src="../../../../../lib/permalink.png" alt="Permalink" />
</a>
</span>
</li><li name="org.apache.gearpump.streaming.task.StreamingTransportSerializer" visbl="pub" data-isabs="false" fullComment="no" group="Ungrouped">
<a id="StreamingTransportSerializerextendsITransportMessageSerializer"></a>
<a id="StreamingTransportSerializer:StreamingTransportSerializer"></a>
<h4 class="signature">
<span class="modifier_kind">
<span class="modifier"></span>
<span class="kind">class</span>
</span>
<span class="symbol">
<a href="StreamingTransportSerializer.html"><span class="name">StreamingTransportSerializer</span></a><span class="result"> extends <a href="../../transport/netty/ITransportMessageSerializer.html" class="extype" name="org.apache.gearpump.transport.netty.ITransportMessageSerializer">ITransportMessageSerializer</a></span>
</span>
</h4><span class="permalink">
<a href="../../../../../index.html#org.apache.gearpump.streaming.task.package@StreamingTransportSerializerextendsITransportMessageSerializer" title="Permalink" target="_top">
<img src="../../../../../lib/permalink.png" alt="Permalink" />
</a>
</span>
</li><li name="org.apache.gearpump.streaming.task.Subscriber" visbl="pub" data-isabs="false" fullComment="yes" group="Ungrouped">
<a id="SubscriberextendsProductwithSerializable"></a>
<a id="Subscriber:Subscriber"></a>
<h4 class="signature">
<span class="modifier_kind">
<span class="modifier"></span>
<span class="kind">case class</span>
</span>
<span class="symbol">
<a href="Subscriber.html"><span class="name">Subscriber</span></a><span class="params">(<span name="processorId">processorId: <span class="extype" name="scala.Int">Int</span></span>, <span name="partitionerDescription">partitionerDescription: <a href="../partitioner/PartitionerDescription.html" class="extype" name="org.apache.gearpump.streaming.partitioner.PartitionerDescription">PartitionerDescription</a></span>, <span name="parallelism">parallelism: <span class="extype" name="scala.Int">Int</span></span>, <span name="lifeTime">lifeTime: <a href="../LifeTime.html" class="extype" name="org.apache.gearpump.streaming.LifeTime">LifeTime</a></span>)</span><span class="result"> extends <span class="extype" name="scala.Product">Product</span> with <span class="extype" name="scala.Serializable">Serializable</span></span>
</span>
</h4><span class="permalink">
<a href="../../../../../index.html#org.apache.gearpump.streaming.task.package@SubscriberextendsProductwithSerializable" title="Permalink" target="_top">
<img src="../../../../../lib/permalink.png" alt="Permalink" />
</a>
</span>
<p class="shortcomment cmt">Each processor can have multiple downstream subscribers.</p><div class="fullcomment"><div class="comment cmt"><p>Each processor can have multiple downstream subscribers.</p><p>For example: When processor A subscribe to processor B, then the output of B will be
pushed to processor A.
</p></div><dl class="paramcmts block"><dt class="param">processorId</dt><dd class="cmt"><p>subscriber processor Id</p></dd><dt class="param">partitionerDescription</dt><dd class="cmt"><p>subscriber partitioner</p></dd></dl></div>
</li><li name="org.apache.gearpump.streaming.task.Subscription" visbl="pub" data-isabs="false" fullComment="no" group="Ungrouped">
<a id="SubscriptionextendsAnyRef"></a>
<a id="Subscription:Subscription"></a>
<h4 class="signature">
<span class="modifier_kind">
<span class="modifier"></span>
<span class="kind">class</span>
</span>
<span class="symbol">
<a href="Subscription.html"><span class="name">Subscription</span></a><span class="result"> extends <span class="extype" name="scala.AnyRef">AnyRef</span></span>
</span>
</h4><span class="permalink">
<a href="../../../../../index.html#org.apache.gearpump.streaming.task.package@SubscriptionextendsAnyRef" title="Permalink" target="_top">
<img src="../../../../../lib/permalink.png" alt="Permalink" />
</a>
</span>
<p class="shortcomment cmt">Manages the output and message clock for single downstream processor
</p>
</li><li name="org.apache.gearpump.streaming.task.Task" visbl="pub" data-isabs="true" fullComment="no" group="Ungrouped">
<a id="TaskextendsTaskInterface"></a>
<a id="Task:Task"></a>
<h4 class="signature">
<span class="modifier_kind">
<span class="modifier">abstract </span>
<span class="kind">class</span>
</span>
<span class="symbol">
<a href="Task.html"><span class="name">Task</span></a><span class="result"> extends <a href="TaskInterface.html" class="extype" name="org.apache.gearpump.streaming.task.TaskInterface">TaskInterface</a></span>
</span>
</h4><span class="permalink">
<a href="../../../../../index.html#org.apache.gearpump.streaming.task.package@TaskextendsTaskInterface" title="Permalink" target="_top">
<img src="../../../../../lib/permalink.png" alt="Permalink" />
</a>
</span>
</li><li name="org.apache.gearpump.streaming.task.TaskActor" visbl="pub" data-isabs="false" fullComment="yes" group="Ungrouped">
<a id="TaskActorextendsActorwithExpressTransportwithTimeOutScheduler"></a>
<a id="TaskActor:TaskActor"></a>
<h4 class="signature">
<span class="modifier_kind">
<span class="modifier"></span>
<span class="kind">class</span>
</span>
<span class="symbol">
<a href="TaskActor.html"><span class="name">TaskActor</span></a><span class="result"> extends <span class="extype" name="akka.actor.Actor">Actor</span> with <a href="ExpressTransport.html" class="extype" name="org.apache.gearpump.streaming.task.ExpressTransport">ExpressTransport</a> with <a href="../../util/TimeOutScheduler.html" class="extype" name="org.apache.gearpump.util.TimeOutScheduler">TimeOutScheduler</a></span>
</span>
</h4><span class="permalink">
<a href="../../../../../index.html#org.apache.gearpump.streaming.task.package@TaskActorextendsActorwithExpressTransportwithTimeOutScheduler" title="Permalink" target="_top">
<img src="../../../../../lib/permalink.png" alt="Permalink" />
</a>
</span>
<p class="shortcomment cmt">All tasks of Gearpump run inside an Actor.</p><div class="fullcomment"><div class="comment cmt"><p>All tasks of Gearpump run inside an Actor. TaskActor is the Actor container for a task.
</p></div></div>
</li><li name="org.apache.gearpump.streaming.task.TaskContext" visbl="pub" data-isabs="true" fullComment="no" group="Ungrouped">
<a id="TaskContextextendsAnyRef"></a>
<a id="TaskContext:TaskContext"></a>
<h4 class="signature">
<span class="modifier_kind">
<span class="modifier"></span>
<span class="kind">trait</span>
</span>
<span class="symbol">
<a href="TaskContext.html"><span class="name">TaskContext</span></a><span class="result"> extends <span class="extype" name="scala.AnyRef">AnyRef</span></span>
</span>
</h4><span class="permalink">
<a href="../../../../../index.html#org.apache.gearpump.streaming.task.package@TaskContextextendsAnyRef" title="Permalink" target="_top">
<img src="../../../../../lib/permalink.png" alt="Permalink" />
</a>
</span>
<p class="shortcomment cmt">This provides context information for a task.</p>
</li><li name="org.apache.gearpump.streaming.task.TaskContextData" visbl="pub" data-isabs="false" fullComment="no" group="Ungrouped">
<a id="TaskContextDataextendsProductwithSerializable"></a>
<a id="TaskContextData:TaskContextData"></a>
<h4 class="signature">
<span class="modifier_kind">
<span class="modifier"></span>
<span class="kind">case class</span>
</span>
<span class="symbol">
<a href="TaskContextData.html"><span class="name">TaskContextData</span></a><span class="params">(<span name="executorId">executorId: <span class="extype" name="scala.Int">Int</span></span>, <span name="appId">appId: <span class="extype" name="scala.Int">Int</span></span>, <span name="appName">appName: <span class="extype" name="scala.Predef.String">String</span></span>, <span name="appMaster">appMaster: <span class="extype" name="akka.actor.ActorRef">ActorRef</span></span>, <span name="parallelism">parallelism: <span class="extype" name="scala.Int">Int</span></span>, <span name="life">life: <a href="../LifeTime.html" class="extype" name="org.apache.gearpump.streaming.LifeTime">LifeTime</a></span>, <span name="subscribers">subscribers: <span class="extype" name="scala.List">List</span>[<a href="Subscriber.html" class="extype" name="org.apache.gearpump.streaming.task.Subscriber">Subscriber</a>]</span>)</span><span class="result"> extends <span class="extype" name="scala.Product">Product</span> with <span class="extype" name="scala.Serializable">Serializable</span></span>
</span>
</h4><span class="permalink">
<a href="../../../../../index.html#org.apache.gearpump.streaming.task.package@TaskContextDataextendsProductwithSerializable" title="Permalink" target="_top">
<img src="../../../../../lib/permalink.png" alt="Permalink" />
</a>
</span>
</li><li name="org.apache.gearpump.streaming.task.TaskId" visbl="pub" data-isabs="false" fullComment="no" group="Ungrouped">
<a id="TaskIdextendsProductwithSerializable"></a>
<a id="TaskId:TaskId"></a>
<h4 class="signature">
<span class="modifier_kind">
<span class="modifier"></span>
<span class="kind">case class</span>
</span>
<span class="symbol">
<a href="TaskId.html"><span class="name">TaskId</span></a><span class="params">(<span name="processorId">processorId: <a href="../package.html#ProcessorId=Int" class="extmbr" name="org.apache.gearpump.streaming.ProcessorId">ProcessorId</a></span>, <span name="index">index: <a href="../package.html#TaskIndex=Int" class="extmbr" name="org.apache.gearpump.streaming.TaskIndex">TaskIndex</a></span>)</span><span class="result"> extends <span class="extype" name="scala.Product">Product</span> with <span class="extype" name="scala.Serializable">Serializable</span></span>
</span>
</h4><span class="permalink">
<a href="../../../../../index.html#org.apache.gearpump.streaming.task.package@TaskIdextendsProductwithSerializable" title="Permalink" target="_top">
<img src="../../../../../lib/permalink.png" alt="Permalink" />
</a>
</span>
</li><li name="org.apache.gearpump.streaming.task.TaskInterface" visbl="pub" data-isabs="true" fullComment="no" group="Ungrouped">
<a id="TaskInterfaceextendsAnyRef"></a>
<a id="TaskInterface:TaskInterface"></a>
<h4 class="signature">
<span class="modifier_kind">
<span class="modifier"></span>
<span class="kind">trait</span>
</span>
<span class="symbol">
<a href="TaskInterface.html"><span class="name">TaskInterface</span></a><span class="result"> extends <span class="extype" name="scala.AnyRef">AnyRef</span></span>
</span>
</h4><span class="permalink">
<a href="../../../../../index.html#org.apache.gearpump.streaming.task.package@TaskInterfaceextendsAnyRef" title="Permalink" target="_top">
<img src="../../../../../lib/permalink.png" alt="Permalink" />
</a>
</span>
<p class="shortcomment cmt">Streaming Task interface
</p>
</li><li name="org.apache.gearpump.streaming.task.TaskMessageSerializer" visbl="pub" data-isabs="true" fullComment="no" group="Ungrouped">
<a id="TaskMessageSerializer[T]extendsAnyRef"></a>
<a id="TaskMessageSerializer[T]:TaskMessageSerializer[T]"></a>
<h4 class="signature">
<span class="modifier_kind">
<span class="modifier"></span>
<span class="kind">trait</span>
</span>
<span class="symbol">
<a href="TaskMessageSerializer.html"><span class="name">TaskMessageSerializer</span></a><span class="tparams">[<span name="T">T</span>]</span><span class="result"> extends <span class="extype" name="scala.AnyRef">AnyRef</span></span>
</span>
</h4><span class="permalink">
<a href="../../../../../index.html#org.apache.gearpump.streaming.task.package@TaskMessageSerializer[T]extendsAnyRef" title="Permalink" target="_top">
<img src="../../../../../lib/permalink.png" alt="Permalink" />
</a>
</span>
</li><li name="org.apache.gearpump.streaming.task.TaskWrapper" visbl="pub" data-isabs="false" fullComment="no" group="Ungrouped">
<a id="TaskWrapperextendsTaskContextwithTaskInterface"></a>
<a id="TaskWrapper:TaskWrapper"></a>
<h4 class="signature">
<span class="modifier_kind">
<span class="modifier"></span>
<span class="kind">class</span>
</span>
<span class="symbol">
<a href="TaskWrapper.html"><span class="name">TaskWrapper</span></a><span class="result"> extends <a href="TaskContext.html" class="extype" name="org.apache.gearpump.streaming.task.TaskContext">TaskContext</a> with <a href="TaskInterface.html" class="extype" name="org.apache.gearpump.streaming.task.TaskInterface">TaskInterface</a></span>
</span>
</h4><span class="permalink">
<a href="../../../../../index.html#org.apache.gearpump.streaming.task.package@TaskWrapperextendsTaskContextwithTaskInterface" title="Permalink" target="_top">
<img src="../../../../../lib/permalink.png" alt="Permalink" />
</a>
</span>
<p class="shortcomment cmt">This provides TaskContext for user defined tasks
</p>
</li><li name="org.apache.gearpump.streaming.task.UpdateCheckpointClock" visbl="pub" data-isabs="false" fullComment="no" group="Ungrouped">
<a id="UpdateCheckpointClockextendsClockEventwithProductwithSerializable"></a>
<a id="UpdateCheckpointClock:UpdateCheckpointClock"></a>
<h4 class="signature">
<span class="modifier_kind">
<span class="modifier"></span>
<span class="kind">case class</span>
</span>
<span class="symbol">
<a href="UpdateCheckpointClock.html"><span class="name">UpdateCheckpointClock</span></a><span class="params">(<span name="taskId">taskId: <a href="TaskId.html" class="extype" name="org.apache.gearpump.streaming.task.TaskId">TaskId</a></span>, <span name="clock">clock: <a href="../../package.html#TimeStamp=Long" class="extmbr" name="org.apache.gearpump.TimeStamp">TimeStamp</a></span>)</span><span class="result"> extends <a href="ClockEvent.html" class="extype" name="org.apache.gearpump.streaming.task.ClockEvent">ClockEvent</a> with <span class="extype" name="scala.Product">Product</span> with <span class="extype" name="scala.Serializable">Serializable</span></span>
</span>
</h4><span class="permalink">
<a href="../../../../../index.html#org.apache.gearpump.streaming.task.package@UpdateCheckpointClockextendsClockEventwithProductwithSerializable" title="Permalink" target="_top">
<img src="../../../../../lib/permalink.png" alt="Permalink" />
</a>
</span>
</li><li name="org.apache.gearpump.streaming.task.UpdateClock" visbl="pub" data-isabs="false" fullComment="no" group="Ungrouped">
<a id="UpdateClockextendsClockEventwithProductwithSerializable"></a>
<a id="UpdateClock:UpdateClock"></a>
<h4 class="signature">
<span class="modifier_kind">
<span class="modifier"></span>
<span class="kind">case class</span>
</span>
<span class="symbol">
<a href="UpdateClock.html"><span class="name">UpdateClock</span></a><span class="params">(<span name="taskId">taskId: <a href="TaskId.html" class="extype" name="org.apache.gearpump.streaming.task.TaskId">TaskId</a></span>, <span name="time">time: <a href="../../package.html#TimeStamp=Long" class="extmbr" name="org.apache.gearpump.TimeStamp">TimeStamp</a></span>)</span><span class="result"> extends <a href="ClockEvent.html" class="extype" name="org.apache.gearpump.streaming.task.ClockEvent">ClockEvent</a> with <span class="extype" name="scala.Product">Product</span> with <span class="extype" name="scala.Serializable">Serializable</span></span>
</span>
</h4><span class="permalink">
<a href="../../../../../index.html#org.apache.gearpump.streaming.task.package@UpdateClockextendsClockEventwithProductwithSerializable" title="Permalink" target="_top">
<img src="../../../../../lib/permalink.png" alt="Permalink" />
</a>
</span>
</li><li name="org.apache.gearpump.streaming.task.UpstreamMinClock" visbl="pub" data-isabs="false" fullComment="no" group="Ungrouped">
<a id="UpstreamMinClockextendsProductwithSerializable"></a>
<a id="UpstreamMinClock:UpstreamMinClock"></a>
<h4 class="signature">
<span class="modifier_kind">
<span class="modifier"></span>
<span class="kind">case class</span>
</span>
<span class="symbol">
<a href="UpstreamMinClock.html"><span class="name">UpstreamMinClock</span></a><span class="params">(<span name="latestMinClock">latestMinClock: <span class="extype" name="scala.Option">Option</span>[<a href="../../package.html#TimeStamp=Long" class="extmbr" name="org.apache.gearpump.TimeStamp">TimeStamp</a>]</span>)</span><span class="result"> extends <span class="extype" name="scala.Product">Product</span> with <span class="extype" name="scala.Serializable">Serializable</span></span>
</span>
</h4><span class="permalink">
<a href="../../../../../index.html#org.apache.gearpump.streaming.task.package@UpstreamMinClockextendsProductwithSerializable" title="Permalink" target="_top">
<img src="../../../../../lib/permalink.png" alt="Permalink" />
</a>
</span>
</li></ol>
</div>
<div id="values" class="values members">
<h3>Value Members</h3>
<ol><li name="org.apache.gearpump.streaming.task.EndingClock" visbl="pub" data-isabs="false" fullComment="no" group="Ungrouped">
<a id="EndingClock"></a>
<a id="EndingClock:EndingClock"></a>
<h4 class="signature">
<span class="modifier_kind">
<span class="modifier"></span>
<span class="kind">object</span>
</span>
<span class="symbol">
<a href="EndingClock$.html"><span class="name">EndingClock</span></a><span class="result"> extends <span class="extype" name="scala.Product">Product</span> with <span class="extype" name="scala.Serializable">Serializable</span></span>
</span>
</h4><span class="permalink">
<a href="../../../../../index.html#org.apache.gearpump.streaming.task.package@EndingClock" title="Permalink" target="_top">
<img src="../../../../../lib/permalink.png" alt="Permalink" />
</a>
</span>
</li><li name="org.apache.gearpump.streaming.task.GetCheckpointClock" visbl="pub" data-isabs="false" fullComment="no" group="Ungrouped">
<a id="GetCheckpointClock"></a>
<a id="GetCheckpointClock:GetCheckpointClock"></a>
<h4 class="signature">
<span class="modifier_kind">
<span class="modifier"></span>
<span class="kind">object</span>
</span>
<span class="symbol">
<a href="GetCheckpointClock$.html"><span class="name">GetCheckpointClock</span></a><span class="result"> extends <a href="ClockEvent.html" class="extype" name="org.apache.gearpump.streaming.task.ClockEvent">ClockEvent</a> with <span class="extype" name="scala.Product">Product</span> with <span class="extype" name="scala.Serializable">Serializable</span></span>
</span>
</h4><span class="permalink">
<a href="../../../../../index.html#org.apache.gearpump.streaming.task.package@GetCheckpointClock" title="Permalink" target="_top">
<img src="../../../../../lib/permalink.png" alt="Permalink" />
</a>
</span>
</li><li name="org.apache.gearpump.streaming.task.GetDAG" visbl="pub" data-isabs="false" fullComment="no" group="Ungrouped">
<a id="GetDAG"></a>
<a id="GetDAG:GetDAG"></a>
<h4 class="signature">
<span class="modifier_kind">
<span class="modifier"></span>
<span class="kind">object</span>
</span>
<span class="symbol">
<a href="GetDAG$.html"><span class="name">GetDAG</span></a><span class="result"> extends <span class="extype" name="scala.Product">Product</span> with <span class="extype" name="scala.Serializable">Serializable</span></span>
</span>
</h4><span class="permalink">
<a href="../../../../../index.html#org.apache.gearpump.streaming.task.package@GetDAG" title="Permalink" target="_top">
<img src="../../../../../lib/permalink.png" alt="Permalink" />
</a>
</span>
</li><li name="org.apache.gearpump.streaming.task.GetLatestMinClock" visbl="pub" data-isabs="false" fullComment="no" group="Ungrouped">
<a id="GetLatestMinClock"></a>
<a id="GetLatestMinClock:GetLatestMinClock"></a>
<h4 class="signature">
<span class="modifier_kind">
<span class="modifier"></span>
<span class="kind">object</span>
</span>
<span class="symbol">
<a href="GetLatestMinClock$.html"><span class="name">GetLatestMinClock</span></a><span class="result"> extends <a href="ClockEvent.html" class="extype" name="org.apache.gearpump.streaming.task.ClockEvent">ClockEvent</a></span>
</span>
</h4><span class="permalink">
<a href="../../../../../index.html#org.apache.gearpump.streaming.task.package@GetLatestMinClock" title="Permalink" target="_top">
<img src="../../../../../lib/permalink.png" alt="Permalink" />
</a>
</span>
</li><li name="org.apache.gearpump.streaming.task.GetStartClock" visbl="pub" data-isabs="false" fullComment="no" group="Ungrouped">
<a id="GetStartClock"></a>
<a id="GetStartClock:GetStartClock"></a>
<h4 class="signature">
<span class="modifier_kind">
<span class="modifier"></span>
<span class="kind">object</span>
</span>
<span class="symbol">
<a href="GetStartClock$.html"><span class="name">GetStartClock</span></a><span class="result"> extends <span class="extype" name="scala.Product">Product</span> with <span class="extype" name="scala.Serializable">Serializable</span></span>
</span>
</h4><span class="permalink">
<a href="../../../../../index.html#org.apache.gearpump.streaming.task.package@GetStartClock" title="Permalink" target="_top">
<img src="../../../../../lib/permalink.png" alt="Permalink" />
</a>
</span>
</li><li name="org.apache.gearpump.streaming.task.SendMessageLoss" visbl="pub" data-isabs="false" fullComment="no" group="Ungrouped">
<a id="SendMessageLoss"></a>
<a id="SendMessageLoss:SendMessageLoss"></a>
<h4 class="signature">
<span class="modifier_kind">
<span class="modifier"></span>
<span class="kind">object</span>
</span>
<span class="symbol">
<a href="SendMessageLoss$.html"><span class="name">SendMessageLoss</span></a><span class="result"> extends <span class="extype" name="scala.Product">Product</span> with <span class="extype" name="scala.Serializable">Serializable</span></span>
</span>
</h4><span class="permalink">
<a href="../../../../../index.html#org.apache.gearpump.streaming.task.package@SendMessageLoss" title="Permalink" target="_top">
<img src="../../../../../lib/permalink.png" alt="Permalink" />
</a>
</span>
</li><li name="org.apache.gearpump.streaming.task.SerializerResolver" visbl="pub" data-isabs="false" fullComment="no" group="Ungrouped">
<a id="SerializerResolver"></a>
<a id="SerializerResolver:SerializerResolver"></a>
<h4 class="signature">
<span class="modifier_kind">
<span class="modifier"></span>
<span class="kind">object</span>
</span>
<span class="symbol">
<a href="SerializerResolver$.html"><span class="name">SerializerResolver</span></a>
</span>
</h4><span class="permalink">
<a href="../../../../../index.html#org.apache.gearpump.streaming.task.package@SerializerResolver" title="Permalink" target="_top">
<img src="../../../../../lib/permalink.png" alt="Permalink" />
</a>
</span>
</li><li name="org.apache.gearpump.streaming.task.Subscriber" visbl="pub" data-isabs="false" fullComment="no" group="Ungrouped">
<a id="Subscriber"></a>
<a id="Subscriber:Subscriber"></a>
<h4 class="signature">
<span class="modifier_kind">
<span class="modifier"></span>
<span class="kind">object</span>
</span>
<span class="symbol">
<a href="Subscriber$.html"><span class="name">Subscriber</span></a><span class="result"> extends <span class="extype" name="scala.Serializable">Serializable</span></span>
</span>
</h4><span class="permalink">
<a href="../../../../../index.html#org.apache.gearpump.streaming.task.package@Subscriber" title="Permalink" target="_top">
<img src="../../../../../lib/permalink.png" alt="Permalink" />
</a>
</span>
</li><li name="org.apache.gearpump.streaming.task.Subscription" visbl="pub" data-isabs="false" fullComment="no" group="Ungrouped">
<a id="Subscription"></a>
<a id="Subscription:Subscription"></a>
<h4 class="signature">
<span class="modifier_kind">
<span class="modifier"></span>
<span class="kind">object</span>
</span>
<span class="symbol">
<a href="Subscription$.html"><span class="name">Subscription</span></a>
</span>
</h4><span class="permalink">
<a href="../../../../../index.html#org.apache.gearpump.streaming.task.package@Subscription" title="Permalink" target="_top">
<img src="../../../../../lib/permalink.png" alt="Permalink" />
</a>
</span>
</li><li name="org.apache.gearpump.streaming.task.TaskActor" visbl="pub" data-isabs="false" fullComment="no" group="Ungrouped">
<a id="TaskActor"></a>
<a id="TaskActor:TaskActor"></a>
<h4 class="signature">
<span class="modifier_kind">
<span class="modifier"></span>
<span class="kind">object</span>
</span>
<span class="symbol">
<a href="TaskActor$.html"><span class="name">TaskActor</span></a>
</span>
</h4><span class="permalink">
<a href="../../../../../index.html#org.apache.gearpump.streaming.task.package@TaskActor" title="Permalink" target="_top">
<img src="../../../../../lib/permalink.png" alt="Permalink" />
</a>
</span>
</li><li name="org.apache.gearpump.streaming.task.TaskId" visbl="pub" data-isabs="false" fullComment="no" group="Ungrouped">
<a id="TaskId"></a>
<a id="TaskId:TaskId"></a>
<h4 class="signature">
<span class="modifier_kind">
<span class="modifier"></span>
<span class="kind">object</span>
</span>
<span class="symbol">
<a href="TaskId$.html"><span class="name">TaskId</span></a><span class="result"> extends <span class="extype" name="scala.Serializable">Serializable</span></span>
</span>
</h4><span class="permalink">
<a href="../../../../../index.html#org.apache.gearpump.streaming.task.package@TaskId" title="Permalink" target="_top">
<img src="../../../../../lib/permalink.png" alt="Permalink" />
</a>
</span>
</li><li name="org.apache.gearpump.streaming.task.TaskUtil" visbl="pub" data-isabs="false" fullComment="no" group="Ungrouped">
<a id="TaskUtil"></a>
<a id="TaskUtil:TaskUtil"></a>
<h4 class="signature">
<span class="modifier_kind">
<span class="modifier"></span>
<span class="kind">object</span>
</span>
<span class="symbol">
<a href="TaskUtil$.html"><span class="name">TaskUtil</span></a>
</span>
</h4><span class="permalink">
<a href="../../../../../index.html#org.apache.gearpump.streaming.task.package@TaskUtil" title="Permalink" target="_top">
<img src="../../../../../lib/permalink.png" alt="Permalink" />
</a>
</span>
</li></ol>
</div>
</div>
<div id="inheritedMembers">
</div>
<div id="groupedMembers">
<div class="group" name="Ungrouped">
<h3>Ungrouped</h3>
</div>
</div>
</div>
<div id="tooltip"></div>
<div id="footer"> </div>
</body>
</html>