You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by cr...@apache.org on 2013/10/05 00:10:50 UTC
svn commit: r1529329 [3/3] - 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...
Added: 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=1529329&view=auto
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/chooser/package-tree.html (added)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/chooser/package-tree.html Fri Oct 4 22:10:48 2013
@@ -0,0 +1,157 @@
+<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
+<!--NewPage-->
+<HTML>
+<HEAD>
+<!-- Generated by javadoc (build 1.6.0_51) on Fri Oct 04 15:10:30 PDT 2013 -->
+<TITLE>
+org.apache.samza.system.chooser Class Hierarchy (samza-api 0.7.0 API)
+</TITLE>
+
+<META NAME="date" CONTENT="2013-10-04">
+
+<LINK REL ="stylesheet" TYPE="text/css" HREF="../../../../../stylesheet.css" TITLE="Style">
+
+<SCRIPT type="text/javascript">
+function windowTitle()
+{
+ if (location.href.indexOf('is-external=true') == -1) {
+ parent.document.title="org.apache.samza.system.chooser Class Hierarchy (samza-api 0.7.0 API)";
+ }
+}
+</SCRIPT>
+<NOSCRIPT>
+</NOSCRIPT>
+
+</HEAD>
+
+<BODY BGCOLOR="white" onload="windowTitle();">
+<HR>
+
+
+<!-- ========= START OF TOP NAVBAR ======= -->
+<A NAME="navbar_top"><!-- --></A>
+<A HREF="#skip-navbar_top" title="Skip navigation links"></A>
+<TABLE BORDER="0" WIDTH="100%" CELLPADDING="1" CELLSPACING="0" SUMMARY="">
+<TR>
+<TD COLSPAN=2 BGCOLOR="#EEEEFF" CLASS="NavBarCell1">
+<A NAME="navbar_top_firstrow"><!-- --></A>
+<TABLE BORDER="0" CELLPADDING="0" CELLSPACING="3" SUMMARY="">
+ <TR ALIGN="center" VALIGN="top">
+ <TD BGCOLOR="#EEEEFF" CLASS="NavBarCell1"> <A HREF="../../../../../overview-summary.html"><FONT CLASS="NavBarFont1"><B>Overview</B></FONT></A> </TD>
+ <TD BGCOLOR="#EEEEFF" CLASS="NavBarCell1"> <A HREF="package-summary.html"><FONT CLASS="NavBarFont1"><B>Package</B></FONT></A> </TD>
+ <TD BGCOLOR="#EEEEFF" CLASS="NavBarCell1"> <FONT CLASS="NavBarFont1">Class</FONT> </TD>
+ <TD BGCOLOR="#FFFFFF" CLASS="NavBarCell1Rev"> <FONT CLASS="NavBarFont1Rev"><B>Tree</B></FONT> </TD>
+ <TD BGCOLOR="#EEEEFF" CLASS="NavBarCell1"> <A HREF="../../../../../deprecated-list.html"><FONT CLASS="NavBarFont1"><B>Deprecated</B></FONT></A> </TD>
+ <TD BGCOLOR="#EEEEFF" CLASS="NavBarCell1"> <A HREF="../../../../../index-all.html"><FONT CLASS="NavBarFont1"><B>Index</B></FONT></A> </TD>
+ <TD BGCOLOR="#EEEEFF" CLASS="NavBarCell1"> <A HREF="../../../../../help-doc.html"><FONT CLASS="NavBarFont1"><B>Help</B></FONT></A> </TD>
+ </TR>
+</TABLE>
+</TD>
+<TD ALIGN="right" VALIGN="top" ROWSPAN=3><EM>
+</EM>
+</TD>
+</TR>
+
+<TR>
+<TD BGCOLOR="white" CLASS="NavBarCell2"><FONT SIZE="-2">
+ <A HREF="../../../../../org/apache/samza/system/package-tree.html"><B>PREV</B></A>
+ <A HREF="../../../../../org/apache/samza/task/package-tree.html"><B>NEXT</B></A></FONT></TD>
+<TD BGCOLOR="white" CLASS="NavBarCell2"><FONT SIZE="-2">
+ <A HREF="../../../../../index.html?org/apache/samza/system/chooser/package-tree.html" target="_top"><B>FRAMES</B></A>
+ <A HREF="package-tree.html" target="_top"><B>NO FRAMES</B></A>
+ <SCRIPT type="text/javascript">
+ <!--
+ if(window==top) {
+ document.writeln('<A HREF="../../../../../allclasses-noframe.html"><B>All Classes</B></A>');
+ }
+ //-->
+</SCRIPT>
+<NOSCRIPT>
+ <A HREF="../../../../../allclasses-noframe.html"><B>All Classes</B></A>
+</NOSCRIPT>
+
+
+</FONT></TD>
+</TR>
+</TABLE>
+<A NAME="skip-navbar_top"></A>
+<!-- ========= END OF TOP NAVBAR ========= -->
+
+<HR>
+<CENTER>
+<H2>
+Hierarchy For Package org.apache.samza.system.chooser
+</H2>
+</CENTER>
+<DL>
+<DT><B>Package Hierarchies:</B><DD><A HREF="../../../../../overview-tree.html">All Packages</A></DL>
+<HR>
+<H2>
+Class Hierarchy
+</H2>
+<UL>
+<LI TYPE="circle">java.lang.Object<UL>
+<LI TYPE="circle">org.apache.samza.system.chooser.<A HREF="../../../../../org/apache/samza/system/chooser/BaseMessageChooser.html" title="class in org.apache.samza.system.chooser"><B>BaseMessageChooser</B></A> (implements org.apache.samza.system.chooser.<A HREF="../../../../../org/apache/samza/system/chooser/MessageChooser.html" title="interface in org.apache.samza.system.chooser">MessageChooser</A>)
+</UL>
+</UL>
+<H2>
+Interface Hierarchy
+</H2>
+<UL>
+<LI TYPE="circle">org.apache.samza.system.chooser.<A HREF="../../../../../org/apache/samza/system/chooser/MessageChooser.html" title="interface in org.apache.samza.system.chooser"><B>MessageChooser</B></A><LI TYPE="circle">org.apache.samza.system.chooser.<A HREF="../../../../../org/apache/samza/system/chooser/MessageChooserFactory.html" title="interface in org.apache.samza.system.chooser"><B>MessageChooserFactory</B></A></UL>
+<HR>
+
+
+<!-- ======= START OF BOTTOM NAVBAR ====== -->
+<A NAME="navbar_bottom"><!-- --></A>
+<A HREF="#skip-navbar_bottom" title="Skip navigation links"></A>
+<TABLE BORDER="0" WIDTH="100%" CELLPADDING="1" CELLSPACING="0" SUMMARY="">
+<TR>
+<TD COLSPAN=2 BGCOLOR="#EEEEFF" CLASS="NavBarCell1">
+<A NAME="navbar_bottom_firstrow"><!-- --></A>
+<TABLE BORDER="0" CELLPADDING="0" CELLSPACING="3" SUMMARY="">
+ <TR ALIGN="center" VALIGN="top">
+ <TD BGCOLOR="#EEEEFF" CLASS="NavBarCell1"> <A HREF="../../../../../overview-summary.html"><FONT CLASS="NavBarFont1"><B>Overview</B></FONT></A> </TD>
+ <TD BGCOLOR="#EEEEFF" CLASS="NavBarCell1"> <A HREF="package-summary.html"><FONT CLASS="NavBarFont1"><B>Package</B></FONT></A> </TD>
+ <TD BGCOLOR="#EEEEFF" CLASS="NavBarCell1"> <FONT CLASS="NavBarFont1">Class</FONT> </TD>
+ <TD BGCOLOR="#FFFFFF" CLASS="NavBarCell1Rev"> <FONT CLASS="NavBarFont1Rev"><B>Tree</B></FONT> </TD>
+ <TD BGCOLOR="#EEEEFF" CLASS="NavBarCell1"> <A HREF="../../../../../deprecated-list.html"><FONT CLASS="NavBarFont1"><B>Deprecated</B></FONT></A> </TD>
+ <TD BGCOLOR="#EEEEFF" CLASS="NavBarCell1"> <A HREF="../../../../../index-all.html"><FONT CLASS="NavBarFont1"><B>Index</B></FONT></A> </TD>
+ <TD BGCOLOR="#EEEEFF" CLASS="NavBarCell1"> <A HREF="../../../../../help-doc.html"><FONT CLASS="NavBarFont1"><B>Help</B></FONT></A> </TD>
+ </TR>
+</TABLE>
+</TD>
+<TD ALIGN="right" VALIGN="top" ROWSPAN=3><EM>
+</EM>
+</TD>
+</TR>
+
+<TR>
+<TD BGCOLOR="white" CLASS="NavBarCell2"><FONT SIZE="-2">
+ <A HREF="../../../../../org/apache/samza/system/package-tree.html"><B>PREV</B></A>
+ <A HREF="../../../../../org/apache/samza/task/package-tree.html"><B>NEXT</B></A></FONT></TD>
+<TD BGCOLOR="white" CLASS="NavBarCell2"><FONT SIZE="-2">
+ <A HREF="../../../../../index.html?org/apache/samza/system/chooser/package-tree.html" target="_top"><B>FRAMES</B></A>
+ <A HREF="package-tree.html" target="_top"><B>NO FRAMES</B></A>
+ <SCRIPT type="text/javascript">
+ <!--
+ if(window==top) {
+ document.writeln('<A HREF="../../../../../allclasses-noframe.html"><B>All Classes</B></A>');
+ }
+ //-->
+</SCRIPT>
+<NOSCRIPT>
+ <A HREF="../../../../../allclasses-noframe.html"><B>All Classes</B></A>
+</NOSCRIPT>
+
+
+</FONT></TD>
+</TR>
+</TABLE>
+<A NAME="skip-navbar_bottom"></A>
+<!-- ======== END OF BOTTOM NAVBAR ======= -->
+
+<HR>
+
+</BODY>
+</HTML>
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=1529329&r1=1529328&r2=1529329&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 Fri Oct 4 22:10:48 2013
@@ -2,12 +2,12 @@
<!--NewPage-->
<HTML>
<HEAD>
-<!-- Generated by javadoc (build 1.6.0_51) on Thu Sep 19 09:23:12 PDT 2013 -->
+<!-- Generated by javadoc (build 1.6.0_51) on Fri Oct 04 15:10:30 PDT 2013 -->
<TITLE>
org.apache.samza.system (samza-api 0.7.0 API)
</TITLE>
-<META NAME="date" CONTENT="2013-09-19">
+<META NAME="date" CONTENT="2013-10-04">
<LINK REL ="stylesheet" TYPE="text/css" HREF="../../../../stylesheet.css" TITLE="Style">
@@ -23,8 +23,6 @@ org.apache.samza.system (samza-api 0.7.0
Interfaces</FONT>
<FONT CLASS="FrameItemFont">
<BR>
-<A HREF="MessageChooser.html" title="interface in org.apache.samza.system" target="classFrame"><I>MessageChooser</I></A>
-<BR>
<A HREF="SystemAdmin.html" title="interface in org.apache.samza.system" target="classFrame"><I>SystemAdmin</I></A>
<BR>
<A HREF="SystemConsumer.html" title="interface in org.apache.samza.system" target="classFrame"><I>SystemConsumer</I></A>
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=1529329&r1=1529328&r2=1529329&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 Fri Oct 4 22:10:48 2013
@@ -2,12 +2,12 @@
<!--NewPage-->
<HTML>
<HEAD>
-<!-- Generated by javadoc (build 1.6.0_51) on Thu Sep 19 09:23:12 PDT 2013 -->
+<!-- Generated by javadoc (build 1.6.0_51) on Fri Oct 04 15:10:30 PDT 2013 -->
<TITLE>
org.apache.samza.system (samza-api 0.7.0 API)
</TITLE>
-<META NAME="date" CONTENT="2013-09-19">
+<META NAME="date" CONTENT="2013-10-04">
<LINK REL ="stylesheet" TYPE="text/css" HREF="../../../../stylesheet.css" TITLE="Style">
@@ -55,7 +55,7 @@ function windowTitle()
<TR>
<TD BGCOLOR="white" CLASS="NavBarCell2"><FONT SIZE="-2">
<A HREF="../../../../org/apache/samza/storage/package-summary.html"><B>PREV PACKAGE</B></A>
- <A HREF="../../../../org/apache/samza/task/package-summary.html"><B>NEXT PACKAGE</B></A></FONT></TD>
+ <A HREF="../../../../org/apache/samza/system/chooser/package-summary.html"><B>NEXT PACKAGE</B></A></FONT></TD>
<TD BGCOLOR="white" CLASS="NavBarCell2"><FONT SIZE="-2">
<A HREF="../../../../index.html?org/apache/samza/system/package-summary.html" target="_top"><B>FRAMES</B></A>
<A HREF="package-summary.html" target="_top"><B>NO FRAMES</B></A>
@@ -88,10 +88,6 @@ Package org.apache.samza.system
<B>Interface Summary</B></FONT></TH>
</TR>
<TR BGCOLOR="white" CLASS="TableRowColor">
-<TD WIDTH="15%"><B><A HREF="../../../../org/apache/samza/system/MessageChooser.html" title="interface in org.apache.samza.system">MessageChooser</A></B></TD>
-<TD> </TD>
-</TR>
-<TR BGCOLOR="white" CLASS="TableRowColor">
<TD WIDTH="15%"><B><A HREF="../../../../org/apache/samza/system/SystemAdmin.html" title="interface in org.apache.samza.system">SystemAdmin</A></B></TD>
<TD> </TD>
</TR>
@@ -173,7 +169,7 @@ Package org.apache.samza.system
<TR>
<TD BGCOLOR="white" CLASS="NavBarCell2"><FONT SIZE="-2">
<A HREF="../../../../org/apache/samza/storage/package-summary.html"><B>PREV PACKAGE</B></A>
- <A HREF="../../../../org/apache/samza/task/package-summary.html"><B>NEXT PACKAGE</B></A></FONT></TD>
+ <A HREF="../../../../org/apache/samza/system/chooser/package-summary.html"><B>NEXT PACKAGE</B></A></FONT></TD>
<TD BGCOLOR="white" CLASS="NavBarCell2"><FONT SIZE="-2">
<A HREF="../../../../index.html?org/apache/samza/system/package-summary.html" target="_top"><B>FRAMES</B></A>
<A HREF="package-summary.html" target="_top"><B>NO FRAMES</B></A>
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=1529329&r1=1529328&r2=1529329&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 Fri Oct 4 22:10:48 2013
@@ -2,12 +2,12 @@
<!--NewPage-->
<HTML>
<HEAD>
-<!-- Generated by javadoc (build 1.6.0_51) on Thu Sep 19 09:23:12 PDT 2013 -->
+<!-- Generated by javadoc (build 1.6.0_51) on Fri Oct 04 15:10:30 PDT 2013 -->
<TITLE>
org.apache.samza.system Class Hierarchy (samza-api 0.7.0 API)
</TITLE>
-<META NAME="date" CONTENT="2013-09-19">
+<META NAME="date" CONTENT="2013-10-04">
<LINK REL ="stylesheet" TYPE="text/css" HREF="../../../../stylesheet.css" TITLE="Style">
@@ -55,7 +55,7 @@ function windowTitle()
<TR>
<TD BGCOLOR="white" CLASS="NavBarCell2"><FONT SIZE="-2">
<A HREF="../../../../org/apache/samza/storage/package-tree.html"><B>PREV</B></A>
- <A HREF="../../../../org/apache/samza/task/package-tree.html"><B>NEXT</B></A></FONT></TD>
+ <A HREF="../../../../org/apache/samza/system/chooser/package-tree.html"><B>NEXT</B></A></FONT></TD>
<TD BGCOLOR="white" CLASS="NavBarCell2"><FONT SIZE="-2">
<A HREF="../../../../index.html?org/apache/samza/system/package-tree.html" target="_top"><B>FRAMES</B></A>
<A HREF="package-tree.html" target="_top"><B>NO FRAMES</B></A>
@@ -100,7 +100,7 @@ Class Hierarchy
Interface Hierarchy
</H2>
<UL>
-<LI TYPE="circle">org.apache.samza.system.<A HREF="../../../../org/apache/samza/system/MessageChooser.html" title="interface in org.apache.samza.system"><B>MessageChooser</B></A><LI TYPE="circle">org.apache.samza.system.<A HREF="../../../../org/apache/samza/system/SystemAdmin.html" title="interface in org.apache.samza.system"><B>SystemAdmin</B></A><LI TYPE="circle">org.apache.samza.system.<A HREF="../../../../org/apache/samza/system/SystemConsumer.html" title="interface in org.apache.samza.system"><B>SystemConsumer</B></A><LI TYPE="circle">org.apache.samza.system.<A HREF="../../../../org/apache/samza/system/SystemFactory.html" title="interface in org.apache.samza.system"><B>SystemFactory</B></A><LI TYPE="circle">org.apache.samza.system.<A HREF="../../../../org/apache/samza/system/SystemProducer.html" title="interface in org.apache.samza.system"><B>SystemProducer</B></A></UL>
+<LI TYPE="circle">org.apache.samza.system.<A HREF="../../../../org/apache/samza/system/SystemAdmin.html" title="interface in org.apache.samza.system"><B>SystemAdmin</B></A><LI TYPE="circle">org.apache.samza.system.<A HREF="../../../../org/apache/samza/system/SystemConsumer.html" title="interface in org.apache.samza.system"><B>SystemConsumer</B></A><LI TYPE="circle">org.apache.samza.system.<A HREF="../../../../org/apache/samza/system/SystemFactory.html" title="interface in org.apache.samza.system"><B>SystemFactory</B></A><LI TYPE="circle">org.apache.samza.system.<A HREF="../../../../org/apache/samza/system/SystemProducer.html" title="interface in org.apache.samza.system"><B>SystemProducer</B></A></UL>
<HR>
@@ -131,7 +131,7 @@ Interface Hierarchy
<TR>
<TD BGCOLOR="white" CLASS="NavBarCell2"><FONT SIZE="-2">
<A HREF="../../../../org/apache/samza/storage/package-tree.html"><B>PREV</B></A>
- <A HREF="../../../../org/apache/samza/task/package-tree.html"><B>NEXT</B></A></FONT></TD>
+ <A HREF="../../../../org/apache/samza/system/chooser/package-tree.html"><B>NEXT</B></A></FONT></TD>
<TD BGCOLOR="white" CLASS="NavBarCell2"><FONT SIZE="-2">
<A HREF="../../../../index.html?org/apache/samza/system/package-tree.html" target="_top"><B>FRAMES</B></A>
<A HREF="package-tree.html" target="_top"><B>NO FRAMES</B></A>
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=1529329&r1=1529328&r2=1529329&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 Fri Oct 4 22:10:48 2013
@@ -2,12 +2,12 @@
<!--NewPage-->
<HTML>
<HEAD>
-<!-- Generated by javadoc (build 1.6.0_51) on Thu Sep 19 09:23:12 PDT 2013 -->
+<!-- Generated by javadoc (build 1.6.0_51) on Fri Oct 04 15:10:30 PDT 2013 -->
<TITLE>
ClosableTask (samza-api 0.7.0 API)
</TITLE>
-<META NAME="date" CONTENT="2013-09-19">
+<META NAME="date" CONTENT="2013-10-04">
<LINK REL ="stylesheet" TYPE="text/css" HREF="../../../../stylesheet.css" TITLE="Style">
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=1529329&r1=1529328&r2=1529329&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 Fri Oct 4 22:10:48 2013
@@ -2,12 +2,12 @@
<!--NewPage-->
<HTML>
<HEAD>
-<!-- Generated by javadoc (build 1.6.0_51) on Thu Sep 19 09:23:12 PDT 2013 -->
+<!-- Generated by javadoc (build 1.6.0_51) on Fri Oct 04 15:10:30 PDT 2013 -->
<TITLE>
InitableTask (samza-api 0.7.0 API)
</TITLE>
-<META NAME="date" CONTENT="2013-09-19">
+<META NAME="date" CONTENT="2013-10-04">
<LINK REL ="stylesheet" TYPE="text/css" HREF="../../../../stylesheet.css" TITLE="Style">
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=1529329&r1=1529328&r2=1529329&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 Fri Oct 4 22:10:48 2013
@@ -2,12 +2,12 @@
<!--NewPage-->
<HTML>
<HEAD>
-<!-- Generated by javadoc (build 1.6.0_51) on Thu Sep 19 09:23:12 PDT 2013 -->
+<!-- Generated by javadoc (build 1.6.0_51) on Fri Oct 04 15:10:30 PDT 2013 -->
<TITLE>
MessageCollector (samza-api 0.7.0 API)
</TITLE>
-<META NAME="date" CONTENT="2013-09-19">
+<META NAME="date" CONTENT="2013-10-04">
<LINK REL ="stylesheet" TYPE="text/css" HREF="../../../../stylesheet.css" TITLE="Style">
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=1529329&r1=1529328&r2=1529329&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 Fri Oct 4 22:10:48 2013
@@ -2,12 +2,12 @@
<!--NewPage-->
<HTML>
<HEAD>
-<!-- Generated by javadoc (build 1.6.0_51) on Thu Sep 19 09:23:12 PDT 2013 -->
+<!-- Generated by javadoc (build 1.6.0_51) on Fri Oct 04 15:10:30 PDT 2013 -->
<TITLE>
StreamTask (samza-api 0.7.0 API)
</TITLE>
-<META NAME="date" CONTENT="2013-09-19">
+<META NAME="date" CONTENT="2013-10-04">
<LINK REL ="stylesheet" TYPE="text/css" HREF="../../../../stylesheet.css" TITLE="Style">
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=1529329&r1=1529328&r2=1529329&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 Fri Oct 4 22:10:48 2013
@@ -2,12 +2,12 @@
<!--NewPage-->
<HTML>
<HEAD>
-<!-- Generated by javadoc (build 1.6.0_51) on Thu Sep 19 09:23:12 PDT 2013 -->
+<!-- Generated by javadoc (build 1.6.0_51) on Fri Oct 04 15:10:30 PDT 2013 -->
<TITLE>
TaskContext (samza-api 0.7.0 API)
</TITLE>
-<META NAME="date" CONTENT="2013-09-19">
+<META NAME="date" CONTENT="2013-10-04">
<LINK REL ="stylesheet" TYPE="text/css" HREF="../../../../stylesheet.css" TITLE="Style">
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=1529329&r1=1529328&r2=1529329&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 Fri Oct 4 22:10:48 2013
@@ -2,12 +2,12 @@
<!--NewPage-->
<HTML>
<HEAD>
-<!-- Generated by javadoc (build 1.6.0_51) on Thu Sep 19 09:23:12 PDT 2013 -->
+<!-- Generated by javadoc (build 1.6.0_51) on Fri Oct 04 15:10:30 PDT 2013 -->
<TITLE>
TaskCoordinator (samza-api 0.7.0 API)
</TITLE>
-<META NAME="date" CONTENT="2013-09-19">
+<META NAME="date" CONTENT="2013-10-04">
<LINK REL ="stylesheet" TYPE="text/css" HREF="../../../../stylesheet.css" TITLE="Style">
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=1529329&r1=1529328&r2=1529329&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 Fri Oct 4 22:10:48 2013
@@ -2,12 +2,12 @@
<!--NewPage-->
<HTML>
<HEAD>
-<!-- Generated by javadoc (build 1.6.0_51) on Thu Sep 19 09:23:12 PDT 2013 -->
+<!-- Generated by javadoc (build 1.6.0_51) on Fri Oct 04 15:10:30 PDT 2013 -->
<TITLE>
TaskLifecycleListener (samza-api 0.7.0 API)
</TITLE>
-<META NAME="date" CONTENT="2013-09-19">
+<META NAME="date" CONTENT="2013-10-04">
<LINK REL ="stylesheet" TYPE="text/css" HREF="../../../../stylesheet.css" TITLE="Style">
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=1529329&r1=1529328&r2=1529329&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 Fri Oct 4 22:10:48 2013
@@ -2,12 +2,12 @@
<!--NewPage-->
<HTML>
<HEAD>
-<!-- Generated by javadoc (build 1.6.0_51) on Thu Sep 19 09:23:12 PDT 2013 -->
+<!-- Generated by javadoc (build 1.6.0_51) on Fri Oct 04 15:10:30 PDT 2013 -->
<TITLE>
TaskLifecycleListenerFactory (samza-api 0.7.0 API)
</TITLE>
-<META NAME="date" CONTENT="2013-09-19">
+<META NAME="date" CONTENT="2013-10-04">
<LINK REL ="stylesheet" TYPE="text/css" HREF="../../../../stylesheet.css" TITLE="Style">
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=1529329&r1=1529328&r2=1529329&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 Fri Oct 4 22:10:48 2013
@@ -2,12 +2,12 @@
<!--NewPage-->
<HTML>
<HEAD>
-<!-- Generated by javadoc (build 1.6.0_51) on Thu Sep 19 09:23:12 PDT 2013 -->
+<!-- Generated by javadoc (build 1.6.0_51) on Fri Oct 04 15:10:30 PDT 2013 -->
<TITLE>
WindowableTask (samza-api 0.7.0 API)
</TITLE>
-<META NAME="date" CONTENT="2013-09-19">
+<META NAME="date" CONTENT="2013-10-04">
<LINK REL ="stylesheet" TYPE="text/css" HREF="../../../../stylesheet.css" TITLE="Style">
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=1529329&r1=1529328&r2=1529329&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 Fri Oct 4 22:10:48 2013
@@ -2,12 +2,12 @@
<!--NewPage-->
<HTML>
<HEAD>
-<!-- Generated by javadoc (build 1.6.0_51) on Thu Sep 19 09:23:12 PDT 2013 -->
+<!-- Generated by javadoc (build 1.6.0_51) on Fri Oct 04 15:10:30 PDT 2013 -->
<TITLE>
org.apache.samza.task (samza-api 0.7.0 API)
</TITLE>
-<META NAME="date" CONTENT="2013-09-19">
+<META NAME="date" CONTENT="2013-10-04">
<LINK REL ="stylesheet" TYPE="text/css" HREF="../../../../stylesheet.css" TITLE="Style">
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=1529329&r1=1529328&r2=1529329&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 Fri Oct 4 22:10:48 2013
@@ -2,12 +2,12 @@
<!--NewPage-->
<HTML>
<HEAD>
-<!-- Generated by javadoc (build 1.6.0_51) on Thu Sep 19 09:23:12 PDT 2013 -->
+<!-- Generated by javadoc (build 1.6.0_51) on Fri Oct 04 15:10:30 PDT 2013 -->
<TITLE>
org.apache.samza.task (samza-api 0.7.0 API)
</TITLE>
-<META NAME="date" CONTENT="2013-09-19">
+<META NAME="date" CONTENT="2013-10-04">
<LINK REL ="stylesheet" TYPE="text/css" HREF="../../../../stylesheet.css" TITLE="Style">
@@ -54,7 +54,7 @@ function windowTitle()
<TR>
<TD BGCOLOR="white" CLASS="NavBarCell2"><FONT SIZE="-2">
- <A HREF="../../../../org/apache/samza/system/package-summary.html"><B>PREV PACKAGE</B></A>
+ <A HREF="../../../../org/apache/samza/system/chooser/package-summary.html"><B>PREV PACKAGE</B></A>
<A HREF="../../../../org/apache/samza/util/package-summary.html"><B>NEXT PACKAGE</B></A></FONT></TD>
<TD BGCOLOR="white" CLASS="NavBarCell2"><FONT SIZE="-2">
<A HREF="../../../../index.html?org/apache/samza/task/package-summary.html" target="_top"><B>FRAMES</B></A>
@@ -159,7 +159,7 @@ Package org.apache.samza.task
<TR>
<TD BGCOLOR="white" CLASS="NavBarCell2"><FONT SIZE="-2">
- <A HREF="../../../../org/apache/samza/system/package-summary.html"><B>PREV PACKAGE</B></A>
+ <A HREF="../../../../org/apache/samza/system/chooser/package-summary.html"><B>PREV PACKAGE</B></A>
<A HREF="../../../../org/apache/samza/util/package-summary.html"><B>NEXT PACKAGE</B></A></FONT></TD>
<TD BGCOLOR="white" CLASS="NavBarCell2"><FONT SIZE="-2">
<A HREF="../../../../index.html?org/apache/samza/task/package-summary.html" target="_top"><B>FRAMES</B></A>
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=1529329&r1=1529328&r2=1529329&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 Fri Oct 4 22:10:48 2013
@@ -2,12 +2,12 @@
<!--NewPage-->
<HTML>
<HEAD>
-<!-- Generated by javadoc (build 1.6.0_51) on Thu Sep 19 09:23:12 PDT 2013 -->
+<!-- Generated by javadoc (build 1.6.0_51) on Fri Oct 04 15:10:30 PDT 2013 -->
<TITLE>
org.apache.samza.task Class Hierarchy (samza-api 0.7.0 API)
</TITLE>
-<META NAME="date" CONTENT="2013-09-19">
+<META NAME="date" CONTENT="2013-10-04">
<LINK REL ="stylesheet" TYPE="text/css" HREF="../../../../stylesheet.css" TITLE="Style">
@@ -54,7 +54,7 @@ function windowTitle()
<TR>
<TD BGCOLOR="white" CLASS="NavBarCell2"><FONT SIZE="-2">
- <A HREF="../../../../org/apache/samza/system/package-tree.html"><B>PREV</B></A>
+ <A HREF="../../../../org/apache/samza/system/chooser/package-tree.html"><B>PREV</B></A>
<A HREF="../../../../org/apache/samza/util/package-tree.html"><B>NEXT</B></A></FONT></TD>
<TD BGCOLOR="white" CLASS="NavBarCell2"><FONT SIZE="-2">
<A HREF="../../../../index.html?org/apache/samza/task/package-tree.html" target="_top"><B>FRAMES</B></A>
@@ -120,7 +120,7 @@ Interface Hierarchy
<TR>
<TD BGCOLOR="white" CLASS="NavBarCell2"><FONT SIZE="-2">
- <A HREF="../../../../org/apache/samza/system/package-tree.html"><B>PREV</B></A>
+ <A HREF="../../../../org/apache/samza/system/chooser/package-tree.html"><B>PREV</B></A>
<A HREF="../../../../org/apache/samza/util/package-tree.html"><B>NEXT</B></A></FONT></TD>
<TD BGCOLOR="white" CLASS="NavBarCell2"><FONT SIZE="-2">
<A HREF="../../../../index.html?org/apache/samza/task/package-tree.html" target="_top"><B>FRAMES</B></A>
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=1529329&r1=1529328&r2=1529329&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 Fri Oct 4 22:10:48 2013
@@ -2,12 +2,12 @@
<!--NewPage-->
<HTML>
<HEAD>
-<!-- Generated by javadoc (build 1.6.0_51) on Thu Sep 19 09:23:12 PDT 2013 -->
+<!-- Generated by javadoc (build 1.6.0_51) on Fri Oct 04 15:10:30 PDT 2013 -->
<TITLE>
BlockingEnvelopeMap.BlockingEnvelopeMapMetrics (samza-api 0.7.0 API)
</TITLE>
-<META NAME="date" CONTENT="2013-09-19">
+<META NAME="date" CONTENT="2013-10-04">
<LINK REL ="stylesheet" TYPE="text/css" HREF="../../../../stylesheet.css" TITLE="Style">
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/util/BlockingEnvelopeMap.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/util/BlockingEnvelopeMap.html?rev=1529329&r1=1529328&r2=1529329&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/util/BlockingEnvelopeMap.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/util/BlockingEnvelopeMap.html Fri Oct 4 22:10:48 2013
@@ -2,12 +2,12 @@
<!--NewPage-->
<HTML>
<HEAD>
-<!-- Generated by javadoc (build 1.6.0_51) on Thu Sep 19 09:23:12 PDT 2013 -->
+<!-- Generated by javadoc (build 1.6.0_51) on Fri Oct 04 15:10:30 PDT 2013 -->
<TITLE>
BlockingEnvelopeMap (samza-api 0.7.0 API)
</TITLE>
-<META NAME="date" CONTENT="2013-09-19">
+<META NAME="date" CONTENT="2013-10-04">
<LINK REL ="stylesheet" TYPE="text/css" HREF="../../../../stylesheet.css" TITLE="Style">
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/util/Clock.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/util/Clock.html?rev=1529329&r1=1529328&r2=1529329&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/util/Clock.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/util/Clock.html Fri Oct 4 22:10:48 2013
@@ -2,12 +2,12 @@
<!--NewPage-->
<HTML>
<HEAD>
-<!-- Generated by javadoc (build 1.6.0_51) on Thu Sep 19 09:23:12 PDT 2013 -->
+<!-- Generated by javadoc (build 1.6.0_51) on Fri Oct 04 15:10:30 PDT 2013 -->
<TITLE>
Clock (samza-api 0.7.0 API)
</TITLE>
-<META NAME="date" CONTENT="2013-09-19">
+<META NAME="date" CONTENT="2013-10-04">
<LINK REL ="stylesheet" TYPE="text/css" HREF="../../../../stylesheet.css" TITLE="Style">
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/util/NoOpMetricsRegistry.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/util/NoOpMetricsRegistry.html?rev=1529329&r1=1529328&r2=1529329&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/util/NoOpMetricsRegistry.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/util/NoOpMetricsRegistry.html Fri Oct 4 22:10:48 2013
@@ -2,12 +2,12 @@
<!--NewPage-->
<HTML>
<HEAD>
-<!-- Generated by javadoc (build 1.6.0_51) on Thu Sep 19 09:23:12 PDT 2013 -->
+<!-- Generated by javadoc (build 1.6.0_51) on Fri Oct 04 15:10:30 PDT 2013 -->
<TITLE>
NoOpMetricsRegistry (samza-api 0.7.0 API)
</TITLE>
-<META NAME="date" CONTENT="2013-09-19">
+<META NAME="date" CONTENT="2013-10-04">
<LINK REL ="stylesheet" TYPE="text/css" HREF="../../../../stylesheet.css" TITLE="Style">
@@ -134,6 +134,15 @@ java.lang.Object
<TR BGCOLOR="white" CLASS="TableRowColor">
<TD ALIGN="right" VALIGN="top" WIDTH="1%"><FONT SIZE="-1">
<CODE> <A HREF="../../../../org/apache/samza/metrics/Counter.html" title="class in org.apache.samza.metrics">Counter</A></CODE></FONT></TD>
+<TD><CODE><B><A HREF="../../../../org/apache/samza/util/NoOpMetricsRegistry.html#newCounter(java.lang.String, org.apache.samza.metrics.Counter)">newCounter</A></B>(java.lang.String group,
+ <A HREF="../../../../org/apache/samza/metrics/Counter.html" title="class in org.apache.samza.metrics">Counter</A> counter)</CODE>
+
+<BR>
+ </TD>
+</TR>
+<TR BGCOLOR="white" CLASS="TableRowColor">
+<TD ALIGN="right" VALIGN="top" WIDTH="1%"><FONT SIZE="-1">
+<CODE> <A HREF="../../../../org/apache/samza/metrics/Counter.html" title="class in org.apache.samza.metrics">Counter</A></CODE></FONT></TD>
<TD><CODE><B><A HREF="../../../../org/apache/samza/util/NoOpMetricsRegistry.html#newCounter(java.lang.String, java.lang.String)">newCounter</A></B>(java.lang.String group,
java.lang.String name)</CODE>
@@ -150,6 +159,22 @@ java.lang.Object
</TR>
</TABLE>
</CODE></FONT></TD>
+<TD><CODE><B><A HREF="../../../../org/apache/samza/util/NoOpMetricsRegistry.html#newGauge(java.lang.String, org.apache.samza.metrics.Gauge)">newGauge</A></B>(java.lang.String group,
+ <A HREF="../../../../org/apache/samza/metrics/Gauge.html" title="class in org.apache.samza.metrics">Gauge</A><T> gauge)</CODE>
+
+<BR>
+ </TD>
+</TR>
+<TR BGCOLOR="white" CLASS="TableRowColor">
+<TD ALIGN="right" VALIGN="top" WIDTH="1%"><FONT SIZE="-1">
+<CODE>
+<TABLE BORDER="0" CELLPADDING="0" CELLSPACING="0" SUMMARY="">
+<TR ALIGN="right" VALIGN="">
+<TD NOWRAP><FONT SIZE="-1">
+<CODE><T> <A HREF="../../../../org/apache/samza/metrics/Gauge.html" title="class in org.apache.samza.metrics">Gauge</A><T></CODE></FONT></TD>
+</TR>
+</TABLE>
+</CODE></FONT></TD>
<TD><CODE><B><A HREF="../../../../org/apache/samza/util/NoOpMetricsRegistry.html#newGauge(java.lang.String, java.lang.String, T)">newGauge</A></B>(java.lang.String group,
java.lang.String name,
T value)</CODE>
@@ -212,6 +237,21 @@ public <A HREF="../../../../org/apache/s
</DL>
<HR>
+<A NAME="newCounter(java.lang.String, org.apache.samza.metrics.Counter)"><!-- --></A><H3>
+newCounter</H3>
+<PRE>
+public <A HREF="../../../../org/apache/samza/metrics/Counter.html" title="class in org.apache.samza.metrics">Counter</A> <B>newCounter</B>(java.lang.String group,
+ <A HREF="../../../../org/apache/samza/metrics/Counter.html" title="class in org.apache.samza.metrics">Counter</A> counter)</PRE>
+<DL>
+<DD><DL>
+<DT><B>Specified by:</B><DD><CODE><A HREF="../../../../org/apache/samza/metrics/MetricsRegistry.html#newCounter(java.lang.String, org.apache.samza.metrics.Counter)">newCounter</A></CODE> in interface <CODE><A HREF="../../../../org/apache/samza/metrics/MetricsRegistry.html" title="interface in org.apache.samza.metrics">MetricsRegistry</A></CODE></DL>
+</DD>
+<DD><DL>
+</DL>
+</DD>
+</DL>
+<HR>
+
<A NAME="newGauge(java.lang.String,java.lang.String,java.lang.Object)"><!-- --></A><A NAME="newGauge(java.lang.String, java.lang.String, T)"><!-- --></A><H3>
newGauge</H3>
<PRE>
@@ -226,6 +266,21 @@ public <T> <A HREF="../../../../or
</DL>
</DD>
</DL>
+<HR>
+
+<A NAME="newGauge(java.lang.String, org.apache.samza.metrics.Gauge)"><!-- --></A><H3>
+newGauge</H3>
+<PRE>
+public <T> <A HREF="../../../../org/apache/samza/metrics/Gauge.html" title="class in org.apache.samza.metrics">Gauge</A><T> <B>newGauge</B>(java.lang.String group,
+ <A HREF="../../../../org/apache/samza/metrics/Gauge.html" title="class in org.apache.samza.metrics">Gauge</A><T> gauge)</PRE>
+<DL>
+<DD><DL>
+<DT><B>Specified by:</B><DD><CODE><A HREF="../../../../org/apache/samza/metrics/MetricsRegistry.html#newGauge(java.lang.String, org.apache.samza.metrics.Gauge)">newGauge</A></CODE> in interface <CODE><A HREF="../../../../org/apache/samza/metrics/MetricsRegistry.html" title="interface in org.apache.samza.metrics">MetricsRegistry</A></CODE></DL>
+</DD>
+<DD><DL>
+</DL>
+</DD>
+</DL>
<!-- ========= END OF CLASS DATA ========= -->
<HR>
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/util/SinglePartitionSystemAdmin.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/util/SinglePartitionSystemAdmin.html?rev=1529329&r1=1529328&r2=1529329&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/util/SinglePartitionSystemAdmin.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/util/SinglePartitionSystemAdmin.html Fri Oct 4 22:10:48 2013
@@ -2,12 +2,12 @@
<!--NewPage-->
<HTML>
<HEAD>
-<!-- Generated by javadoc (build 1.6.0_51) on Thu Sep 19 09:23:12 PDT 2013 -->
+<!-- Generated by javadoc (build 1.6.0_51) on Fri Oct 04 15:10:30 PDT 2013 -->
<TITLE>
SinglePartitionSystemAdmin (samza-api 0.7.0 API)
</TITLE>
-<META NAME="date" CONTENT="2013-09-19">
+<META NAME="date" CONTENT="2013-10-04">
<LINK REL ="stylesheet" TYPE="text/css" HREF="../../../../stylesheet.css" TITLE="Style">
@@ -140,6 +140,14 @@ A simple helper admin class that defines
</TR>
<TR BGCOLOR="white" CLASS="TableRowColor">
<TD ALIGN="right" VALIGN="top" WIDTH="1%"><FONT SIZE="-1">
+<CODE> java.util.Map<<A HREF="../../../../org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system">SystemStreamPartition</A>,java.lang.String></CODE></FONT></TD>
+<TD><CODE><B><A HREF="../../../../org/apache/samza/util/SinglePartitionSystemAdmin.html#getLastOffsets(java.util.Set)">getLastOffsets</A></B>(java.util.Set<java.lang.String> streams)</CODE>
+
+<BR>
+ </TD>
+</TR>
+<TR BGCOLOR="white" CLASS="TableRowColor">
+<TD ALIGN="right" VALIGN="top" WIDTH="1%"><FONT SIZE="-1">
<CODE> java.util.Set<<A HREF="../../../../org/apache/samza/Partition.html" title="class in org.apache.samza">Partition</A>></CODE></FONT></TD>
<TD><CODE><B><A HREF="../../../../org/apache/samza/util/SinglePartitionSystemAdmin.html#getPartitions(java.lang.String)">getPartitions</A></B>(java.lang.String streamName)</CODE>
@@ -198,6 +206,20 @@ public java.util.Set<<A HREF="../../.
</DL>
</DD>
</DL>
+<HR>
+
+<A NAME="getLastOffsets(java.util.Set)"><!-- --></A><H3>
+getLastOffsets</H3>
+<PRE>
+public java.util.Map<<A HREF="../../../../org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system">SystemStreamPartition</A>,java.lang.String> <B>getLastOffsets</B>(java.util.Set<java.lang.String> streams)</PRE>
+<DL>
+<DD><DL>
+<DT><B>Specified by:</B><DD><CODE><A HREF="../../../../org/apache/samza/system/SystemAdmin.html#getLastOffsets(java.util.Set)">getLastOffsets</A></CODE> in interface <CODE><A HREF="../../../../org/apache/samza/system/SystemAdmin.html" title="interface in org.apache.samza.system">SystemAdmin</A></CODE></DL>
+</DD>
+<DD><DL>
+</DL>
+</DD>
+</DL>
<!-- ========= END OF CLASS DATA ========= -->
<HR>
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/util/package-frame.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/util/package-frame.html?rev=1529329&r1=1529328&r2=1529329&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/util/package-frame.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/util/package-frame.html Fri Oct 4 22:10:48 2013
@@ -2,12 +2,12 @@
<!--NewPage-->
<HTML>
<HEAD>
-<!-- Generated by javadoc (build 1.6.0_51) on Thu Sep 19 09:23:12 PDT 2013 -->
+<!-- Generated by javadoc (build 1.6.0_51) on Fri Oct 04 15:10:30 PDT 2013 -->
<TITLE>
org.apache.samza.util (samza-api 0.7.0 API)
</TITLE>
-<META NAME="date" CONTENT="2013-09-19">
+<META NAME="date" CONTENT="2013-10-04">
<LINK REL ="stylesheet" TYPE="text/css" HREF="../../../../stylesheet.css" TITLE="Style">
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/util/package-summary.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/util/package-summary.html?rev=1529329&r1=1529328&r2=1529329&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/util/package-summary.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/util/package-summary.html Fri Oct 4 22:10:48 2013
@@ -2,12 +2,12 @@
<!--NewPage-->
<HTML>
<HEAD>
-<!-- Generated by javadoc (build 1.6.0_51) on Thu Sep 19 09:23:12 PDT 2013 -->
+<!-- Generated by javadoc (build 1.6.0_51) on Fri Oct 04 15:10:30 PDT 2013 -->
<TITLE>
org.apache.samza.util (samza-api 0.7.0 API)
</TITLE>
-<META NAME="date" CONTENT="2013-09-19">
+<META NAME="date" CONTENT="2013-10-04">
<LINK REL ="stylesheet" TYPE="text/css" HREF="../../../../stylesheet.css" TITLE="Style">
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/util/package-tree.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/util/package-tree.html?rev=1529329&r1=1529328&r2=1529329&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/util/package-tree.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/org/apache/samza/util/package-tree.html Fri Oct 4 22:10:48 2013
@@ -2,12 +2,12 @@
<!--NewPage-->
<HTML>
<HEAD>
-<!-- Generated by javadoc (build 1.6.0_51) on Thu Sep 19 09:23:12 PDT 2013 -->
+<!-- Generated by javadoc (build 1.6.0_51) on Fri Oct 04 15:10:30 PDT 2013 -->
<TITLE>
org.apache.samza.util Class Hierarchy (samza-api 0.7.0 API)
</TITLE>
-<META NAME="date" CONTENT="2013-09-19">
+<META NAME="date" CONTENT="2013-10-04">
<LINK REL ="stylesheet" TYPE="text/css" HREF="../../../../stylesheet.css" TITLE="Style">
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/overview-frame.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/overview-frame.html?rev=1529329&r1=1529328&r2=1529329&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/overview-frame.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/overview-frame.html Fri Oct 4 22:10:48 2013
@@ -2,12 +2,12 @@
<!--NewPage-->
<HTML>
<HEAD>
-<!-- Generated by javadoc (build 1.6.0_51) on Thu Sep 19 09:23:12 PDT 2013 -->
+<!-- Generated by javadoc (build 1.6.0_51) on Fri Oct 04 15:10:30 PDT 2013 -->
<TITLE>
Overview List (samza-api 0.7.0 API)
</TITLE>
-<META NAME="date" CONTENT="2013-09-19">
+<META NAME="date" CONTENT="2013-10-04">
<LINK REL ="stylesheet" TYPE="text/css" HREF="stylesheet.css" TITLE="Style">
@@ -46,6 +46,8 @@ Packages</FONT>
<BR>
<FONT CLASS="FrameItemFont"><A HREF="org/apache/samza/system/package-frame.html" target="packageFrame">org.apache.samza.system</A></FONT>
<BR>
+<FONT CLASS="FrameItemFont"><A HREF="org/apache/samza/system/chooser/package-frame.html" target="packageFrame">org.apache.samza.system.chooser</A></FONT>
+<BR>
<FONT CLASS="FrameItemFont"><A HREF="org/apache/samza/task/package-frame.html" target="packageFrame">org.apache.samza.task</A></FONT>
<BR>
<FONT CLASS="FrameItemFont"><A HREF="org/apache/samza/util/package-frame.html" target="packageFrame">org.apache.samza.util</A></FONT>
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/overview-summary.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/overview-summary.html?rev=1529329&r1=1529328&r2=1529329&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/overview-summary.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/overview-summary.html Fri Oct 4 22:10:48 2013
@@ -2,12 +2,12 @@
<!--NewPage-->
<HTML>
<HEAD>
-<!-- Generated by javadoc (build 1.6.0_51) on Thu Sep 19 09:23:13 PDT 2013 -->
+<!-- Generated by javadoc (build 1.6.0_51) on Fri Oct 04 15:10:30 PDT 2013 -->
<TITLE>
Overview (samza-api 0.7.0 API)
</TITLE>
-<META NAME="date" CONTENT="2013-09-19">
+<META NAME="date" CONTENT="2013-10-04">
<LINK REL ="stylesheet" TYPE="text/css" HREF="stylesheet.css" TITLE="Style">
@@ -122,6 +122,10 @@ samza-api 0.7.0 API
<TD> </TD>
</TR>
<TR BGCOLOR="white" CLASS="TableRowColor">
+<TD WIDTH="20%"><B><A HREF="org/apache/samza/system/chooser/package-summary.html">org.apache.samza.system.chooser</A></B></TD>
+<TD> </TD>
+</TR>
+<TR BGCOLOR="white" CLASS="TableRowColor">
<TD WIDTH="20%"><B><A HREF="org/apache/samza/task/package-summary.html">org.apache.samza.task</A></B></TD>
<TD> </TD>
</TR>
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/overview-tree.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/overview-tree.html?rev=1529329&r1=1529328&r2=1529329&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/overview-tree.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/overview-tree.html Fri Oct 4 22:10:48 2013
@@ -2,12 +2,12 @@
<!--NewPage-->
<HTML>
<HEAD>
-<!-- Generated by javadoc (build 1.6.0_51) on Thu Sep 19 09:23:12 PDT 2013 -->
+<!-- Generated by javadoc (build 1.6.0_51) on Fri Oct 04 15:10:30 PDT 2013 -->
<TITLE>
Class Hierarchy (samza-api 0.7.0 API)
</TITLE>
-<META NAME="date" CONTENT="2013-09-19">
+<META NAME="date" CONTENT="2013-10-04">
<LINK REL ="stylesheet" TYPE="text/css" HREF="stylesheet.css" TITLE="Style">
@@ -83,13 +83,14 @@ function windowTitle()
Hierarchy For All Packages</H2>
</CENTER>
<DL>
-<DT><B>Package Hierarchies:</B><DD><A HREF="org/apache/samza/package-tree.html">org.apache.samza</A>, <A HREF="org/apache/samza/checkpoint/package-tree.html">org.apache.samza.checkpoint</A>, <A HREF="org/apache/samza/config/package-tree.html">org.apache.samza.config</A>, <A HREF="org/apache/samza/job/package-tree.html">org.apache.samza.job</A>, <A HREF="org/apache/samza/metrics/package-tree.html">org.apache.samza.metrics</A>, <A HREF="org/apache/samza/serializers/package-tree.html">org.apache.samza.serializers</A>, <A HREF="org/apache/samza/storage/package-tree.html">org.apache.samza.storage</A>, <A HREF="org/apache/samza/system/package-tree.html">org.apache.samza.system</A>, <A HREF="org/apache/samza/task/package-tree.html">org.apache.samza.task</A>, <A HREF="org/apache/samza/util/package-tree.html">org.apache.samza.util</A></DL>
+<DT><B>Package Hierarchies:</B><DD><A HREF="org/apache/samza/package-tree.html">org.apache.samza</A>, <A HREF="org/apache/samza/checkpoint/package-tree.html">org.apache.samza.checkpoint</A>, <A HREF="org/apache/samza/config/package-tree.html">org.apache.samza.config</A>, <A HREF="org/apache/samza/job/package-tree.html">org.apache.samza.job</A>, <A HREF="org/apache/samza/metrics/package-tree.html">org.apache.samza.metrics</A>, <A HREF="org/apache/samza/serializers/package-tree.html">org.apache.samza.serializers</A>, <A HREF="org/apache/samza/storage/package-tree.html">org.apache.samza.storage</A>, <A HREF="org/apache/samza/system/package-tree.html">org.apache.samza.system</A>, <A HREF="org/apache/samza/system/chooser/package-tree.html">org.apache.samza.system.chooser</A>, <A HREF="org/apache/samza/task/package-tree.html">org.apache.samza.task</A>, <A HREF="org/apache/samza/util/package-tree.html">org.apache.samza.util</A></DL>
<HR>
<H2>
Class Hierarchy
</H2>
<UL>
<LI TYPE="circle">java.lang.Object<UL>
+<LI TYPE="circle">org.apache.samza.system.chooser.<A HREF="org/apache/samza/system/chooser/BaseMessageChooser.html" title="class in org.apache.samza.system.chooser"><B>BaseMessageChooser</B></A> (implements org.apache.samza.system.chooser.<A HREF="org/apache/samza/system/chooser/MessageChooser.html" title="interface in org.apache.samza.system.chooser">MessageChooser</A>)
<LI TYPE="circle">org.apache.samza.util.<A HREF="org/apache/samza/util/BlockingEnvelopeMap.html" title="class in org.apache.samza.util"><B>BlockingEnvelopeMap</B></A> (implements org.apache.samza.system.<A HREF="org/apache/samza/system/SystemConsumer.html" title="interface in org.apache.samza.system">SystemConsumer</A>)
<LI TYPE="circle">org.apache.samza.util.<A HREF="org/apache/samza/util/BlockingEnvelopeMap.BlockingEnvelopeMapMetrics.html" title="class in org.apache.samza.util"><B>BlockingEnvelopeMap.BlockingEnvelopeMapMetrics</B></A><LI TYPE="circle">org.apache.samza.checkpoint.<A HREF="org/apache/samza/checkpoint/Checkpoint.html" title="class in org.apache.samza.checkpoint"><B>Checkpoint</B></A><LI TYPE="circle">org.apache.samza.job.<A HREF="org/apache/samza/job/CommandBuilder.html" title="class in org.apache.samza.job"><B>CommandBuilder</B></A><LI TYPE="circle">org.apache.samza.config.<A HREF="org/apache/samza/config/Config.html" title="class in org.apache.samza.config"><B>Config</B></A> (implements java.util.Map<K,V>)
<UL>
@@ -119,7 +120,7 @@ Interface Hierarchy
<LI TYPE="circle">org.apache.samza.checkpoint.<A HREF="org/apache/samza/checkpoint/CheckpointManager.html" title="interface in org.apache.samza.checkpoint"><B>CheckpointManager</B></A><LI TYPE="circle">org.apache.samza.checkpoint.<A HREF="org/apache/samza/checkpoint/CheckpointManagerFactory.html" title="interface in org.apache.samza.checkpoint"><B>CheckpointManagerFactory</B></A><LI TYPE="circle">org.apache.samza.util.<A HREF="org/apache/samza/util/Clock.html" title="interface in org.apache.samza.util"><B>Clock</B></A><LI TYPE="circle">org.apache.samza.task.<A HREF="org/apache/samza/task/ClosableTask.html" title="interface in org.apache.samza.task"><B>ClosableTask</B></A><LI TYPE="circle">org.apache.samza.config.<A HREF="org/apache/samza/config/ConfigFactory.html" title="interface in org.apache.samza.config"><B>ConfigFactory</B></A><LI TYPE="circle">org.apache.samza.config.<A HREF="org/apache/samza/config/ConfigRewriter.html" title="interface in org.apache.samza.config"><B>ConfigRew
riter</B></A><LI TYPE="circle">org.apache.samza.serializers.<A HREF="org/apache/samza/serializers/Deserializer.html" title="interface in org.apache.samza.serializers"><B>Deserializer</B></A><T><UL>
<LI TYPE="circle">org.apache.samza.serializers.<A HREF="org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers"><B>Serde</B></A><T> (also extends org.apache.samza.serializers.<A HREF="org/apache/samza/serializers/Serializer.html" title="interface in org.apache.samza.serializers">Serializer</A><T>)
</UL>
-<LI TYPE="circle">org.apache.samza.task.<A HREF="org/apache/samza/task/InitableTask.html" title="interface in org.apache.samza.task"><B>InitableTask</B></A><LI TYPE="circle">org.apache.samza.system.<A HREF="org/apache/samza/system/MessageChooser.html" title="interface in org.apache.samza.system"><B>MessageChooser</B></A><LI TYPE="circle">org.apache.samza.task.<A HREF="org/apache/samza/task/MessageCollector.html" title="interface in org.apache.samza.task"><B>MessageCollector</B></A><LI TYPE="circle">org.apache.samza.metrics.<A HREF="org/apache/samza/metrics/Metric.html" title="interface in org.apache.samza.metrics"><B>Metric</B></A><LI TYPE="circle">org.apache.samza.metrics.<A HREF="org/apache/samza/metrics/MetricsRegistry.html" title="interface in org.apache.samza.metrics"><B>MetricsRegistry</B></A><UL>
+<LI TYPE="circle">org.apache.samza.task.<A HREF="org/apache/samza/task/InitableTask.html" title="interface in org.apache.samza.task"><B>InitableTask</B></A><LI TYPE="circle">org.apache.samza.system.chooser.<A HREF="org/apache/samza/system/chooser/MessageChooser.html" title="interface in org.apache.samza.system.chooser"><B>MessageChooser</B></A><LI TYPE="circle">org.apache.samza.system.chooser.<A HREF="org/apache/samza/system/chooser/MessageChooserFactory.html" title="interface in org.apache.samza.system.chooser"><B>MessageChooserFactory</B></A><LI TYPE="circle">org.apache.samza.task.<A HREF="org/apache/samza/task/MessageCollector.html" title="interface in org.apache.samza.task"><B>MessageCollector</B></A><LI TYPE="circle">org.apache.samza.metrics.<A HREF="org/apache/samza/metrics/Metric.html" title="interface in org.apache.samza.metrics"><B>Metric</B></A><LI TYPE="circle">org.apache.samza.metrics.<A HREF="org/apache/samza/metrics/MetricsRegistry.html" title="interface in org.apache.
samza.metrics"><B>MetricsRegistry</B></A><UL>
<LI TYPE="circle">org.apache.samza.metrics.<A HREF="org/apache/samza/metrics/ReadableMetricsRegistry.html" title="interface in org.apache.samza.metrics"><B>ReadableMetricsRegistry</B></A></UL>
<LI TYPE="circle">org.apache.samza.metrics.<A HREF="org/apache/samza/metrics/MetricsReporter.html" title="interface in org.apache.samza.metrics"><B>MetricsReporter</B></A><LI TYPE="circle">org.apache.samza.metrics.<A HREF="org/apache/samza/metrics/MetricsReporterFactory.html" title="interface in org.apache.samza.metrics"><B>MetricsReporterFactory</B></A><LI TYPE="circle">org.apache.samza.metrics.<A HREF="org/apache/samza/metrics/ReadableMetricsRegistryListener.html" title="interface in org.apache.samza.metrics"><B>ReadableMetricsRegistryListener</B></A><LI TYPE="circle">org.apache.samza.serializers.<A HREF="org/apache/samza/serializers/SerdeFactory.html" title="interface in org.apache.samza.serializers"><B>SerdeFactory</B></A><T><LI TYPE="circle">org.apache.samza.serializers.<A HREF="org/apache/samza/serializers/Serializer.html" title="interface in org.apache.samza.serializers"><B>Serializer</B></A><T><UL>
<LI TYPE="circle">org.apache.samza.serializers.<A HREF="org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers"><B>Serde</B></A><T> (also extends org.apache.samza.serializers.<A HREF="org/apache/samza/serializers/Deserializer.html" title="interface in org.apache.samza.serializers">Deserializer</A><T>)
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/package-list
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/package-list?rev=1529329&r1=1529328&r2=1529329&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/package-list (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/package-list Fri Oct 4 22:10:48 2013
@@ -6,5 +6,6 @@ org.apache.samza.metrics
org.apache.samza.serializers
org.apache.samza.storage
org.apache.samza.system
+org.apache.samza.system.chooser
org.apache.samza.task
org.apache.samza.util
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/serialized-form.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/serialized-form.html?rev=1529329&r1=1529328&r2=1529329&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/serialized-form.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/serialized-form.html Fri Oct 4 22:10:48 2013
@@ -2,12 +2,12 @@
<!--NewPage-->
<HTML>
<HEAD>
-<!-- Generated by javadoc (build 1.6.0_51) on Thu Sep 19 09:23:12 PDT 2013 -->
+<!-- Generated by javadoc (build 1.6.0_51) on Fri Oct 04 15:10:30 PDT 2013 -->
<TITLE>
Serialized Form (samza-api 0.7.0 API)
</TITLE>
-<META NAME="date" CONTENT="2013-09-19">
+<META NAME="date" CONTENT="2013-10-04">
<LINK REL ="stylesheet" TYPE="text/css" HREF="stylesheet.css" TITLE="Style">
Modified: incubator/samza/site/learn/documentation/0.7.0/container/streams.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/container/streams.html?rev=1529329&r1=1529328&r2=1529329&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/container/streams.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/container/streams.html Fri Oct 4 22:10:48 2013
@@ -112,6 +112,80 @@ public class OutgoingMessageEnvelope {
<p>In the process method in StreamTask, there is a MessageCollector parameter given to use. When the TaskRunner calls process() on one of your StreamTask instances, it provides the collector. After the process() method completes, the TaskRunner takes any output messages that your StreamTask wrote to the collector, serializes the messages, and calls the send() method on the appropriate SystemProducer.</p>
+<h3>Message Ordering</h3>
+
+<p>If a job is consuming messages from more than one system/stream/partition combination, by default, messages will be processed in a round robin fashion. For example, if a job is reading partitions 1 and 2 of page-view-events from a Kafka system, and there are messages available to be processed from both partitions, your StreamTask will get messages in round robin order (partition 1, partition 2, partition 1, partition 2, etc). If a message is not available for a given partition, it will be skipped, until a message becomes available.</p>
+
+<h4>MessageChooser</h4>
+
+<p>The default round robin behavior can be overridden by implementing a custom MessageChooser. A MessageChooser's job is to answer the question, "Given a set of incoming messages, which one should a Samza container process next?". To write a custom MessageChooser, take a look at the <a href="http://localhost:4000/learn/documentation/0.7.0/api/javadocs/org/apache/samza/system/MessageChooser.html">Javadocs</a>, and then configure your task with the "task.chooser.class" configuration, which should point to your MessageChooserFactory.</p>
+
+<p>Out of the box, Samza ships with a RoundRobinChooser, which is the default. You can use the StreamChooser by adding the following configuration to your job.</p>
+<div class="highlight"><pre><code class="text language-text" data-lang="text">task.chooser.class=org.apache.samza.system.YourStreamChooserFactory
+</code></pre></div>
+<h4>Prioritizing</h4>
+
+<p>There are certain times when messages from a stream should be favored over messages from any other stream. For example, some Samza jobs consume two streams: one stream is fed by a real-time system and the other stream is fed by a batch system. A typical pattern is to have a Samza processor with a statistical model that is ranking a real-time feed of data. Periodically, this model needs to be retrained and updated. The Samza processor can be re-deployed with the new model, but how do you re-process all of the old data that the processor has already seen? This can be accomplished by having a batch system send messages to the Samza processor for any data that needs to be re-processed. In this example, you'd like to favor the real-time system over the batch system, when messages are available for the real-time system. This prevents latency from being introduced into the real-time feed even when the batch system is sending messages by always processing the real-time messages first
.</p>
+
+<p>Samza provides a mechanism to prioritize one stream over another by setting this value: systems.<system>.streams.<stream>.samza.priority=2. A config snippet illustrates the settings:</p>
+<div class="highlight"><pre><code class="text language-text" data-lang="text">systems.kafka.streams.my-stream.samza.priority=2
+systems.kafka.streams.my-other-stream.samza.priority=1
+</code></pre></div>
+<p>This declares that my-stream's messages will be processed before my-other-stream's. If my-stream has no messages available at the moment (because more are still being read in, for instance), then my-other-stream's messages will get processed.</p>
+
+<p>Each priority level gets its own MessageChooser. In the example above, one MessageChooser is used for my-stream, and another is used for my-other-stream. The MessageChooser for my-other-stream will only be used when my-stream's MessageChooser doesn't return a message to process. </p>
+
+<p>It is also valid to define two streams with the same priority. If messages are available from two streams at the same priority level, it's up to the MessageChooser for that priority level to decide which message should be processed first.</p>
+
+<p>It's also valid to only define priorities for some streams. All non-prioritized streams will be treated as the lowest priority, and will share a single MessageChooser. If you had my-third-stream, as a third input stream in the example above, it would be prioritized as the lowest stream, and also get its own MessageChooser.</p>
+
+<h4>Bootstrapping</h4>
+
+<p>Some Samza jobs wish to fully consume a stream from offset 0 all the way through to the last message in the stream before they process messages from any other stream. This is useful for streams that have some key-value data that a Samza job wishes to use when processing messages from another stream. This is </p>
+
+<p>Consider a case where you want to read a currency-code stream, which has mappings of country code (e.g. USD) to symbols (e.g. $), and is partitioned by country code. You might want to join these symbols to a stream called transactions which is also partitioned by currency, and has a schema like {"country": "USD", "amount": 1234}. You could then have your StreamTask join the currency symbol to each transaction message, and emit messages like {"amount": "$1234"}.</p>
+
+<p>To bootstrap the currency-code stream, you need to read it from offset 0 all the way to the last message in the stream (what I'm calling head). It is not desirable to read any message from the transactions stream until the currency-code stream has been fully read, or else you might try to join a transaction message to a country code that hasn't yet been read.</p>
+
+<p>Samza supports this style of processing with the systems.<system>.streams.<stream>.samza.bootstrap property.</p>
+<div class="highlight"><pre><code class="text language-text" data-lang="text">systems.kafka.streams.currency-code.samza.bootstrap=true
+</code></pre></div>
+<p>This configuration tells Samza that currency-code's messages should be read from the last checkpointed offset all the way until the stream is caught up to "head", before any other message is processed. If you wish to process all messages in currency-code from offset 0 to head, you can define:</p>
+<div class="highlight"><pre><code class="text language-text" data-lang="text">systems.kafka.streams.currency-code.samza.bootstrap=true
+systems.kafka.streams.currency-code.samza.reset.offset=true
+</code></pre></div>
+<p>This tells Samza to start from beginning of the currency-code stream, and read all the way to head.</p>
+
+<p>The difference between prioritizing a stream and bootstrapping a stream, is a high priority stream will still allow lower priority stream messages to be processed when no messages are available for the high priority stream. In the case of bootstrapping, no streams will be allowed to be processed until all messages in the bootstrap stream have been read up to the last message.</p>
+
+<p>Once a bootstrap stream has been fully consumed ("caught up"), it is treated like a normal stream, and no bootstrapping logic happens.</p>
+
+<p>It is valid to define multiple bootstrap streams.</p>
+<div class="highlight"><pre><code class="text language-text" data-lang="text">systems.kafka.streams.currency-code.samza.bootstrap=true
+systems.kafka.streams.other-bootstrap-stream.samza.bootstrap=true
+</code></pre></div>
+<p>In this case, currency-code and other-bootstrap-stream will both be processed before any other stream is processed. The order of message processing (the bootstrap order) between currency-code and other-bootstrap-stream is up to the MessageChooser. If you want to fully process one bootstrap stream before another, you can use priorities:</p>
+<div class="highlight"><pre><code class="text language-text" data-lang="text">systems.kafka.streams.currency-code.samza.bootstrap=true
+systems.kafka.streams.currency-code.samza.priority=2
+systems.kafka.streams.other-bootstrap-stream.samza.bootstrap=true
+systems.kafka.streams.other-bootstrap-stream.samza.priority=1
+</code></pre></div>
+<p>This defines a specific bootstrap ordering: fully bootstrap currency-code before bootstrapping other-bootstrap-stream.</p>
+
+<p>Lastly, bootstrap and non-bootstrap prioritized streams can be mixed:</p>
+<div class="highlight"><pre><code class="text language-text" data-lang="text">systems.kafka.streams.currency-code.samza.bootstrap=true
+systems.kafka.streams.non-bootstrap-stream.samza.priority=2
+systems.kafka.streams.other-non-bootstrap-stream.samza.priority=1
+</code></pre></div>
+<p>Bootstrap streams are assigned a priority of Int.MaxInt by default, so they will always be prioritized over any other prioritized stream. In this case, currency-code will be fully bootstrapped, and then treated as the highest priority stream (Int.IntMax). The next highest priority stream will be non-bootstrap-stream (priority 2), followed by other-non-bootstrap-stream (priority 1), and then any non-bootstrap/non-prioritized streams.</p>
+
+<h4>Batching</h4>
+
+<p>There are cases where consuming from the same SystemStreamPartition repeatedly leads to better performance. Samza allows for consumer batching to satisfy this use case. For example, if you had two SystemStreamPartitions, SSP1 and SSP2, you might wish to read 100 messages from SSP1 and then one from SSP2, regardless of the MessageChooser that's used. This can be accomplished with:</p>
+<div class="highlight"><pre><code class="text language-text" data-lang="text">task.consumer.batch.size=100
+</code></pre></div>
+<p>With this setting, Samza will always try and read a message from the last SystemStreamPartition that was read. This behavior will continue until no message is available for the SystemStreamPartition, or the batch size has been reached. In either of these cases, Samza will defer to the MessageChooser to determine the next message to process. It will then try and stick to the new message's SystemStreamPartition again.</p>
+
<h2><a href="checkpointing.html">Checkpointing »</a></h2>
Modified: incubator/samza/site/sitemap.xml
URL: http://svn.apache.org/viewvc/incubator/samza/site/sitemap.xml?rev=1529329&r1=1529328&r2=1529329&view=diff
==============================================================================
--- incubator/samza/site/sitemap.xml (original)
+++ incubator/samza/site/sitemap.xml Fri Oct 4 22:10:48 2013
@@ -4,7 +4,7 @@
<url>
<loc>http://samza.incubator.apache.org/</loc>
- <lastmod>2013-09-19</lastmod>
+ <lastmod>2013-10-04</lastmod>
<changefreq>daily</changefreq>
<priority>1.0</priority>
</url>
@@ -14,273 +14,273 @@
<url>
<loc>http://samza.incubator.apache.org/community/committers.html</loc>
- <lastmod>2013-09-19</lastmod>
+ <lastmod>2013-10-04</lastmod>
</url>
<url>
<loc>http://samza.incubator.apache.org/community/irc.html</loc>
- <lastmod>2013-09-19</lastmod>
+ <lastmod>2013-10-04</lastmod>
</url>
<url>
<loc>http://samza.incubator.apache.org/community/mailing-lists.html</loc>
- <lastmod>2013-09-19</lastmod>
+ <lastmod>2013-10-04</lastmod>
</url>
<url>
<loc>http://samza.incubator.apache.org/contribute/code.html</loc>
- <lastmod>2013-09-19</lastmod>
+ <lastmod>2013-10-04</lastmod>
</url>
<url>
<loc>http://samza.incubator.apache.org/contribute/coding-guide.html</loc>
- <lastmod>2013-09-19</lastmod>
+ <lastmod>2013-10-04</lastmod>
</url>
<url>
<loc>http://samza.incubator.apache.org/contribute/disclaimer.html</loc>
- <lastmod>2013-09-19</lastmod>
+ <lastmod>2013-10-04</lastmod>
</url>
<url>
<loc>http://samza.incubator.apache.org/contribute/projects.html</loc>
- <lastmod>2013-09-19</lastmod>
+ <lastmod>2013-10-04</lastmod>
</url>
<url>
<loc>http://samza.incubator.apache.org/contribute/rules.html</loc>
- <lastmod>2013-09-19</lastmod>
+ <lastmod>2013-10-04</lastmod>
</url>
<url>
<loc>http://samza.incubator.apache.org/contribute/seps.html</loc>
- <lastmod>2013-09-19</lastmod>
+ <lastmod>2013-10-04</lastmod>
</url>
<url>
<loc>http://samza.incubator.apache.org/index.html</loc>
- <lastmod>2013-09-19</lastmod>
+ <lastmod>2013-10-04</lastmod>
</url>
<url>
<loc>http://samza.incubator.apache.org/learn/documentation/0.7.0/api/overview.html</loc>
- <lastmod>2013-09-19</lastmod>
+ <lastmod>2013-10-04</lastmod>
</url>
<url>
<loc>http://samza.incubator.apache.org/learn/documentation/0.7.0/comparisons/introduction.html</loc>
- <lastmod>2013-09-19</lastmod>
+ <lastmod>2013-10-04</lastmod>
</url>
<url>
<loc>http://samza.incubator.apache.org/learn/documentation/0.7.0/comparisons/mupd8.html</loc>
- <lastmod>2013-09-19</lastmod>
+ <lastmod>2013-10-04</lastmod>
</url>
<url>
<loc>http://samza.incubator.apache.org/learn/documentation/0.7.0/comparisons/storm.html</loc>
- <lastmod>2013-09-19</lastmod>
+ <lastmod>2013-10-04</lastmod>
</url>
<url>
<loc>http://samza.incubator.apache.org/learn/documentation/0.7.0/container/checkpointing.html</loc>
- <lastmod>2013-09-19</lastmod>
+ <lastmod>2013-10-04</lastmod>
</url>
<url>
<loc>http://samza.incubator.apache.org/learn/documentation/0.7.0/container/event-loop.html</loc>
- <lastmod>2013-09-19</lastmod>
+ <lastmod>2013-10-04</lastmod>
</url>
<url>
<loc>http://samza.incubator.apache.org/learn/documentation/0.7.0/container/index.html</loc>
- <lastmod>2013-09-19</lastmod>
+ <lastmod>2013-10-04</lastmod>
</url>
<url>
<loc>http://samza.incubator.apache.org/learn/documentation/0.7.0/container/jmx.html</loc>
- <lastmod>2013-09-19</lastmod>
+ <lastmod>2013-10-04</lastmod>
</url>
<url>
<loc>http://samza.incubator.apache.org/learn/documentation/0.7.0/container/metrics.html</loc>
- <lastmod>2013-09-19</lastmod>
+ <lastmod>2013-10-04</lastmod>
</url>
<url>
<loc>http://samza.incubator.apache.org/learn/documentation/0.7.0/container/state-management.html</loc>
- <lastmod>2013-09-19</lastmod>
+ <lastmod>2013-10-04</lastmod>
</url>
<url>
<loc>http://samza.incubator.apache.org/learn/documentation/0.7.0/container/streams.html</loc>
- <lastmod>2013-09-19</lastmod>
+ <lastmod>2013-10-04</lastmod>
</url>
<url>
<loc>http://samza.incubator.apache.org/learn/documentation/0.7.0/container/task-runner.html</loc>
- <lastmod>2013-09-19</lastmod>
+ <lastmod>2013-10-04</lastmod>
</url>
<url>
<loc>http://samza.incubator.apache.org/learn/documentation/0.7.0/container/windowing.html</loc>
- <lastmod>2013-09-19</lastmod>
+ <lastmod>2013-10-04</lastmod>
</url>
<url>
<loc>http://samza.incubator.apache.org/learn/documentation/0.7.0/index.html</loc>
- <lastmod>2013-09-19</lastmod>
+ <lastmod>2013-10-04</lastmod>
</url>
<url>
<loc>http://samza.incubator.apache.org/learn/documentation/0.7.0/introduction/architecture.html</loc>
- <lastmod>2013-09-19</lastmod>
+ <lastmod>2013-10-04</lastmod>
</url>
<url>
<loc>http://samza.incubator.apache.org/learn/documentation/0.7.0/introduction/background.html</loc>
- <lastmod>2013-09-19</lastmod>
+ <lastmod>2013-10-04</lastmod>
</url>
<url>
<loc>http://samza.incubator.apache.org/learn/documentation/0.7.0/introduction/concepts.html</loc>
- <lastmod>2013-09-19</lastmod>
+ <lastmod>2013-10-04</lastmod>
</url>
<url>
<loc>http://samza.incubator.apache.org/learn/documentation/0.7.0/jobs/configuration.html</loc>
- <lastmod>2013-09-19</lastmod>
+ <lastmod>2013-10-04</lastmod>
</url>
<url>
<loc>http://samza.incubator.apache.org/learn/documentation/0.7.0/jobs/job-runner.html</loc>
- <lastmod>2013-09-19</lastmod>
+ <lastmod>2013-10-04</lastmod>
</url>
<url>
<loc>http://samza.incubator.apache.org/learn/documentation/0.7.0/jobs/logging.html</loc>
- <lastmod>2013-09-19</lastmod>
+ <lastmod>2013-10-04</lastmod>
</url>
<url>
<loc>http://samza.incubator.apache.org/learn/documentation/0.7.0/jobs/packaging.html</loc>
- <lastmod>2013-09-19</lastmod>
+ <lastmod>2013-10-04</lastmod>
</url>
<url>
<loc>http://samza.incubator.apache.org/learn/documentation/0.7.0/jobs/yarn-jobs.html</loc>
- <lastmod>2013-09-19</lastmod>
+ <lastmod>2013-10-04</lastmod>
</url>
<url>
<loc>http://samza.incubator.apache.org/learn/documentation/0.7.0/operations/kafka.html</loc>
- <lastmod>2013-09-19</lastmod>
+ <lastmod>2013-10-04</lastmod>
</url>
<url>
<loc>http://samza.incubator.apache.org/learn/documentation/0.7.0/operations/security.html</loc>
- <lastmod>2013-09-19</lastmod>
+ <lastmod>2013-10-04</lastmod>
</url>
<url>
<loc>http://samza.incubator.apache.org/learn/documentation/0.7.0/yarn/application-master.html</loc>
- <lastmod>2013-09-19</lastmod>
+ <lastmod>2013-10-04</lastmod>
</url>
<url>
<loc>http://samza.incubator.apache.org/learn/documentation/0.7.0/yarn/isolation.html</loc>
- <lastmod>2013-09-19</lastmod>
+ <lastmod>2013-10-04</lastmod>
</url>
<url>
<loc>http://samza.incubator.apache.org/learn/tutorials/0.7.0/index.html</loc>
- <lastmod>2013-09-19</lastmod>
+ <lastmod>2013-10-04</lastmod>
</url>
<url>
<loc>http://samza.incubator.apache.org/startup/download/index.html</loc>
- <lastmod>2013-09-19</lastmod>
+ <lastmod>2013-10-04</lastmod>
</url>
<url>
<loc>http://samza.incubator.apache.org/startup/hello-samza/0.7.0/index.html</loc>
- <lastmod>2013-09-19</lastmod>
+ <lastmod>2013-10-04</lastmod>
</url>