You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by ma...@apache.org on 2014/06/19 03:14:18 UTC
svn commit: r1603693 [5/8] - in /incubator/samza/site: ./
learn/documentation/0.7.0/api/javadocs/
learn/documentation/0.7.0/api/javadocs/org/apache/samza/
learn/documentation/0.7.0/api/javadocs/org/apache/samza/checkpoint/
learn/documentation/0.7.0/api...
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/SystemStreamMetadata.OffsetType.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/SystemStreamMetadata.OffsetType.html?rev=1603693&r1=1603692&r2=1603693&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/SystemStreamMetadata.OffsetType.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/SystemStreamMetadata.OffsetType.html Thu Jun 19 01:14:15 2014
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_60) on Tue Jun 17 22:49:30 PDT 2014 -->
+<!-- Generated by javadoc (version 1.7.0_51) on Wed Jun 18 18:05:17 PDT 2014 -->
<title>SystemStreamMetadata.OffsetType (samza-api 0.7.0 API)</title>
-<meta name="date" content="2014-06-17">
+<meta name="date" content="2014-06-18">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
</head>
<body>
@@ -257,7 +257,8 @@ over the constants as follows:
for (SystemStreamMetadata.OffsetType c : SystemStreamMetadata.OffsetType.values())
System.out.println(c);
</pre></div>
-<dl><dt><span class="strong">Returns:</span></dt><dd>an array containing the constants of this enum type, in the order they are declared</dd></dl>
+<dl><dt><span class="strong">Returns:</span></dt><dd>an array containing the constants of this enum type, in
+the order they are declared</dd></dl>
</li>
</ul>
<a name="valueOf(java.lang.String)">
@@ -274,7 +275,8 @@ not permitted.)</div>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>name</code> - the name of the enum constant to be returned.</dd>
<dt><span class="strong">Returns:</span></dt><dd>the enum constant with the specified name</dd>
<dt><span class="strong">Throws:</span></dt>
-<dd><code>java.lang.IllegalArgumentException</code> - if this enum type has no constant with the specified name</dd>
+<dd><code>java.lang.IllegalArgumentException</code> - if this enum type has no constant
+with the specified name</dd>
<dd><code>java.lang.NullPointerException</code> - if the argument is null</dd></dl>
</li>
</ul>
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/SystemStreamMetadata.SystemStreamPartitionMetadata.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/SystemStreamMetadata.SystemStreamPartitionMetadata.html?rev=1603693&r1=1603692&r2=1603693&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/SystemStreamMetadata.SystemStreamPartitionMetadata.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/SystemStreamMetadata.SystemStreamPartitionMetadata.html Thu Jun 19 01:14:15 2014
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_60) on Tue Jun 17 22:49:30 PDT 2014 -->
+<!-- Generated by javadoc (version 1.7.0_51) on Wed Jun 18 18:05:17 PDT 2014 -->
<title>SystemStreamMetadata.SystemStreamPartitionMetadata (samza-api 0.7.0 API)</title>
-<meta name="date" content="2014-06-17">
+<meta name="date" content="2014-06-18">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
</head>
<body>
@@ -121,7 +121,7 @@ extends java.lang.Object</pre>
<th class="colOne" scope="col">Constructor and Description</th>
</tr>
<tr class="altColor">
-<td class="colOne"><code><strong><a href="../../../../org/apache/samza/system/SystemStreamMetadata.SystemStreamPartitionMetadata.html#SystemStreamMetadata.SystemStreamPartitionMetadata(java.lang.String,%20java.lang.String,%20java.lang.String)">SystemStreamMetadata.SystemStreamPartitionMetadata</a></strong>(java.lang.String oldestOffset,
+<td class="colOne"><code><strong><a href="../../../../org/apache/samza/system/SystemStreamMetadata.SystemStreamPartitionMetadata.html#SystemStreamMetadata.SystemStreamPartitionMetadata(java.lang.String, java.lang.String, java.lang.String)">SystemStreamMetadata.SystemStreamPartitionMetadata</a></strong>(java.lang.String oldestOffset,
java.lang.String newestOffset,
java.lang.String upcomingOffset)</code> </td>
</tr>
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/SystemStreamMetadata.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/SystemStreamMetadata.html?rev=1603693&r1=1603692&r2=1603693&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/SystemStreamMetadata.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/SystemStreamMetadata.html Thu Jun 19 01:14:15 2014
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_60) on Tue Jun 17 22:49:30 PDT 2014 -->
+<!-- Generated by javadoc (version 1.7.0_51) on Wed Jun 18 18:05:17 PDT 2014 -->
<title>SystemStreamMetadata (samza-api 0.7.0 API)</title>
-<meta name="date" content="2014-06-17">
+<meta name="date" content="2014-06-18">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
</head>
<body>
@@ -145,7 +145,7 @@ extends java.lang.Object</pre>
<th class="colOne" scope="col">Constructor and Description</th>
</tr>
<tr class="altColor">
-<td class="colOne"><code><strong><a href="../../../../org/apache/samza/system/SystemStreamMetadata.html#SystemStreamMetadata(java.lang.String,%20java.util.Map)">SystemStreamMetadata</a></strong>(java.lang.String streamName,
+<td class="colOne"><code><strong><a href="../../../../org/apache/samza/system/SystemStreamMetadata.html#SystemStreamMetadata(java.lang.String, java.util.Map)">SystemStreamMetadata</a></strong>(java.lang.String streamName,
java.util.Map<<a href="../../../../org/apache/samza/Partition.html" title="class in org.apache.samza">Partition</a>,<a href="../../../../org/apache/samza/system/SystemStreamMetadata.SystemStreamPartitionMetadata.html" title="class in org.apache.samza.system">SystemStreamMetadata.SystemStreamPartitionMetadata</a>> partitionMetadata)</code> </td>
</tr>
</table>
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/SystemStreamPartition.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/SystemStreamPartition.html?rev=1603693&r1=1603692&r2=1603693&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/SystemStreamPartition.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/SystemStreamPartition.html Thu Jun 19 01:14:15 2014
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_60) on Tue Jun 17 22:49:30 PDT 2014 -->
+<!-- Generated by javadoc (version 1.7.0_51) on Wed Jun 18 18:05:17 PDT 2014 -->
<title>SystemStreamPartition (samza-api 0.7.0 API)</title>
-<meta name="date" content="2014-06-17">
+<meta name="date" content="2014-06-18">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
</head>
<body>
@@ -102,7 +102,7 @@
<br>
<pre>public class <span class="strong">SystemStreamPartition</span>
extends <a href="../../../../org/apache/samza/system/SystemStream.html" title="class in org.apache.samza.system">SystemStream</a></pre>
-<div class="block">Aggregate object representing a partition of a Samza stream.</div>
+<div class="block">Aggregate object representing a both the <a href="../../../../org/apache/samza/system/SystemStream.html" title="class in org.apache.samza.system"><code>SystemStream</code></a> and <a href="../../../../org/apache/samza/Partition.html" title="class in org.apache.samza"><code>Partition</code></a>.</div>
</li>
</ul>
</div>
@@ -151,7 +151,7 @@ extends <a href="../../../../org/apache/
<th class="colOne" scope="col">Constructor and Description</th>
</tr>
<tr class="altColor">
-<td class="colOne"><code><strong><a href="../../../../org/apache/samza/system/SystemStreamPartition.html#SystemStreamPartition(java.lang.String,%20java.lang.String,%20org.apache.samza.Partition)">SystemStreamPartition</a></strong>(java.lang.String system,
+<td class="colOne"><code><strong><a href="../../../../org/apache/samza/system/SystemStreamPartition.html#SystemStreamPartition(java.lang.String, java.lang.String, org.apache.samza.Partition)">SystemStreamPartition</a></strong>(java.lang.String system,
java.lang.String stream,
<a href="../../../../org/apache/samza/Partition.html" title="class in org.apache.samza">Partition</a> partition)</code>
<div class="block">Constructs a Samza stream partition object from specified components.</div>
@@ -163,7 +163,7 @@ extends <a href="../../../../org/apache/
</td>
</tr>
<tr class="altColor">
-<td class="colOne"><code><strong><a href="../../../../org/apache/samza/system/SystemStreamPartition.html#SystemStreamPartition(org.apache.samza.system.SystemStream,%20org.apache.samza.Partition)">SystemStreamPartition</a></strong>(<a href="../../../../org/apache/samza/system/SystemStream.html" title="class in org.apache.samza.system">SystemStream</a> other,
+<td class="colOne"><code><strong><a href="../../../../org/apache/samza/system/SystemStreamPartition.html#SystemStreamPartition(org.apache.samza.system.SystemStream, org.apache.samza.Partition)">SystemStreamPartition</a></strong>(<a href="../../../../org/apache/samza/system/SystemStream.html" title="class in org.apache.samza.system">SystemStream</a> other,
<a href="../../../../org/apache/samza/Partition.html" title="class in org.apache.samza">Partition</a> partition)</code>
<div class="block">Constructs a Samza stream partition object based upon another Samza stream and a specified partition.</div>
</td>
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/SystemStreamPartitionIterator.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/SystemStreamPartitionIterator.html?rev=1603693&r1=1603692&r2=1603693&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/SystemStreamPartitionIterator.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/SystemStreamPartitionIterator.html Thu Jun 19 01:14:15 2014
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_60) on Tue Jun 17 22:49:30 PDT 2014 -->
+<!-- Generated by javadoc (version 1.7.0_51) on Wed Jun 18 18:05:17 PDT 2014 -->
<title>SystemStreamPartitionIterator (samza-api 0.7.0 API)</title>
-<meta name="date" content="2014-06-17">
+<meta name="date" content="2014-06-18">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
</head>
<body>
@@ -102,6 +102,8 @@
<pre>public class <span class="strong">SystemStreamPartitionIterator</span>
extends java.lang.Object
implements java.util.Iterator<<a href="../../../../org/apache/samza/system/IncomingMessageEnvelope.html" title="class in org.apache.samza.system">IncomingMessageEnvelope</a>></pre>
+<div class="block"><code>Iterator</code> that wraps a <a href="../../../../org/apache/samza/system/SystemConsumer.html" title="interface in org.apache.samza.system"><code>SystemConsumer</code></a> to iterate over
+ the messages the consumer provides for the specified <a href="../../../../org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system"><code>SystemStreamPartition</code></a>.</div>
</li>
</ul>
</div>
@@ -120,11 +122,11 @@ implements java.util.Iterator<<a href
<th class="colOne" scope="col">Constructor and Description</th>
</tr>
<tr class="altColor">
-<td class="colOne"><code><strong><a href="../../../../org/apache/samza/system/SystemStreamPartitionIterator.html#SystemStreamPartitionIterator(org.apache.samza.system.SystemConsumer,%20org.apache.samza.system.SystemStreamPartition)">SystemStreamPartitionIterator</a></strong>(<a href="../../../../org/apache/samza/system/SystemConsumer.html" title="interface in org.apache.samza.system">SystemConsumer</a> systemConsumer,
+<td class="colOne"><code><strong><a href="../../../../org/apache/samza/system/SystemStreamPartitionIterator.html#SystemStreamPartitionIterator(org.apache.samza.system.SystemConsumer, org.apache.samza.system.SystemStreamPartition)">SystemStreamPartitionIterator</a></strong>(<a href="../../../../org/apache/samza/system/SystemConsumer.html" title="interface in org.apache.samza.system">SystemConsumer</a> systemConsumer,
<a href="../../../../org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system">SystemStreamPartition</a> systemStreamPartition)</code> </td>
</tr>
<tr class="rowColor">
-<td class="colOne"><code><strong><a href="../../../../org/apache/samza/system/SystemStreamPartitionIterator.html#SystemStreamPartitionIterator(org.apache.samza.system.SystemConsumer,%20org.apache.samza.system.SystemStreamPartition,%20int)">SystemStreamPartitionIterator</a></strong>(<a href="../../../../org/apache/samza/system/SystemConsumer.html" title="interface in org.apache.samza.system">SystemConsumer</a> systemConsumer,
+<td class="colOne"><code><strong><a href="../../../../org/apache/samza/system/SystemStreamPartitionIterator.html#SystemStreamPartitionIterator(org.apache.samza.system.SystemConsumer, org.apache.samza.system.SystemStreamPartition, int)">SystemStreamPartitionIterator</a></strong>(<a href="../../../../org/apache/samza/system/SystemConsumer.html" title="interface in org.apache.samza.system">SystemConsumer</a> systemConsumer,
<a href="../../../../org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system">SystemStreamPartition</a> systemStreamPartition,
int fetchSize)</code> </td>
</tr>
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/chooser/BaseMessageChooser.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/chooser/BaseMessageChooser.html?rev=1603693&r1=1603692&r2=1603693&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/chooser/BaseMessageChooser.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/chooser/BaseMessageChooser.html Thu Jun 19 01:14:15 2014
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_60) on Tue Jun 17 22:49:30 PDT 2014 -->
+<!-- Generated by javadoc (version 1.7.0_51) on Wed Jun 18 18:05:17 PDT 2014 -->
<title>BaseMessageChooser (samza-api 0.7.0 API)</title>
-<meta name="date" content="2014-06-17">
+<meta name="date" content="2014-06-18">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
@@ -141,7 +141,7 @@ implements <a href="../../../../../org/a
</tr>
<tr class="altColor">
<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><strong><a href="../../../../../org/apache/samza/system/chooser/BaseMessageChooser.html#register(org.apache.samza.system.SystemStreamPartition,%20java.lang.String)">register</a></strong>(<a href="../../../../../org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system">SystemStreamPartition</a> systemStreamPartition,
+<td class="colLast"><code><strong><a href="../../../../../org/apache/samza/system/chooser/BaseMessageChooser.html#register(org.apache.samza.system.SystemStreamPartition, java.lang.String)">register</a></strong>(<a href="../../../../../org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system">SystemStreamPartition</a> systemStreamPartition,
java.lang.String offset)</code>
<div class="block">Called before start, to let the chooser know that it will be handling
envelopes from the given SystemStreamPartition.</div>
@@ -245,13 +245,13 @@ implements <a href="../../../../../org/a
<h4>register</h4>
<pre>public void register(<a href="../../../../../org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system">SystemStreamPartition</a> systemStreamPartition,
java.lang.String offset)</pre>
-<div class="block"><strong>Description copied from interface: <code><a href="../../../../../org/apache/samza/system/chooser/MessageChooser.html#register(org.apache.samza.system.SystemStreamPartition,%20java.lang.String)">MessageChooser</a></code></strong></div>
+<div class="block"><strong>Description copied from interface: <code><a href="../../../../../org/apache/samza/system/chooser/MessageChooser.html#register(org.apache.samza.system.SystemStreamPartition, java.lang.String)">MessageChooser</a></code></strong></div>
<div class="block">Called before start, to let the chooser know that it will be handling
envelopes from the given SystemStreamPartition. Register will only be
called before start.</div>
<dl>
<dt><strong>Specified by:</strong></dt>
-<dd><code><a href="../../../../../org/apache/samza/system/chooser/MessageChooser.html#register(org.apache.samza.system.SystemStreamPartition,%20java.lang.String)">register</a></code> in interface <code><a href="../../../../../org/apache/samza/system/chooser/MessageChooser.html" title="interface in org.apache.samza.system.chooser">MessageChooser</a></code></dd>
+<dd><code><a href="../../../../../org/apache/samza/system/chooser/MessageChooser.html#register(org.apache.samza.system.SystemStreamPartition, java.lang.String)">register</a></code> in interface <code><a href="../../../../../org/apache/samza/system/chooser/MessageChooser.html" title="interface in org.apache.samza.system.chooser">MessageChooser</a></code></dd>
<dt><span class="strong">Parameters:</span></dt><dd><code>systemStreamPartition</code> - A SystemStreamPartition that envelopes will be coming from.</dd><dd><code>offset</code> - The offset of the first message expected for the
system/stream/partition that's being registered. If "7" were
supplied as the offset, then the MessageChooser can expect the
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/chooser/MessageChooser.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/chooser/MessageChooser.html?rev=1603693&r1=1603692&r2=1603693&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/chooser/MessageChooser.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/chooser/MessageChooser.html Thu Jun 19 01:14:15 2014
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_60) on Tue Jun 17 22:49:30 PDT 2014 -->
+<!-- Generated by javadoc (version 1.7.0_51) on Wed Jun 18 18:05:17 PDT 2014 -->
<title>MessageChooser (samza-api 0.7.0 API)</title>
-<meta name="date" content="2014-06-17">
+<meta name="date" content="2014-06-18">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
@@ -94,46 +94,46 @@
<pre>public interface <span class="strong">MessageChooser</span></pre>
<div class="block">MessageChooser is an interface for programmatic fine-grain control over
stream consumption.
-
- Consider the case of a Samza task is consuming multiple streams where some
+
+ <p>Consider the case of a Samza task consuming multiple streams, where some
streams may be from live systems that have stricter SLA requirements and must
always be prioritized over other streams that may be from batch systems.
MessageChooser allows developers to inject message prioritization logic into
the SamzaContainer.
-
- In general, the MessageChooser can be used to prioritize certain systems,
+
+ <p>In general, the MessageChooser can be used to prioritize certain systems,
streams or partitions over others. It can also be used to throttle certain
- partitions if it chooses not to return messages even though they are
- available when choose is invoked. The MessageChooser can also throttle the
- entire SamzaContainer by performing a blocking operation, such as
- Thread.sleep.
-
- The manner in which MessageChooser is used is:
-
+ partitions, by choosing not to return messages even though they are
+ available. The MessageChooser can also throttle the entire SamzaContainer by
+ performing a blocking operation, such as Thread.sleep.
+
+ <p>The manner in which MessageChooser is used is:
+
<ul>
- <li>SystemConsumers buffers messages from all SystemStreamPartitions as they
+ <li>SystemConsumers buffer messages from all SystemStreamPartitions as they
become available.</li>
<li>If MessageChooser has no messages for a given SystemStreamPartition, and
- SystemConsumers has a message in its buffer for the SystemStreamPartition,
+ a SystemConsumer has a message in its buffer for the SystemStreamPartition,
the MessageChooser will be updated once with the next message in the buffer.</li>
<li>When SamzaContainer is ready to process another message, it calls
- SystemConsumers.choose, which in-turn calls MessageChooser.choose.</li>
+ SystemConsumers.choose, which in turn calls <a href="../../../../../org/apache/samza/system/chooser/MessageChooser.html#choose()"><code>choose()</code></a>.</li>
</ul>
-
- Since the MessageChooser only receives one message at a time per
- SystemStreamPartition, it can be used to order messages between different
+
+ <p>Since the MessageChooser only receives one message at a time per
+ <a href="../../../../../org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system"><code>SystemStreamPartition</code></a>, it can be used to order messages between different
SystemStreamPartitions, but it can't be used to re-order messages within a
single SystemStreamPartition (a buffered sort). This must be done within a
StreamTask.
-
- The contract between the MessageChooser and the SystemConsumers is:
-
+
+ <p>The contract between the MessageChooser and the SystemConsumers is:
+
<ul>
- <li>Update can be called multiple times before choose is called.</li>
- <li>A null return from MessageChooser.choose means no envelopes should be
+ <li><a href="../../../../../org/apache/samza/system/chooser/MessageChooser.html#update(org.apache.samza.system.IncomingMessageEnvelope)"><code>update(IncomingMessageEnvelope)</code></a> can be called multiple times
+ before <a href="../../../../../org/apache/samza/system/chooser/MessageChooser.html#choose()"><code>choose()</code></a> is called.</li>
+ <li>If <a href="../../../../../org/apache/samza/system/chooser/MessageChooser.html#choose()"><code>choose()</code></a> returns null, that means no envelopes should be
processed at the moment.</li>
- <li>A MessageChooser may elect to return null when choose is called, even if
- unprocessed messages have been given by the update method.</li>
+ <li>A MessageChooser may elect to return null when <a href="../../../../../org/apache/samza/system/chooser/MessageChooser.html#choose()"><code>choose()</code></a> is
+ called, even if unprocessed messages have been given by the update method.</li>
<li>A MessageChooser will not have any of its in-memory state restored in the
event of a failure.</li>
<li>Blocking operations (such as Thread.sleep) will block all processing in
@@ -169,7 +169,7 @@
</tr>
<tr class="rowColor">
<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><strong><a href="../../../../../org/apache/samza/system/chooser/MessageChooser.html#register(org.apache.samza.system.SystemStreamPartition,%20java.lang.String)">register</a></strong>(<a href="../../../../../org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system">SystemStreamPartition</a> systemStreamPartition,
+<td class="colLast"><code><strong><a href="../../../../../org/apache/samza/system/chooser/MessageChooser.html#register(org.apache.samza.system.SystemStreamPartition, java.lang.String)">register</a></strong>(<a href="../../../../../org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system">SystemStreamPartition</a> systemStreamPartition,
java.lang.String offset)</code>
<div class="block">Called before start, to let the chooser know that it will be handling
envelopes from the given SystemStreamPartition.</div>
@@ -190,9 +190,7 @@
<tr class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><strong><a href="../../../../../org/apache/samza/system/chooser/MessageChooser.html#update(org.apache.samza.system.IncomingMessageEnvelope)">update</a></strong>(<a href="../../../../../org/apache/samza/system/IncomingMessageEnvelope.html" title="class in org.apache.samza.system">IncomingMessageEnvelope</a> envelope)</code>
-<div class="block">Notify the chooser that a new envelope is available for a processing.A
- MessageChooser will receive, at most, one outstanding envelope per
- system/stream/partition combination.</div>
+<div class="block">Notify the chooser that a new envelope is available for a processing.</div>
</td>
</tr>
</table>
@@ -257,7 +255,7 @@
<li class="blockList">
<h4>update</h4>
<pre>void update(<a href="../../../../../org/apache/samza/system/IncomingMessageEnvelope.html" title="class in org.apache.samza.system">IncomingMessageEnvelope</a> envelope)</pre>
-<div class="block">Notify the chooser that a new envelope is available for a processing.A
+<div class="block">Notify the chooser that a new envelope is available for a processing. A
MessageChooser will receive, at most, one outstanding envelope per
system/stream/partition combination. For example, if update is called for
partition 7 of kafka.mystream, then update will not be called with an
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/chooser/MessageChooserFactory.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/chooser/MessageChooserFactory.html?rev=1603693&r1=1603692&r2=1603693&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/chooser/MessageChooserFactory.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/chooser/MessageChooserFactory.html Thu Jun 19 01:14:15 2014
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_60) on Tue Jun 17 22:49:30 PDT 2014 -->
+<!-- Generated by javadoc (version 1.7.0_51) on Wed Jun 18 18:05:17 PDT 2014 -->
<title>MessageChooserFactory (samza-api 0.7.0 API)</title>
-<meta name="date" content="2014-06-17">
+<meta name="date" content="2014-06-18">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
@@ -88,6 +88,7 @@
<hr>
<br>
<pre>public interface <span class="strong">MessageChooserFactory</span></pre>
+<div class="block">Build an instance of a <a href="../../../../../org/apache/samza/system/chooser/MessageChooser.html" title="interface in org.apache.samza.system.chooser"><code>MessageChooser</code></a></div>
</li>
</ul>
</div>
@@ -108,7 +109,7 @@
</tr>
<tr class="altColor">
<td class="colFirst"><code><a href="../../../../../org/apache/samza/system/chooser/MessageChooser.html" title="interface in org.apache.samza.system.chooser">MessageChooser</a></code></td>
-<td class="colLast"><code><strong><a href="../../../../../org/apache/samza/system/chooser/MessageChooserFactory.html#getChooser(org.apache.samza.config.Config,%20org.apache.samza.metrics.MetricsRegistry)">getChooser</a></strong>(<a href="../../../../../org/apache/samza/config/Config.html" title="class in org.apache.samza.config">Config</a> config,
+<td class="colLast"><code><strong><a href="../../../../../org/apache/samza/system/chooser/MessageChooserFactory.html#getChooser(org.apache.samza.config.Config, org.apache.samza.metrics.MetricsRegistry)">getChooser</a></strong>(<a href="../../../../../org/apache/samza/config/Config.html" title="class in org.apache.samza.config">Config</a> config,
<a href="../../../../../org/apache/samza/metrics/MetricsRegistry.html" title="interface in org.apache.samza.metrics">MetricsRegistry</a> registry)</code> </td>
</tr>
</table>
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/chooser/package-frame.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/chooser/package-frame.html?rev=1603693&r1=1603692&r2=1603693&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/chooser/package-frame.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/chooser/package-frame.html Thu Jun 19 01:14:15 2014
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_60) on Tue Jun 17 22:49:30 PDT 2014 -->
+<!-- Generated by javadoc (version 1.7.0_51) on Wed Jun 18 18:05:17 PDT 2014 -->
<title>org.apache.samza.system.chooser (samza-api 0.7.0 API)</title>
-<meta name="date" content="2014-06-17">
+<meta name="date" content="2014-06-18">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/chooser/package-summary.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/chooser/package-summary.html?rev=1603693&r1=1603692&r2=1603693&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/chooser/package-summary.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/chooser/package-summary.html Thu Jun 19 01:14:15 2014
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_60) on Tue Jun 17 22:49:30 PDT 2014 -->
+<!-- Generated by javadoc (version 1.7.0_51) on Wed Jun 18 18:05:17 PDT 2014 -->
<title>org.apache.samza.system.chooser (samza-api 0.7.0 API)</title>
-<meta name="date" content="2014-06-17">
+<meta name="date" content="2014-06-18">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
@@ -83,7 +83,9 @@
</tr>
<tr class="rowColor">
<td class="colFirst"><a href="../../../../../org/apache/samza/system/chooser/MessageChooserFactory.html" title="interface in org.apache.samza.system.chooser">MessageChooserFactory</a></td>
-<td class="colLast"> </td>
+<td class="colLast">
+<div class="block">Build an instance of a <a href="../../../../../org/apache/samza/system/chooser/MessageChooser.html" title="interface in org.apache.samza.system.chooser"><code>MessageChooser</code></a></div>
+</td>
</tr>
</tbody>
</table>
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/chooser/package-tree.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/chooser/package-tree.html?rev=1603693&r1=1603692&r2=1603693&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/chooser/package-tree.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/chooser/package-tree.html Thu Jun 19 01:14:15 2014
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_60) on Tue Jun 17 22:49:30 PDT 2014 -->
+<!-- Generated by javadoc (version 1.7.0_51) on Wed Jun 18 18:05:17 PDT 2014 -->
<title>org.apache.samza.system.chooser Class Hierarchy (samza-api 0.7.0 API)</title>
-<meta name="date" content="2014-06-17">
+<meta name="date" content="2014-06-18">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/package-frame.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/package-frame.html?rev=1603693&r1=1603692&r2=1603693&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/package-frame.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/package-frame.html Thu Jun 19 01:14:15 2014
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_60) on Tue Jun 17 22:49:30 PDT 2014 -->
+<!-- Generated by javadoc (version 1.7.0_51) on Wed Jun 18 18:05:17 PDT 2014 -->
<title>org.apache.samza.system (samza-api 0.7.0 API)</title>
-<meta name="date" content="2014-06-17">
+<meta name="date" content="2014-06-18">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
</head>
<body>
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/package-summary.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/package-summary.html?rev=1603693&r1=1603692&r2=1603693&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/package-summary.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/package-summary.html Thu Jun 19 01:14:15 2014
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_60) on Tue Jun 17 22:49:30 PDT 2014 -->
+<!-- Generated by javadoc (version 1.7.0_51) on Wed Jun 18 18:05:17 PDT 2014 -->
<title>org.apache.samza.system (samza-api 0.7.0 API)</title>
-<meta name="date" content="2014-06-17">
+<meta name="date" content="2014-06-18">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
</head>
<body>
@@ -77,7 +77,7 @@
<tr class="altColor">
<td class="colFirst"><a href="../../../../org/apache/samza/system/SystemAdmin.html" title="interface in org.apache.samza.system">SystemAdmin</a></td>
<td class="colLast">
-<div class="block">An interface that's use to interact with the underlying system to fetch
+<div class="block">Helper interface attached to an underlying system to fetch
information about streams, partitions, offsets, etc.</div>
</td>
</tr>
@@ -91,12 +91,16 @@
</tr>
<tr class="altColor">
<td class="colFirst"><a href="../../../../org/apache/samza/system/SystemFactory.html" title="interface in org.apache.samza.system">SystemFactory</a></td>
-<td class="colLast"> </td>
+<td class="colLast">
+<div class="block">Build the <a href="../../../../org/apache/samza/system/SystemConsumer.html" title="interface in org.apache.samza.system"><code>SystemConsumer</code></a> and <a href="../../../../org/apache/samza/system/SystemProducer.html" title="interface in org.apache.samza.system"><code>SystemProducer</code></a> for
+ a particular system, as well as the accompanying <a href="../../../../org/apache/samza/system/SystemAdmin.html" title="interface in org.apache.samza.system"><code>SystemAdmin</code></a>.</div>
+</td>
</tr>
<tr class="rowColor">
<td class="colFirst"><a href="../../../../org/apache/samza/system/SystemProducer.html" title="interface in org.apache.samza.system">SystemProducer</a></td>
<td class="colLast">
-<div class="block">Used as a standard interface for all producers of messages from a specified Samza source.</div>
+<div class="block">SystemProducers are how Samza writes messages from <a href="../../../../org/apache/samza/task/StreamTask.html" title="interface in org.apache.samza.task"><code>StreamTask</code></a>s to outside systems,
+ such as messaging systems like Kafka, or file systems.</div>
</td>
</tr>
</tbody>
@@ -120,13 +124,14 @@
<tr class="rowColor">
<td class="colFirst"><a href="../../../../org/apache/samza/system/OutgoingMessageEnvelope.html" title="class in org.apache.samza.system">OutgoingMessageEnvelope</a></td>
<td class="colLast">
-<div class="block">This class represents a message envelope that is sent by a StreamTask.</div>
+<div class="block">An OutgoingMessageEnvelope is sent to a specified <a href="../../../../org/apache/samza/system/SystemStream.html" title="class in org.apache.samza.system"><code>SystemStream</code></a> via the appropriate <a href="../../../../org/apache/samza/system/SystemProducer.html" title="interface in org.apache.samza.system"><code>SystemProducer</code></a>
+ from the user's <a href="../../../../org/apache/samza/task/StreamTask.html" title="interface in org.apache.samza.task"><code>StreamTask</code></a>.</div>
</td>
</tr>
<tr class="altColor">
<td class="colFirst"><a href="../../../../org/apache/samza/system/SystemStream.html" title="class in org.apache.samza.system">SystemStream</a></td>
<td class="colLast">
-<div class="block">Used to represent a Samza stream.</div>
+<div class="block">Streams in Samza consist of both the stream name and the system to which the stream belongs.</div>
</td>
</tr>
<tr class="rowColor">
@@ -145,12 +150,15 @@
<tr class="rowColor">
<td class="colFirst"><a href="../../../../org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system">SystemStreamPartition</a></td>
<td class="colLast">
-<div class="block">Aggregate object representing a partition of a Samza stream.</div>
+<div class="block">Aggregate object representing a both the <a href="../../../../org/apache/samza/system/SystemStream.html" title="class in org.apache.samza.system"><code>SystemStream</code></a> and <a href="../../../../org/apache/samza/Partition.html" title="class in org.apache.samza"><code>Partition</code></a>.</div>
</td>
</tr>
<tr class="altColor">
<td class="colFirst"><a href="../../../../org/apache/samza/system/SystemStreamPartitionIterator.html" title="class in org.apache.samza.system">SystemStreamPartitionIterator</a></td>
-<td class="colLast"> </td>
+<td class="colLast">
+<div class="block"><code>Iterator</code> that wraps a <a href="../../../../org/apache/samza/system/SystemConsumer.html" title="interface in org.apache.samza.system"><code>SystemConsumer</code></a> to iterate over
+ the messages the consumer provides for the specified <a href="../../../../org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system"><code>SystemStreamPartition</code></a>.</div>
+</td>
</tr>
</tbody>
</table>
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/package-tree.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/package-tree.html?rev=1603693&r1=1603692&r2=1603693&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/package-tree.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/package-tree.html Thu Jun 19 01:14:15 2014
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_60) on Tue Jun 17 22:49:30 PDT 2014 -->
+<!-- Generated by javadoc (version 1.7.0_51) on Wed Jun 18 18:05:17 PDT 2014 -->
<title>org.apache.samza.system Class Hierarchy (samza-api 0.7.0 API)</title>
-<meta name="date" content="2014-06-17">
+<meta name="date" content="2014-06-18">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
</head>
<body>
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/ClosableTask.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/ClosableTask.html?rev=1603693&r1=1603692&r2=1603693&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/ClosableTask.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/ClosableTask.html Thu Jun 19 01:14:15 2014
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_60) on Tue Jun 17 22:49:30 PDT 2014 -->
+<!-- Generated by javadoc (version 1.7.0_51) on Wed Jun 18 18:05:17 PDT 2014 -->
<title>ClosableTask (samza-api 0.7.0 API)</title>
-<meta name="date" content="2014-06-17">
+<meta name="date" content="2014-06-18">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
</head>
<body>
@@ -88,6 +88,10 @@
<hr>
<br>
<pre>public interface <span class="strong">ClosableTask</span></pre>
+<div class="block">A ClosableTask augments <a href="../../../../org/apache/samza/task/StreamTask.html" title="interface in org.apache.samza.task"><code>StreamTask</code></a>, allowing the method implementer to specify
+ code that will be called when the StreamTask is being shut down by the framework, providing to emit final metrics,
+ clean or close resources, etc. The close method is not guaranteed to be called in event of crash or hard kill
+ of the process.</div>
</li>
</ul>
</div>
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/InitableTask.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/InitableTask.html?rev=1603693&r1=1603692&r2=1603693&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/InitableTask.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/InitableTask.html Thu Jun 19 01:14:15 2014
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_60) on Tue Jun 17 22:49:30 PDT 2014 -->
+<!-- Generated by javadoc (version 1.7.0_51) on Wed Jun 18 18:05:17 PDT 2014 -->
<title>InitableTask (samza-api 0.7.0 API)</title>
-<meta name="date" content="2014-06-17">
+<meta name="date" content="2014-06-18">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
</head>
<body>
@@ -110,7 +110,7 @@
</tr>
<tr class="altColor">
<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><strong><a href="../../../../org/apache/samza/task/InitableTask.html#init(org.apache.samza.config.Config,%20org.apache.samza.task.TaskContext)">init</a></strong>(<a href="../../../../org/apache/samza/config/Config.html" title="class in org.apache.samza.config">Config</a> config,
+<td class="colLast"><code><strong><a href="../../../../org/apache/samza/task/InitableTask.html#init(org.apache.samza.config.Config, org.apache.samza.task.TaskContext)">init</a></strong>(<a href="../../../../org/apache/samza/config/Config.html" title="class in org.apache.samza.config">Config</a> config,
<a href="../../../../org/apache/samza/task/TaskContext.html" title="interface in org.apache.samza.task">TaskContext</a> context)</code>
<div class="block">Called by TaskRunner each time an implementing task is created.</div>
</td>
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/MessageCollector.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/MessageCollector.html?rev=1603693&r1=1603692&r2=1603693&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/MessageCollector.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/MessageCollector.html Thu Jun 19 01:14:15 2014
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_60) on Tue Jun 17 22:49:30 PDT 2014 -->
+<!-- Generated by javadoc (version 1.7.0_51) on Wed Jun 18 18:05:17 PDT 2014 -->
<title>MessageCollector (samza-api 0.7.0 API)</title>
-<meta name="date" content="2014-06-17">
+<meta name="date" content="2014-06-18">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
</head>
<body>
@@ -90,8 +90,8 @@
<pre>public interface <span class="strong">MessageCollector</span></pre>
<div class="block">Used as an interface for the means of sending message envelopes to an output stream.
- <p>A MessageCollector is provided on every call to <a href="../../../../org/apache/samza/task/StreamTask.html#process(org.apache.samza.system.IncomingMessageEnvelope,%20org.apache.samza.task.MessageCollector,%20org.apache.samza.task.TaskCoordinator)"><code>StreamTask.process(org.apache.samza.system.IncomingMessageEnvelope, org.apache.samza.task.MessageCollector, org.apache.samza.task.TaskCoordinator)</code></a> and
- <a href="../../../../org/apache/samza/task/WindowableTask.html#window(org.apache.samza.task.MessageCollector,%20org.apache.samza.task.TaskCoordinator)"><code>WindowableTask.window(org.apache.samza.task.MessageCollector, org.apache.samza.task.TaskCoordinator)</code></a>. You must use those MessageCollector objects only within
+ <p>A MessageCollector is provided on every call to <a href="../../../../org/apache/samza/task/StreamTask.html#process(org.apache.samza.system.IncomingMessageEnvelope, org.apache.samza.task.MessageCollector, org.apache.samza.task.TaskCoordinator)"><code>StreamTask.process(org.apache.samza.system.IncomingMessageEnvelope, org.apache.samza.task.MessageCollector, org.apache.samza.task.TaskCoordinator)</code></a> and
+ <a href="../../../../org/apache/samza/task/WindowableTask.html#window(org.apache.samza.task.MessageCollector, org.apache.samza.task.TaskCoordinator)"><code>WindowableTask.window(org.apache.samza.task.MessageCollector, org.apache.samza.task.TaskCoordinator)</code></a>. You must use those MessageCollector objects only within
those method calls, and not hold on to a reference for use at any other time.</div>
</li>
</ul>
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/StreamTask.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/StreamTask.html?rev=1603693&r1=1603692&r2=1603693&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/StreamTask.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/StreamTask.html Thu Jun 19 01:14:15 2014
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_60) on Tue Jun 17 22:49:30 PDT 2014 -->
+<!-- Generated by javadoc (version 1.7.0_51) on Wed Jun 18 18:05:17 PDT 2014 -->
<title>StreamTask (samza-api 0.7.0 API)</title>
-<meta name="date" content="2014-06-17">
+<meta name="date" content="2014-06-18">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
</head>
<body>
@@ -88,8 +88,17 @@
<hr>
<br>
<pre>public interface <span class="strong">StreamTask</span></pre>
-<div class="block">Used as a standard interface for all user processing tasks. Receives messages from a partition of a specified input
- stream.</div>
+<div class="block">A StreamTask is the basic class on which Samza jobs are implemented. Developers writing Samza jobs begin by
+ implementing this class, which processes messages from the job's input streams and writes messages out to
+ streams via the provided <a href="../../../../org/apache/samza/task/MessageCollector.html" title="interface in org.apache.samza.task"><code>MessageCollector</code></a>. A StreamTask may be augmented by
+ implementing other interfaces, such as <a href="../../../../org/apache/samza/task/InitableTask.html" title="interface in org.apache.samza.task"><code>InitableTask</code></a>, <a href="../../../../org/apache/samza/task/WindowableTask.html" title="interface in org.apache.samza.task"><code>WindowableTask</code></a>,
+ or <a href="../../../../org/apache/samza/task/ClosableTask.html" title="interface in org.apache.samza.task"><code>ClosableTask</code></a>.
+ <p>
+ The methods of StreamTasks and associated other tasks are guaranteed to be called in a single-threaded fashion;
+ no extra synchronization is necessary on the part of the class implementer. References to instances of
+ <a href="../../../../org/apache/samza/system/IncomingMessageEnvelope.html" title="class in org.apache.samza.system"><code>IncomingMessageEnvelope</code></a>s,<a href="../../../../org/apache/samza/task/MessageCollector.html" title="interface in org.apache.samza.task"><code>MessageCollector</code></a>s, and
+ <a href="../../../../org/apache/samza/task/TaskCoordinator.html" title="interface in org.apache.samza.task"><code>TaskCoordinator</code></a> should not be held onto between calls; there is no guarantee that
+ these will not be invalidated or otherwise used by the framework.</div>
</li>
</ul>
</div>
@@ -110,7 +119,7 @@
</tr>
<tr class="altColor">
<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><strong><a href="../../../../org/apache/samza/task/StreamTask.html#process(org.apache.samza.system.IncomingMessageEnvelope,%20org.apache.samza.task.MessageCollector,%20org.apache.samza.task.TaskCoordinator)">process</a></strong>(<a href="../../../../org/apache/samza/system/IncomingMessageEnvelope.html" title="class in org.apache.samza.system">IncomingMessageEnvelope</a> envelope,
+<td class="colLast"><code><strong><a href="../../../../org/apache/samza/task/StreamTask.html#process(org.apache.samza.system.IncomingMessageEnvelope, org.apache.samza.task.MessageCollector, org.apache.samza.task.TaskCoordinator)">process</a></strong>(<a href="../../../../org/apache/samza/system/IncomingMessageEnvelope.html" title="class in org.apache.samza.system">IncomingMessageEnvelope</a> envelope,
<a href="../../../../org/apache/samza/task/MessageCollector.html" title="interface in org.apache.samza.task">MessageCollector</a> collector,
<a href="../../../../org/apache/samza/task/TaskCoordinator.html" title="interface in org.apache.samza.task">TaskCoordinator</a> coordinator)</code>
<div class="block">Called once for each message that this StreamTask receives.</div>
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/TaskContext.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/TaskContext.html?rev=1603693&r1=1603692&r2=1603693&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/TaskContext.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/TaskContext.html Thu Jun 19 01:14:15 2014
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_60) on Tue Jun 17 22:49:30 PDT 2014 -->
+<!-- Generated by javadoc (version 1.7.0_51) on Wed Jun 18 18:05:17 PDT 2014 -->
<title>TaskContext (samza-api 0.7.0 API)</title>
-<meta name="date" content="2014-06-17">
+<meta name="date" content="2014-06-18">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
</head>
<body>
@@ -88,6 +88,8 @@
<hr>
<br>
<pre>public interface <span class="strong">TaskContext</span></pre>
+<div class="block">A TaskContext provides resources about the <a href="../../../../org/apache/samza/task/StreamTask.html" title="interface in org.apache.samza.task"><code>StreamTask</code></a>, particularly during
+ initialization in an <a href="../../../../org/apache/samza/task/InitableTask.html" title="interface in org.apache.samza.task"><code>InitableTask</code></a> and during calls to <a href="../../../../org/apache/samza/task/TaskLifecycleListener.html" title="interface in org.apache.samza.task"><code>TaskLifecycleListener</code></a>s.</div>
</li>
</ul>
</div>
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/TaskCoordinator.RequestScope.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/TaskCoordinator.RequestScope.html?rev=1603693&r1=1603692&r2=1603693&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/TaskCoordinator.RequestScope.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/TaskCoordinator.RequestScope.html Thu Jun 19 01:14:15 2014
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_60) on Tue Jun 17 22:49:30 PDT 2014 -->
+<!-- Generated by javadoc (version 1.7.0_51) on Wed Jun 18 18:05:17 PDT 2014 -->
<title>TaskCoordinator.RequestScope (samza-api 0.7.0 API)</title>
-<meta name="date" content="2014-06-17">
+<meta name="date" content="2014-06-18">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
</head>
<body>
@@ -241,7 +241,8 @@ over the constants as follows:
for (TaskCoordinator.RequestScope c : TaskCoordinator.RequestScope.values())
System.out.println(c);
</pre></div>
-<dl><dt><span class="strong">Returns:</span></dt><dd>an array containing the constants of this enum type, in the order they are declared</dd></dl>
+<dl><dt><span class="strong">Returns:</span></dt><dd>an array containing the constants of this enum type, in
+the order they are declared</dd></dl>
</li>
</ul>
<a name="valueOf(java.lang.String)">
@@ -258,7 +259,8 @@ not permitted.)</div>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>name</code> - the name of the enum constant to be returned.</dd>
<dt><span class="strong">Returns:</span></dt><dd>the enum constant with the specified name</dd>
<dt><span class="strong">Throws:</span></dt>
-<dd><code>java.lang.IllegalArgumentException</code> - if this enum type has no constant with the specified name</dd>
+<dd><code>java.lang.IllegalArgumentException</code> - if this enum type has no constant
+with the specified name</dd>
<dd><code>java.lang.NullPointerException</code> - if the argument is null</dd></dl>
</li>
</ul>
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/TaskCoordinator.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/TaskCoordinator.html?rev=1603693&r1=1603692&r2=1603693&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/TaskCoordinator.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/TaskCoordinator.html Thu Jun 19 01:14:15 2014
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_60) on Tue Jun 17 22:49:30 PDT 2014 -->
+<!-- Generated by javadoc (version 1.7.0_51) on Wed Jun 18 18:05:17 PDT 2014 -->
<title>TaskCoordinator (samza-api 0.7.0 API)</title>
-<meta name="date" content="2014-06-17">
+<meta name="date" content="2014-06-18">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
</head>
<body>
@@ -88,6 +88,13 @@
<hr>
<br>
<pre>public interface <span class="strong">TaskCoordinator</span></pre>
+<div class="block">TaskCoordinators are provided to the process methods of <a href="../../../../org/apache/samza/task/StreamTask.html" title="interface in org.apache.samza.task"><code>StreamTask</code></a> implementations
+ to allow the user code to request actions from the Samza framework, including committing the current checkpoints
+ to configured <a href="../../../../org/apache/samza/checkpoint/CheckpointManager.html" title="interface in org.apache.samza.checkpoint"><code>CheckpointManager</code></a>s or shutting down the task or all tasks within
+ a container.
+ <p>
+ This interface may evolve over time.
+ </p></div>
</li>
</ul>
</div>
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/TaskLifecycleListener.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/TaskLifecycleListener.html?rev=1603693&r1=1603692&r2=1603693&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/TaskLifecycleListener.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/TaskLifecycleListener.html Thu Jun 19 01:14:15 2014
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_60) on Tue Jun 17 22:49:30 PDT 2014 -->
+<!-- Generated by javadoc (version 1.7.0_51) on Wed Jun 18 18:05:17 PDT 2014 -->
<title>TaskLifecycleListener (samza-api 0.7.0 API)</title>
-<meta name="date" content="2014-06-17">
+<meta name="date" content="2014-06-18">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
</head>
<body>
@@ -110,21 +110,21 @@
</tr>
<tr class="altColor">
<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><strong><a href="../../../../org/apache/samza/task/TaskLifecycleListener.html#afterClose(org.apache.samza.config.Config,%20org.apache.samza.task.TaskContext)">afterClose</a></strong>(<a href="../../../../org/apache/samza/config/Config.html" title="class in org.apache.samza.config">Config</a> config,
+<td class="colLast"><code><strong><a href="../../../../org/apache/samza/task/TaskLifecycleListener.html#afterClose(org.apache.samza.config.Config, org.apache.samza.task.TaskContext)">afterClose</a></strong>(<a href="../../../../org/apache/samza/config/Config.html" title="class in org.apache.samza.config">Config</a> config,
<a href="../../../../org/apache/samza/task/TaskContext.html" title="interface in org.apache.samza.task">TaskContext</a> context)</code>
<div class="block">Called after all tasks in TaskRunner are closed.</div>
</td>
</tr>
<tr class="rowColor">
<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><strong><a href="../../../../org/apache/samza/task/TaskLifecycleListener.html#afterInit(org.apache.samza.config.Config,%20org.apache.samza.task.TaskContext)">afterInit</a></strong>(<a href="../../../../org/apache/samza/config/Config.html" title="class in org.apache.samza.config">Config</a> config,
+<td class="colLast"><code><strong><a href="../../../../org/apache/samza/task/TaskLifecycleListener.html#afterInit(org.apache.samza.config.Config, org.apache.samza.task.TaskContext)">afterInit</a></strong>(<a href="../../../../org/apache/samza/config/Config.html" title="class in org.apache.samza.config">Config</a> config,
<a href="../../../../org/apache/samza/task/TaskContext.html" title="interface in org.apache.samza.task">TaskContext</a> context)</code>
<div class="block">Called after all tasks in TaskRunner are initialized.</div>
</td>
</tr>
<tr class="altColor">
<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><strong><a href="../../../../org/apache/samza/task/TaskLifecycleListener.html#afterProcess(org.apache.samza.system.IncomingMessageEnvelope,%20org.apache.samza.config.Config,%20org.apache.samza.task.TaskContext)">afterProcess</a></strong>(<a href="../../../../org/apache/samza/system/IncomingMessageEnvelope.html" title="class in org.apache.samza.system">IncomingMessageEnvelope</a> envelope,
+<td class="colLast"><code><strong><a href="../../../../org/apache/samza/task/TaskLifecycleListener.html#afterProcess(org.apache.samza.system.IncomingMessageEnvelope, org.apache.samza.config.Config, org.apache.samza.task.TaskContext)">afterProcess</a></strong>(<a href="../../../../org/apache/samza/system/IncomingMessageEnvelope.html" title="class in org.apache.samza.system">IncomingMessageEnvelope</a> envelope,
<a href="../../../../org/apache/samza/config/Config.html" title="class in org.apache.samza.config">Config</a> config,
<a href="../../../../org/apache/samza/task/TaskContext.html" title="interface in org.apache.samza.task">TaskContext</a> context)</code>
<div class="block">Called after a message is processed by a task.</div>
@@ -132,21 +132,21 @@
</tr>
<tr class="rowColor">
<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><strong><a href="../../../../org/apache/samza/task/TaskLifecycleListener.html#beforeClose(org.apache.samza.config.Config,%20org.apache.samza.task.TaskContext)">beforeClose</a></strong>(<a href="../../../../org/apache/samza/config/Config.html" title="class in org.apache.samza.config">Config</a> config,
+<td class="colLast"><code><strong><a href="../../../../org/apache/samza/task/TaskLifecycleListener.html#beforeClose(org.apache.samza.config.Config, org.apache.samza.task.TaskContext)">beforeClose</a></strong>(<a href="../../../../org/apache/samza/config/Config.html" title="class in org.apache.samza.config">Config</a> config,
<a href="../../../../org/apache/samza/task/TaskContext.html" title="interface in org.apache.samza.task">TaskContext</a> context)</code>
<div class="block">Called before all tasks in TaskRunner are closed.</div>
</td>
</tr>
<tr class="altColor">
<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><strong><a href="../../../../org/apache/samza/task/TaskLifecycleListener.html#beforeInit(org.apache.samza.config.Config,%20org.apache.samza.task.TaskContext)">beforeInit</a></strong>(<a href="../../../../org/apache/samza/config/Config.html" title="class in org.apache.samza.config">Config</a> config,
+<td class="colLast"><code><strong><a href="../../../../org/apache/samza/task/TaskLifecycleListener.html#beforeInit(org.apache.samza.config.Config, org.apache.samza.task.TaskContext)">beforeInit</a></strong>(<a href="../../../../org/apache/samza/config/Config.html" title="class in org.apache.samza.config">Config</a> config,
<a href="../../../../org/apache/samza/task/TaskContext.html" title="interface in org.apache.samza.task">TaskContext</a> context)</code>
<div class="block">Called before all tasks in TaskRunner are initialized.</div>
</td>
</tr>
<tr class="rowColor">
<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><strong><a href="../../../../org/apache/samza/task/TaskLifecycleListener.html#beforeProcess(org.apache.samza.system.IncomingMessageEnvelope,%20org.apache.samza.config.Config,%20org.apache.samza.task.TaskContext)">beforeProcess</a></strong>(<a href="../../../../org/apache/samza/system/IncomingMessageEnvelope.html" title="class in org.apache.samza.system">IncomingMessageEnvelope</a> envelope,
+<td class="colLast"><code><strong><a href="../../../../org/apache/samza/task/TaskLifecycleListener.html#beforeProcess(org.apache.samza.system.IncomingMessageEnvelope, org.apache.samza.config.Config, org.apache.samza.task.TaskContext)">beforeProcess</a></strong>(<a href="../../../../org/apache/samza/system/IncomingMessageEnvelope.html" title="class in org.apache.samza.system">IncomingMessageEnvelope</a> envelope,
<a href="../../../../org/apache/samza/config/Config.html" title="class in org.apache.samza.config">Config</a> config,
<a href="../../../../org/apache/samza/task/TaskContext.html" title="interface in org.apache.samza.task">TaskContext</a> context)</code>
<div class="block">Called before a message is processed by a task.</div>
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/TaskLifecycleListenerFactory.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/TaskLifecycleListenerFactory.html?rev=1603693&r1=1603692&r2=1603693&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/TaskLifecycleListenerFactory.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/TaskLifecycleListenerFactory.html Thu Jun 19 01:14:15 2014
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_60) on Tue Jun 17 22:49:30 PDT 2014 -->
+<!-- Generated by javadoc (version 1.7.0_51) on Wed Jun 18 18:05:17 PDT 2014 -->
<title>TaskLifecycleListenerFactory (samza-api 0.7.0 API)</title>
-<meta name="date" content="2014-06-17">
+<meta name="date" content="2014-06-18">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
</head>
<body>
@@ -88,6 +88,7 @@
<hr>
<br>
<pre>public interface <span class="strong">TaskLifecycleListenerFactory</span></pre>
+<div class="block">Build a <a href="../../../../org/apache/samza/task/TaskLifecycleListener.html" title="interface in org.apache.samza.task"><code>TaskLifecycleListener</code></a></div>
</li>
</ul>
</div>
@@ -108,7 +109,7 @@
</tr>
<tr class="altColor">
<td class="colFirst"><code><a href="../../../../org/apache/samza/task/TaskLifecycleListener.html" title="interface in org.apache.samza.task">TaskLifecycleListener</a></code></td>
-<td class="colLast"><code><strong><a href="../../../../org/apache/samza/task/TaskLifecycleListenerFactory.html#getLifecyleListener(java.lang.String,%20org.apache.samza.config.Config)">getLifecyleListener</a></strong>(java.lang.String name,
+<td class="colLast"><code><strong><a href="../../../../org/apache/samza/task/TaskLifecycleListenerFactory.html#getLifecyleListener(java.lang.String, org.apache.samza.config.Config)">getLifecyleListener</a></strong>(java.lang.String name,
<a href="../../../../org/apache/samza/config/Config.html" title="class in org.apache.samza.config">Config</a> config)</code> </td>
</tr>
</table>
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/WindowableTask.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/WindowableTask.html?rev=1603693&r1=1603692&r2=1603693&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/WindowableTask.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/WindowableTask.html Thu Jun 19 01:14:15 2014
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_60) on Tue Jun 17 22:49:30 PDT 2014 -->
+<!-- Generated by javadoc (version 1.7.0_51) on Wed Jun 18 18:05:17 PDT 2014 -->
<title>WindowableTask (samza-api 0.7.0 API)</title>
-<meta name="date" content="2014-06-17">
+<meta name="date" content="2014-06-18">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
</head>
<body>
@@ -88,7 +88,10 @@
<hr>
<br>
<pre>public interface <span class="strong">WindowableTask</span></pre>
-<div class="block">Used as a standard interface to allow user processing tasks to operate on specified time intervals, or "windows".</div>
+<div class="block">Add-on interface to <a href="../../../../org/apache/samza/task/StreamTask.html" title="interface in org.apache.samza.task"><code>StreamTask</code></a> implementations to add code which will be run on
+ a specified time interval (via configuration). This can be used to implement direct time-based windowing or,
+ with a frequent window interval, windowing based on some other condition which is checked during the call to
+ window. The window method will be called even if no messages are received for a particular StreamTask.</div>
</li>
</ul>
</div>
@@ -109,7 +112,7 @@
</tr>
<tr class="altColor">
<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><strong><a href="../../../../org/apache/samza/task/WindowableTask.html#window(org.apache.samza.task.MessageCollector,%20org.apache.samza.task.TaskCoordinator)">window</a></strong>(<a href="../../../../org/apache/samza/task/MessageCollector.html" title="interface in org.apache.samza.task">MessageCollector</a> collector,
+<td class="colLast"><code><strong><a href="../../../../org/apache/samza/task/WindowableTask.html#window(org.apache.samza.task.MessageCollector, org.apache.samza.task.TaskCoordinator)">window</a></strong>(<a href="../../../../org/apache/samza/task/MessageCollector.html" title="interface in org.apache.samza.task">MessageCollector</a> collector,
<a href="../../../../org/apache/samza/task/TaskCoordinator.html" title="interface in org.apache.samza.task">TaskCoordinator</a> coordinator)</code>
<div class="block">Called by TaskRunner for each implementing task at the end of every specified window.</div>
</td>
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/package-frame.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/package-frame.html?rev=1603693&r1=1603692&r2=1603693&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/package-frame.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/package-frame.html Thu Jun 19 01:14:15 2014
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_60) on Tue Jun 17 22:49:30 PDT 2014 -->
+<!-- Generated by javadoc (version 1.7.0_51) on Wed Jun 18 18:05:17 PDT 2014 -->
<title>org.apache.samza.task (samza-api 0.7.0 API)</title>
-<meta name="date" content="2014-06-17">
+<meta name="date" content="2014-06-18">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
</head>
<body>
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/package-summary.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/package-summary.html?rev=1603693&r1=1603692&r2=1603693&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/package-summary.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/package-summary.html Thu Jun 19 01:14:15 2014
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_60) on Tue Jun 17 22:49:30 PDT 2014 -->
+<!-- Generated by javadoc (version 1.7.0_51) on Wed Jun 18 18:05:17 PDT 2014 -->
<title>org.apache.samza.task (samza-api 0.7.0 API)</title>
-<meta name="date" content="2014-06-17">
+<meta name="date" content="2014-06-18">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
</head>
<body>
@@ -76,7 +76,11 @@
<tbody>
<tr class="altColor">
<td class="colFirst"><a href="../../../../org/apache/samza/task/ClosableTask.html" title="interface in org.apache.samza.task">ClosableTask</a></td>
-<td class="colLast"> </td>
+<td class="colLast">
+<div class="block">A ClosableTask augments <a href="../../../../org/apache/samza/task/StreamTask.html" title="interface in org.apache.samza.task"><code>StreamTask</code></a>, allowing the method implementer to specify
+ code that will be called when the StreamTask is being shut down by the framework, providing to emit final metrics,
+ clean or close resources, etc.</div>
+</td>
</tr>
<tr class="rowColor">
<td class="colFirst"><a href="../../../../org/apache/samza/task/InitableTask.html" title="interface in org.apache.samza.task">InitableTask</a></td>
@@ -94,16 +98,24 @@
<tr class="rowColor">
<td class="colFirst"><a href="../../../../org/apache/samza/task/StreamTask.html" title="interface in org.apache.samza.task">StreamTask</a></td>
<td class="colLast">
-<div class="block">Used as a standard interface for all user processing tasks.</div>
+<div class="block">A StreamTask is the basic class on which Samza jobs are implemented.</div>
</td>
</tr>
<tr class="altColor">
<td class="colFirst"><a href="../../../../org/apache/samza/task/TaskContext.html" title="interface in org.apache.samza.task">TaskContext</a></td>
-<td class="colLast"> </td>
+<td class="colLast">
+<div class="block">A TaskContext provides resources about the <a href="../../../../org/apache/samza/task/StreamTask.html" title="interface in org.apache.samza.task"><code>StreamTask</code></a>, particularly during
+ initialization in an <a href="../../../../org/apache/samza/task/InitableTask.html" title="interface in org.apache.samza.task"><code>InitableTask</code></a> and during calls to <a href="../../../../org/apache/samza/task/TaskLifecycleListener.html" title="interface in org.apache.samza.task"><code>TaskLifecycleListener</code></a>s.</div>
+</td>
</tr>
<tr class="rowColor">
<td class="colFirst"><a href="../../../../org/apache/samza/task/TaskCoordinator.html" title="interface in org.apache.samza.task">TaskCoordinator</a></td>
-<td class="colLast"> </td>
+<td class="colLast">
+<div class="block">TaskCoordinators are provided to the process methods of <a href="../../../../org/apache/samza/task/StreamTask.html" title="interface in org.apache.samza.task"><code>StreamTask</code></a> implementations
+ to allow the user code to request actions from the Samza framework, including committing the current checkpoints
+ to configured <a href="../../../../org/apache/samza/checkpoint/CheckpointManager.html" title="interface in org.apache.samza.checkpoint"><code>CheckpointManager</code></a>s or shutting down the task or all tasks within
+ a container.</div>
+</td>
</tr>
<tr class="altColor">
<td class="colFirst"><a href="../../../../org/apache/samza/task/TaskLifecycleListener.html" title="interface in org.apache.samza.task">TaskLifecycleListener</a></td>
@@ -114,12 +126,15 @@
</tr>
<tr class="rowColor">
<td class="colFirst"><a href="../../../../org/apache/samza/task/TaskLifecycleListenerFactory.html" title="interface in org.apache.samza.task">TaskLifecycleListenerFactory</a></td>
-<td class="colLast"> </td>
+<td class="colLast">
+<div class="block">Build a <a href="../../../../org/apache/samza/task/TaskLifecycleListener.html" title="interface in org.apache.samza.task"><code>TaskLifecycleListener</code></a></div>
+</td>
</tr>
<tr class="altColor">
<td class="colFirst"><a href="../../../../org/apache/samza/task/WindowableTask.html" title="interface in org.apache.samza.task">WindowableTask</a></td>
<td class="colLast">
-<div class="block">Used as a standard interface to allow user processing tasks to operate on specified time intervals, or "windows".</div>
+<div class="block">Add-on interface to <a href="../../../../org/apache/samza/task/StreamTask.html" title="interface in org.apache.samza.task"><code>StreamTask</code></a> implementations to add code which will be run on
+ a specified time interval (via configuration).</div>
</td>
</tr>
</tbody>
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/package-tree.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/package-tree.html?rev=1603693&r1=1603692&r2=1603693&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/package-tree.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/task/package-tree.html Thu Jun 19 01:14:15 2014
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_60) on Tue Jun 17 22:49:30 PDT 2014 -->
+<!-- Generated by javadoc (version 1.7.0_51) on Wed Jun 18 18:05:17 PDT 2014 -->
<title>org.apache.samza.task Class Hierarchy (samza-api 0.7.0 API)</title>
-<meta name="date" content="2014-06-17">
+<meta name="date" content="2014-06-18">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
</head>
<body>
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/util/BlockingEnvelopeMap.BlockingEnvelopeMapMetrics.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/util/BlockingEnvelopeMap.BlockingEnvelopeMapMetrics.html?rev=1603693&r1=1603692&r2=1603693&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/util/BlockingEnvelopeMap.BlockingEnvelopeMapMetrics.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/util/BlockingEnvelopeMap.BlockingEnvelopeMapMetrics.html Thu Jun 19 01:14:15 2014
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_60) on Tue Jun 17 22:49:30 PDT 2014 -->
+<!-- Generated by javadoc (version 1.7.0_51) on Wed Jun 18 18:05:17 PDT 2014 -->
<title>BlockingEnvelopeMap.BlockingEnvelopeMapMetrics (samza-api 0.7.0 API)</title>
-<meta name="date" content="2014-06-17">
+<meta name="date" content="2014-06-18">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
</head>
<body>
@@ -119,7 +119,7 @@ extends java.lang.Object</pre>
<th class="colOne" scope="col">Constructor and Description</th>
</tr>
<tr class="altColor">
-<td class="colOne"><code><strong><a href="../../../../org/apache/samza/util/BlockingEnvelopeMap.BlockingEnvelopeMapMetrics.html#BlockingEnvelopeMap.BlockingEnvelopeMapMetrics(java.lang.String,%20org.apache.samza.metrics.MetricsRegistry)">BlockingEnvelopeMap.BlockingEnvelopeMapMetrics</a></strong>(java.lang.String group,
+<td class="colOne"><code><strong><a href="../../../../org/apache/samza/util/BlockingEnvelopeMap.BlockingEnvelopeMapMetrics.html#BlockingEnvelopeMap.BlockingEnvelopeMapMetrics(java.lang.String, org.apache.samza.metrics.MetricsRegistry)">BlockingEnvelopeMap.BlockingEnvelopeMapMetrics</a></strong>(java.lang.String group,
<a href="../../../../org/apache/samza/metrics/MetricsRegistry.html" title="interface in org.apache.samza.metrics">MetricsRegistry</a> metricsRegistry)</code> </td>
</tr>
</table>
@@ -155,7 +155,7 @@ extends java.lang.Object</pre>
</tr>
<tr class="altColor">
<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><strong><a href="../../../../org/apache/samza/util/BlockingEnvelopeMap.BlockingEnvelopeMapMetrics.html#setNoMoreMessages(org.apache.samza.system.SystemStreamPartition,%20boolean)">setNoMoreMessages</a></strong>(<a href="../../../../org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system">SystemStreamPartition</a> systemStreamPartition,
+<td class="colLast"><code><strong><a href="../../../../org/apache/samza/util/BlockingEnvelopeMap.BlockingEnvelopeMapMetrics.html#setNoMoreMessages(org.apache.samza.system.SystemStreamPartition, boolean)">setNoMoreMessages</a></strong>(<a href="../../../../org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system">SystemStreamPartition</a> systemStreamPartition,
boolean noMoreMessages)</code> </td>
</tr>
</table>
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/util/BlockingEnvelopeMap.BufferGauge.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/util/BlockingEnvelopeMap.BufferGauge.html?rev=1603693&r1=1603692&r2=1603693&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/util/BlockingEnvelopeMap.BufferGauge.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/util/BlockingEnvelopeMap.BufferGauge.html Thu Jun 19 01:14:15 2014
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_60) on Tue Jun 17 22:49:30 PDT 2014 -->
+<!-- Generated by javadoc (version 1.7.0_51) on Wed Jun 18 18:05:17 PDT 2014 -->
<title>BlockingEnvelopeMap.BufferGauge (samza-api 0.7.0 API)</title>
-<meta name="date" content="2014-06-17">
+<meta name="date" content="2014-06-18">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
</head>
<body>
@@ -128,7 +128,7 @@ extends <a href="../../../../org/apache/
<th class="colOne" scope="col">Constructor and Description</th>
</tr>
<tr class="altColor">
-<td class="colOne"><code><strong><a href="../../../../org/apache/samza/util/BlockingEnvelopeMap.BufferGauge.html#BlockingEnvelopeMap.BufferGauge(org.apache.samza.system.SystemStreamPartition,%20java.lang.String)">BlockingEnvelopeMap.BufferGauge</a></strong>(<a href="../../../../org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system">SystemStreamPartition</a> systemStreamPartition,
+<td class="colOne"><code><strong><a href="../../../../org/apache/samza/util/BlockingEnvelopeMap.BufferGauge.html#BlockingEnvelopeMap.BufferGauge(org.apache.samza.system.SystemStreamPartition, java.lang.String)">BlockingEnvelopeMap.BufferGauge</a></strong>(<a href="../../../../org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system">SystemStreamPartition</a> systemStreamPartition,
java.lang.String name)</code> </td>
</tr>
</table>
@@ -156,7 +156,7 @@ extends <a href="../../../../org/apache/
<!-- -->
</a>
<h3>Methods inherited from class org.apache.samza.metrics.<a href="../../../../org/apache/samza/metrics/Gauge.html" title="class in org.apache.samza.metrics">Gauge</a></h3>
-<code><a href="../../../../org/apache/samza/metrics/Gauge.html#compareAndSet(T,%20T)">compareAndSet</a>, <a href="../../../../org/apache/samza/metrics/Gauge.html#getName()">getName</a>, <a href="../../../../org/apache/samza/metrics/Gauge.html#set(T)">set</a>, <a href="../../../../org/apache/samza/metrics/Gauge.html#toString()">toString</a>, <a href="../../../../org/apache/samza/metrics/Gauge.html#visit(org.apache.samza.metrics.MetricsVisitor)">visit</a></code></li>
+<code><a href="../../../../org/apache/samza/metrics/Gauge.html#compareAndSet(T, T)">compareAndSet</a>, <a href="../../../../org/apache/samza/metrics/Gauge.html#getName()">getName</a>, <a href="../../../../org/apache/samza/metrics/Gauge.html#set(T)">set</a>, <a href="../../../../org/apache/samza/metrics/Gauge.html#toString()">toString</a>, <a href="../../../../org/apache/samza/metrics/Gauge.html#visit(org.apache.samza.metrics.MetricsVisitor)">visit</a></code></li>
</ul>
<ul class="blockList">
<li class="blockList"><a name="methods_inherited_from_class_java.lang.Object">