Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/TaskCoordinator.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/TaskCoordinator.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/TaskCoordinator.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/TaskCoordinator.html Wed Dec 11 00:28:27 2019 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Mon Dec 09 10:28:22 PST 2019 --> -<title>TaskCoordinator (samza-api 1.3.0 API)</title> -<meta name="date" content="2019-12-09"> +<!-- Generated by javadoc (1.8.0_212) on Tue Dec 10 16:24:08 PST 2019 --> +<title>TaskCoordinator (samza-api 1.4.0-SNAPSHOT API)</title> +<meta name="date" content="2019-12-10"> <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="TaskCoordinator (samza-api 1.3.0 API)"; + parent.document.title="TaskCoordinator (samza-api 1.4.0-SNAPSHOT API)"; } } catch(err) {
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/TaskFactory.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/TaskFactory.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/TaskFactory.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/TaskFactory.html Wed Dec 11 00:28:27 2019 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Mon Dec 09 10:28:22 PST 2019 --> -<title>TaskFactory (samza-api 1.3.0 API)</title> -<meta name="date" content="2019-12-09"> +<!-- Generated by javadoc (1.8.0_212) on Tue Dec 10 16:24:08 PST 2019 --> +<title>TaskFactory (samza-api 1.4.0-SNAPSHOT API)</title> +<meta name="date" content="2019-12-10"> <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="TaskFactory (samza-api 1.3.0 API)"; + parent.document.title="TaskFactory (samza-api 1.4.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/WindowableTask.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/WindowableTask.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/WindowableTask.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/WindowableTask.html Wed Dec 11 00:28:27 2019 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Mon Dec 09 10:28:22 PST 2019 --> -<title>WindowableTask (samza-api 1.3.0 API)</title> -<meta name="date" content="2019-12-09"> +<!-- Generated by javadoc (1.8.0_212) on Tue Dec 10 16:24:08 PST 2019 --> +<title>WindowableTask (samza-api 1.4.0-SNAPSHOT API)</title> +<meta name="date" content="2019-12-10"> <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="WindowableTask (samza-api 1.3.0 API)"; + parent.document.title="WindowableTask (samza-api 1.4.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/package-frame.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/package-frame.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/package-frame.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/package-frame.html Wed Dec 11 00:28:27 2019 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Mon Dec 09 10:28:22 PST 2019 --> -<title>org.apache.samza.task (samza-api 1.3.0 API)</title> -<meta name="date" content="2019-12-09"> +<!-- Generated by javadoc (1.8.0_212) on Tue Dec 10 16:24:09 PST 2019 --> +<title>org.apache.samza.task (samza-api 1.4.0-SNAPSHOT API)</title> +<meta name="date" content="2019-12-10"> <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/task/package-summary.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/package-summary.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/package-summary.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/package-summary.html Wed Dec 11 00:28:27 2019 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Mon Dec 09 10:28:22 PST 2019 --> -<title>org.apache.samza.task (samza-api 1.3.0 API)</title> -<meta name="date" content="2019-12-09"> +<!-- Generated by javadoc (1.8.0_212) on Tue Dec 10 16:24:09 PST 2019 --> +<title>org.apache.samza.task (samza-api 1.4.0-SNAPSHOT API)</title> +<meta name="date" content="2019-12-10"> <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.task (samza-api 1.3.0 API)"; + parent.document.title="org.apache.samza.task (samza-api 1.4.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/package-tree.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/package-tree.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/package-tree.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/package-tree.html Wed Dec 11 00:28:27 2019 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Mon Dec 09 10:28:22 PST 2019 --> -<title>org.apache.samza.task Class Hierarchy (samza-api 1.3.0 API)</title> -<meta name="date" content="2019-12-09"> +<!-- Generated by javadoc (1.8.0_212) on Tue Dec 10 16:24:09 PST 2019 --> +<title>org.apache.samza.task Class Hierarchy (samza-api 1.4.0-SNAPSHOT API)</title> +<meta name="date" content="2019-12-10"> <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.task Class Hierarchy (samza-api 1.3.0 API)"; + parent.document.title="org.apache.samza.task Class Hierarchy (samza-api 1.4.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/BlockingEnvelopeMap.BlockingEnvelopeMapMetrics.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/BlockingEnvelopeMap.BlockingEnvelopeMapMetrics.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/BlockingEnvelopeMap.BlockingEnvelopeMapMetrics.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/BlockingEnvelopeMap.BlockingEnvelopeMapMetrics.html Wed Dec 11 00:28:27 2019 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Mon Dec 09 10:28:22 PST 2019 --> -<title>BlockingEnvelopeMap.BlockingEnvelopeMapMetrics (samza-api 1.3.0 API)</title> -<meta name="date" content="2019-12-09"> +<!-- Generated by javadoc (1.8.0_212) on Tue Dec 10 16:24:08 PST 2019 --> +<title>BlockingEnvelopeMap.BlockingEnvelopeMapMetrics (samza-api 1.4.0-SNAPSHOT API)</title> +<meta name="date" content="2019-12-10"> <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="BlockingEnvelopeMap.BlockingEnvelopeMapMetrics (samza-api 1.3.0 API)"; + parent.document.title="BlockingEnvelopeMap.BlockingEnvelopeMapMetrics (samza-api 1.4.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/BlockingEnvelopeMap.BufferGauge.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/BlockingEnvelopeMap.BufferGauge.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/BlockingEnvelopeMap.BufferGauge.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/BlockingEnvelopeMap.BufferGauge.html Wed Dec 11 00:28:27 2019 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Mon Dec 09 10:28:22 PST 2019 --> -<title>BlockingEnvelopeMap.BufferGauge (samza-api 1.3.0 API)</title> -<meta name="date" content="2019-12-09"> +<!-- Generated by javadoc (1.8.0_212) on Tue Dec 10 16:24:08 PST 2019 --> +<title>BlockingEnvelopeMap.BufferGauge (samza-api 1.4.0-SNAPSHOT API)</title> +<meta name="date" content="2019-12-10"> <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="BlockingEnvelopeMap.BufferGauge (samza-api 1.3.0 API)"; + parent.document.title="BlockingEnvelopeMap.BufferGauge (samza-api 1.4.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/BlockingEnvelopeMap.BufferSizeGauge.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/BlockingEnvelopeMap.BufferSizeGauge.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/BlockingEnvelopeMap.BufferSizeGauge.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/BlockingEnvelopeMap.BufferSizeGauge.html Wed Dec 11 00:28:27 2019 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Mon Dec 09 10:28:22 PST 2019 --> -<title>BlockingEnvelopeMap.BufferSizeGauge (samza-api 1.3.0 API)</title> -<meta name="date" content="2019-12-09"> +<!-- Generated by javadoc (1.8.0_212) on Tue Dec 10 16:24:08 PST 2019 --> +<title>BlockingEnvelopeMap.BufferSizeGauge (samza-api 1.4.0-SNAPSHOT API)</title> +<meta name="date" content="2019-12-10"> <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="BlockingEnvelopeMap.BufferSizeGauge (samza-api 1.3.0 API)"; + parent.document.title="BlockingEnvelopeMap.BufferSizeGauge (samza-api 1.4.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/BlockingEnvelopeMap.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/BlockingEnvelopeMap.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/BlockingEnvelopeMap.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/BlockingEnvelopeMap.html Wed Dec 11 00:28:27 2019 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Mon Dec 09 10:28:22 PST 2019 --> -<title>BlockingEnvelopeMap (samza-api 1.3.0 API)</title> -<meta name="date" content="2019-12-09"> +<!-- Generated by javadoc (1.8.0_212) on Tue Dec 10 16:24:08 PST 2019 --> +<title>BlockingEnvelopeMap (samza-api 1.4.0-SNAPSHOT API)</title> +<meta name="date" content="2019-12-10"> <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="BlockingEnvelopeMap (samza-api 1.3.0 API)"; + parent.document.title="BlockingEnvelopeMap (samza-api 1.4.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/Clock.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/Clock.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/Clock.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/Clock.html Wed Dec 11 00:28:27 2019 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Mon Dec 09 10:28:22 PST 2019 --> -<title>Clock (samza-api 1.3.0 API)</title> -<meta name="date" content="2019-12-09"> +<!-- Generated by javadoc (1.8.0_212) on Tue Dec 10 16:24:08 PST 2019 --> +<title>Clock (samza-api 1.4.0-SNAPSHOT API)</title> +<meta name="date" content="2019-12-10"> <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="Clock (samza-api 1.3.0 API)"; + parent.document.title="Clock (samza-api 1.4.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/NoOpMetricsRegistry.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/NoOpMetricsRegistry.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/NoOpMetricsRegistry.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/NoOpMetricsRegistry.html Wed Dec 11 00:28:27 2019 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Mon Dec 09 10:28:22 PST 2019 --> -<title>NoOpMetricsRegistry (samza-api 1.3.0 API)</title> -<meta name="date" content="2019-12-09"> +<!-- Generated by javadoc (1.8.0_212) on Tue Dec 10 16:24:08 PST 2019 --> +<title>NoOpMetricsRegistry (samza-api 1.4.0-SNAPSHOT API)</title> +<meta name="date" content="2019-12-10"> <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="NoOpMetricsRegistry (samza-api 1.3.0 API)"; + parent.document.title="NoOpMetricsRegistry (samza-api 1.4.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/RateLimiter.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/RateLimiter.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/RateLimiter.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/RateLimiter.html Wed Dec 11 00:28:27 2019 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Mon Dec 09 10:28:22 PST 2019 --> -<title>RateLimiter (samza-api 1.3.0 API)</title> -<meta name="date" content="2019-12-09"> +<!-- Generated by javadoc (1.8.0_212) on Tue Dec 10 16:24:08 PST 2019 --> +<title>RateLimiter (samza-api 1.4.0-SNAPSHOT API)</title> +<meta name="date" content="2019-12-10"> <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="RateLimiter (samza-api 1.3.0 API)"; + parent.document.title="RateLimiter (samza-api 1.4.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/SinglePartitionWithoutOffsetsSystemAdmin.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/SinglePartitionWithoutOffsetsSystemAdmin.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/SinglePartitionWithoutOffsetsSystemAdmin.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/SinglePartitionWithoutOffsetsSystemAdmin.html Wed Dec 11 00:28:27 2019 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Mon Dec 09 10:28:22 PST 2019 --> -<title>SinglePartitionWithoutOffsetsSystemAdmin (samza-api 1.3.0 API)</title> -<meta name="date" content="2019-12-09"> +<!-- Generated by javadoc (1.8.0_212) on Tue Dec 10 16:24:08 PST 2019 --> +<title>SinglePartitionWithoutOffsetsSystemAdmin (samza-api 1.4.0-SNAPSHOT API)</title> +<meta name="date" content="2019-12-10"> <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="SinglePartitionWithoutOffsetsSystemAdmin (samza-api 1.3.0 API)"; + parent.document.title="SinglePartitionWithoutOffsetsSystemAdmin (samza-api 1.4.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/TimestampedValue.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/TimestampedValue.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/TimestampedValue.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/TimestampedValue.html Wed Dec 11 00:28:27 2019 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Mon Dec 09 10:28:22 PST 2019 --> -<title>TimestampedValue (samza-api 1.3.0 API)</title> -<meta name="date" content="2019-12-09"> +<!-- Generated by javadoc (1.8.0_212) on Tue Dec 10 16:24:08 PST 2019 --> +<title>TimestampedValue (samza-api 1.4.0-SNAPSHOT API)</title> +<meta name="date" content="2019-12-10"> <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="TimestampedValue (samza-api 1.3.0 API)"; + parent.document.title="TimestampedValue (samza-api 1.4.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/package-frame.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/package-frame.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/package-frame.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/package-frame.html Wed Dec 11 00:28:27 2019 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Mon Dec 09 10:28:22 PST 2019 --> -<title>org.apache.samza.util (samza-api 1.3.0 API)</title> -<meta name="date" content="2019-12-09"> +<!-- Generated by javadoc (1.8.0_212) on Tue Dec 10 16:24:09 PST 2019 --> +<title>org.apache.samza.util (samza-api 1.4.0-SNAPSHOT API)</title> +<meta name="date" content="2019-12-10"> <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/util/package-summary.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/package-summary.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/package-summary.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/package-summary.html Wed Dec 11 00:28:27 2019 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Mon Dec 09 10:28:22 PST 2019 --> -<title>org.apache.samza.util (samza-api 1.3.0 API)</title> -<meta name="date" content="2019-12-09"> +<!-- Generated by javadoc (1.8.0_212) on Tue Dec 10 16:24:09 PST 2019 --> +<title>org.apache.samza.util (samza-api 1.4.0-SNAPSHOT API)</title> +<meta name="date" content="2019-12-10"> <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.util (samza-api 1.3.0 API)"; + parent.document.title="org.apache.samza.util (samza-api 1.4.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/package-tree.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/package-tree.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/package-tree.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/package-tree.html Wed Dec 11 00:28:27 2019 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Mon Dec 09 10:28:22 PST 2019 --> -<title>org.apache.samza.util Class Hierarchy (samza-api 1.3.0 API)</title> -<meta name="date" content="2019-12-09"> +<!-- Generated by javadoc (1.8.0_212) on Tue Dec 10 16:24:09 PST 2019 --> +<title>org.apache.samza.util Class Hierarchy (samza-api 1.4.0-SNAPSHOT API)</title> +<meta name="date" content="2019-12-10"> <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.util Class Hierarchy (samza-api 1.3.0 API)"; + parent.document.title="org.apache.samza.util Class Hierarchy (samza-api 1.4.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/overview-frame.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/overview-frame.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/overview-frame.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/overview-frame.html Wed Dec 11 00:28:27 2019 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Mon Dec 09 10:28:22 PST 2019 --> -<title>Overview List (samza-api 1.3.0 API)</title> -<meta name="date" content="2019-12-09"> +<!-- Generated by javadoc (1.8.0_212) on Tue Dec 10 16:24:08 PST 2019 --> +<title>Overview List (samza-api 1.4.0-SNAPSHOT API)</title> +<meta name="date" content="2019-12-10"> <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/overview-summary.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/overview-summary.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/overview-summary.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/overview-summary.html Wed Dec 11 00:28:27 2019 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Mon Dec 09 10:28:22 PST 2019 --> -<title>Overview (samza-api 1.3.0 API)</title> -<meta name="date" content="2019-12-09"> +<!-- Generated by javadoc (1.8.0_212) on Tue Dec 10 16:24:09 PST 2019 --> +<title>Overview (samza-api 1.4.0-SNAPSHOT API)</title> +<meta name="date" content="2019-12-10"> <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="Overview (samza-api 1.3.0 API)"; + parent.document.title="Overview (samza-api 1.4.0-SNAPSHOT API)"; } } catch(err) { @@ -69,7 +69,7 @@ </a></div> <!-- ========= END OF TOP NAVBAR ========= --> <div class="header"> -<h1 class="title">samza-api 1.3.0 API</h1> +<h1 class="title">samza-api 1.4.0-SNAPSHOT API</h1> </div> <div class="contentContainer"> <table class="overviewSummary" border="0" cellpadding="3" cellspacing="0" summary="Packages table, listing packages, and an explanation"> Modified: samza/site/learn/documentation/latest/api/javadocs/overview-tree.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/overview-tree.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/overview-tree.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/overview-tree.html Wed Dec 11 00:28:27 2019 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Mon Dec 09 10:28:22 PST 2019 --> -<title>Class Hierarchy (samza-api 1.3.0 API)</title> -<meta name="date" content="2019-12-09"> +<!-- Generated by javadoc (1.8.0_212) on Tue Dec 10 16:24:09 PST 2019 --> +<title>Class Hierarchy (samza-api 1.4.0-SNAPSHOT API)</title> +<meta name="date" content="2019-12-10"> <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="Class Hierarchy (samza-api 1.3.0 API)"; + parent.document.title="Class Hierarchy (samza-api 1.4.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/serialized-form.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/serialized-form.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/serialized-form.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/serialized-form.html Wed Dec 11 00:28:27 2019 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Mon Dec 09 10:28:22 PST 2019 --> -<title>Serialized Form (samza-api 1.3.0 API)</title> -<meta name="date" content="2019-12-09"> +<!-- Generated by javadoc (1.8.0_212) on Tue Dec 10 16:24:09 PST 2019 --> +<title>Serialized Form (samza-api 1.4.0-SNAPSHOT API)</title> +<meta name="date" content="2019-12-10"> <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="Serialized Form (samza-api 1.3.0 API)"; + parent.document.title="Serialized Form (samza-api 1.4.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/low-level-api.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/low-level-api.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/low-level-api.html (original) +++ samza/site/learn/documentation/latest/api/low-level-api.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/api/low-level-api">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/api/low-level-api">1.2</a></li> @@ -848,6 +852,21 @@ whether they’re provided by the fr <span class="o">}</span> <span class="o">}</span></code></pre></figure> +<h3 id="side-inputs-for-local-tables">Side Inputs for Local Tables</h3> + +<p>For populating a local <a href="javadocs/org/apache/samza/table/Table">Table</a> with secondary data sources, we can use side inputs to specify the source stream. Additionally, the table descriptor also takes +in a <code>SideInputsProcessor</code> that will be applied before writing the entries to the table. The <code>TableDescriptor</code> that is registered with the <code>TaskApplicationDescriptor</code> can be used to specify side input properties.</p> + +<p>The following code snippet shows a sample <code>TableDescriptor</code> for a local table that is backed by side inputs.</p> + +<figure class="highlight"><pre><code class="language-java" data-lang="java"><span></span> <span class="n">RocksDbTableDescriptor</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="n">Profile</span><span class="o">></span> <span class="n">tableDesc</span> <span class="o">=</span> + <span class="k">new</span> <span class="n">RocksDbTableDescriptor</span><span class="o">(</span><span class="err">â</span><span class="n">viewCounts</span><span class="err">â</span><span class="o">,</span> <span class="n">KVSerde</span><span class="o">.</span><span class="na">of</span><span class="o">(</span><span class="k">new</span> <span class="n">StringSerde</span><span class="o">(),</span> <span class="k">new</span> <span class="n">JsonSerdeV2</span><span class="o"><>(</span><span class="n">Profile</span><span class="o">.</span><span class="na">class</span><span class="o">)))</span> + <span class="o">.</span><span class="na">withSideInput</span><span class="o">(</span><span class="n">ImmutableList</span><span class="o">.</span><span class="na">of</span><span class="o">(</span><span class="s">"profile"</span><span class="o">))</span> + <span class="o">.</span><span class="na">withSideInputsProcessor</span><span class="o">((</span><span class="n">message</span><span class="o">,</span> <span class="n">store</span><span class="o">)</span> <span class="o">-></span> <span class="o">{</span> + <span class="o">...</span> + <span class="o">});</span></code></pre></figure> + + <h3 id="legacy-applications">Legacy Applications</h3> <p>For legacy Low Level API applications, you can continue specifying your system, stream and store properties along with your task.class in configuration. An incomplete example of configuration for legacy task application looks like this (see the <a href="../jobs/configuration.html">configuration</a> documentation for more detail):</p> @@ -867,6 +886,13 @@ whether they’re provided by the fr <span class="c"># Use the "json" serializer for messages in the "PageViewEvent" topic</span> <span class="na"> systems.kafka.streams.PageViewEvent.samza.msg.serde</span><span class="o">=</span><span class="s">json</span> + + <span class="c"># Use "ProfileEvent" from the "kafka" system for side inputs for "profile-store"</span> +<span class="na"> stores.profile-store.side.inputs</span><span class="o">=</span><span class="s">kafka.ProfileEvent</span> + + <span class="c"># Use "MySideInputsProcessorFactory" to instantiate the "SideInputsProcessor" </span> + <span class="c"># that will applied on the "ProfileEvent" before writing to "profile-store"</span> +<span class="na"> stores.profile-store.side.inputs.processor.factory</span><span class="o">=</span><span class="s">org.apache.samza.MySideInputsProcessorFactory</span> </code></pre></figure> Modified: samza/site/learn/documentation/latest/api/programming-model.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/programming-model.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/programming-model.html (original) +++ samza/site/learn/documentation/latest/api/programming-model.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/api/programming-model">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/api/programming-model">1.2</a></li> @@ -651,7 +655,7 @@ <p><a href="javadocs/org/apache/samza/system/descriptors/InputDescriptor.html">InputDescriptor</a>s and <a href="javadocs/org/apache/samza/system/descriptors/OutputDescriptor.html">OutputDescriptor</a>s can be used for specifying Samza and implementation-specific properties of the streaming inputs and outputs for your application. You can obtain InputDescriptors and OutputDescriptors using a <a href="javadocs/org/apache/samza/system/descriptors/SystemDescriptor.html">SystemDescriptor</a> for your system. This SystemDescriptor can be used for specify Samza and implementation-specific properties of the producer and consumers for your I/O system. Most Samza system implementations come with their own SystemDescriptors, but if one isn’t available, you can use the <a href="javadocs/org/apache/samza/system/descriptors/GenericSystemDescriptor.html">GenericSystemDescriptor</a>.</p> -<p>A <a href="javadocs/org/apache/samza/table/descriptors/TableDescriptor.html">TableDescriptor</a> can be used for specifying Samza and implementation-specific properties of a <a href="javadocs/org/apache/samza/table/Table.html">Table</a>. You can use a Local TableDescriptor (e.g. <a href="javadocs/org/apache/samza/storage/kv/descriptors/RocksDbTableDescriptor.html">RocksDbTableDescriptor</a> or a <a href="javadocs/org/apache/samza/table/descriptors/RemoteTableDescriptor">RemoteTableDescriptor</a>.</p> +<p>A <a href="javadocs/org/apache/samza/table/descriptors/TableDescriptor.html">TableDescriptor</a> can be used for specifying Samza and implementation-specific properties of a <a href="javadocs/org/apache/samza/table/Table.html">Table</a>. You can use a Local TableDescriptor (e.g. <a href="javadocs/org/apache/samza/storage/kv/descriptors/RocksDbTableDescriptor.html">RocksDbTableDescriptor</a> or a <a href="javadocs/org/apache/samza/table/descriptors/RemoteTableDescriptor">RemoteTableDescriptor</a>. </p> <p>The following example illustrates how you can use input and output descriptors for a Kafka system, and a table descriptor for a local RocksDB table within your application:</p> Modified: samza/site/learn/documentation/latest/api/samza-sql.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/samza-sql.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/samza-sql.html (original) +++ samza/site/learn/documentation/latest/api/samza-sql.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/api/samza-sql">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/api/samza-sql">1.2</a></li> Modified: samza/site/learn/documentation/latest/api/table-api.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/table-api.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/table-api.html (original) +++ samza/site/learn/documentation/latest/api/table-api.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/api/table-api">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/api/table-api">1.2</a></li> @@ -756,6 +760,62 @@ function defined in lines 30-39.</li> <li>Line 12: writes the join result stream to another table</li> </ol> +<h1 id="using-table-with-samza-high-level-api-using-side-inputs">Using Table with Samza High Level API using Side Inputs</h1> + +<p>The code snippet below illustrates the usage of table in Samza high level API using side inputs.</p> + +<figure class="highlight"><pre><code class="language-java" data-lang="java"><span></span> <span class="mi">1</span> <span class="kd">class</span> <span class="nc">SamzaStreamApplication</span> <span class="kd">implements</span> <span class="n">StreamApplication</span> <span class="o">{</span> + <span class="mi">2</span> <span class="nd">@Override</span> + <span class="mi">3</span> <span class="kd">public</span> <span class="kt">void</span> <span class="nf">describe</span><span class="o">(</span><span class="n">StreamApplicationDescriptor</span> <span class="n">appDesc</span><span class="o">)</span> <span class="o">{</span> + <span class="mi">4</span> <span class="n">TableDescriptor</span><span class="o"><</span><span class="n">Integer</span><span class="o">,</span> <span class="n">Profile</span><span class="o">></span> <span class="n">desc</span> <span class="o">=</span> <span class="k">new</span> <span class="n">InMemoryTableDescriptor</span><span class="o">(</span> + <span class="mi">5</span> <span class="s">"t1"</span><span class="o">,</span> <span class="n">KVSerde</span><span class="o">.</span><span class="na">of</span><span class="o">(</span><span class="k">new</span> <span class="n">IntegerSerde</span><span class="o">(),</span> <span class="k">new</span> <span class="n">ProfileJsonSerde</span><span class="o">()))</span> + <span class="mi">6</span> <span class="o">.</span><span class="na">withSideInputs</span><span class="o">(</span><span class="n">ImmutableList</span><span class="o">.</span><span class="na">of</span><span class="o">(</span><span class="n">PROFILE_STREAM</span><span class="o">))</span> + <span class="mi">7</span> <span class="o">.</span><span class="na">withSideInputsProcessor</span><span class="o">((</span><span class="n">msg</span><span class="o">,</span> <span class="n">store</span><span class="o">)</span> <span class="o">-></span> <span class="o">{</span> + <span class="mi">8</span> <span class="n">Profile</span> <span class="n">profile</span> <span class="o">=</span> <span class="o">(</span><span class="n">Profile</span><span class="o">)</span> <span class="n">msg</span><span class="o">.</span><span class="na">getMessage</span><span class="o">();</span> + <span class="mi">9</span> <span class="kt">int</span> <span class="n">key</span> <span class="o">=</span> <span class="n">profile</span><span class="o">.</span><span class="na">getMemberId</span><span class="o">();</span> +<span class="mi">10</span> <span class="k">return</span> <span class="n">ImmutableList</span><span class="o">.</span><span class="na">of</span><span class="o">(</span><span class="k">new</span> <span class="n">Entry</span><span class="o"><>(</span><span class="n">key</span><span class="o">,</span> <span class="n">profile</span><span class="o">));</span> +<span class="mi">11</span> <span class="o">});</span> +<span class="mi">12</span> +<span class="mi">13</span> <span class="n">Table</span><span class="o"><</span><span class="n">KV</span><span class="o"><</span><span class="n">Integer</span><span class="o">,</span> <span class="n">Profile</span><span class="o">>></span> <span class="n">table</span> <span class="o">=</span> <span class="n">appDesc</span><span class="o">.</span><span class="na">getTable</span><span class="o">(</span><span class="n">desc</span><span class="o">);</span> +<span class="mi">14</span> +<span class="mi">15</span> <span class="n">appDesc</span><span class="o">.</span><span class="na">getInputStream</span><span class="o">(</span><span class="s">"PageView"</span><span class="o">,</span> <span class="k">new</span> <span class="n">NoOpSerde</span><span class="o"><</span><span class="n">PageView</span><span class="o">>())</span> +<span class="mi">16</span> <span class="o">.</span><span class="na">map</span><span class="o">(</span><span class="k">new</span> <span class="n">MyMapFunc</span><span class="o">())</span> +<span class="mi">17</span> <span class="o">.</span><span class="na">join</span><span class="o">(</span><span class="n">table</span><span class="o">,</span> <span class="k">new</span> <span class="n">MyJoinFunc</span><span class="o">())</span> +<span class="mi">18</span> <span class="o">.</span><span class="na">sendTo</span><span class="o">(</span><span class="n">anotherTable</span><span class="o">);</span> +<span class="mi">19</span> <span class="o">}</span> +<span class="mi">21</span> <span class="o">}</span> +<span class="mi">22</span> +<span class="mi">23</span> <span class="kd">static</span> <span class="kd">class</span> <span class="nc">MyMapFunc</span> <span class="kd">implements</span> <span class="n">MapFunction</span><span class="o"><</span><span class="n">PageView</span><span class="o">,</span> <span class="n">KV</span><span class="o"><</span><span class="n">Integer</span><span class="o">,</span> <span class="n">PageView</span><span class="o">>></span> <span class="o">{</span> +<span class="mi">24</span> <span class="kd">private</span> <span class="n">ReadableTable</span><span class="o"><</span><span class="n">Integer</span><span class="o">,</span> <span class="n">Profile</span><span class="o">></span> <span class="n">profileTable</span><span class="o">;</span> +<span class="mi">25</span> +<span class="mi">26</span> <span class="nd">@Override</span> +<span class="mi">27</span> <span class="kd">public</span> <span class="kt">void</span> <span class="nf">init</span><span class="o">(</span><span class="n">Config</span> <span class="n">config</span><span class="o">,</span> <span class="n">TaskContext</span> <span class="n">context</span><span class="o">)</span> <span class="o">{</span> +<span class="mi">28</span> <span class="n">profileTable</span> <span class="o">=</span> <span class="o">(</span><span class="n">ReadableTable</span><span class="o"><</span><span class="n">Integer</span><span class="o">,</span> <span class="n">Profile</span><span class="o">>)</span> <span class="n">context</span><span class="o">.</span><span class="na">getTable</span><span class="o">(</span><span class="s">"t1"</span><span class="o">);</span> +<span class="mi">29</span> <span class="o">}</span> +<span class="mi">30</span> +<span class="mi">31</span> <span class="nd">@Override</span> +<span class="mi">32</span> <span class="kd">public</span> <span class="n">KV</span><span class="o"><</span><span class="n">Integer</span><span class="o">,</span> <span class="n">PageView</span><span class="o">></span> <span class="nf">apply</span><span class="o">(</span><span class="n">PageView</span> <span class="n">message</span><span class="o">)</span> <span class="o">{</span> +<span class="mi">33</span> <span class="k">return</span> <span class="k">new</span> <span class="n">KV</span><span class="o">.</span><span class="na">of</span><span class="o">(</span><span class="n">message</span><span class="o">.</span><span class="na">getId</span><span class="o">(),</span> <span class="n">message</span><span class="o">);</span> +<span class="mi">34</span> <span class="o">}</span> +<span class="mi">35</span> <span class="o">}</span> +<span class="mi">36</span> +<span class="mi">37</span> <span class="kd">static</span> <span class="kd">class</span> <span class="nc">MyJoinFunc</span> <span class="kd">implements</span> <span class="n">StreamTableJoinFunction</span> +<span class="mi">38</span> <span class="o"><</span><span class="n">Integer</span><span class="o">,</span> <span class="n">KV</span><span class="o"><</span><span class="n">Integer</span><span class="o">,</span> <span class="n">PageView</span><span class="o">>,</span> <span class="n">KV</span><span class="o"><</span><span class="n">Integer</span><span class="o">,</span> <span class="n">Profile</span><span class="o">>,</span> <span class="n">EnrichedPageView</span><span class="o">></span> <span class="o">{</span> +<span class="mi">39</span> +<span class="mi">40</span> <span class="nd">@Override</span> +<span class="mi">41</span> <span class="kd">public</span> <span class="n">EnrichedPageView</span> <span class="nf">apply</span><span class="o">(</span><span class="n">KV</span><span class="o"><</span><span class="n">Integer</span><span class="o">,</span> <span class="n">PageView</span><span class="o">></span> <span class="n">m</span><span class="o">,</span> <span class="n">KV</span><span class="o"><</span><span class="n">Integer</span><span class="o">,</span> <span class="n">Profile</span><span class="o">></span> <span class="n">r</span><span class="o">)</span> <span class="o">{</span> +<span class="mi">42</span> <span class="n">counterPerJoinFn</span><span class="o">.</span><span class="na">get</span><span class="o">(</span><span class="k">this</span><span class="o">.</span><span class="na">currentSeqNo</span><span class="o">).</span><span class="na">incrementAndGet</span><span class="o">();</span> +<span class="mi">43</span> <span class="k">return</span> <span class="n">r</span> <span class="o">==</span> <span class="kc">null</span> <span class="o">?</span> <span class="kc">null</span> <span class="o">:</span> <span class="k">new</span> <span class="n">EnrichedPageView</span><span class="o">(</span> +<span class="mi">44</span> <span class="n">m</span><span class="o">.</span><span class="na">getValue</span><span class="o">().</span><span class="na">getPageKey</span><span class="o">(),</span> <span class="n">m</span><span class="o">.</span><span class="na">getKey</span><span class="o">(),</span> <span class="n">r</span><span class="o">.</span><span class="na">getValue</span><span class="o">().</span><span class="na">getCompany</span><span class="o">());</span> +<span class="mi">45</span> <span class="o">}</span> +<span class="mi">46</span> <span class="o">}</span></code></pre></figure> + +<p>The code above uses side inputs to populate the profile table. +1. Line 6: Denotes the source stream for the profile table +2. Line 7-11: Provides an implementation of <code>SideInputsProcessor</code> that reads from profile stream + and populates the table. +3. Line 17: Incoming page views are joined against the profile table.</p> + <h1 id="using-table-with-samza-low-level-api">Using Table with Samza Low Level API</h1> <p>The code snippet below illustrates the usage of table in Samza Low Level Task API.</p> @@ -1141,7 +1201,11 @@ on the current implementation of in-memo feature parity to existing in-memory and RocksDB-based stores. For more detailed information please refer to <a href="https://github.com/apache/samza/blob/master/samza-kv-rocksdb/src/main/java/org/apache/samza/storage/kv/RocksDbTableDescriptor.java";><code>RocksDbTableDescriptor</code></a> and -<a href="https://github.com/apache/samza/blob/master/samza-kv-inmemory/src/main/java/org/apache/samza/storage/kv/inmemory/InMemoryTableDescriptor.java";><code>InMemoryTableDescriptor</code></a>. </p> +<a href="https://github.com/apache/samza/blob/master/samza-kv-inmemory/src/main/java/org/apache/samza/storage/kv/inmemory/InMemoryTableDescriptor.java";><code>InMemoryTableDescriptor</code></a>.</p> + +<p>For local tables that are populated by secondary data sources, side inputs can be used to populate the data. +The source streams will be used to bootstrap the data instead of a changelog in the event of failure. Side inputs and +the processor implementation can be provided as properties to the <code>TableDescriptor</code>.</p> <h2 id="hybrid-table">Hybrid Table</h2> Modified: samza/site/learn/documentation/latest/api/test-framework.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/test-framework.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/test-framework.html (original) +++ samza/site/learn/documentation/latest/api/test-framework.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/api/test-framework">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/api/test-framework">1.2</a></li> Modified: samza/site/learn/documentation/latest/architecture/architecture-overview.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/architecture/architecture-overview.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/architecture/architecture-overview.html (original) +++ samza/site/learn/documentation/latest/architecture/architecture-overview.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/architecture/architecture-overview">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/architecture/architecture-overview">1.2</a></li> Modified: samza/site/learn/documentation/latest/architecture/kinesis.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/architecture/kinesis.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/architecture/kinesis.html (original) +++ samza/site/learn/documentation/latest/architecture/kinesis.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/architecture/kinesis">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/architecture/kinesis">1.2</a></li> Modified: samza/site/learn/documentation/latest/comparisons/introduction.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/comparisons/introduction.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/comparisons/introduction.html (original) +++ samza/site/learn/documentation/latest/comparisons/introduction.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/comparisons/introduction">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/comparisons/introduction">1.2</a></li> Modified: samza/site/learn/documentation/latest/comparisons/mupd8.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/comparisons/mupd8.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/comparisons/mupd8.html (original) +++ samza/site/learn/documentation/latest/comparisons/mupd8.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/comparisons/mupd8">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/comparisons/mupd8">1.2</a></li> Modified: samza/site/learn/documentation/latest/comparisons/spark-streaming.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/comparisons/spark-streaming.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/comparisons/spark-streaming.html (original) +++ samza/site/learn/documentation/latest/comparisons/spark-streaming.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/comparisons/spark-streaming">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/comparisons/spark-streaming">1.2</a></li> Modified: samza/site/learn/documentation/latest/comparisons/storm.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/comparisons/storm.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/comparisons/storm.html (original) +++ samza/site/learn/documentation/latest/comparisons/storm.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/comparisons/storm">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/comparisons/storm">1.2</a></li> Modified: samza/site/learn/documentation/latest/connectors/eventhubs.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/connectors/eventhubs.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/connectors/eventhubs.html (original) +++ samza/site/learn/documentation/latest/connectors/eventhubs.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/connectors/eventhubs">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/connectors/eventhubs">1.2</a></li> Modified: samza/site/learn/documentation/latest/connectors/hdfs.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/connectors/hdfs.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/connectors/hdfs.html (original) +++ samza/site/learn/documentation/latest/connectors/hdfs.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/connectors/hdfs">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/connectors/hdfs">1.2</a></li> Modified: samza/site/learn/documentation/latest/connectors/kafka.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/connectors/kafka.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/connectors/kafka.html (original) +++ samza/site/learn/documentation/latest/connectors/kafka.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/connectors/kafka">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/connectors/kafka">1.2</a></li> Modified: samza/site/learn/documentation/latest/connectors/kinesis.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/connectors/kinesis.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/connectors/kinesis.html (original) +++ samza/site/learn/documentation/latest/connectors/kinesis.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/connectors/kinesis">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/connectors/kinesis">1.2</a></li> Modified: samza/site/learn/documentation/latest/connectors/overview.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/connectors/overview.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/connectors/overview.html (original) +++ samza/site/learn/documentation/latest/connectors/overview.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/connectors/overview">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/connectors/overview">1.2</a></li> Modified: samza/site/learn/documentation/latest/container/checkpointing.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/container/checkpointing.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/container/checkpointing.html (original) +++ samza/site/learn/documentation/latest/container/checkpointing.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/container/checkpointing">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/container/checkpointing">1.2</a></li> Modified: samza/site/learn/documentation/latest/container/coordinator-stream.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/container/coordinator-stream.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/container/coordinator-stream.html (original) +++ samza/site/learn/documentation/latest/container/coordinator-stream.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/container/coordinator-stream">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/container/coordinator-stream">1.2</a></li> Modified: samza/site/learn/documentation/latest/container/event-loop.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/container/event-loop.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/container/event-loop.html (original) +++ samza/site/learn/documentation/latest/container/event-loop.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/container/event-loop">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/container/event-loop">1.2</a></li> Modified: samza/site/learn/documentation/latest/container/jmx.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/container/jmx.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/container/jmx.html (original) +++ samza/site/learn/documentation/latest/container/jmx.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/container/jmx">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/container/jmx">1.2</a></li> Modified: samza/site/learn/documentation/latest/container/metrics.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/container/metrics.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/container/metrics.html (original) +++ samza/site/learn/documentation/latest/container/metrics.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/container/metrics">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/container/metrics">1.2</a></li> Modified: samza/site/learn/documentation/latest/container/samza-container.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/container/samza-container.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/container/samza-container.html (original) +++ samza/site/learn/documentation/latest/container/samza-container.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/container/samza-container">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/container/samza-container">1.2</a></li> Modified: samza/site/learn/documentation/latest/container/serialization.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/container/serialization.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/container/serialization.html (original) +++ samza/site/learn/documentation/latest/container/serialization.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/container/serialization">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/container/serialization">1.2</a></li> Modified: samza/site/learn/documentation/latest/container/state-management.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/container/state-management.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/container/state-management.html (original) +++ samza/site/learn/documentation/latest/container/state-management.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/container/state-management">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/container/state-management">1.2</a></li> Modified: samza/site/learn/documentation/latest/container/streams.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/container/streams.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/container/streams.html (original) +++ samza/site/learn/documentation/latest/container/streams.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/container/streams">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/container/streams">1.2</a></li> Modified: samza/site/learn/documentation/latest/container/windowing.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/container/windowing.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/container/windowing.html (original) +++ samza/site/learn/documentation/latest/container/windowing.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/container/windowing">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/container/windowing">1.2</a></li> Modified: samza/site/learn/documentation/latest/core-concepts/core-concepts.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/core-concepts/core-concepts.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/core-concepts/core-concepts.html (original) +++ samza/site/learn/documentation/latest/core-concepts/core-concepts.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/core-concepts/core-concepts">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/core-concepts/core-concepts">1.2</a></li> Modified: samza/site/learn/documentation/latest/deployment/deployment-model.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/deployment/deployment-model.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/deployment/deployment-model.html (original) +++ samza/site/learn/documentation/latest/deployment/deployment-model.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/deployment/deployment-model">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/deployment/deployment-model">1.2</a></li> Modified: samza/site/learn/documentation/latest/deployment/standalone.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/deployment/standalone.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/deployment/standalone.html (original) +++ samza/site/learn/documentation/latest/deployment/standalone.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/deployment/standalone">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/deployment/standalone">1.2</a></li> Modified: samza/site/learn/documentation/latest/deployment/yarn.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/deployment/yarn.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/deployment/yarn.html (original) +++ samza/site/learn/documentation/latest/deployment/yarn.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/deployment/yarn">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/deployment/yarn">1.2</a></li> Modified: samza/site/learn/documentation/latest/hadoop/consumer.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/hadoop/consumer.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/hadoop/consumer.html (original) +++ samza/site/learn/documentation/latest/hadoop/consumer.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/hadoop/consumer">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/hadoop/consumer">1.2</a></li> Modified: samza/site/learn/documentation/latest/hadoop/overview.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/hadoop/overview.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/hadoop/overview.html (original) +++ samza/site/learn/documentation/latest/hadoop/overview.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/hadoop/overview">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/hadoop/overview">1.2</a></li> Modified: samza/site/learn/documentation/latest/hadoop/producer.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/hadoop/producer.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/hadoop/producer.html (original) +++ samza/site/learn/documentation/latest/hadoop/producer.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/hadoop/producer">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/hadoop/producer">1.2</a></li> Modified: samza/site/learn/documentation/latest/index.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/index.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/index.html (original) +++ samza/site/learn/documentation/latest/index.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/">1.2</a></li> Modified: samza/site/learn/documentation/latest/introduction/architecture.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/introduction/architecture.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/introduction/architecture.html (original) +++ samza/site/learn/documentation/latest/introduction/architecture.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/introduction/architecture">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/introduction/architecture">1.2</a></li> Modified: samza/site/learn/documentation/latest/introduction/background.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/introduction/background.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/introduction/background.html (original) +++ samza/site/learn/documentation/latest/introduction/background.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/introduction/background">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/introduction/background">1.2</a></li> Modified: samza/site/learn/documentation/latest/introduction/concepts.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/introduction/concepts.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/introduction/concepts.html (original) +++ samza/site/learn/documentation/latest/introduction/concepts.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/introduction/concepts">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/introduction/concepts">1.2</a></li> Modified: samza/site/learn/documentation/latest/jobs/configuration-table.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/jobs/configuration-table.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/jobs/configuration-table.html (original) +++ samza/site/learn/documentation/latest/jobs/configuration-table.html Wed Dec 11 00:28:27 2019 @@ -347,7 +347,7 @@ <strong>required</strong> configuration. Specify a comma separated list of range(s) to determine which partition matches, and thus statically assigned to the Job. For example "2,3,11-20", statically assigns partition 2, 3, and 11 to 20 for all the specified system and streams (topics in case of Kafka) to the job. - A singel configuration value like "19" is valid as well. This statically assigns partition 19. + A single configuration value like "19" is valid as well. This statically assigns partition 19. For config validation each element in the comma separated list much conform to one of the following regex: <ul> Modified: samza/site/learn/documentation/latest/jobs/configuration.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/jobs/configuration.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/jobs/configuration.html (original) +++ samza/site/learn/documentation/latest/jobs/configuration.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/jobs/configuration">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/jobs/configuration">1.2</a></li> Modified: samza/site/learn/documentation/latest/jobs/job-runner.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/jobs/job-runner.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/jobs/job-runner.html (original) +++ samza/site/learn/documentation/latest/jobs/job-runner.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/jobs/job-runner">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/jobs/job-runner">1.2</a></li> Modified: samza/site/learn/documentation/latest/jobs/logging.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/jobs/logging.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/jobs/logging.html (original) +++ samza/site/learn/documentation/latest/jobs/logging.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/jobs/logging">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/jobs/logging">1.2</a></li> Modified: samza/site/learn/documentation/latest/jobs/packaging.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/jobs/packaging.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/jobs/packaging.html (original) +++ samza/site/learn/documentation/latest/jobs/packaging.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/jobs/packaging">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/jobs/packaging">1.2</a></li> Modified: samza/site/learn/documentation/latest/jobs/reprocessing.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/jobs/reprocessing.html?rev=1871151&r1=1871150&r2=1871151&view=diff ============================================================================== --- samza/site/learn/documentation/latest/jobs/reprocessing.html (original) +++ samza/site/learn/documentation/latest/jobs/reprocessing.html Wed Dec 11 00:28:27 2019 @@ -520,6 +520,10 @@ + <li class="hide"><a href="/learn/documentation/1.3/jobs/reprocessing">1.3</a></li> + + + <li class="hide"><a href="/learn/documentation/1.2/jobs/reprocessing">1.2</a></li>
