You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by xi...@apache.org on 2018/01/04 00:31:43 UTC
svn commit: r1820026 [5/24] - in /samza/site: ./
img/latest/learn/documentation/hadoop/ img/latest/learn/documentation/rest/
learn/documentation/latest/ learn/documentation/latest/api/
learn/documentation/latest/api/javadocs/ learn/documentation/latest...
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/MetricsRegistry.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/MetricsRegistry.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/MetricsRegistry.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/MetricsRegistry.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:21 PDT 2017 -->
-<title>MetricsRegistry (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>MetricsRegistry (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
<script type="text/javascript" src="../../../../script.js"></script>
</head>
@@ -12,7 +12,7 @@
<script type="text/javascript"><!--
try {
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="MetricsRegistry (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="MetricsRegistry (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/MetricsReporter.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/MetricsReporter.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/MetricsReporter.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/MetricsReporter.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:21 PDT 2017 -->
-<title>MetricsReporter (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>MetricsReporter (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
<script type="text/javascript" src="../../../../script.js"></script>
</head>
@@ -12,7 +12,7 @@
<script type="text/javascript"><!--
try {
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="MetricsReporter (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="MetricsReporter (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/MetricsReporterFactory.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/MetricsReporterFactory.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/MetricsReporterFactory.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/MetricsReporterFactory.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:21 PDT 2017 -->
-<title>MetricsReporterFactory (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>MetricsReporterFactory (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
<script type="text/javascript" src="../../../../script.js"></script>
</head>
@@ -12,7 +12,7 @@
<script type="text/javascript"><!--
try {
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="MetricsReporterFactory (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="MetricsReporterFactory (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/MetricsValidationFailureException.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/MetricsValidationFailureException.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/MetricsValidationFailureException.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/MetricsValidationFailureException.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:21 PDT 2017 -->
-<title>MetricsValidationFailureException (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>MetricsValidationFailureException (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
<script type="text/javascript" src="../../../../script.js"></script>
</head>
@@ -12,7 +12,7 @@
<script type="text/javascript"><!--
try {
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="MetricsValidationFailureException (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="MetricsValidationFailureException (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/MetricsValidator.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/MetricsValidator.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/MetricsValidator.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/MetricsValidator.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:21 PDT 2017 -->
-<title>MetricsValidator (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>MetricsValidator (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
<script type="text/javascript" src="../../../../script.js"></script>
</head>
@@ -12,7 +12,7 @@
<script type="text/javascript"><!--
try {
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="MetricsValidator (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="MetricsValidator (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/MetricsVisitor.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/MetricsVisitor.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/MetricsVisitor.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/MetricsVisitor.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:21 PDT 2017 -->
-<title>MetricsVisitor (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>MetricsVisitor (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
<script type="text/javascript" src="../../../../script.js"></script>
</head>
@@ -12,7 +12,7 @@
<script type="text/javascript"><!--
try {
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="MetricsVisitor (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="MetricsVisitor (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/ReadableMetricsRegistry.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/ReadableMetricsRegistry.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/ReadableMetricsRegistry.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/ReadableMetricsRegistry.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:21 PDT 2017 -->
-<title>ReadableMetricsRegistry (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>ReadableMetricsRegistry (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
<script type="text/javascript" src="../../../../script.js"></script>
</head>
@@ -12,7 +12,7 @@
<script type="text/javascript"><!--
try {
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="ReadableMetricsRegistry (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="ReadableMetricsRegistry (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/ReadableMetricsRegistryListener.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/ReadableMetricsRegistryListener.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/ReadableMetricsRegistryListener.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/ReadableMetricsRegistryListener.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:21 PDT 2017 -->
-<title>ReadableMetricsRegistryListener (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>ReadableMetricsRegistryListener (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
<script type="text/javascript" src="../../../../script.js"></script>
</head>
@@ -12,7 +12,7 @@
<script type="text/javascript"><!--
try {
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="ReadableMetricsRegistryListener (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="ReadableMetricsRegistryListener (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/Reservoir.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/Reservoir.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/Reservoir.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/Reservoir.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:21 PDT 2017 -->
-<title>Reservoir (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>Reservoir (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
<script type="text/javascript" src="../../../../script.js"></script>
</head>
@@ -12,7 +12,7 @@
<script type="text/javascript"><!--
try {
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="Reservoir (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="Reservoir (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/SlidingTimeWindowReservoir.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/SlidingTimeWindowReservoir.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/SlidingTimeWindowReservoir.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/SlidingTimeWindowReservoir.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:21 PDT 2017 -->
-<title>SlidingTimeWindowReservoir (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>SlidingTimeWindowReservoir (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
<script type="text/javascript" src="../../../../script.js"></script>
</head>
@@ -12,7 +12,7 @@
<script type="text/javascript"><!--
try {
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="SlidingTimeWindowReservoir (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="SlidingTimeWindowReservoir (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/Snapshot.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/Snapshot.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/Snapshot.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/Snapshot.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:21 PDT 2017 -->
-<title>Snapshot (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>Snapshot (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
<script type="text/javascript" src="../../../../script.js"></script>
</head>
@@ -12,7 +12,7 @@
<script type="text/javascript"><!--
try {
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="Snapshot (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="Snapshot (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/Timer.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/Timer.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/Timer.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/Timer.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:21 PDT 2017 -->
-<title>Timer (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>Timer (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
<script type="text/javascript" src="../../../../script.js"></script>
</head>
@@ -12,7 +12,7 @@
<script type="text/javascript"><!--
try {
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="Timer (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="Timer (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/package-frame.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/package-frame.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/package-frame.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/package-frame.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:22 PDT 2017 -->
-<title>org.apache.samza.metrics (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>org.apache.samza.metrics (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
<script type="text/javascript" src="../../../../script.js"></script>
</head>
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/package-summary.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/package-summary.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/package-summary.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/package-summary.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:22 PDT 2017 -->
-<title>org.apache.samza.metrics (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>org.apache.samza.metrics (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
<script type="text/javascript" src="../../../../script.js"></script>
</head>
@@ -12,7 +12,7 @@
<script type="text/javascript"><!--
try {
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="org.apache.samza.metrics (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="org.apache.samza.metrics (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/package-tree.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/package-tree.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/package-tree.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/package-tree.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:22 PDT 2017 -->
-<title>org.apache.samza.metrics Class Hierarchy (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>org.apache.samza.metrics Class Hierarchy (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
<script type="text/javascript" src="../../../../script.js"></script>
</head>
@@ -12,7 +12,7 @@
<script type="text/javascript"><!--
try {
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="org.apache.samza.metrics Class Hierarchy (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="org.apache.samza.metrics Class Hierarchy (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/ContextManager.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/ContextManager.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/ContextManager.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/ContextManager.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:21 PDT 2017 -->
-<title>ContextManager (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>ContextManager (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
<script type="text/javascript" src="../../../../script.js"></script>
</head>
@@ -12,7 +12,7 @@
<script type="text/javascript"><!--
try {
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="ContextManager (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="ContextManager (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
@@ -49,7 +49,7 @@ var activeTableTab = "activeTableTab";
<div class="subNav">
<ul class="navList">
<li>Prev Class</li>
-<li><a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><span class="typeNameLink">Next Class</span></a></li>
+<li><a href="../../../../org/apache/samza/operators/KV.html" title="class in org.apache.samza.operators"><span class="typeNameLink">Next Class</span></a></li>
</ul>
<ul class="navList">
<li><a href="../../../../index.html?org/apache/samza/operators/ContextManager.html" target="_top">Frames</a></li>
@@ -207,7 +207,7 @@ public interface <span class="typeNameLa
<div class="subNav">
<ul class="navList">
<li>Prev Class</li>
-<li><a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><span class="typeNameLink">Next Class</span></a></li>
+<li><a href="../../../../org/apache/samza/operators/KV.html" title="class in org.apache.samza.operators"><span class="typeNameLink">Next Class</span></a></li>
</ul>
<ul class="navList">
<li><a href="../../../../index.html?org/apache/samza/operators/ContextManager.html" target="_top">Frames</a></li>
Added: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/KV.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/KV.html?rev=1820026&view=auto
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/KV.html (added)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/KV.html Thu Jan 4 00:31:39 2018
@@ -0,0 +1,358 @@
+<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
+<!-- NewPage -->
+<html lang="en">
+<head>
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>KV (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
+<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
+<script type="text/javascript" src="../../../../script.js"></script>
+</head>
+<body>
+<script type="text/javascript"><!--
+ try {
+ if (location.href.indexOf('is-external=true') == -1) {
+ parent.document.title="KV (samza-api 0.14.1-SNAPSHOT API)";
+ }
+ }
+ catch(err) {
+ }
+//-->
+var methods = {"i0":10,"i1":10,"i2":9};
+var tabs = {65535:["t0","All Methods"],1:["t1","Static Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]};
+var altColor = "altColor";
+var rowColor = "rowColor";
+var tableTab = "tableTab";
+var activeTableTab = "activeTableTab";
+</script>
+<noscript>
+<div>JavaScript is disabled on your browser.</div>
+</noscript>
+<!-- ========= START OF TOP NAVBAR ======= -->
+<div class="topNav"><a name="navbar.top">
+<!-- -->
+</a>
+<div class="skipNav"><a href="#skip.navbar.top" title="Skip navigation links">Skip navigation links</a></div>
+<a name="navbar.top.firstrow">
+<!-- -->
+</a>
+<ul class="navList" title="Navigation">
+<li><a href="../../../../overview-summary.html">Overview</a></li>
+<li><a href="package-summary.html">Package</a></li>
+<li class="navBarCell1Rev">Class</li>
+<li><a href="package-tree.html">Tree</a></li>
+<li><a href="../../../../deprecated-list.html">Deprecated</a></li>
+<li><a href="../../../../index-all.html">Index</a></li>
+<li><a href="../../../../help-doc.html">Help</a></li>
+</ul>
+</div>
+<div class="subNav">
+<ul class="navList">
+<li><a href="../../../../org/apache/samza/operators/ContextManager.html" title="interface in org.apache.samza.operators"><span class="typeNameLink">Prev Class</span></a></li>
+<li><a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><span class="typeNameLink">Next Class</span></a></li>
+</ul>
+<ul class="navList">
+<li><a href="../../../../index.html?org/apache/samza/operators/KV.html" target="_top">Frames</a></li>
+<li><a href="KV.html" target="_top">No Frames</a></li>
+</ul>
+<ul class="navList" id="allclasses_navbar_top">
+<li><a href="../../../../allclasses-noframe.html">All Classes</a></li>
+</ul>
+<div>
+<script type="text/javascript"><!--
+ allClassesLink = document.getElementById("allclasses_navbar_top");
+ if(window==top) {
+ allClassesLink.style.display = "block";
+ }
+ else {
+ allClassesLink.style.display = "none";
+ }
+ //-->
+</script>
+</div>
+<div>
+<ul class="subNavList">
+<li>Summary: </li>
+<li>Nested | </li>
+<li><a href="#field.summary">Field</a> | </li>
+<li><a href="#constructor.summary">Constr</a> | </li>
+<li><a href="#method.summary">Method</a></li>
+</ul>
+<ul class="subNavList">
+<li>Detail: </li>
+<li><a href="#field.detail">Field</a> | </li>
+<li><a href="#constructor.detail">Constr</a> | </li>
+<li><a href="#method.detail">Method</a></li>
+</ul>
+</div>
+<a name="skip.navbar.top">
+<!-- -->
+</a></div>
+<!-- ========= END OF TOP NAVBAR ========= -->
+<!-- ======== START OF CLASS DATA ======== -->
+<div class="header">
+<div class="subTitle">org.apache.samza.operators</div>
+<h2 title="Class KV" class="title">Class KV<K,V></h2>
+</div>
+<div class="contentContainer">
+<ul class="inheritance">
+<li>java.lang.Object</li>
+<li>
+<ul class="inheritance">
+<li>org.apache.samza.operators.KV<K,V></li>
+</ul>
+</li>
+</ul>
+<div class="description">
+<ul class="blockList">
+<li class="blockList">
+<dl>
+<dt><span class="paramLabel">Type Parameters:</span></dt>
+<dd><code>K</code> - type of the key</dd>
+<dd><code>V</code> - type of the value</dd>
+</dl>
+<hr>
+<br>
+<pre>public final class <span class="typeNameLabel">KV<K,V></span>
+extends java.lang.Object</pre>
+<div class="block">A key and value pair.</div>
+</li>
+</ul>
+</div>
+<div class="summary">
+<ul class="blockList">
+<li class="blockList">
+<!-- =========== FIELD SUMMARY =========== -->
+<ul class="blockList">
+<li class="blockList"><a name="field.summary">
+<!-- -->
+</a>
+<h3>Field Summary</h3>
+<table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Field Summary table, listing fields, and an explanation">
+<caption><span>Fields</span><span class="tabEnd"> </span></caption>
+<tr>
+<th class="colFirst" scope="col">Modifier and Type</th>
+<th class="colLast" scope="col">Field and Description</th>
+</tr>
+<tr class="altColor">
+<td class="colFirst"><code><a href="../../../../org/apache/samza/operators/KV.html" title="type parameter in KV">K</a></code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/operators/KV.html#key">key</a></span></code> </td>
+</tr>
+<tr class="rowColor">
+<td class="colFirst"><code><a href="../../../../org/apache/samza/operators/KV.html" title="type parameter in KV">V</a></code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/operators/KV.html#value">value</a></span></code> </td>
+</tr>
+</table>
+</li>
+</ul>
+<!-- ======== CONSTRUCTOR SUMMARY ======== -->
+<ul class="blockList">
+<li class="blockList"><a name="constructor.summary">
+<!-- -->
+</a>
+<h3>Constructor Summary</h3>
+<table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Constructor Summary table, listing constructors, and an explanation">
+<caption><span>Constructors</span><span class="tabEnd"> </span></caption>
+<tr>
+<th class="colOne" scope="col">Constructor and Description</th>
+</tr>
+<tr class="altColor">
+<td class="colOne"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/operators/KV.html#KV-K-V-">KV</a></span>(<a href="../../../../org/apache/samza/operators/KV.html" title="type parameter in KV">K</a> key,
+ <a href="../../../../org/apache/samza/operators/KV.html" title="type parameter in KV">V</a> value)</code> </td>
+</tr>
+</table>
+</li>
+</ul>
+<!-- ========== METHOD SUMMARY =========== -->
+<ul class="blockList">
+<li class="blockList"><a name="method.summary">
+<!-- -->
+</a>
+<h3>Method Summary</h3>
+<table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Method Summary table, listing methods, and an explanation">
+<caption><span id="t0" class="activeTableTab"><span>All Methods</span><span class="tabEnd"> </span></span><span id="t1" class="tableTab"><span><a href="javascript:show(1);">Static Methods</a></span><span class="tabEnd"> </span></span><span id="t2" class="tableTab"><span><a href="javascript:show(2);">Instance Methods</a></span><span class="tabEnd"> </span></span><span id="t4" class="tableTab"><span><a href="javascript:show(8);">Concrete Methods</a></span><span class="tabEnd"> </span></span></caption>
+<tr>
+<th class="colFirst" scope="col">Modifier and Type</th>
+<th class="colLast" scope="col">Method and Description</th>
+</tr>
+<tr id="i0" class="altColor">
+<td class="colFirst"><code><a href="../../../../org/apache/samza/operators/KV.html" title="type parameter in KV">K</a></code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/operators/KV.html#getKey--">getKey</a></span>()</code> </td>
+</tr>
+<tr id="i1" class="rowColor">
+<td class="colFirst"><code><a href="../../../../org/apache/samza/operators/KV.html" title="type parameter in KV">V</a></code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/operators/KV.html#getValue--">getValue</a></span>()</code> </td>
+</tr>
+<tr id="i2" class="altColor">
+<td class="colFirst"><code>static <K,V> <a href="../../../../org/apache/samza/operators/KV.html" title="class in org.apache.samza.operators">KV</a><K,V></code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/operators/KV.html#of-K-V-">of</a></span>(K key,
+ V value)</code> </td>
+</tr>
+</table>
+<ul class="blockList">
+<li class="blockList"><a name="methods.inherited.from.class.java.lang.Object">
+<!-- -->
+</a>
+<h3>Methods inherited from class java.lang.Object</h3>
+<code>clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait</code></li>
+</ul>
+</li>
+</ul>
+</li>
+</ul>
+</div>
+<div class="details">
+<ul class="blockList">
+<li class="blockList">
+<!-- ============ FIELD DETAIL =========== -->
+<ul class="blockList">
+<li class="blockList"><a name="field.detail">
+<!-- -->
+</a>
+<h3>Field Detail</h3>
+<a name="key">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>key</h4>
+<pre>public final <a href="../../../../org/apache/samza/operators/KV.html" title="type parameter in KV">K</a> key</pre>
+</li>
+</ul>
+<a name="value">
+<!-- -->
+</a>
+<ul class="blockListLast">
+<li class="blockList">
+<h4>value</h4>
+<pre>public final <a href="../../../../org/apache/samza/operators/KV.html" title="type parameter in KV">V</a> value</pre>
+</li>
+</ul>
+</li>
+</ul>
+<!-- ========= CONSTRUCTOR DETAIL ======== -->
+<ul class="blockList">
+<li class="blockList"><a name="constructor.detail">
+<!-- -->
+</a>
+<h3>Constructor Detail</h3>
+<a name="KV-java.lang.Object-java.lang.Object-">
+<!-- -->
+</a><a name="KV-K-V-">
+<!-- -->
+</a>
+<ul class="blockListLast">
+<li class="blockList">
+<h4>KV</h4>
+<pre>public KV(<a href="../../../../org/apache/samza/operators/KV.html" title="type parameter in KV">K</a> key,
+ <a href="../../../../org/apache/samza/operators/KV.html" title="type parameter in KV">V</a> value)</pre>
+</li>
+</ul>
+</li>
+</ul>
+<!-- ============ METHOD DETAIL ========== -->
+<ul class="blockList">
+<li class="blockList"><a name="method.detail">
+<!-- -->
+</a>
+<h3>Method Detail</h3>
+<a name="of-java.lang.Object-java.lang.Object-">
+<!-- -->
+</a><a name="of-K-V-">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>of</h4>
+<pre>public static <K,V> <a href="../../../../org/apache/samza/operators/KV.html" title="class in org.apache.samza.operators">KV</a><K,V> of(K key,
+ V value)</pre>
+</li>
+</ul>
+<a name="getKey--">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>getKey</h4>
+<pre>public <a href="../../../../org/apache/samza/operators/KV.html" title="type parameter in KV">K</a> getKey()</pre>
+</li>
+</ul>
+<a name="getValue--">
+<!-- -->
+</a>
+<ul class="blockListLast">
+<li class="blockList">
+<h4>getValue</h4>
+<pre>public <a href="../../../../org/apache/samza/operators/KV.html" title="type parameter in KV">V</a> getValue()</pre>
+</li>
+</ul>
+</li>
+</ul>
+</li>
+</ul>
+</div>
+</div>
+<!-- ========= END OF CLASS DATA ========= -->
+<!-- ======= START OF BOTTOM NAVBAR ====== -->
+<div class="bottomNav"><a name="navbar.bottom">
+<!-- -->
+</a>
+<div class="skipNav"><a href="#skip.navbar.bottom" title="Skip navigation links">Skip navigation links</a></div>
+<a name="navbar.bottom.firstrow">
+<!-- -->
+</a>
+<ul class="navList" title="Navigation">
+<li><a href="../../../../overview-summary.html">Overview</a></li>
+<li><a href="package-summary.html">Package</a></li>
+<li class="navBarCell1Rev">Class</li>
+<li><a href="package-tree.html">Tree</a></li>
+<li><a href="../../../../deprecated-list.html">Deprecated</a></li>
+<li><a href="../../../../index-all.html">Index</a></li>
+<li><a href="../../../../help-doc.html">Help</a></li>
+</ul>
+</div>
+<div class="subNav">
+<ul class="navList">
+<li><a href="../../../../org/apache/samza/operators/ContextManager.html" title="interface in org.apache.samza.operators"><span class="typeNameLink">Prev Class</span></a></li>
+<li><a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><span class="typeNameLink">Next Class</span></a></li>
+</ul>
+<ul class="navList">
+<li><a href="../../../../index.html?org/apache/samza/operators/KV.html" target="_top">Frames</a></li>
+<li><a href="KV.html" target="_top">No Frames</a></li>
+</ul>
+<ul class="navList" id="allclasses_navbar_bottom">
+<li><a href="../../../../allclasses-noframe.html">All Classes</a></li>
+</ul>
+<div>
+<script type="text/javascript"><!--
+ allClassesLink = document.getElementById("allclasses_navbar_bottom");
+ if(window==top) {
+ allClassesLink.style.display = "block";
+ }
+ else {
+ allClassesLink.style.display = "none";
+ }
+ //-->
+</script>
+</div>
+<div>
+<ul class="subNavList">
+<li>Summary: </li>
+<li>Nested | </li>
+<li><a href="#field.summary">Field</a> | </li>
+<li><a href="#constructor.summary">Constr</a> | </li>
+<li><a href="#method.summary">Method</a></li>
+</ul>
+<ul class="subNavList">
+<li>Detail: </li>
+<li><a href="#field.detail">Field</a> | </li>
+<li><a href="#constructor.detail">Constr</a> | </li>
+<li><a href="#method.detail">Method</a></li>
+</ul>
+</div>
+<a name="skip.navbar.bottom">
+<!-- -->
+</a></div>
+<!-- ======== END OF BOTTOM NAVBAR ======= -->
+</body>
+</html>
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/MessageStream.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/MessageStream.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/MessageStream.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/MessageStream.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:21 PDT 2017 -->
-<title>MessageStream (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>MessageStream (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
<script type="text/javascript" src="../../../../script.js"></script>
</head>
@@ -12,13 +12,13 @@
<script type="text/javascript"><!--
try {
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="MessageStream (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="MessageStream (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
}
//-->
-var methods = {"i0":6,"i1":6,"i2":6,"i3":6,"i4":6,"i5":17,"i6":6,"i7":6,"i8":6,"i9":6};
+var methods = {"i0":6,"i1":6,"i2":6,"i3":6,"i4":6,"i5":6,"i6":17,"i7":6,"i8":6,"i9":6,"i10":6,"i11":6,"i12":6};
var tabs = {65535:["t0","All Methods"],1:["t1","Static Methods"],2:["t2","Instance Methods"],4:["t3","Abstract Methods"],16:["t5","Default Methods"]};
var altColor = "altColor";
var rowColor = "rowColor";
@@ -48,7 +48,7 @@ var activeTableTab = "activeTableTab";
</div>
<div class="subNav">
<ul class="navList">
-<li><a href="../../../../org/apache/samza/operators/ContextManager.html" title="interface in org.apache.samza.operators"><span class="typeNameLink">Prev Class</span></a></li>
+<li><a href="../../../../org/apache/samza/operators/KV.html" title="class in org.apache.samza.operators"><span class="typeNameLink">Prev Class</span></a></li>
<li><a href="../../../../org/apache/samza/operators/OutputStream.html" title="interface in org.apache.samza.operators"><span class="typeNameLink">Next Class</span></a></li>
</ul>
<ul class="navList">
@@ -108,7 +108,7 @@ var activeTableTab = "activeTableTab";
public interface <span class="typeNameLabel">MessageStream<M></span></pre>
<div class="block">A stream of messages that can be transformed into another <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a>.
<p>
- A <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> corresponding to an input stream can be obtained using <a href="../../../../org/apache/samza/operators/StreamGraph.html#getInputStream-java.lang.String-java.util.function.BiFunction-"><code>StreamGraph.getInputStream(java.lang.String, java.util.function.BiFunction<? super K, ? super V, ? extends M>)</code></a>.</div>
+ A <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> corresponding to an input stream can be obtained using <a href="../../../../org/apache/samza/operators/StreamGraph.html#getInputStream-java.lang.String-org.apache.samza.serializers.Serde-"><code>StreamGraph.getInputStream(java.lang.String, org.apache.samza.serializers.Serde<M>)</code></a>.</div>
</li>
</ul>
</div>
@@ -142,55 +142,85 @@ public interface <span class="typeNameLa
</td>
</tr>
<tr id="i2" class="altColor">
-<td class="colFirst"><code><K,JM,OM> <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators">MessageStream</a><OM></code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/operators/MessageStream.html#join-org.apache.samza.operators.MessageStream-org.apache.samza.operators.functions.JoinFunction-java.time.Duration-">join</a></span>(<a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators">MessageStream</a><JM> otherStream,
- <a href="../../../../org/apache/samza/operators/functions/JoinFunction.html" title="interface in org.apache.samza.operators.functions">JoinFunction</a><? extends K,? super <a href="../../../../org/apache/samza/operators/MessageStream.html" title="type parameter in MessageStream">M</a>,? super JM,? extends OM> joinFn,
- java.time.Duration ttl)</code>
+<td class="colFirst"><code><K,OM,JM> <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators">MessageStream</a><JM></code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/operators/MessageStream.html#join-org.apache.samza.operators.MessageStream-org.apache.samza.operators.functions.JoinFunction-org.apache.samza.serializers.Serde-org.apache.samza.serializers.Serde-org.apache.samza.serializers.Serde-java.time.Duration-java.lang.String-">join</a></span>(<a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators">MessageStream</a><OM> otherStream,
+ <a href="../../../../org/apache/samza/operators/functions/JoinFunction.html" title="interface in org.apache.samza.operators.functions">JoinFunction</a><? extends K,? super <a href="../../../../org/apache/samza/operators/MessageStream.html" title="type parameter in MessageStream">M</a>,? super OM,? extends JM> joinFn,
+ <a href="../../../../org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><K> keySerde,
+ <a href="../../../../org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><<a href="../../../../org/apache/samza/operators/MessageStream.html" title="type parameter in MessageStream">M</a>> messageSerde,
+ <a href="../../../../org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><OM> otherMessageSerde,
+ java.time.Duration ttl,
+ java.lang.String id)</code>
<div class="block">Joins this <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> with another <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> using the provided
pairwise <a href="../../../../org/apache/samza/operators/functions/JoinFunction.html" title="interface in org.apache.samza.operators.functions"><code>JoinFunction</code></a>.</div>
</td>
</tr>
<tr id="i3" class="rowColor">
+<td class="colFirst"><code><K,R extends <a href="../../../../org/apache/samza/operators/KV.html" title="class in org.apache.samza.operators">KV</a>,JM><br><a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators">MessageStream</a><JM></code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/operators/MessageStream.html#join-org.apache.samza.table.Table-org.apache.samza.operators.functions.StreamTableJoinFunction-">join</a></span>(<a href="../../../../org/apache/samza/table/Table.html" title="interface in org.apache.samza.table">Table</a><R> table,
+ <a href="../../../../org/apache/samza/operators/functions/StreamTableJoinFunction.html" title="interface in org.apache.samza.operators.functions">StreamTableJoinFunction</a><? extends K,? super <a href="../../../../org/apache/samza/operators/MessageStream.html" title="type parameter in MessageStream">M</a>,? super R,? extends JM> joinFn)</code>
+<div class="block">Joins this <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> with another <a href="../../../../org/apache/samza/table/Table.html" title="interface in org.apache.samza.table"><code>Table</code></a> using the provided
+ pairwise <a href="../../../../org/apache/samza/operators/functions/StreamTableJoinFunction.html" title="interface in org.apache.samza.operators.functions"><code>StreamTableJoinFunction</code></a>.</div>
+</td>
+</tr>
+<tr id="i4" class="altColor">
<td class="colFirst"><code><OM> <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators">MessageStream</a><OM></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/operators/MessageStream.html#map-org.apache.samza.operators.functions.MapFunction-">map</a></span>(<a href="../../../../org/apache/samza/operators/functions/MapFunction.html" title="interface in org.apache.samza.operators.functions">MapFunction</a><? super <a href="../../../../org/apache/samza/operators/MessageStream.html" title="type parameter in MessageStream">M</a>,? extends OM> mapFn)</code>
<div class="block">Applies the provided 1:1 function to messages in this <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> and returns the
transformed <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a>.</div>
</td>
</tr>
-<tr id="i4" class="altColor">
+<tr id="i5" class="rowColor">
<td class="colFirst"><code><a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators">MessageStream</a><<a href="../../../../org/apache/samza/operators/MessageStream.html" title="type parameter in MessageStream">M</a>></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/operators/MessageStream.html#merge-java.util.Collection-">merge</a></span>(java.util.Collection<? extends <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators">MessageStream</a><? extends <a href="../../../../org/apache/samza/operators/MessageStream.html" title="type parameter in MessageStream">M</a>>> otherStreams)</code>
<div class="block">Merges all <code>otherStreams</code> with this <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a>.</div>
</td>
</tr>
-<tr id="i5" class="rowColor">
+<tr id="i6" class="altColor">
<td class="colFirst"><code>static <T> <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators">MessageStream</a><T></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/operators/MessageStream.html#mergeAll-java.util.Collection-">mergeAll</a></span>(java.util.Collection<? extends <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators">MessageStream</a><? extends T>> streams)</code>
<div class="block">Merges all <code>streams</code>.</div>
</td>
</tr>
-<tr id="i6" class="altColor">
-<td class="colFirst"><code><K> <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators">MessageStream</a><<a href="../../../../org/apache/samza/operators/MessageStream.html" title="type parameter in MessageStream">M</a>></code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/operators/MessageStream.html#partitionBy-java.util.function.Function-">partitionBy</a></span>(java.util.function.Function<? super <a href="../../../../org/apache/samza/operators/MessageStream.html" title="type parameter in MessageStream">M</a>,? extends K> keyExtractor)</code>
+<tr id="i7" class="rowColor">
+<td class="colFirst"><code><K,V> <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators">MessageStream</a><<a href="../../../../org/apache/samza/operators/KV.html" title="class in org.apache.samza.operators">KV</a><K,V>></code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/operators/MessageStream.html#partitionBy-java.util.function.Function-java.util.function.Function-org.apache.samza.serializers.KVSerde-java.lang.String-">partitionBy</a></span>(java.util.function.Function<? super <a href="../../../../org/apache/samza/operators/MessageStream.html" title="type parameter in MessageStream">M</a>,? extends K> keyExtractor,
+ java.util.function.Function<? super <a href="../../../../org/apache/samza/operators/MessageStream.html" title="type parameter in MessageStream">M</a>,? extends V> valueExtractor,
+ <a href="../../../../org/apache/samza/serializers/KVSerde.html" title="class in org.apache.samza.serializers">KVSerde</a><K,V> serde,
+ java.lang.String id)</code>
<div class="block">Re-partitions this <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> using keys from the <code>keyExtractor</code> by creating a new
intermediate stream on the <code>job.default.system</code>.</div>
</td>
</tr>
-<tr id="i7" class="rowColor">
-<td class="colFirst"><code><K,V> void</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/operators/MessageStream.html#sendTo-org.apache.samza.operators.OutputStream-">sendTo</a></span>(<a href="../../../../org/apache/samza/operators/OutputStream.html" title="interface in org.apache.samza.operators">OutputStream</a><K,V,<a href="../../../../org/apache/samza/operators/MessageStream.html" title="type parameter in MessageStream">M</a>> outputStream)</code>
+<tr id="i8" class="altColor">
+<td class="colFirst"><code><K,V> <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators">MessageStream</a><<a href="../../../../org/apache/samza/operators/KV.html" title="class in org.apache.samza.operators">KV</a><K,V>></code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/operators/MessageStream.html#partitionBy-java.util.function.Function-java.util.function.Function-java.lang.String-">partitionBy</a></span>(java.util.function.Function<? super <a href="../../../../org/apache/samza/operators/MessageStream.html" title="type parameter in MessageStream">M</a>,? extends K> keyExtractor,
+ java.util.function.Function<? super <a href="../../../../org/apache/samza/operators/MessageStream.html" title="type parameter in MessageStream">M</a>,? extends V> valueExtractor,
+ java.lang.String id)</code>
+<div class="block">Same as calling <a href="../../../../org/apache/samza/operators/MessageStream.html#partitionBy-java.util.function.Function-java.util.function.Function-org.apache.samza.serializers.KVSerde-java.lang.String-"><code>partitionBy(Function, Function, KVSerde, String)</code></a> with a null KVSerde.</div>
+</td>
+</tr>
+<tr id="i9" class="rowColor">
+<td class="colFirst"><code>void</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/operators/MessageStream.html#sendTo-org.apache.samza.operators.OutputStream-">sendTo</a></span>(<a href="../../../../org/apache/samza/operators/OutputStream.html" title="interface in org.apache.samza.operators">OutputStream</a><<a href="../../../../org/apache/samza/operators/MessageStream.html" title="type parameter in MessageStream">M</a>> outputStream)</code>
<div class="block">Allows sending messages in this <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> to an <a href="../../../../org/apache/samza/operators/OutputStream.html" title="interface in org.apache.samza.operators"><code>OutputStream</code></a>.</div>
</td>
</tr>
-<tr id="i8" class="altColor">
+<tr id="i10" class="altColor">
+<td class="colFirst"><code><K,V> void</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/operators/MessageStream.html#sendTo-org.apache.samza.table.Table-">sendTo</a></span>(<a href="../../../../org/apache/samza/table/Table.html" title="interface in org.apache.samza.table">Table</a><<a href="../../../../org/apache/samza/operators/KV.html" title="class in org.apache.samza.operators">KV</a><K,V>> table)</code>
+<div class="block">Sends messages in this <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> to a <a href="../../../../org/apache/samza/table/Table.html" title="interface in org.apache.samza.table"><code>Table</code></a>.</div>
+</td>
+</tr>
+<tr id="i11" class="rowColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/operators/MessageStream.html#sink-org.apache.samza.operators.functions.SinkFunction-">sink</a></span>(<a href="../../../../org/apache/samza/operators/functions/SinkFunction.html" title="interface in org.apache.samza.operators.functions">SinkFunction</a><? super <a href="../../../../org/apache/samza/operators/MessageStream.html" title="type parameter in MessageStream">M</a>> sinkFn)</code>
<div class="block">Allows sending messages in this <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> to an output system using the provided <a href="../../../../org/apache/samza/operators/functions/SinkFunction.html" title="interface in org.apache.samza.operators.functions"><code>SinkFunction</code></a>.</div>
</td>
</tr>
-<tr id="i9" class="rowColor">
+<tr id="i12" class="altColor">
<td class="colFirst"><code><K,WV> <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators">MessageStream</a><<a href="../../../../org/apache/samza/operators/windows/WindowPane.html" title="class in org.apache.samza.operators.windows">WindowPane</a><K,WV>></code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/operators/MessageStream.html#window-org.apache.samza.operators.windows.Window-">window</a></span>(<a href="../../../../org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows">Window</a><<a href="../../../../org/apache/samza/operators/MessageStream.html" title="type parameter in MessageStream">M</a>,K,WV> window)</code>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/operators/MessageStream.html#window-org.apache.samza.operators.windows.Window-java.lang.String-">window</a></span>(<a href="../../../../org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows">Window</a><<a href="../../../../org/apache/samza/operators/MessageStream.html" title="type parameter in MessageStream">M</a>,K,WV> window,
+ java.lang.String id)</code>
<div class="block">Groups the messages in this <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> according to the provided <a href="../../../../org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows"><code>Window</code></a> semantics
(e.g.</div>
</td>
@@ -258,13 +288,13 @@ public interface <span class="typeNameLa
<div class="block">Applies the provided function to messages in this <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> and returns the
filtered <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a>.
<p>
- The <code>Function</code> is a predicate which determines whether a message in this <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a>
+ The <a href="../../../../org/apache/samza/operators/functions/FilterFunction.html" title="interface in org.apache.samza.operators.functions"><code>FilterFunction</code></a> is a predicate which determines whether a message in this <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a>
should be retained in the filtered <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a>.</div>
<dl>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>filterFn</code> - the predicate to filter messages from this <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a>.</dd>
<dt><span class="returnLabel">Returns:</span></dt>
-<dd>the transformed <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a></dd>
+<dd>the filtered <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a></dd>
</dl>
</li>
</ul>
@@ -295,31 +325,35 @@ public interface <span class="typeNameLa
<ul class="blockList">
<li class="blockList">
<h4>sendTo</h4>
-<pre><K,V> void sendTo(<a href="../../../../org/apache/samza/operators/OutputStream.html" title="interface in org.apache.samza.operators">OutputStream</a><K,V,<a href="../../../../org/apache/samza/operators/MessageStream.html" title="type parameter in MessageStream">M</a>> outputStream)</pre>
-<div class="block">Allows sending messages in this <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> to an <a href="../../../../org/apache/samza/operators/OutputStream.html" title="interface in org.apache.samza.operators"><code>OutputStream</code></a>.</div>
+<pre>void sendTo(<a href="../../../../org/apache/samza/operators/OutputStream.html" title="interface in org.apache.samza.operators">OutputStream</a><<a href="../../../../org/apache/samza/operators/MessageStream.html" title="type parameter in MessageStream">M</a>> outputStream)</pre>
+<div class="block">Allows sending messages in this <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> to an <a href="../../../../org/apache/samza/operators/OutputStream.html" title="interface in org.apache.samza.operators"><code>OutputStream</code></a>.
+ <p>
+ When sending messages to an <code>OutputStream<KV<K, V>></code>, messages are partitioned using their serialized key.
+ When sending messages to any other <code>OutputStream<M></code>, messages are partitioned using a null partition key.</div>
<dl>
-<dt><span class="paramLabel">Type Parameters:</span></dt>
-<dd><code>K</code> - the type of key in the outgoing message</dd>
-<dd><code>V</code> - the type of message in the outgoing message</dd>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>outputStream</code> - the output stream to send messages to</dd>
</dl>
</li>
</ul>
-<a name="window-org.apache.samza.operators.windows.Window-">
+<a name="window-org.apache.samza.operators.windows.Window-java.lang.String-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>window</h4>
-<pre><K,WV> <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators">MessageStream</a><<a href="../../../../org/apache/samza/operators/windows/WindowPane.html" title="class in org.apache.samza.operators.windows">WindowPane</a><K,WV>> window(<a href="../../../../org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows">Window</a><<a href="../../../../org/apache/samza/operators/MessageStream.html" title="type parameter in MessageStream">M</a>,K,WV> window)</pre>
+<pre><K,WV> <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators">MessageStream</a><<a href="../../../../org/apache/samza/operators/windows/WindowPane.html" title="class in org.apache.samza.operators.windows">WindowPane</a><K,WV>> window(<a href="../../../../org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows">Window</a><<a href="../../../../org/apache/samza/operators/MessageStream.html" title="type parameter in MessageStream">M</a>,K,WV> window,
+ java.lang.String id)</pre>
<div class="block">Groups the messages in this <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> according to the provided <a href="../../../../org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows"><code>Window</code></a> semantics
(e.g. tumbling, sliding or session windows) and returns the transformed <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> of
<a href="../../../../org/apache/samza/operators/windows/WindowPane.html" title="class in org.apache.samza.operators.windows"><code>WindowPane</code></a>s.
<p>
Use the <a href="../../../../org/apache/samza/operators/windows/Windows.html" title="class in org.apache.samza.operators.windows"><code>Windows</code></a> helper methods to create the appropriate windows.
<p>
- <b>Warning:</b> As of version 0.13.0, messages in windows are kept in memory and will be lost during restarts.</div>
+ The <code>id</code> must be unique for each operator in this application. It is used as part of the unique ID
+ for any state stores and streams created by this operator (the full ID also contains the job name, job id and
+ operator type). If the application logic is changed, this ID must be reused in the new operator to retain
+ state from the previous version, and changed for the new operator to discard the state from the previous version.</div>
<dl>
<dt><span class="paramLabel">Type Parameters:</span></dt>
<dd><code>K</code> - the type of key in the message in this <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a>. If a key is specified,
@@ -327,20 +361,25 @@ public interface <span class="typeNameLa
<dd><code>WV</code> - the type of value in the <a href="../../../../org/apache/samza/operators/windows/WindowPane.html" title="class in org.apache.samza.operators.windows"><code>WindowPane</code></a> in the transformed <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a></dd>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>window</code> - the window to group and process messages from this <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a></dd>
+<dd><code>id</code> - the unique id of this operator in this application</dd>
<dt><span class="returnLabel">Returns:</span></dt>
-<dd>the transformed <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a></dd>
+<dd>the windowed <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a></dd>
</dl>
</li>
</ul>
-<a name="join-org.apache.samza.operators.MessageStream-org.apache.samza.operators.functions.JoinFunction-java.time.Duration-">
+<a name="join-org.apache.samza.operators.MessageStream-org.apache.samza.operators.functions.JoinFunction-org.apache.samza.serializers.Serde-org.apache.samza.serializers.Serde-org.apache.samza.serializers.Serde-java.time.Duration-java.lang.String-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>join</h4>
-<pre><K,JM,OM> <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators">MessageStream</a><OM> join(<a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators">MessageStream</a><JM> otherStream,
- <a href="../../../../org/apache/samza/operators/functions/JoinFunction.html" title="interface in org.apache.samza.operators.functions">JoinFunction</a><? extends K,? super <a href="../../../../org/apache/samza/operators/MessageStream.html" title="type parameter in MessageStream">M</a>,? super JM,? extends OM> joinFn,
- java.time.Duration ttl)</pre>
+<pre><K,OM,JM> <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators">MessageStream</a><JM> join(<a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators">MessageStream</a><OM> otherStream,
+ <a href="../../../../org/apache/samza/operators/functions/JoinFunction.html" title="interface in org.apache.samza.operators.functions">JoinFunction</a><? extends K,? super <a href="../../../../org/apache/samza/operators/MessageStream.html" title="type parameter in MessageStream">M</a>,? super OM,? extends JM> joinFn,
+ <a href="../../../../org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><K> keySerde,
+ <a href="../../../../org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><<a href="../../../../org/apache/samza/operators/MessageStream.html" title="type parameter in MessageStream">M</a>> messageSerde,
+ <a href="../../../../org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><OM> otherMessageSerde,
+ java.time.Duration ttl,
+ java.lang.String id)</pre>
<div class="block">Joins this <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> with another <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> using the provided
pairwise <a href="../../../../org/apache/samza/operators/functions/JoinFunction.html" title="interface in org.apache.samza.operators.functions"><code>JoinFunction</code></a>.
<p>
@@ -349,16 +388,60 @@ public interface <span class="typeNameLa
<p>
Both inputs being joined must have the same number of partitions, and should be partitioned by the join key.
<p>
- <b>Warning:</b> As of version 0.13.0, messages in joins are kept in memory and will be lost during restarts.</div>
+ The <code>id</code> must be unique for each operator in this application. It is used as part of the unique ID
+ for any state stores and streams created by this operator (the full ID also contains the job name, job id and
+ operator type). If the application logic is changed, this ID must be reused in the new operator to retain
+ state from the previous version, and changed for the new operator to discard the state from the previous version.</div>
<dl>
<dt><span class="paramLabel">Type Parameters:</span></dt>
<dd><code>K</code> - the type of join key</dd>
-<dd><code>JM</code> - the type of messages in the other stream</dd>
-<dd><code>OM</code> - the type of messages resulting from the <code>joinFn</code></dd>
+<dd><code>OM</code> - the type of messages in the other stream</dd>
+<dd><code>JM</code> - the type of messages resulting from the <code>joinFn</code></dd>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>otherStream</code> - the other <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> to be joined with</dd>
<dd><code>joinFn</code> - the function to join messages from this and the other <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a></dd>
+<dd><code>keySerde</code> - the serde for the join key</dd>
+<dd><code>messageSerde</code> - the serde for messages in this stream</dd>
+<dd><code>otherMessageSerde</code> - the serde for messages in the other stream</dd>
<dd><code>ttl</code> - the ttl for messages in each stream</dd>
+<dd><code>id</code> - the unique id of this operator in this application</dd>
+<dt><span class="returnLabel">Returns:</span></dt>
+<dd>the joined <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a></dd>
+</dl>
+</li>
+</ul>
+<a name="join-org.apache.samza.table.Table-org.apache.samza.operators.functions.StreamTableJoinFunction-">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>join</h4>
+<pre><K,R extends <a href="../../../../org/apache/samza/operators/KV.html" title="class in org.apache.samza.operators">KV</a>,JM> <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators">MessageStream</a><JM> join(<a href="../../../../org/apache/samza/table/Table.html" title="interface in org.apache.samza.table">Table</a><R> table,
+ <a href="../../../../org/apache/samza/operators/functions/StreamTableJoinFunction.html" title="interface in org.apache.samza.operators.functions">StreamTableJoinFunction</a><? extends K,? super <a href="../../../../org/apache/samza/operators/MessageStream.html" title="type parameter in MessageStream">M</a>,? super R,? extends JM> joinFn)</pre>
+<div class="block">Joins this <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> with another <a href="../../../../org/apache/samza/table/Table.html" title="interface in org.apache.samza.table"><code>Table</code></a> using the provided
+ pairwise <a href="../../../../org/apache/samza/operators/functions/StreamTableJoinFunction.html" title="interface in org.apache.samza.operators.functions"><code>StreamTableJoinFunction</code></a>.
+ <p>
+ The type of input message is expected to be <a href="../../../../org/apache/samza/operators/KV.html" title="class in org.apache.samza.operators"><code>KV</code></a>.
+ <p>
+ Records are looked up from the joined table using the join key, join function
+ is applied and join results are emitted as matches are found.
+ <p>
+ The join function allows implementation of both inner and left outer join. A null will be
+ passed to the join function, if no record matching the join key is found in the table.
+ The join function can choose to return an instance of JM (outer left join) or null
+ (inner join); if null is returned, it won't be processed further.
+ <p>
+ Both the input stream and table being joined must have the same number of partitions,
+ and should be partitioned by the same join key.
+ <p></div>
+<dl>
+<dt><span class="paramLabel">Type Parameters:</span></dt>
+<dd><code>K</code> - the type of join key</dd>
+<dd><code>R</code> - the type of table record</dd>
+<dd><code>JM</code> - the type of messages resulting from the <code>joinFn</code></dd>
+<dt><span class="paramLabel">Parameters:</span></dt>
+<dd><code>table</code> - the table being joined</dd>
+<dd><code>joinFn</code> - the join function</dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>the joined <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a></dd>
</dl>
@@ -404,38 +487,99 @@ public interface <span class="typeNameLa
</dl>
</li>
</ul>
-<a name="partitionBy-java.util.function.Function-">
+<a name="partitionBy-java.util.function.Function-java.util.function.Function-org.apache.samza.serializers.KVSerde-java.lang.String-">
<!-- -->
</a>
-<ul class="blockListLast">
+<ul class="blockList">
<li class="blockList">
<h4>partitionBy</h4>
-<pre><K> <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators">MessageStream</a><<a href="../../../../org/apache/samza/operators/MessageStream.html" title="type parameter in MessageStream">M</a>> partitionBy(java.util.function.Function<? super <a href="../../../../org/apache/samza/operators/MessageStream.html" title="type parameter in MessageStream">M</a>,? extends K> keyExtractor)</pre>
+<pre><K,V> <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators">MessageStream</a><<a href="../../../../org/apache/samza/operators/KV.html" title="class in org.apache.samza.operators">KV</a><K,V>> partitionBy(java.util.function.Function<? super <a href="../../../../org/apache/samza/operators/MessageStream.html" title="type parameter in MessageStream">M</a>,? extends K> keyExtractor,
+ java.util.function.Function<? super <a href="../../../../org/apache/samza/operators/MessageStream.html" title="type parameter in MessageStream">M</a>,? extends V> valueExtractor,
+ <a href="../../../../org/apache/samza/serializers/KVSerde.html" title="class in org.apache.samza.serializers">KVSerde</a><K,V> serde,
+ java.lang.String id)</pre>
<div class="block">Re-partitions this <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> using keys from the <code>keyExtractor</code> by creating a new
intermediate stream on the <code>job.default.system</code>. This intermediate stream is both an output and
input to the job.
<p>
- The key and message Serdes configured for the default system must be able to serialize and deserialize
- types K and M respectively.
+ Uses the provided <a href="../../../../org/apache/samza/serializers/KVSerde.html" title="class in org.apache.samza.serializers"><code>KVSerde</code></a> for serialization of keys and values. If the provided <code>serde</code> is null,
+ uses the default serde provided via <a href="../../../../org/apache/samza/operators/StreamGraph.html#setDefaultSerde-org.apache.samza.serializers.Serde-"><code>StreamGraph.setDefaultSerde(org.apache.samza.serializers.Serde<?>)</code></a>, which must be a KVSerde. If the default
+ serde is not a <a href="../../../../org/apache/samza/serializers/KVSerde.html" title="class in org.apache.samza.serializers"><code>KVSerde</code></a>, a runtime exception will be thrown. If no default serde has been provided
+ <b>before</b> calling this method, a <code>KVSerde<NoOpSerde, NoOpSerde></code> is used.
<p>
The number of partitions for this intermediate stream is determined as follows:
- If the stream is an eventual input to a <a href="../../../../org/apache/samza/operators/MessageStream.html#join-org.apache.samza.operators.MessageStream-org.apache.samza.operators.functions.JoinFunction-java.time.Duration-"><code>join(org.apache.samza.operators.MessageStream<JM>, org.apache.samza.operators.functions.JoinFunction<? extends K, ? super M, ? super JM, ? extends OM>, java.time.Duration)</code></a>, and the number of partitions for the other stream is known,
+ If the stream is an eventual input to a <a href="../../../../org/apache/samza/operators/MessageStream.html#join-org.apache.samza.operators.MessageStream-org.apache.samza.operators.functions.JoinFunction-org.apache.samza.serializers.Serde-org.apache.samza.serializers.Serde-org.apache.samza.serializers.Serde-java.time.Duration-java.lang.String-"><code>join(org.apache.samza.operators.MessageStream<OM>, org.apache.samza.operators.functions.JoinFunction<? extends K, ? super M, ? super OM, ? extends JM>, org.apache.samza.serializers.Serde<K>, org.apache.samza.serializers.Serde<M>, org.apache.samza.serializers.Serde<OM>, java.time.Duration, java.lang.String)</code></a>, and the number of partitions for the other stream is known,
then number of partitions for this stream is set to the number of partitions in the other input stream.
Else, the number of partitions is set to the value of the <code>job.intermediate.stream.partitions</code>
configuration, if present.
Else, the number of partitions is set to to the max of number of partitions for all input and output streams
- (excluding intermediate streams).</div>
+ (excluding intermediate streams).
+ <p>
+ The <code>id</code> must be unique for each operator in this application. It is used as part of the unique ID
+ for any state stores and streams created by this operator (the full ID also contains the job name, job id and
+ operator type). If the application logic is changed, this ID must be reused in the new operator to retain
+ state from the previous version, and changed for the new operator to discard the state from the previous version.
+ <p>
+ Unlike <a href="../../../../org/apache/samza/operators/MessageStream.html#sendTo-org.apache.samza.operators.OutputStream-"><code>sendTo(org.apache.samza.operators.OutputStream<M>)</code></a>, messages with a null key are all sent to partition 0.</div>
+<dl>
+<dt><span class="paramLabel">Type Parameters:</span></dt>
+<dd><code>K</code> - the type of output key</dd>
+<dd><code>V</code> - the type of output value</dd>
+<dt><span class="paramLabel">Parameters:</span></dt>
+<dd><code>keyExtractor</code> - the <code>Function</code> to extract the message and partition key from the input message.
+ Messages with a null key are all sent to partition 0.</dd>
+<dd><code>valueExtractor</code> - the <code>Function</code> to extract the value from the input message</dd>
+<dd><code>serde</code> - the <a href="../../../../org/apache/samza/serializers/KVSerde.html" title="class in org.apache.samza.serializers"><code>KVSerde</code></a> to use for (de)serializing the key and value.</dd>
+<dd><code>id</code> - the unique id of this operator in this application</dd>
+<dt><span class="returnLabel">Returns:</span></dt>
+<dd>the repartitioned <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a></dd>
+</dl>
+</li>
+</ul>
+<a name="partitionBy-java.util.function.Function-java.util.function.Function-java.lang.String-">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>partitionBy</h4>
+<pre><K,V> <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators">MessageStream</a><<a href="../../../../org/apache/samza/operators/KV.html" title="class in org.apache.samza.operators">KV</a><K,V>> partitionBy(java.util.function.Function<? super <a href="../../../../org/apache/samza/operators/MessageStream.html" title="type parameter in MessageStream">M</a>,? extends K> keyExtractor,
+ java.util.function.Function<? super <a href="../../../../org/apache/samza/operators/MessageStream.html" title="type parameter in MessageStream">M</a>,? extends V> valueExtractor,
+ java.lang.String id)</pre>
+<div class="block">Same as calling <a href="../../../../org/apache/samza/operators/MessageStream.html#partitionBy-java.util.function.Function-java.util.function.Function-org.apache.samza.serializers.KVSerde-java.lang.String-"><code>partitionBy(Function, Function, KVSerde, String)</code></a> with a null KVSerde.
+ <p>
+ Uses the default serde provided via <a href="../../../../org/apache/samza/operators/StreamGraph.html#setDefaultSerde-org.apache.samza.serializers.Serde-"><code>StreamGraph.setDefaultSerde(org.apache.samza.serializers.Serde<?>)</code></a>, which must be a KVSerde. If the default
+ serde is not a <a href="../../../../org/apache/samza/serializers/KVSerde.html" title="class in org.apache.samza.serializers"><code>KVSerde</code></a>, a runtime exception will be thrown. If no default serde has been provided
+ <b>before</b> calling this method, a <code>KVSerde<NoOpSerde, NoOpSerde></code> is used.</div>
<dl>
<dt><span class="paramLabel">Type Parameters:</span></dt>
-<dd><code>K</code> - the type of output message key and partition key</dd>
+<dd><code>K</code> - the type of output key</dd>
+<dd><code>V</code> - the type of output value</dd>
<dt><span class="paramLabel">Parameters:</span></dt>
-<dd><code>keyExtractor</code> - the <code>Function</code> to extract the output message key and partition key from
- the input message</dd>
+<dd><code>keyExtractor</code> - the <code>Function</code> to extract the message and partition key from the input message</dd>
+<dd><code>valueExtractor</code> - the <code>Function</code> to extract the value from the input message</dd>
+<dd><code>id</code> - the unique id of this operator in this application</dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>the repartitioned <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a></dd>
</dl>
</li>
</ul>
+<a name="sendTo-org.apache.samza.table.Table-">
+<!-- -->
+</a>
+<ul class="blockListLast">
+<li class="blockList">
+<h4>sendTo</h4>
+<pre><K,V> void sendTo(<a href="../../../../org/apache/samza/table/Table.html" title="interface in org.apache.samza.table">Table</a><<a href="../../../../org/apache/samza/operators/KV.html" title="class in org.apache.samza.operators">KV</a><K,V>> table)</pre>
+<div class="block">Sends messages in this <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> to a <a href="../../../../org/apache/samza/table/Table.html" title="interface in org.apache.samza.table"><code>Table</code></a>. The type of input message is expected
+ to be <a href="../../../../org/apache/samza/operators/KV.html" title="class in org.apache.samza.operators"><code>KV</code></a>, otherwise a <code>ClassCastException</code> will be thrown.</div>
+<dl>
+<dt><span class="paramLabel">Type Parameters:</span></dt>
+<dd><code>K</code> - the type of key in the table</dd>
+<dd><code>V</code> - the type of record value in the table</dd>
+<dt><span class="paramLabel">Parameters:</span></dt>
+<dd><code>table</code> - the table to write messages to</dd>
+</dl>
+</li>
+</ul>
</li>
</ul>
</li>
@@ -463,7 +607,7 @@ public interface <span class="typeNameLa
</div>
<div class="subNav">
<ul class="navList">
-<li><a href="../../../../org/apache/samza/operators/ContextManager.html" title="interface in org.apache.samza.operators"><span class="typeNameLink">Prev Class</span></a></li>
+<li><a href="../../../../org/apache/samza/operators/KV.html" title="class in org.apache.samza.operators"><span class="typeNameLink">Prev Class</span></a></li>
<li><a href="../../../../org/apache/samza/operators/OutputStream.html" title="interface in org.apache.samza.operators"><span class="typeNameLink">Next Class</span></a></li>
</ul>
<ul class="navList">