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 [17/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/lates...
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=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/overview-summary.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/overview-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>Overview (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>Overview (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="Overview (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="Overview (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
@@ -69,7 +69,7 @@
</a></div>
<!-- ========= END OF TOP NAVBAR ========= -->
<div class="header">
-<h1 class="title">samza-api 0.13.1-SNAPSHOT API</h1>
+<h1 class="title">samza-api 0.14.1-SNAPSHOT API</h1>
</div>
<div class="contentContainer">
<table class="overviewSummary" border="0" cellpadding="3" cellspacing="0" summary="Packages table, listing packages, and an explanation">
@@ -144,21 +144,29 @@
<td class="colLast"> </td>
</tr>
<tr class="altColor">
-<td class="colFirst"><a href="org/apache/samza/storage/package-summary.html">org.apache.samza.storage</a></td>
+<td class="colFirst"><a href="org/apache/samza/sql/udfs/package-summary.html">org.apache.samza.sql.udfs</a></td>
<td class="colLast"> </td>
</tr>
<tr class="rowColor">
-<td class="colFirst"><a href="org/apache/samza/storage/kv/package-summary.html">org.apache.samza.storage.kv</a></td>
+<td class="colFirst"><a href="org/apache/samza/storage/package-summary.html">org.apache.samza.storage</a></td>
<td class="colLast"> </td>
</tr>
<tr class="altColor">
-<td class="colFirst"><a href="org/apache/samza/system/package-summary.html">org.apache.samza.system</a></td>
+<td class="colFirst"><a href="org/apache/samza/storage/kv/package-summary.html">org.apache.samza.storage.kv</a></td>
<td class="colLast"> </td>
</tr>
<tr class="rowColor">
+<td class="colFirst"><a href="org/apache/samza/system/package-summary.html">org.apache.samza.system</a></td>
+<td class="colLast"> </td>
+</tr>
+<tr class="altColor">
<td class="colFirst"><a href="org/apache/samza/system/chooser/package-summary.html">org.apache.samza.system.chooser</a></td>
<td class="colLast"> </td>
</tr>
+<tr class="rowColor">
+<td class="colFirst"><a href="org/apache/samza/table/package-summary.html">org.apache.samza.table</a></td>
+<td class="colLast"> </td>
+</tr>
<tr class="altColor">
<td class="colFirst"><a href="org/apache/samza/task/package-summary.html">org.apache.samza.task</a></td>
<td class="colLast"> </td>
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=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/overview-tree.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/overview-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>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>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="Class Hierarchy (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="Class Hierarchy (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
@@ -88,10 +88,12 @@
<li><a href="org/apache/samza/operators/windows/internal/package-tree.html">org.apache.samza.operators.windows.internal</a>, </li>
<li><a href="org/apache/samza/runtime/package-tree.html">org.apache.samza.runtime</a>, </li>
<li><a href="org/apache/samza/serializers/package-tree.html">org.apache.samza.serializers</a>, </li>
+<li><a href="org/apache/samza/sql/udfs/package-tree.html">org.apache.samza.sql.udfs</a>, </li>
<li><a href="org/apache/samza/storage/package-tree.html">org.apache.samza.storage</a>, </li>
<li><a href="org/apache/samza/storage/kv/package-tree.html">org.apache.samza.storage.kv</a>, </li>
<li><a href="org/apache/samza/system/package-tree.html">org.apache.samza.system</a>, </li>
<li><a href="org/apache/samza/system/chooser/package-tree.html">org.apache.samza.system.chooser</a>, </li>
+<li><a href="org/apache/samza/table/package-tree.html">org.apache.samza.table</a>, </li>
<li><a href="org/apache/samza/task/package-tree.html">org.apache.samza.task</a>, </li>
<li><a href="org/apache/samza/util/package-tree.html">org.apache.samza.util</a></li>
</ul>
@@ -107,6 +109,10 @@
<li type="circle">org.apache.samza.system.chooser.<a href="org/apache/samza/system/chooser/BaseMessageChooser.html" title="class in org.apache.samza.system.chooser"><span class="typeNameLink">BaseMessageChooser</span></a> (implements org.apache.samza.system.chooser.<a href="org/apache/samza/system/chooser/MessageChooser.html" title="interface in org.apache.samza.system.chooser">MessageChooser</a>)</li>
<li type="circle">org.apache.samza.util.<a href="org/apache/samza/util/BlockingEnvelopeMap.html" title="class in org.apache.samza.util"><span class="typeNameLink">BlockingEnvelopeMap</span></a> (implements org.apache.samza.system.<a href="org/apache/samza/system/SystemConsumer.html" title="interface in org.apache.samza.system">SystemConsumer</a>)</li>
<li type="circle">org.apache.samza.util.<a href="org/apache/samza/util/BlockingEnvelopeMap.BlockingEnvelopeMapMetrics.html" title="class in org.apache.samza.util"><span class="typeNameLink">BlockingEnvelopeMap.BlockingEnvelopeMapMetrics</span></a></li>
+<li type="circle">org.apache.samza.serializers.<a href="org/apache/samza/serializers/ByteBufferSerde.html" title="class in org.apache.samza.serializers"><span class="typeNameLink">ByteBufferSerde</span></a> (implements org.apache.samza.serializers.<a href="org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><T>)</li>
+<li type="circle">org.apache.samza.serializers.<a href="org/apache/samza/serializers/ByteBufferSerdeFactory.html" title="class in org.apache.samza.serializers"><span class="typeNameLink">ByteBufferSerdeFactory</span></a> (implements org.apache.samza.serializers.<a href="org/apache/samza/serializers/SerdeFactory.html" title="interface in org.apache.samza.serializers">SerdeFactory</a><T>)</li>
+<li type="circle">org.apache.samza.serializers.<a href="org/apache/samza/serializers/ByteSerde.html" title="class in org.apache.samza.serializers"><span class="typeNameLink">ByteSerde</span></a> (implements org.apache.samza.serializers.<a href="org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><T>)</li>
+<li type="circle">org.apache.samza.serializers.<a href="org/apache/samza/serializers/ByteSerdeFactory.html" title="class in org.apache.samza.serializers"><span class="typeNameLink">ByteSerdeFactory</span></a> (implements org.apache.samza.serializers.<a href="org/apache/samza/serializers/SerdeFactory.html" title="interface in org.apache.samza.serializers">SerdeFactory</a><T>)</li>
<li type="circle">org.apache.samza.checkpoint.<a href="org/apache/samza/checkpoint/Checkpoint.html" title="class in org.apache.samza.checkpoint"><span class="typeNameLink">Checkpoint</span></a></li>
<li type="circle">org.apache.samza.job.<a href="org/apache/samza/job/CommandBuilder.html" title="class in org.apache.samza.job"><span class="typeNameLink">CommandBuilder</span></a></li>
<li type="circle">org.apache.samza.config.<a href="org/apache/samza/config/Config.html" title="class in org.apache.samza.config"><span class="typeNameLink">Config</span></a> (implements java.util.Map<K,V>)
@@ -114,8 +120,16 @@
<li type="circle">org.apache.samza.config.<a href="org/apache/samza/config/MapConfig.html" title="class in org.apache.samza.config"><span class="typeNameLink">MapConfig</span></a></li>
</ul>
</li>
+<li type="circle">org.apache.samza.system.<a href="org/apache/samza/system/ControlMessage.html" title="class in org.apache.samza.system"><span class="typeNameLink">ControlMessage</span></a>
+<ul>
+<li type="circle">org.apache.samza.system.<a href="org/apache/samza/system/EndOfStreamMessage.html" title="class in org.apache.samza.system"><span class="typeNameLink">EndOfStreamMessage</span></a></li>
+<li type="circle">org.apache.samza.system.<a href="org/apache/samza/system/WatermarkMessage.html" title="class in org.apache.samza.system"><span class="typeNameLink">WatermarkMessage</span></a></li>
+</ul>
+</li>
<li type="circle">org.apache.samza.metrics.<a href="org/apache/samza/metrics/Counter.html" title="class in org.apache.samza.metrics"><span class="typeNameLink">Counter</span></a> (implements org.apache.samza.metrics.<a href="org/apache/samza/metrics/Metric.html" title="interface in org.apache.samza.metrics">Metric</a>)</li>
<li type="circle">org.apache.samza.operators.triggers.<a href="org/apache/samza/operators/triggers/CountTrigger.html" title="class in org.apache.samza.operators.triggers"><span class="typeNameLink">CountTrigger</span></a><M> (implements org.apache.samza.operators.triggers.<a href="org/apache/samza/operators/triggers/Trigger.html" title="interface in org.apache.samza.operators.triggers">Trigger</a><M>)</li>
+<li type="circle">org.apache.samza.serializers.<a href="org/apache/samza/serializers/DoubleSerde.html" title="class in org.apache.samza.serializers"><span class="typeNameLink">DoubleSerde</span></a> (implements org.apache.samza.serializers.<a href="org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><T>)</li>
+<li type="circle">org.apache.samza.serializers.<a href="org/apache/samza/serializers/DoubleSerdeFactory.html" title="class in org.apache.samza.serializers"><span class="typeNameLink">DoubleSerdeFactory</span></a> (implements org.apache.samza.serializers.<a href="org/apache/samza/serializers/SerdeFactory.html" title="interface in org.apache.samza.serializers">SerdeFactory</a><T>)</li>
<li type="circle">org.apache.samza.storage.kv.<a href="org/apache/samza/storage/kv/Entry.html" title="class in org.apache.samza.storage.kv"><span class="typeNameLink">Entry</span></a><K,V></li>
<li type="circle">org.apache.samza.metrics.<a href="org/apache/samza/metrics/Gauge.html" title="class in org.apache.samza.metrics"><span class="typeNameLink">Gauge</span></a><T> (implements org.apache.samza.metrics.<a href="org/apache/samza/metrics/Metric.html" title="interface in org.apache.samza.metrics">Metric</a>)
<ul>
@@ -124,20 +138,32 @@
</ul>
</li>
<li type="circle">org.apache.samza.system.<a href="org/apache/samza/system/IncomingMessageEnvelope.html" title="class in org.apache.samza.system"><span class="typeNameLink">IncomingMessageEnvelope</span></a></li>
+<li type="circle">org.apache.samza.serializers.<a href="org/apache/samza/serializers/IntegerSerde.html" title="class in org.apache.samza.serializers"><span class="typeNameLink">IntegerSerde</span></a> (implements org.apache.samza.serializers.<a href="org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><T>)</li>
+<li type="circle">org.apache.samza.serializers.<a href="org/apache/samza/serializers/IntegerSerdeFactory.html" title="class in org.apache.samza.serializers"><span class="typeNameLink">IntegerSerdeFactory</span></a> (implements org.apache.samza.serializers.<a href="org/apache/samza/serializers/SerdeFactory.html" title="interface in org.apache.samza.serializers">SerdeFactory</a><T>)</li>
<li type="circle">org.apache.samza.annotation.<a href="org/apache/samza/annotation/InterfaceStability.html" title="class in org.apache.samza.annotation"><span class="typeNameLink">InterfaceStability</span></a></li>
-<li type="circle">org.apache.samza.storage.kv.<a href="org/apache/samza/storage/kv/KeyValueStore.Extension.html" title="class in org.apache.samza.storage.kv"><span class="typeNameLink">KeyValueStore.Extension</span></a></li>
+<li type="circle">org.apache.samza.serializers.<a href="org/apache/samza/serializers/JsonSerdeV2.html" title="class in org.apache.samza.serializers"><span class="typeNameLink">JsonSerdeV2</span></a><T> (implements org.apache.samza.serializers.<a href="org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><T>)</li>
+<li type="circle">org.apache.samza.serializers.<a href="org/apache/samza/serializers/JsonSerdeV2Factory.html" title="class in org.apache.samza.serializers"><span class="typeNameLink">JsonSerdeV2Factory</span></a> (implements org.apache.samza.serializers.<a href="org/apache/samza/serializers/SerdeFactory.html" title="interface in org.apache.samza.serializers">SerdeFactory</a><T>)</li>
+<li type="circle">org.apache.samza.operators.<a href="org/apache/samza/operators/KV.html" title="class in org.apache.samza.operators"><span class="typeNameLink">KV</span></a><K,V></li>
+<li type="circle">org.apache.samza.serializers.<a href="org/apache/samza/serializers/KVSerde.html" title="class in org.apache.samza.serializers"><span class="typeNameLink">KVSerde</span></a><K,V> (implements org.apache.samza.serializers.<a href="org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><T>)</li>
+<li type="circle">org.apache.samza.serializers.<a href="org/apache/samza/serializers/LongSerde.html" title="class in org.apache.samza.serializers"><span class="typeNameLink">LongSerde</span></a> (implements org.apache.samza.serializers.<a href="org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><T>)</li>
+<li type="circle">org.apache.samza.serializers.<a href="org/apache/samza/serializers/LongSerdeFactory.html" title="class in org.apache.samza.serializers"><span class="typeNameLink">LongSerdeFactory</span></a> (implements org.apache.samza.serializers.<a href="org/apache/samza/serializers/SerdeFactory.html" title="interface in org.apache.samza.serializers">SerdeFactory</a><T>)</li>
<li type="circle">org.apache.samza.metrics.<a href="org/apache/samza/metrics/MetricsVisitor.html" title="class in org.apache.samza.metrics"><span class="typeNameLink">MetricsVisitor</span></a></li>
<li type="circle">org.apache.samza.util.<a href="org/apache/samza/util/NoOpMetricsRegistry.html" title="class in org.apache.samza.util"><span class="typeNameLink">NoOpMetricsRegistry</span></a> (implements org.apache.samza.metrics.<a href="org/apache/samza/metrics/MetricsRegistry.html" title="interface in org.apache.samza.metrics">MetricsRegistry</a>)</li>
+<li type="circle">org.apache.samza.serializers.<a href="org/apache/samza/serializers/NoOpSerde.html" title="class in org.apache.samza.serializers"><span class="typeNameLink">NoOpSerde</span></a><T> (implements org.apache.samza.serializers.<a href="org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><T>)</li>
<li type="circle">org.apache.samza.system.<a href="org/apache/samza/system/OutgoingMessageEnvelope.html" title="class in org.apache.samza.system"><span class="typeNameLink">OutgoingMessageEnvelope</span></a></li>
<li type="circle">org.apache.samza.<a href="org/apache/samza/Partition.html" title="class in org.apache.samza"><span class="typeNameLink">Partition</span></a> (implements java.lang.Comparable<T>)</li>
<li type="circle">org.apache.samza.operators.triggers.<a href="org/apache/samza/operators/triggers/RepeatingTrigger.html" title="class in org.apache.samza.operators.triggers"><span class="typeNameLink">RepeatingTrigger</span></a><M> (implements org.apache.samza.operators.triggers.<a href="org/apache/samza/operators/triggers/Trigger.html" title="interface in org.apache.samza.operators.triggers">Trigger</a><M>)</li>
<li type="circle">org.apache.samza.container.<a href="org/apache/samza/container/SamzaContainerContext.html" title="class in org.apache.samza.container"><span class="typeNameLink">SamzaContainerContext</span></a></li>
+<li type="circle">org.apache.samza.serializers.<a href="org/apache/samza/serializers/SerializableSerde.html" title="class in org.apache.samza.serializers"><span class="typeNameLink">SerializableSerde</span></a><T> (implements org.apache.samza.serializers.<a href="org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><T>)</li>
+<li type="circle">org.apache.samza.serializers.<a href="org/apache/samza/serializers/SerializableSerdeFactory.html" title="class in org.apache.samza.serializers"><span class="typeNameLink">SerializableSerdeFactory</span></a><T> (implements org.apache.samza.serializers.<a href="org/apache/samza/serializers/SerdeFactory.html" title="interface in org.apache.samza.serializers">SerdeFactory</a><T>)</li>
<li type="circle">org.apache.samza.util.<a href="org/apache/samza/util/SinglePartitionWithoutOffsetsSystemAdmin.html" title="class in org.apache.samza.util"><span class="typeNameLink">SinglePartitionWithoutOffsetsSystemAdmin</span></a> (implements org.apache.samza.system.<a href="org/apache/samza/system/SystemAdmin.html" title="interface in org.apache.samza.system">SystemAdmin</a>)</li>
<li type="circle">org.apache.samza.metrics.<a href="org/apache/samza/metrics/SlidingTimeWindowReservoir.html" title="class in org.apache.samza.metrics"><span class="typeNameLink">SlidingTimeWindowReservoir</span></a> (implements org.apache.samza.metrics.<a href="org/apache/samza/metrics/Reservoir.html" title="interface in org.apache.samza.metrics">Reservoir</a>)</li>
<li type="circle">org.apache.samza.metrics.<a href="org/apache/samza/metrics/Snapshot.html" title="class in org.apache.samza.metrics"><span class="typeNameLink">Snapshot</span></a></li>
<li type="circle">org.apache.samza.storage.<a href="org/apache/samza/storage/StoreProperties.html" title="class in org.apache.samza.storage"><span class="typeNameLink">StoreProperties</span></a></li>
<li type="circle">org.apache.samza.storage.<a href="org/apache/samza/storage/StoreProperties.StorePropertiesBuilder.html" title="class in org.apache.samza.storage"><span class="typeNameLink">StoreProperties.StorePropertiesBuilder</span></a></li>
<li type="circle">org.apache.samza.system.<a href="org/apache/samza/system/StreamSpec.html" title="class in org.apache.samza.system"><span class="typeNameLink">StreamSpec</span></a></li>
+<li type="circle">org.apache.samza.serializers.<a href="org/apache/samza/serializers/StringSerde.html" title="class in org.apache.samza.serializers"><span class="typeNameLink">StringSerde</span></a> (implements org.apache.samza.serializers.<a href="org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><T>)</li>
+<li type="circle">org.apache.samza.serializers.<a href="org/apache/samza/serializers/StringSerdeFactory.html" title="class in org.apache.samza.serializers"><span class="typeNameLink">StringSerdeFactory</span></a> (implements org.apache.samza.serializers.<a href="org/apache/samza/serializers/SerdeFactory.html" title="interface in org.apache.samza.serializers">SerdeFactory</a><T>)</li>
<li type="circle">org.apache.samza.system.<a href="org/apache/samza/system/SystemStream.html" title="class in org.apache.samza.system"><span class="typeNameLink">SystemStream</span></a>
<ul>
<li type="circle">org.apache.samza.system.<a href="org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system"><span class="typeNameLink">SystemStreamPartition</span></a> (implements java.lang.Comparable<T>)</li>
@@ -146,6 +172,7 @@
<li type="circle">org.apache.samza.system.<a href="org/apache/samza/system/SystemStreamMetadata.html" title="class in org.apache.samza.system"><span class="typeNameLink">SystemStreamMetadata</span></a></li>
<li type="circle">org.apache.samza.system.<a href="org/apache/samza/system/SystemStreamMetadata.SystemStreamPartitionMetadata.html" title="class in org.apache.samza.system"><span class="typeNameLink">SystemStreamMetadata.SystemStreamPartitionMetadata</span></a></li>
<li type="circle">org.apache.samza.system.<a href="org/apache/samza/system/SystemStreamPartitionIterator.html" title="class in org.apache.samza.system"><span class="typeNameLink">SystemStreamPartitionIterator</span></a> (implements java.util.Iterator<E>)</li>
+<li type="circle">org.apache.samza.table.<a href="org/apache/samza/table/TableSpec.html" title="class in org.apache.samza.table"><span class="typeNameLink">TableSpec</span></a></li>
<li type="circle">org.apache.samza.container.<a href="org/apache/samza/container/TaskName.html" title="class in org.apache.samza.container"><span class="typeNameLink">TaskName</span></a> (implements java.lang.Comparable<T>)</li>
<li type="circle">java.lang.Throwable (implements java.io.Serializable)
<ul>
@@ -158,6 +185,7 @@
<ul>
<li type="circle">org.apache.samza.config.<a href="org/apache/samza/config/ConfigException.html" title="class in org.apache.samza.config"><span class="typeNameLink">ConfigException</span></a></li>
<li type="circle">org.apache.samza.system.<a href="org/apache/samza/system/StreamValidationException.html" title="class in org.apache.samza.system"><span class="typeNameLink">StreamValidationException</span></a></li>
+<li type="circle">org.apache.samza.system.<a href="org/apache/samza/system/SystemProducerException.html" title="class in org.apache.samza.system"><span class="typeNameLink">SystemProducerException</span></a></li>
</ul>
</li>
</ul>
@@ -171,6 +199,8 @@
<li type="circle">org.apache.samza.operators.triggers.<a href="org/apache/samza/operators/triggers/TimeSinceLastMessageTrigger.html" title="class in org.apache.samza.operators.triggers"><span class="typeNameLink">TimeSinceLastMessageTrigger</span></a><M> (implements org.apache.samza.operators.triggers.<a href="org/apache/samza/operators/triggers/TimeBasedTrigger.html" title="interface in org.apache.samza.operators.triggers">TimeBasedTrigger</a><M>, org.apache.samza.operators.triggers.<a href="org/apache/samza/operators/triggers/Trigger.html" title="interface in org.apache.samza.operators.triggers">Trigger</a><M>)</li>
<li type="circle">org.apache.samza.operators.triggers.<a href="org/apache/samza/operators/triggers/TimeTrigger.html" title="class in org.apache.samza.operators.triggers"><span class="typeNameLink">TimeTrigger</span></a><M> (implements org.apache.samza.operators.triggers.<a href="org/apache/samza/operators/triggers/TimeBasedTrigger.html" title="interface in org.apache.samza.operators.triggers">TimeBasedTrigger</a><M>, org.apache.samza.operators.triggers.<a href="org/apache/samza/operators/triggers/Trigger.html" title="interface in org.apache.samza.operators.triggers">Trigger</a><M>)</li>
<li type="circle">org.apache.samza.operators.triggers.<a href="org/apache/samza/operators/triggers/Triggers.html" title="class in org.apache.samza.operators.triggers"><span class="typeNameLink">Triggers</span></a></li>
+<li type="circle">org.apache.samza.serializers.<a href="org/apache/samza/serializers/UUIDSerde.html" title="class in org.apache.samza.serializers"><span class="typeNameLink">UUIDSerde</span></a> (implements org.apache.samza.serializers.<a href="org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><T>)</li>
+<li type="circle">org.apache.samza.serializers.<a href="org/apache/samza/serializers/UUIDSerdeFactory.html" title="class in org.apache.samza.serializers"><span class="typeNameLink">UUIDSerdeFactory</span></a> (implements org.apache.samza.serializers.<a href="org/apache/samza/serializers/SerdeFactory.html" title="interface in org.apache.samza.serializers">SerdeFactory</a><T>)</li>
<li type="circle">org.apache.samza.operators.windows.internal.<a href="org/apache/samza/operators/windows/internal/WindowInternal.html" title="class in org.apache.samza.operators.windows.internal"><span class="typeNameLink">WindowInternal</span></a><M,WK,WV> (implements org.apache.samza.operators.windows.<a href="org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows">Window</a><M,K,WV>)</li>
<li type="circle">org.apache.samza.operators.windows.<a href="org/apache/samza/operators/windows/WindowKey.html" title="class in org.apache.samza.operators.windows"><span class="typeNameLink">WindowKey</span></a><K></li>
<li type="circle">org.apache.samza.operators.windows.<a href="org/apache/samza/operators/windows/WindowPane.html" title="class in org.apache.samza.operators.windows"><span class="typeNameLink">WindowPane</span></a><K,V></li>
@@ -194,6 +224,7 @@
<li type="circle">org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/JoinFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">JoinFunction</span></a><K,M,JM,RM> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a>)</li>
<li type="circle">org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/MapFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">MapFunction</span></a><M,OM> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a>)</li>
<li type="circle">org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/SinkFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">SinkFunction</span></a><M> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a>)</li>
+<li type="circle">org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/StreamTableJoinFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">StreamTableJoinFunction</span></a><K,M,R,JM> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a>)</li>
</ul>
</li>
<li type="circle">org.apache.samza.task.<a href="org/apache/samza/task/ClosableTask.html" title="interface in org.apache.samza.task"><span class="typeNameLink">ClosableTask</span></a></li>
@@ -202,7 +233,7 @@
<li type="circle">org.apache.samza.operators.<a href="org/apache/samza/operators/ContextManager.html" title="interface in org.apache.samza.operators"><span class="typeNameLink">ContextManager</span></a></li>
<li type="circle">org.apache.samza.serializers.<a href="org/apache/samza/serializers/Deserializer.html" title="interface in org.apache.samza.serializers"><span class="typeNameLink">Deserializer</span></a><T>
<ul>
-<li type="circle">org.apache.samza.serializers.<a href="org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers"><span class="typeNameLink">Serde</span></a><T> (also extends org.apache.samza.serializers.<a href="org/apache/samza/serializers/Serializer.html" title="interface in org.apache.samza.serializers">Serializer</a><T>)</li>
+<li type="circle">org.apache.samza.serializers.<a href="org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers"><span class="typeNameLink">Serde</span></a><T> (also extends java.io.Serializable, org.apache.samza.serializers.<a href="org/apache/samza/serializers/Serializer.html" title="interface in org.apache.samza.serializers">Serializer</a><T>)</li>
</ul>
</li>
<li type="circle">org.apache.samza.task.<a href="org/apache/samza/task/EndOfStreamListenerTask.html" title="interface in org.apache.samza.task"><span class="typeNameLink">EndOfStreamListenerTask</span></a></li>
@@ -214,11 +245,13 @@
<li type="circle">org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/JoinFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">JoinFunction</span></a><K,M,JM,RM> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/ClosableFunction.html" title="interface in org.apache.samza.operators.functions">ClosableFunction</a>)</li>
<li type="circle">org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/MapFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">MapFunction</span></a><M,OM> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/ClosableFunction.html" title="interface in org.apache.samza.operators.functions">ClosableFunction</a>)</li>
<li type="circle">org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/SinkFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">SinkFunction</span></a><M> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/ClosableFunction.html" title="interface in org.apache.samza.operators.functions">ClosableFunction</a>)</li>
+<li type="circle">org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/StreamTableJoinFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">StreamTableJoinFunction</span></a><K,M,R,JM> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/ClosableFunction.html" title="interface in org.apache.samza.operators.functions">ClosableFunction</a>)</li>
</ul>
</li>
<li type="circle">org.apache.samza.task.<a href="org/apache/samza/task/InitableTask.html" title="interface in org.apache.samza.task"><span class="typeNameLink">InitableTask</span></a></li>
<li type="circle">java.util.Iterator<E>
<ul>
+<li type="circle">org.apache.samza.storage.kv.<a href="org/apache/samza/storage/kv/ClosableIterator.html" title="interface in org.apache.samza.storage.kv"><span class="typeNameLink">ClosableIterator</span></a><V></li>
<li type="circle">org.apache.samza.storage.kv.<a href="org/apache/samza/storage/kv/KeyValueIterator.html" title="interface in org.apache.samza.storage.kv"><span class="typeNameLink">KeyValueIterator</span></a><K,V></li>
</ul>
</li>
@@ -237,14 +270,20 @@
<li type="circle">org.apache.samza.metrics.<a href="org/apache/samza/metrics/MetricsReporter.html" title="interface in org.apache.samza.metrics"><span class="typeNameLink">MetricsReporter</span></a></li>
<li type="circle">org.apache.samza.metrics.<a href="org/apache/samza/metrics/MetricsReporterFactory.html" title="interface in org.apache.samza.metrics"><span class="typeNameLink">MetricsReporterFactory</span></a></li>
<li type="circle">org.apache.samza.metrics.<a href="org/apache/samza/metrics/MetricsValidator.html" title="interface in org.apache.samza.metrics"><span class="typeNameLink">MetricsValidator</span></a></li>
-<li type="circle">org.apache.samza.operators.<a href="org/apache/samza/operators/OutputStream.html" title="interface in org.apache.samza.operators"><span class="typeNameLink">OutputStream</span></a><K,V,M></li>
+<li type="circle">org.apache.samza.operators.<a href="org/apache/samza/operators/OutputStream.html" title="interface in org.apache.samza.operators"><span class="typeNameLink">OutputStream</span></a><M></li>
<li type="circle">org.apache.samza.runtime.<a href="org/apache/samza/runtime/ProcessorIdGenerator.html" title="interface in org.apache.samza.runtime"><span class="typeNameLink">ProcessorIdGenerator</span></a></li>
<li type="circle">org.apache.samza.metrics.<a href="org/apache/samza/metrics/ReadableMetricsRegistryListener.html" title="interface in org.apache.samza.metrics"><span class="typeNameLink">ReadableMetricsRegistryListener</span></a></li>
<li type="circle">org.apache.samza.metrics.<a href="org/apache/samza/metrics/Reservoir.html" title="interface in org.apache.samza.metrics"><span class="typeNameLink">Reservoir</span></a></li>
+<li type="circle">org.apache.samza.sql.udfs.<a href="org/apache/samza/sql/udfs/ScalarUdf.html" title="interface in org.apache.samza.sql.udfs"><span class="typeNameLink">ScalarUdf</span></a></li>
<li type="circle">org.apache.samza.serializers.<a href="org/apache/samza/serializers/SerdeFactory.html" title="interface in org.apache.samza.serializers"><span class="typeNameLink">SerdeFactory</span></a><T></li>
+<li type="circle">java.io.Serializable
+<ul>
+<li type="circle">org.apache.samza.serializers.<a href="org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers"><span class="typeNameLink">Serde</span></a><T> (also extends org.apache.samza.serializers.<a href="org/apache/samza/serializers/Deserializer.html" title="interface in org.apache.samza.serializers">Deserializer</a><T>, org.apache.samza.serializers.<a href="org/apache/samza/serializers/Serializer.html" title="interface in org.apache.samza.serializers">Serializer</a><T>)</li>
+</ul>
+</li>
<li type="circle">org.apache.samza.serializers.<a href="org/apache/samza/serializers/Serializer.html" title="interface in org.apache.samza.serializers"><span class="typeNameLink">Serializer</span></a><T>
<ul>
-<li type="circle">org.apache.samza.serializers.<a href="org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers"><span class="typeNameLink">Serde</span></a><T> (also extends org.apache.samza.serializers.<a href="org/apache/samza/serializers/Deserializer.html" title="interface in org.apache.samza.serializers">Deserializer</a><T>)</li>
+<li type="circle">org.apache.samza.serializers.<a href="org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers"><span class="typeNameLink">Serde</span></a><T> (also extends org.apache.samza.serializers.<a href="org/apache/samza/serializers/Deserializer.html" title="interface in org.apache.samza.serializers">Deserializer</a><T>, java.io.Serializable)</li>
</ul>
</li>
<li type="circle">org.apache.samza.storage.<a href="org/apache/samza/storage/StorageEngine.html" title="interface in org.apache.samza.storage"><span class="typeNameLink">StorageEngine</span></a></li>
@@ -266,6 +305,23 @@
<li type="circle">org.apache.samza.container.grouper.stream.<a href="org/apache/samza/container/grouper/stream/SystemStreamPartitionGrouper.html" title="interface in org.apache.samza.container.grouper.stream"><span class="typeNameLink">SystemStreamPartitionGrouper</span></a></li>
<li type="circle">org.apache.samza.container.grouper.stream.<a href="org/apache/samza/container/grouper/stream/SystemStreamPartitionGrouperFactory.html" title="interface in org.apache.samza.container.grouper.stream"><span class="typeNameLink">SystemStreamPartitionGrouperFactory</span></a></li>
<li type="circle">org.apache.samza.system.<a href="org/apache/samza/system/SystemStreamPartitionMatcher.html" title="interface in org.apache.samza.system"><span class="typeNameLink">SystemStreamPartitionMatcher</span></a></li>
+<li type="circle">org.apache.samza.table.<a href="org/apache/samza/table/Table.html" title="interface in org.apache.samza.table"><span class="typeNameLink">Table</span></a><R>
+<ul>
+<li type="circle">org.apache.samza.table.<a href="org/apache/samza/table/ReadableTable.html" title="interface in org.apache.samza.table"><span class="typeNameLink">ReadableTable</span></a><K,V>
+<ul>
+<li type="circle">org.apache.samza.table.<a href="org/apache/samza/table/ReadWriteTable.html" title="interface in org.apache.samza.table"><span class="typeNameLink">ReadWriteTable</span></a><K,V></li>
+</ul>
+</li>
+<li type="circle">org.apache.samza.table.<a href="org/apache/samza/table/ReadWriteTable.html" title="interface in org.apache.samza.table"><span class="typeNameLink">ReadWriteTable</span></a><K,V></li>
+</ul>
+</li>
+<li type="circle">org.apache.samza.operators.<a href="org/apache/samza/operators/TableDescriptor.html" title="interface in org.apache.samza.operators"><span class="typeNameLink">TableDescriptor</span></a><K,V,D></li>
+<li type="circle">org.apache.samza.table.<a href="org/apache/samza/table/TableProvider.html" title="interface in org.apache.samza.table"><span class="typeNameLink">TableProvider</span></a>
+<ul>
+<li type="circle">org.apache.samza.table.<a href="org/apache/samza/table/LocalStoreBackedTableProvider.html" title="interface in org.apache.samza.table"><span class="typeNameLink">LocalStoreBackedTableProvider</span></a></li>
+</ul>
+</li>
+<li type="circle">org.apache.samza.table.<a href="org/apache/samza/table/TableProviderFactory.html" title="interface in org.apache.samza.table"><span class="typeNameLink">TableProviderFactory</span></a></li>
<li type="circle">org.apache.samza.task.<a href="org/apache/samza/task/TaskCallback.html" title="interface in org.apache.samza.task"><span class="typeNameLink">TaskCallback</span></a></li>
<li type="circle">org.apache.samza.task.<a href="org/apache/samza/task/TaskContext.html" title="interface in org.apache.samza.task"><span class="typeNameLink">TaskContext</span></a></li>
<li type="circle">org.apache.samza.task.<a href="org/apache/samza/task/TaskCoordinator.html" title="interface in org.apache.samza.task"><span class="typeNameLink">TaskCoordinator</span></a></li>
@@ -274,6 +330,7 @@
<li type="circle">org.apache.samza.operators.triggers.<a href="org/apache/samza/operators/triggers/TimeBasedTrigger.html" title="interface in org.apache.samza.operators.triggers"><span class="typeNameLink">TimeBasedTrigger</span></a><M></li>
</ul>
</li>
+<li type="circle">org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/WatermarkFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">WatermarkFunction</span></a><T></li>
<li type="circle">org.apache.samza.operators.windows.<a href="org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows"><span class="typeNameLink">Window</span></a><M,K,WV></li>
<li type="circle">org.apache.samza.task.<a href="org/apache/samza/task/WindowableTask.html" title="interface in org.apache.samza.task"><span class="typeNameLink">WindowableTask</span></a></li>
</ul>
@@ -289,13 +346,14 @@
<ul>
<li type="circle">java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
<ul>
-<li type="circle">org.apache.samza.job.<a href="org/apache/samza/job/ApplicationStatus.StatusCode.html" title="enum in org.apache.samza.job"><span class="typeNameLink">ApplicationStatus.StatusCode</span></a></li>
-<li type="circle">org.apache.samza.operators.triggers.<a href="org/apache/samza/operators/triggers/DurationCharacteristic.html" title="enum in org.apache.samza.operators.triggers"><span class="typeNameLink">DurationCharacteristic</span></a></li>
-<li type="circle">org.apache.samza.operators.triggers.<a href="org/apache/samza/operators/triggers/FiringType.html" title="enum in org.apache.samza.operators.triggers"><span class="typeNameLink">FiringType</span></a></li>
+<li type="circle">org.apache.samza.task.<a href="org/apache/samza/task/TaskCoordinator.RequestScope.html" title="enum in org.apache.samza.task"><span class="typeNameLink">TaskCoordinator.RequestScope</span></a></li>
+<li type="circle">org.apache.samza.system.<a href="org/apache/samza/system/SystemStreamMetadata.OffsetType.html" title="enum in org.apache.samza.system"><span class="typeNameLink">SystemStreamMetadata.OffsetType</span></a></li>
+<li type="circle">org.apache.samza.system.<a href="org/apache/samza/system/MessageType.html" title="enum in org.apache.samza.system"><span class="typeNameLink">MessageType</span></a></li>
<li type="circle">org.apache.samza.operators.windows.<a href="org/apache/samza/operators/windows/AccumulationMode.html" title="enum in org.apache.samza.operators.windows"><span class="typeNameLink">AccumulationMode</span></a></li>
<li type="circle">org.apache.samza.operators.windows.internal.<a href="org/apache/samza/operators/windows/internal/WindowType.html" title="enum in org.apache.samza.operators.windows.internal"><span class="typeNameLink">WindowType</span></a></li>
-<li type="circle">org.apache.samza.system.<a href="org/apache/samza/system/SystemStreamMetadata.OffsetType.html" title="enum in org.apache.samza.system"><span class="typeNameLink">SystemStreamMetadata.OffsetType</span></a></li>
-<li type="circle">org.apache.samza.task.<a href="org/apache/samza/task/TaskCoordinator.RequestScope.html" title="enum in org.apache.samza.task"><span class="typeNameLink">TaskCoordinator.RequestScope</span></a></li>
+<li type="circle">org.apache.samza.operators.triggers.<a href="org/apache/samza/operators/triggers/FiringType.html" title="enum in org.apache.samza.operators.triggers"><span class="typeNameLink">FiringType</span></a></li>
+<li type="circle">org.apache.samza.operators.triggers.<a href="org/apache/samza/operators/triggers/DurationCharacteristic.html" title="enum in org.apache.samza.operators.triggers"><span class="typeNameLink">DurationCharacteristic</span></a></li>
+<li type="circle">org.apache.samza.job.<a href="org/apache/samza/job/ApplicationStatus.StatusCode.html" title="enum in org.apache.samza.job"><span class="typeNameLink">ApplicationStatus.StatusCode</span></a></li>
</ul>
</li>
</ul>
Modified: samza/site/learn/documentation/latest/api/javadocs/package-list
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/package-list?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/package-list (original)
+++ samza/site/learn/documentation/latest/api/javadocs/package-list Thu Jan 4 00:31:39 2018
@@ -14,9 +14,11 @@ org.apache.samza.operators.windows
org.apache.samza.operators.windows.internal
org.apache.samza.runtime
org.apache.samza.serializers
+org.apache.samza.sql.udfs
org.apache.samza.storage
org.apache.samza.storage.kv
org.apache.samza.system
org.apache.samza.system.chooser
+org.apache.samza.table
org.apache.samza.task
org.apache.samza.util
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=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/serialized-form.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/serialized-form.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>Serialized Form (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>Serialized Form (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="Serialized Form (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="Serialized Form (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
@@ -112,6 +112,119 @@
</ul>
</li>
<li class="blockList">
+<h2 title="Package">Package org.apache.samza.serializers</h2>
+<ul class="blockList">
+<li class="blockList"><a name="org.apache.samza.serializers.ByteBufferSerde">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/samza/serializers/ByteBufferSerde.html" title="class in org.apache.samza.serializers">org.apache.samza.serializers.ByteBufferSerde</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.samza.serializers.ByteSerde">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/samza/serializers/ByteSerde.html" title="class in org.apache.samza.serializers">org.apache.samza.serializers.ByteSerde</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.samza.serializers.DoubleSerde">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/samza/serializers/DoubleSerde.html" title="class in org.apache.samza.serializers">org.apache.samza.serializers.DoubleSerde</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.samza.serializers.IntegerSerde">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/samza/serializers/IntegerSerde.html" title="class in org.apache.samza.serializers">org.apache.samza.serializers.IntegerSerde</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.samza.serializers.JsonSerdeV2">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/samza/serializers/JsonSerdeV2.html" title="class in org.apache.samza.serializers">org.apache.samza.serializers.JsonSerdeV2</a> extends java.lang.Object implements Serializable</h3>
+<ul class="blockList">
+<li class="blockList">
+<h3>Serialization Methods</h3>
+<ul class="blockList">
+<li class="blockListLast">
+<h4>readObject</h4>
+<pre>private void readObject(java.io.ObjectInputStream in)
+ throws java.io.IOException,
+ java.lang.ClassNotFoundException</pre>
+<dl>
+<dt><span class="throwsLabel">Throws:</span></dt>
+<dd><code>java.io.IOException</code></dd>
+<dd><code>java.lang.ClassNotFoundException</code></dd>
+</dl>
+</li>
+</ul>
+</li>
+<li class="blockList">
+<h3>Serialized Fields</h3>
+<ul class="blockList">
+<li class="blockListLast">
+<h4>clazz</h4>
+<pre>java.lang.Class<T> clazz</pre>
+</li>
+</ul>
+</li>
+</ul>
+</li>
+<li class="blockList"><a name="org.apache.samza.serializers.KVSerde">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/samza/serializers/KVSerde.html" title="class in org.apache.samza.serializers">org.apache.samza.serializers.KVSerde</a> extends java.lang.Object implements Serializable</h3>
+<ul class="blockList">
+<li class="blockList">
+<h3>Serialized Fields</h3>
+<ul class="blockList">
+<li class="blockList">
+<h4>keySerde</h4>
+<pre><a href="org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><<a href="org/apache/samza/serializers/Serde.html" title="type parameter in Serde">T</a>> keySerde</pre>
+</li>
+<li class="blockListLast">
+<h4>valueSerde</h4>
+<pre><a href="org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><<a href="org/apache/samza/serializers/Serde.html" title="type parameter in Serde">T</a>> valueSerde</pre>
+</li>
+</ul>
+</li>
+</ul>
+</li>
+<li class="blockList"><a name="org.apache.samza.serializers.LongSerde">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/samza/serializers/LongSerde.html" title="class in org.apache.samza.serializers">org.apache.samza.serializers.LongSerde</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.samza.serializers.NoOpSerde">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/samza/serializers/NoOpSerde.html" title="class in org.apache.samza.serializers">org.apache.samza.serializers.NoOpSerde</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.samza.serializers.SerializableSerde">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/samza/serializers/SerializableSerde.html" title="class in org.apache.samza.serializers">org.apache.samza.serializers.SerializableSerde</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.samza.serializers.StringSerde">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/samza/serializers/StringSerde.html" title="class in org.apache.samza.serializers">org.apache.samza.serializers.StringSerde</a> extends java.lang.Object implements Serializable</h3>
+<ul class="blockList">
+<li class="blockList">
+<h3>Serialized Fields</h3>
+<ul class="blockList">
+<li class="blockListLast">
+<h4>encoding</h4>
+<pre>java.lang.String encoding</pre>
+</li>
+</ul>
+</li>
+</ul>
+</li>
+<li class="blockList"><a name="org.apache.samza.serializers.UUIDSerde">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/samza/serializers/UUIDSerde.html" title="class in org.apache.samza.serializers">org.apache.samza.serializers.UUIDSerde</a> extends java.lang.Object implements Serializable</h3>
+</li>
+</ul>
+</li>
+<li class="blockList">
<h2 title="Package">Package org.apache.samza.system</h2>
<ul class="blockList">
<li class="blockList"><a name="org.apache.samza.system.StreamValidationException">
@@ -121,6 +234,15 @@
<dl class="nameValue">
<dt>serialVersionUID:</dt>
<dd>1L</dd>
+</dl>
+</li>
+<li class="blockList"><a name="org.apache.samza.system.SystemProducerException">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/samza/system/SystemProducerException.html" title="class in org.apache.samza.system">org.apache.samza.system.SystemProducerException</a> extends <a href="org/apache/samza/SamzaException.html" title="class in org.apache.samza">SamzaException</a> implements Serializable</h3>
+<dl class="nameValue">
+<dt>serialVersionUID:</dt>
+<dd>1L</dd>
</dl>
</li>
</ul>
Modified: samza/site/learn/documentation/latest/api/overview.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/overview.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/overview.html (original)
+++ samza/site/learn/documentation/latest/api/overview.html Thu Jan 4 00:31:39 2018
@@ -46,7 +46,7 @@
- <a href="http://samza.apache.org/learn/documentation/0.13/api/overview.html"><i id="switch-version-button"></i></a>
+ <a href="http://samza.apache.org/learn/documentation/0.14/api/overview.html"><i id="switch-version-button"></i></a>
<!-- links for the navigation bar -->
@@ -99,6 +99,7 @@
<h1><i class="fa fa-history"></i> Archive</h1>
<ul>
<li><a href="/archive/index.html#latest">latest</a></li>
+ <li><a href="/archive/index.html#14">0.14</a></li>
<li><a href="/archive/index.html#13">0.13</a></li>
<li><a href="/archive/index.html#12">0.12</a></li>
<li><a href="/archive/index.html#11">0.11</a></li>
@@ -291,7 +292,7 @@
<script>
$( document ).ready(function() {
- if ( $.fn.urlExists( "/learn/documentation/0.13/api/overview.html" ) ) {
+ if ( $.fn.urlExists( "/learn/documentation/0.14/api/overview.html" ) ) {
$("#switch-version-button").addClass("fa fa-history masthead-icon");
}
});
Added: samza/site/learn/documentation/latest/aws/kinesis.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/aws/kinesis.html?rev=1820026&view=auto
==============================================================================
--- samza/site/learn/documentation/latest/aws/kinesis.html (added)
+++ samza/site/learn/documentation/latest/aws/kinesis.html Thu Jan 4 00:31:39 2018
@@ -0,0 +1,271 @@
+<!DOCTYPE html>
+<!--
+ Licensed to the Apache Software Foundation (ASF) under one or more
+ contributor license agreements. See the NOTICE file distributed with
+ this work for additional information regarding copyright ownership.
+ The ASF licenses this file to You under the Apache License, Version 2.0
+ (the "License"); you may not use this file except in compliance with
+ the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+-->
+<html lang="en">
+ <head>
+ <meta charset="utf-8">
+ <title>Samza - Connecting to Kinesis</title>
+ <link href='/css/ropa-sans.css' rel='stylesheet' type='text/css'/>
+ <link href="/css/bootstrap.min.css" rel="stylesheet"/>
+ <link href="/css/font-awesome.min.css" rel="stylesheet"/>
+ <link href="/css/main.css" rel="stylesheet"/>
+ <link href="/css/syntax.css" rel="stylesheet"/>
+ <link rel="icon" type="image/png" href="/img/samza-icon.png">
+ <script src="/js/jquery-1.11.1.min.js"></script>
+ </head>
+ <body>
+ <div class="wrapper">
+ <div class="wrapper-content">
+
+ <div class="masthead">
+ <div class="container">
+ <div class="masthead-logo">
+ <a href="/" class="logo">samza</a>
+ </div>
+ <div class="masthead-icons">
+ <div class="pull-right">
+ <a href="/startup/download"><i class="fa fa-arrow-circle-o-down masthead-icon"></i></a>
+ <a href="https://git-wip-us.apache.org/repos/asf?p=samza.git;a=tree" target="_blank"><i class="fa fa-code masthead-icon" style="font-weight: bold;"></i></a>
+ <a href="https://twitter.com/samzastream" target="_blank"><i class="fa fa-twitter masthead-icon"></i></a>
+ <!-- this icon only shows in versioned pages -->
+
+
+
+
+ <a href="http://samza.apache.org/learn/documentation/0.14/aws/kinesis.html"><i id="switch-version-button"></i></a>
+ <!-- links for the navigation bar -->
+
+
+ </div>
+ </div>
+ </div><!-- /.container -->
+ </div>
+
+ <div class="container">
+ <div class="menu">
+ <h1><i class="fa fa-rocket"></i> Getting Started</h1>
+ <ul>
+ <li><a href="/startup/hello-samza/latest">Hello Samza</a></li>
+ <li><a href="/startup/download">Download</a></li>
+ <li><a href="/startup/preview">Feature Preview</a></li>
+ </ul>
+
+ <h1><i class="fa fa-book"></i> Learn</h1>
+ <ul>
+ <li><a href="/learn/documentation/latest">Documentation</a></li>
+ <li><a href="/learn/documentation/latest/jobs/configuration-table.html">Configuration</a></li>
+ <li><a href="/learn/documentation/latest/container/metrics-table.html">Metrics</a></li>
+ <li><a href="/learn/documentation/latest/api/javadocs/">Javadocs</a></li>
+ <li><a href="/learn/tutorials/latest">Tutorials</a></li>
+ <li><a href="https://cwiki.apache.org/confluence/display/SAMZA/FAQ">FAQ</a></li>
+ <li><a href="https://cwiki.apache.org/confluence/display/SAMZA/Apache+Samza">Wiki</a></li>
+ <li><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=51812876">Papers & Talks</a></li>
+ <li><a href="http://blogs.apache.org/samza">Blog</a></li>
+ </ul>
+
+ <h1><i class="fa fa-comments"></i> Community</h1>
+ <ul>
+ <li><a href="/community/mailing-lists.html">Mailing Lists</a></li>
+ <li><a href="/community/irc.html">IRC</a></li>
+ <li><a href="https://issues.apache.org/jira/browse/SAMZA">Bugs</a></li>
+ <li><a href="https://cwiki.apache.org/confluence/display/SAMZA/Powered+By">Powered by</a></li>
+ <li><a href="https://cwiki.apache.org/confluence/display/SAMZA/Ecosystem">Ecosystem</a></li>
+ <li><a href="/community/committers.html">Committers</a></li>
+ </ul>
+
+ <h1><i class="fa fa-code"></i> Contribute</h1>
+ <ul>
+ <li><a href="/contribute/contributors-corner.html">Contributor's Corner</a></li>
+ <li><a href="/contribute/coding-guide.html">Coding Guide</a></li>
+ <li><a href="/contribute/design-documents.html">Design Documents</a></li>
+ <li><a href="/contribute/code.html">Code</a></li>
+ <li><a href="/contribute/tests.html">Tests</a></li>
+ </ul>
+
+ <h1><i class="fa fa-history"></i> Archive</h1>
+ <ul>
+ <li><a href="/archive/index.html#latest">latest</a></li>
+ <li><a href="/archive/index.html#14">0.14</a></li>
+ <li><a href="/archive/index.html#13">0.13</a></li>
+ <li><a href="/archive/index.html#12">0.12</a></li>
+ <li><a href="/archive/index.html#11">0.11</a></li>
+ <li><a href="/archive/index.html#10">0.10</a></li>
+ <li><a href="/archive/index.html#09">0.9</a></li>
+ <li><a href="/archive/index.html#08">0.8</a></li>
+ <li><a href="/archive/index.html#07">0.7</a></li>
+ </ul>
+ </div>
+
+ <div class="content">
+ <!--
+ Licensed to the Apache Software Foundation (ASF) under one or more
+ contributor license agreements. See the NOTICE file distributed with
+ this work for additional information regarding copyright ownership.
+ The ASF licenses this file to You under the Apache License, Version 2.0
+ (the "License"); you may not use this file except in compliance with
+ the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+-->
+
+<h2>Connecting to Kinesis</h2>
+
+<!--
+ Licensed to the Apache Software Foundation (ASF) under one or more
+ contributor license agreements. See the NOTICE file distributed with
+ this work for additional information regarding copyright ownership.
+ The ASF licenses this file to You under the Apache License, Version 2.0
+ (the "License"); you may not use this file except in compliance with
+ the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+-->
+
+<p>You can configure your Samza jobs to process data from <a href="https://aws.amazon.com/kinesis/data-streams">AWS Kinesis</a>, Amazon’s data streaming service. A <code>Kinesis data stream</code> is similar to a Kafka topic and can have multiple partitions. Each message consumed from a Kinesis data stream is an instance of <a href="http://docs.aws.amazon.com/goto/WebAPI/kinesis-2013-12-02/Record">Record</a>.</p>
+
+<h3 id="consuming-from-kinesis:">Consuming from Kinesis:</h3>
+
+<p>Samza’s <a href="https://github.com/apache/samza/blob/master/samza-aws/src/main/java/org/apache/samza/system/kinesis/consumer/KinesisSystemConsumer.java">KinesisSystemConsumer</a> wraps the Record into a <a href="https://github.com/apache/samza/blob/master/samza-aws/src/main/java/org/apache/samza/system/kinesis/consumer/KinesisIncomingMessageEnvelope.java">KinesisIncomingMessageEnvelope</a>. The key of the message is set to partition key of the Record. The message is obtained from the Record body.</p>
+
+<p>To configure Samza to consume from Kinesis streams:</p>
+
+<div class="highlight"><pre><code class="jproperties"><span class="c"># define a kinesis system factory with your identifier. eg: kinesis-system</span>
+<span class="na">systems.kinesis-system.samza.factory</span><span class="o">=</span><span class="s">org.apache.samza.system.eventhub.KinesisSystemFactory</span>
+
+<span class="c"># kinesis system consumer works with only AllSspToSingleTaskGrouperFactory</span>
+<span class="na">job.systemstreampartition.grouper.factory</span><span class="o">=</span><span class="s">org.apache.samza.container.grouper.stream.AllSspToSingleTaskGrouperFactory</span>
+
+<span class="c"># define your streams</span>
+<span class="na">task.inputs</span><span class="o">=</span><span class="s">kinesis-system.input0</span>
+
+<span class="c"># define required properties for your streams</span>
+<span class="na">systems.kinesis-system.streams.input0.aws.region</span><span class="o">=</span><span class="s">YOUR-STREAM-REGION</span>
+<span class="na">systems.kinesis-system.streams.input0.aws.accessKey</span><span class="o">=</span><span class="s">YOUR-ACCESS_KEY</span>
+<span class="na">sensitive.systems.kinesis-system.streams.input0.aws.secretKey</span><span class="o">=</span><span class="s">YOUR-SECRET-KEY</span></code></pre></div>
+
+<p>The tuple required to access the Kinesis data stream must be provided, namely the fields <code>YOUR-STREAM-REGION</code>, <code>YOUR-ACCESS-KEY</code>, <code>YOUR-SECRET-KEY</code>.</p>
+
+<h4 id="advanced-configuration:">Advanced Configuration:</h4>
+
+<h5 id="aws-client-configs:">AWS Client Configs:</h5>
+
+<p>You can configure any <a href="http://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/ClientConfiguration.html">AWS client config</a> with the prefix <code>system.system-name.aws.clientConfig.*</code></p>
+
+<div class="highlight"><pre><code class="jproperties"><span class="na">system.system-name.aws.clientConfig.CONFIG-NAME</span><span class="o">=</span><span class="s">CONFIG-VALUE</span></code></pre></div>
+
+<p>As an example, to set a proxy host and proxy port for the AWS Client:</p>
+
+<div class="highlight"><pre><code class="jproperties"><span class="na">systems.system-name.aws.clientConfig.ProxyHost</span><span class="o">=</span><span class="s">my-proxy-host.com</span>
+<span class="na">systems.system-name.aws.clientConfig.ProxyPort</span><span class="o">=</span><span class="s">my-proxy-port</span></code></pre></div>
+
+<h5 id="kcl-configs:">KCL Configs:</h5>
+
+<p>Similarly, you can set any <a href="https://github.com/awslabs/amazon-kinesis-client/blob/master/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/KinesisClientLibConfiguration.java">Kinesis Client Library config</a> for a stream by configuring it under <code>systems.system-name.streams.stream-name.aws.kcl.*</code></p>
+
+<div class="highlight"><pre><code class="jproperties"><span class="na">systems.system-name.streams.stream-name.aws.kcl.CONFIG-NAME</span><span class="o">=</span><span class="s">CONFIG-VALUE</span></code></pre></div>
+
+<p>As an example, to reset the checkpoint and set the starting position for a stream:</p>
+
+<div class="highlight"><pre><code class="jproperties"><span class="na">systems.kinesis-system.streams.input0.aws.kcl.TableName</span><span class="o">=</span><span class="s">my-app-table-name</span>
+<span class="c"># set the starting position to either TRIM_HORIZON (oldest) or LATEST (latest)</span>
+<span class="na">systems.kinesis-system.streams.input0.aws.kcl.InitialPositionInStream</span><span class="o">=</span><span class="s">my-start-position</span></code></pre></div>
+
+<h4 id="limitations">Limitations</h4>
+
+<p>The following limitations apply for Samza jobs consuming from Kinesis streams using the Samza consumer:
+* Stateful processing (eg: windows or joins) is not supported on Kinesis streams. However, you can accomplish this by chaining two Samza jobs where the first job reads from Kinesis and sends to Kafka while the second job processes the data from Kafka.
+* Kinesis streams cannot be configured as <a href="https://samza.apache.org/learn/documentation/latest/container/streams.html">bootstrap</a> or <a href="https://samza.apache.org/learn/documentation/latest/container/samza-container.html">broadcast</a> streams.
+* Kinesis streams must be used with the <a href="https://github.com/apache/samza/blob/master/samza-core/src/main/java/org/apache/samza/container/grouper/stream/AllSspToSingleTaskGrouperFactory.java">AllSspToSingleTaskGrouperFactory</a>. No other grouper is supported.
+* A Samza job that consumes from Kinesis cannot consume from any other input source. However, you can send your results to any destination (eg: Kafka, EventHubs), and have another Samza job consume them.</p>
+
+<h3 id="producing-to-kinesis:">Producing to Kinesis:</h3>
+
+<p>The KinesisSystemProducer for Samza is not yet implemented.</p>
+
+<h3 id="how-to-configure-samza-job-to-consume-from-kinesis-data-stream-?">How to configure Samza job to consume from Kinesis data stream ?</h3>
+
+<p>This tutorial uses <a href="../../../startup/hello-samza/latest/">hello samza</a> to illustrate running a Samza job on Yarn that consumes from Kinesis. We will use the <a href="https://github.com/apache/samza-hello-samza/blob/master/src/main/java/samza/examples/kinesis/KinesisHelloSamza.java">KinesisHelloSamza</a> example.</p>
+
+<h4 id="update-properties-file">Update properties file</h4>
+
+<p>Update the following properties in the kinesis-hello-samza.properties file:</p>
+
+<div class="highlight"><pre><code class="jproperties"><span class="na">task.inputs</span><span class="o">=</span><span class="s">kinesis.<kinesis-stream></span>
+<span class="na">systems.kinesis.streams.<kinesis-stream>.aws.region</span><span class="o">=</span><span class="s"><kinesis-stream-region></span>
+<span class="na">systems.kinesis.streams.<kinesis-stream>.aws.accessKey</span><span class="o">=</span><span class="s"><your-access-key></span>
+<span class="na">sensitive.systems.kinesis.streams.<kinesis-stream>.aws.region</span><span class="o">=</span><span class="s"><your-secret-key></span></code></pre></div>
+
+<p>Now, you are ready to run your Samza application on Yarn as described <a href="../../../startup/hello-samza/latest/">here</a>. Check the log file for messages read from your Kinesis stream.</p>
+
+
+ </div>
+ </div>
+
+ </div><!-- /.wrapper-content -->
+ </div><!-- /.wrapper -->
+
+ <div class="footer">
+ <div class="container">
+ <!-- nothing for now. -->
+ </div>
+ </div>
+
+
+ <script>
+ $( document ).ready(function() {
+ if ( $.fn.urlExists( "/learn/documentation/0.14/aws/kinesis.html" ) ) {
+ $("#switch-version-button").addClass("fa fa-history masthead-icon");
+ }
+ });
+
+ /* a function to test whether the url exists or not */
+ (function( $ ) {
+ $.fn.urlExists = function(url) {
+ var http = new XMLHttpRequest();
+ http.open('HEAD', url, false);
+ http.send();
+ return http.status != 404;
+ };
+ }( jQuery ));
+ </script>
+
+
+ <!-- Google Analytics -->
+ <script>
+ (function(i,s,o,g,r,a,m){i['GoogleAnalyticsObject']=r;i[r]=i[r]||function(){
+ (i[r].q=i[r].q||[]).push(arguments)},i[r].l=1*new Date();a=s.createElement(o),
+ m=s.getElementsByTagName(o)[0];a.async=1;a.src=g;m.parentNode.insertBefore(a,m)
+ })(window,document,'script','//www.google-analytics.com/analytics.js','ga');
+
+ ga('create', 'UA-43122768-1', 'apache.org');
+ ga('send', 'pageview');
+
+ </script>
+ </body>
+</html>