Modified: samza/site/learn/documentation/latest/api/javadocs/index-all.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/index-all.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/index-all.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/index-all.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:02:53 PST 2018 --> -<title>Index (samza-api 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Thu May 24 12:04:07 PDT 2018 --> +<title>Index (samza-api 0.14.1 API)</title> +<meta name="date" content="2018-05-24"> <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="Index (samza-api 0.14.1-SNAPSHOT API)"; + parent.document.title="Index (samza-api 0.14.1 API)"; } } catch(err) { @@ -77,6 +77,26 @@ <dd> <div class="block">Specifies how a <a href="org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows"><code>Window</code></a> should process its previously emitted <a href="org/apache/samza/operators/windows/WindowPane.html" title="class in org.apache.samza.operators.windows"><code>WindowPane</code></a>s.</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/util/RateLimiter.html#acquire-int-">acquire(int)</a></span> - Method in interface org.apache.samza.util.<a href="org/apache/samza/util/RateLimiter.html" title="interface in org.apache.samza.util">RateLimiter</a></dt> +<dd> +<div class="block">Attempt to acquire the provided number of credits, blocks indefinitely until + all requested credits become available.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/util/RateLimiter.html#acquire-int-long-java.util.concurrent.TimeUnit-">acquire(int, long, TimeUnit)</a></span> - Method in interface org.apache.samza.util.<a href="org/apache/samza/util/RateLimiter.html" title="interface in org.apache.samza.util">RateLimiter</a></dt> +<dd> +<div class="block">Attempt to acquire the provided number of credits, blocks for up to provided amount of + time for credits to become available.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/util/RateLimiter.html#acquire-java.util.Map-">acquire(Map<String, Integer>)</a></span> - Method in interface org.apache.samza.util.<a href="org/apache/samza/util/RateLimiter.html" title="interface in org.apache.samza.util">RateLimiter</a></dt> +<dd> +<div class="block">Attempt to acquire the provided number of credits for a number of tags, blocks indefinitely + until all requested credits become available</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/util/RateLimiter.html#acquire-java.util.Map-long-java.util.concurrent.TimeUnit-">acquire(Map<String, Integer>, long, TimeUnit)</a></span> - Method in interface org.apache.samza.util.<a href="org/apache/samza/util/RateLimiter.html" title="interface in org.apache.samza.util">RateLimiter</a></dt> +<dd> +<div class="block">Attempt to acquire the provided number of credits for a number of tags, blocks for up to provided amount of + time for credits to become available.</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/storage/kv/KeyValueStore.html#all--">all()</a></span> - Method in interface org.apache.samza.storage.kv.<a href="org/apache/samza/storage/kv/KeyValueStore.html" title="interface in org.apache.samza.storage.kv">KeyValueStore</a></dt> <dd> <div class="block">Returns an iterator for all entries in this key-value store.</div> @@ -180,6 +200,14 @@ <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/util/BlockingEnvelopeMap.BlockingEnvelopeMapMetrics.html#BlockingEnvelopeMapMetrics-java.lang.String-org.apache.samza.metrics.MetricsRegistry-">BlockingEnvelopeMapMetrics(String, MetricsRegistry)</a></span> - Constructor for class org.apache.samza.util.<a href="org/apache/samza/util/BlockingEnvelopeMap.BlockingEnvelopeMapMetrics.html" title="class in org.apache.samza.util">BlockingEnvelopeMap.BlockingEnvelopeMapMetrics</a></dt> <dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/operators/MessageStream.html#broadcast-org.apache.samza.serializers.Serde-java.lang.String-">broadcast(Serde<M>, String)</a></span> - Method in interface org.apache.samza.operators.<a href="org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators">MessageStream</a></dt> +<dd> +<div class="block">Broadcasts messages in this <a href="org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> to all instances of its downstream operators..</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/operators/MessageStream.html#broadcast-java.lang.String-">broadcast(String)</a></span> - Method in interface org.apache.samza.operators.<a href="org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators">MessageStream</a></dt> +<dd> +<div class="block">Same as calling <a href="org/apache/samza/operators/MessageStream.html#broadcast-org.apache.samza.serializers.Serde-java.lang.String-"><code>MessageStream.broadcast(Serde, String)</code></a> with a null Serde.</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/util/BlockingEnvelopeMap.BufferGauge.html#BufferGauge-org.apache.samza.system.SystemStreamPartition-java.lang.String-">BufferGauge(SystemStreamPartition, String)</a></span> - Constructor for class org.apache.samza.util.<a href="org/apache/samza/util/BlockingEnvelopeMap.BufferGauge.html" title="class in org.apache.samza.util">BlockingEnvelopeMap.BufferGauge</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/util/BlockingEnvelopeMap.BufferSizeGauge.html#BufferSizeGauge-org.apache.samza.system.SystemStreamPartition-java.lang.String-">BufferSizeGauge(SystemStreamPartition, String)</a></span> - Constructor for class org.apache.samza.util.<a href="org/apache/samza/util/BlockingEnvelopeMap.BufferSizeGauge.html" title="class in org.apache.samza.util">BlockingEnvelopeMap.BufferSizeGauge</a></dt> @@ -259,7 +287,7 @@ </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/system/SystemAdmin.html#clearStream-org.apache.samza.system.StreamSpec-">clearStream(StreamSpec)</a></span> - Method in interface org.apache.samza.system.<a href="org/apache/samza/system/SystemAdmin.html" title="interface in org.apache.samza.system">SystemAdmin</a></dt> <dd> -<div class="block">Clear the stream described by the spec.</div> +<div class="block">Clear the entire stream described by the spec.</div> </dd> <dt><a href="org/apache/samza/util/Clock.html" title="interface in org.apache.samza.util"><span class="typeNameLink">Clock</span></a> - Interface in <a href="org/apache/samza/util/package-summary.html">org.apache.samza.util</a></dt> <dd> @@ -291,6 +319,10 @@ </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/storage/kv/KeyValueIterator.html#close--">close()</a></span> - Method in interface org.apache.samza.storage.kv.<a href="org/apache/samza/storage/kv/KeyValueIterator.html" title="interface in org.apache.samza.storage.kv">KeyValueIterator</a></dt> <dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/storage/kv/KeyValueSnapshot.html#close--">close()</a></span> - Method in interface org.apache.samza.storage.kv.<a href="org/apache/samza/storage/kv/KeyValueSnapshot.html" title="interface in org.apache.samza.storage.kv">KeyValueSnapshot</a></dt> +<dd> +<div class="block">Closes this snapshot releasing any associated resources.</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/storage/kv/KeyValueStore.html#close--">close()</a></span> - Method in interface org.apache.samza.storage.kv.<a href="org/apache/samza/storage/kv/KeyValueStore.html" title="interface in org.apache.samza.storage.kv">KeyValueStore</a></dt> <dd> <div class="block">Closes this key-value store, if applicable, relinquishing any underlying resources.</div> @@ -299,6 +331,10 @@ <dd> <div class="block">Close the table and release any resources acquired</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/TableProvider.html#close--">close()</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/TableProvider.html" title="interface in org.apache.samza.table">TableProvider</a></dt> +<dd> +<div class="block">Shutdown the underlying table</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/task/ClosableTask.html#close--">close()</a></span> - Method in interface org.apache.samza.task.<a href="org/apache/samza/task/ClosableTask.html" title="interface in org.apache.samza.task">ClosableTask</a></dt> <dd> </dd> <dt><a href="org/apache/samza/job/CommandBuilder.html" title="class in org.apache.samza.job"><span class="typeNameLink">CommandBuilder</span></a> - Class in <a href="org/apache/samza/job/package-summary.html">org.apache.samza.job</a></dt> @@ -378,6 +414,8 @@ </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/system/ControlMessage.html#ControlMessage-java.lang.String-">ControlMessage(String)</a></span> - Constructor for class org.apache.samza.system.<a href="org/apache/samza/system/ControlMessage.html" title="class in org.apache.samza.system">ControlMessage</a></dt> <dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/system/StreamSpec.html#copyWithBroadCast--">copyWithBroadCast()</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/StreamSpec.html" title="class in org.apache.samza.system">StreamSpec</a></dt> +<dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/system/StreamSpec.html#copyWithPartitionCount-int-">copyWithPartitionCount(int)</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/StreamSpec.html" title="class in org.apache.samza.system">StreamSpec</a></dt> <dd> <div class="block">Copies this StreamSpec, but applies a new partitionCount.</div> @@ -412,10 +450,16 @@ <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/task/StreamTaskFactory.html#createInstance--">createInstance()</a></span> - Method in interface org.apache.samza.task.<a href="org/apache/samza/task/StreamTaskFactory.html" title="interface in org.apache.samza.task">StreamTaskFactory</a></dt> <dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/checkpoint/CheckpointManager.html#createResources--">createResources()</a></span> - Method in interface org.apache.samza.checkpoint.<a href="org/apache/samza/checkpoint/CheckpointManager.html" title="interface in org.apache.samza.checkpoint">CheckpointManager</a></dt> +<dd> +<div class="block">Creates checkpoint stream.</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/system/SystemAdmin.html#createStream-org.apache.samza.system.StreamSpec-">createStream(StreamSpec)</a></span> - Method in interface org.apache.samza.system.<a href="org/apache/samza/system/SystemAdmin.html" title="interface in org.apache.samza.system">SystemAdmin</a></dt> <dd> <div class="block">Create a stream described by the spec.</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/system/StreamSpec.html#createStreamAppenderStreamSpec-java.lang.String-java.lang.String-int-">createStreamAppenderStreamSpec(String, String, int)</a></span> - Static method in class org.apache.samza.system.<a href="org/apache/samza/system/StreamSpec.html" title="class in org.apache.samza.system">StreamSpec</a></dt> +<dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/util/Clock.html#currentTimeMillis--">currentTimeMillis()</a></span> - Method in interface org.apache.samza.util.<a href="org/apache/samza/util/Clock.html" title="interface in org.apache.samza.util">Clock</a></dt> <dd> </dd> </dl> @@ -428,6 +472,10 @@ <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/metrics/Counter.html#dec-long-">dec(long)</a></span> - Method in class org.apache.samza.metrics.<a href="org/apache/samza/metrics/Counter.html" title="class in org.apache.samza.metrics">Counter</a></dt> <dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/operators/TimerRegistry.html#delete-K-">delete(K)</a></span> - Method in interface org.apache.samza.operators.<a href="org/apache/samza/operators/TimerRegistry.html" title="interface in org.apache.samza.operators">TimerRegistry</a></dt> +<dd> +<div class="block">Delete the timer for the provided key.</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/storage/kv/KeyValueStore.html#delete-K-">delete(K)</a></span> - Method in interface org.apache.samza.storage.kv.<a href="org/apache/samza/storage/kv/KeyValueStore.html" title="interface in org.apache.samza.storage.kv">KeyValueStore</a></dt> <dd> <div class="block">Deletes the mapping for the specified <code>key</code> from this key-value store (if such mapping exists).</div> @@ -444,6 +492,14 @@ <dd> <div class="block">Deletes the mappings for the specified <code>keys</code> from this table.</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/system/SystemAdmin.html#deleteMessages-java.util.Map-">deleteMessages(Map<SystemStreamPartition, String>)</a></span> - Method in interface org.apache.samza.system.<a href="org/apache/samza/system/SystemAdmin.html" title="interface in org.apache.samza.system">SystemAdmin</a></dt> +<dd> +<div class="block">Delete records up to (and including) the provided ssp offsets for all system stream partitions specified in the map</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/task/TaskContext.html#deleteTimer-K-">deleteTimer(K)</a></span> - Method in interface org.apache.samza.task.<a href="org/apache/samza/task/TaskContext.html" title="interface in org.apache.samza.task">TaskContext</a></dt> +<dd> +<div class="block">Delete the keyed timer in this task.</div> +</dd> <dt><a href="org/apache/samza/serializers/Deserializer.html" title="interface in org.apache.samza.serializers"><span class="typeNameLink">Deserializer</span></a><<a href="org/apache/samza/serializers/Deserializer.html" title="type parameter in Deserializer">T</a>> - Interface in <a href="org/apache/samza/serializers/package-summary.html">org.apache.samza.serializers</a></dt> <dd> <div class="block">A standard interface for Samza compatible deserializers, used for deserializing serialized objects back to their @@ -984,6 +1040,10 @@ <dd> <div class="block">Get the sum of values in the collection</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/util/RateLimiter.html#getSupportedTags--">getSupportedTags()</a></span> - Method in interface org.apache.samza.util.<a href="org/apache/samza/util/RateLimiter.html" title="interface in org.apache.samza.util">RateLimiter</a></dt> +<dd> +<div class="block">Get the entire set of tags for which we have configured credits for rate limiting.</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/system/SystemStream.html#getSystem--">getSystem()</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/SystemStream.html" title="class in org.apache.samza.system">SystemStream</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/system/StreamSpec.html#getSystemName--">getSystemName()</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/StreamSpec.html" title="class in org.apache.samza.system">StreamSpec</a></dt> @@ -1173,14 +1233,22 @@ <dd> <div class="block">Udfs can implement this method to perform any initialization that they may need.</div> </dd> -<dt><span class="memberNameLink"><a href="org/apache/samza/table/LocalStoreBackedTableProvider.html#init-org.apache.samza.storage.StorageEngine-">init(StorageEngine)</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/LocalStoreBackedTableProvider.html" title="interface in org.apache.samza.table">LocalStoreBackedTableProvider</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/ReadableTable.html#init-org.apache.samza.container.SamzaContainerContext-org.apache.samza.task.TaskContext-">init(SamzaContainerContext, TaskContext)</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/ReadableTable.html" title="interface in org.apache.samza.table">ReadableTable</a></dt> +<dd> +<div class="block">Initializes the table during container initialization.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/TableProvider.html#init-org.apache.samza.container.SamzaContainerContext-org.apache.samza.task.TaskContext-">init(SamzaContainerContext, TaskContext)</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/TableProvider.html" title="interface in org.apache.samza.table">TableProvider</a></dt> <dd> -<div class="block">Initializes the table provider with the backing store</div> +<div class="block">Initialize TableProvider with container and task context</div> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/task/InitableTask.html#init-org.apache.samza.config.Config-org.apache.samza.task.TaskContext-">init(Config, TaskContext)</a></span> - Method in interface org.apache.samza.task.<a href="org/apache/samza/task/InitableTask.html" title="interface in org.apache.samza.task">InitableTask</a></dt> <dd> <div class="block">Called by TaskRunner each time an implementing task is created.</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/util/RateLimiter.html#init-org.apache.samza.config.Config-org.apache.samza.task.TaskContext-">init(Config, TaskContext)</a></span> - Method in interface org.apache.samza.util.<a href="org/apache/samza/util/RateLimiter.html" title="interface in org.apache.samza.util">RateLimiter</a></dt> +<dd> +<div class="block">Initialize this rate limiter, this method should be called during container initialization.</div> +</dd> <dt><a href="org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">InitableFunction</span></a> - Interface in <a href="org/apache/samza/operators/functions/package-summary.html">org.apache.samza.operators.functions</a></dt> <dd> <div class="block">A function that can be initialized before execution.</div> @@ -1227,6 +1295,8 @@ <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/system/StreamSpec.html#isBounded--">isBounded()</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/StreamSpec.html" title="class in org.apache.samza.system">StreamSpec</a></dt> <dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/system/StreamSpec.html#isBroadcast--">isBroadcast()</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/StreamSpec.html" title="class in org.apache.samza.system">StreamSpec</a></dt> +<dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/system/StreamSpec.html#isChangeLogStream--">isChangeLogStream()</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/StreamSpec.html" title="class in org.apache.samza.system">StreamSpec</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/system/StreamSpec.html#isCoordinatorStream--">isCoordinatorStream()</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/StreamSpec.html" title="class in org.apache.samza.system">StreamSpec</a></dt> @@ -1243,6 +1313,10 @@ <dd> <div class="block">Flag to indicate whether a store can be persisted to disk or not</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/storage/kv/KeyValueSnapshot.html#iterator--">iterator()</a></span> - Method in interface org.apache.samza.storage.kv.<a href="org/apache/samza/storage/kv/KeyValueSnapshot.html" title="interface in org.apache.samza.storage.kv">KeyValueSnapshot</a></dt> +<dd> +<div class="block">Creates a new iterator for this snapshot.</div> +</dd> </dl> <a name="I:J"> <!-- --> @@ -1311,6 +1385,10 @@ <dd> </dd> <dt><a href="org/apache/samza/storage/kv/KeyValueIterator.html" title="interface in org.apache.samza.storage.kv"><span class="typeNameLink">KeyValueIterator</span></a><<a href="org/apache/samza/storage/kv/KeyValueIterator.html" title="type parameter in KeyValueIterator">K</a>,<a href="org/apache/samza/storage/kv/KeyValueIterator.html" title="type parameter in KeyValueIterator">V</a>> - Interface in <a href="org/apache/samza/storage/kv/package-summary.html">org.apache.samza.storage.kv</a></dt> <dd> </dd> +<dt><a href="org/apache/samza/storage/kv/KeyValueSnapshot.html" title="interface in org.apache.samza.storage.kv"><span class="typeNameLink">KeyValueSnapshot</span></a><<a href="org/apache/samza/storage/kv/KeyValueSnapshot.html" title="type parameter in KeyValueSnapshot">K</a>,<a href="org/apache/samza/storage/kv/KeyValueSnapshot.html" title="type parameter in KeyValueSnapshot">V</a>> - Interface in <a href="org/apache/samza/storage/kv/package-summary.html">org.apache.samza.storage.kv</a></dt> +<dd> +<div class="block">An immutable view of the <a href="org/apache/samza/storage/kv/KeyValueStore.html" title="interface in org.apache.samza.storage.kv"><code>KeyValueStore</code></a> at a point-in-time.</div> +</dd> <dt><a href="org/apache/samza/storage/kv/KeyValueStore.html" title="interface in org.apache.samza.storage.kv"><span class="typeNameLink">KeyValueStore</span></a><<a href="org/apache/samza/storage/kv/KeyValueStore.html" title="type parameter in KeyValueStore">K</a>,<a href="org/apache/samza/storage/kv/KeyValueStore.html" title="type parameter in KeyValueStore">V</a>> - Interface in <a href="org/apache/samza/storage/kv/package-summary.html">org.apache.samza.storage.kv</a></dt> <dd> <div class="block">A key-value store that supports put, get, delete, and range queries.</div> @@ -1349,10 +1427,6 @@ <dl> <dt><span class="memberNameLink"><a href="org/apache/samza/metrics/ReadableMetricsRegistry.html#listen-org.apache.samza.metrics.ReadableMetricsRegistryListener-">listen(ReadableMetricsRegistryListener)</a></span> - Method in interface org.apache.samza.metrics.<a href="org/apache/samza/metrics/ReadableMetricsRegistry.html" title="interface in org.apache.samza.metrics">ReadableMetricsRegistry</a></dt> <dd> </dd> -<dt><a href="org/apache/samza/table/LocalStoreBackedTableProvider.html" title="interface in org.apache.samza.table"><span class="typeNameLink">LocalStoreBackedTableProvider</span></a> - Interface in <a href="org/apache/samza/table/package-summary.html">org.apache.samza.table</a></dt> -<dd> -<div class="block">Interface for tables backed by Samza local stores.</div> -</dd> <dt><a href="org/apache/samza/serializers/LongSerde.html" title="class in org.apache.samza.serializers"><span class="typeNameLink">LongSerde</span></a> - Class in <a href="org/apache/samza/serializers/package-summary.html">org.apache.samza.serializers</a></dt> <dd> <div class="block">A serializer for longs</div> @@ -1559,6 +1633,14 @@ <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/metrics/ReadableMetricsRegistryListener.html#onTimer-java.lang.String-org.apache.samza.metrics.Timer-">onTimer(String, Timer)</a></span> - Method in interface org.apache.samza.metrics.<a href="org/apache/samza/metrics/ReadableMetricsRegistryListener.html" title="interface in org.apache.samza.metrics">ReadableMetricsRegistryListener</a></dt> <dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/operators/functions/TimerFunction.html#onTimer-K-long-">onTimer(K, long)</a></span> - Method in interface org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/TimerFunction.html" title="interface in org.apache.samza.operators.functions">TimerFunction</a></dt> +<dd> +<div class="block">Returns the output after the timer with key fires.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/task/TimerCallback.html#onTimer-K-org.apache.samza.task.MessageCollector-org.apache.samza.task.TaskCoordinator-">onTimer(K, MessageCollector, TaskCoordinator)</a></span> - Method in interface org.apache.samza.task.<a href="org/apache/samza/task/TimerCallback.html" title="interface in org.apache.samza.task">TimerCallback</a></dt> +<dd> +<div class="block">Invoked when the timer of key fires.</div> +</dd> <dt><a href="org/apache/samza/package-summary.html">org.apache.samza</a> - package org.apache.samza</dt> <dd> </dd> <dt><a href="org/apache/samza/annotation/package-summary.html">org.apache.samza.annotation</a> - package org.apache.samza.annotation</dt> @@ -1721,6 +1803,11 @@ <dd> <div class="block">Returns an iterator for a sorted range of entries specified by [<code>from</code>, <code>to</code>).</div> </dd> +<dt><a href="org/apache/samza/util/RateLimiter.html" title="interface in org.apache.samza.util"><span class="typeNameLink">RateLimiter</span></a> - Interface in <a href="org/apache/samza/util/package-summary.html">org.apache.samza.util</a></dt> +<dd> +<div class="block">A rate limiter interface used by Samza components to limit throughput of operations + against a resource.</div> +</dd> <dt><a href="org/apache/samza/metrics/ReadableMetricsRegistry.html" title="interface in org.apache.samza.metrics"><span class="typeNameLink">ReadableMetricsRegistry</span></a> - Interface in <a href="org/apache/samza/metrics/package-summary.html">org.apache.samza.metrics</a></dt> <dd> <div class="block">A ReadableMetricsRegistry is a <a href="org/apache/samza/metrics/MetricsRegistry.html" title="interface in org.apache.samza.metrics"><code>MetricsRegistry</code></a> that also @@ -1748,6 +1835,10 @@ </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/metrics/MetricsReporter.html#register-java.lang.String-org.apache.samza.metrics.ReadableMetricsRegistry-">register(String, ReadableMetricsRegistry)</a></span> - Method in interface org.apache.samza.metrics.<a href="org/apache/samza/metrics/MetricsReporter.html" title="interface in org.apache.samza.metrics">MetricsReporter</a></dt> <dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/operators/TimerRegistry.html#register-K-long-">register(K, long)</a></span> - Method in interface org.apache.samza.operators.<a href="org/apache/samza/operators/TimerRegistry.html" title="interface in org.apache.samza.operators">TimerRegistry</a></dt> +<dd> +<div class="block">Register a epoch-time timer with key.</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/system/chooser/BaseMessageChooser.html#register-org.apache.samza.system.SystemStreamPartition-java.lang.String-">register(SystemStreamPartition, String)</a></span> - Method in class org.apache.samza.system.chooser.<a href="org/apache/samza/system/chooser/BaseMessageChooser.html" title="class in org.apache.samza.system.chooser">BaseMessageChooser</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/system/chooser/MessageChooser.html#register-org.apache.samza.system.SystemStreamPartition-java.lang.String-">register(SystemStreamPartition, String)</a></span> - Method in interface org.apache.samza.system.chooser.<a href="org/apache/samza/system/chooser/MessageChooser.html" title="interface in org.apache.samza.system.chooser">MessageChooser</a></dt> @@ -1767,6 +1858,14 @@ <dd> <div class="block">Register a SystemStreamPartition to this SystemConsumer.</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/operators/functions/TimerFunction.html#registerTimer-org.apache.samza.operators.TimerRegistry-">registerTimer(TimerRegistry<K>)</a></span> - Method in interface org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/TimerFunction.html" title="interface in org.apache.samza.operators.functions">TimerFunction</a></dt> +<dd> +<div class="block">Registers any epoch-time timers using the registry</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/task/TaskContext.html#registerTimer-K-long-org.apache.samza.task.TimerCallback-">registerTimer(K, long, TimerCallback<K>)</a></span> - Method in interface org.apache.samza.task.<a href="org/apache/samza/task/TaskContext.html" title="interface in org.apache.samza.task">TaskContext</a></dt> +<dd> +<div class="block">Register a keyed timer with a callback of <a href="org/apache/samza/task/TimerCallback.html" title="interface in org.apache.samza.task"><code>TimerCallback</code></a> in this task.</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/config/Config.html#remove-java.lang.Object-">remove(Object)</a></span> - Method in class org.apache.samza.config.<a href="org/apache/samza/config/Config.html" title="class in org.apache.samza.config">Config</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/system/SystemStreamPartitionIterator.html#remove--">remove()</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/SystemStreamPartitionIterator.html" title="class in org.apache.samza.system">SystemStreamPartitionIterator</a></dt> @@ -1830,7 +1929,7 @@ <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/config/MapConfig.html#sanitize--">sanitize()</a></span> - Method in class org.apache.samza.config.<a href="org/apache/samza/config/MapConfig.html" title="class in org.apache.samza.config">MapConfig</a></dt> <dd> </dd> -<dt><a href="org/apache/samza/sql/udfs/ScalarUdf.html" title="interface in org.apache.samza.sql.udfs"><span class="typeNameLink">ScalarUdf</span></a> - Interface in <a href="org/apache/samza/sql/udfs/package-summary.html">org.apache.samza.sql.udfs</a></dt> +<dt><a href="org/apache/samza/sql/udfs/ScalarUdf.html" title="interface in org.apache.samza.sql.udfs"><span class="typeNameLink">ScalarUdf</span></a><<a href="org/apache/samza/sql/udfs/ScalarUdf.html" title="type parameter in ScalarUdf">T</a>> - Interface in <a href="org/apache/samza/sql/udfs/package-summary.html">org.apache.samza.sql.udfs</a></dt> <dd> <div class="block">The base class for the Scalar UDFs.</div> </dd> @@ -1978,8 +2077,14 @@ <dd> <div class="block">A statistical snapshot of a collection of values</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/storage/kv/KeyValueStore.html#snapshot-K-K-">snapshot(K, K)</a></span> - Method in interface org.apache.samza.storage.kv.<a href="org/apache/samza/storage/kv/KeyValueStore.html" title="interface in org.apache.samza.storage.kv">KeyValueStore</a></dt> +<dd> +<div class="block">Returns a snapshot of this store for a sorted range of entries specified by [<code>from</code>, <code>to</code>).</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/checkpoint/CheckpointManager.html#start--">start()</a></span> - Method in interface org.apache.samza.checkpoint.<a href="org/apache/samza/checkpoint/CheckpointManager.html" title="interface in org.apache.samza.checkpoint">CheckpointManager</a></dt> -<dd> </dd> +<dd> +<div class="block">Perform startup operations.</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/metrics/MetricsReporter.html#start--">start()</a></span> - Method in interface org.apache.samza.metrics.<a href="org/apache/samza/metrics/MetricsReporter.html" title="interface in org.apache.samza.metrics">MetricsReporter</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/system/chooser/BaseMessageChooser.html#start--">start()</a></span> - Method in class org.apache.samza.system.chooser.<a href="org/apache/samza/system/chooser/BaseMessageChooser.html" title="class in org.apache.samza.system.chooser">BaseMessageChooser</a></dt> @@ -1988,6 +2093,8 @@ <dd> <div class="block">Called after all SystemStreamPartitions have been registered.</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/system/SystemAdmin.html#start--">start()</a></span> - Method in interface org.apache.samza.system.<a href="org/apache/samza/system/SystemAdmin.html" title="interface in org.apache.samza.system">SystemAdmin</a></dt> +<dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/system/SystemConsumer.html#start--">start()</a></span> - Method in interface org.apache.samza.system.<a href="org/apache/samza/system/SystemConsumer.html" title="interface in org.apache.samza.system">SystemConsumer</a></dt> <dd> <div class="block">Tells the SystemConsumer to connect to the underlying system, and prepare @@ -1997,10 +2104,6 @@ <dd> <div class="block">Start the SystemProducer.</div> </dd> -<dt><span class="memberNameLink"><a href="org/apache/samza/table/TableProvider.html#start--">start()</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/TableProvider.html" title="interface in org.apache.samza.table">TableProvider</a></dt> -<dd> -<div class="block">Start the underlying table</div> -</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/runtime/ApplicationRunner.html#status-org.apache.samza.application.StreamApplication-">status(StreamApplication)</a></span> - Method in class org.apache.samza.runtime.<a href="org/apache/samza/runtime/ApplicationRunner.html" title="class in org.apache.samza.runtime">ApplicationRunner</a></dt> <dd> <div class="block">Get the collective status of the Samza jobs represented by <a href="org/apache/samza/application/StreamApplication.html" title="interface in org.apache.samza.application"><code>StreamApplication</code></a>.</div> @@ -2021,6 +2124,8 @@ <dd> <div class="block">Called when the chooser is about to be discarded.</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/system/SystemAdmin.html#stop--">stop()</a></span> - Method in interface org.apache.samza.system.<a href="org/apache/samza/system/SystemAdmin.html" title="interface in org.apache.samza.system">SystemAdmin</a></dt> +<dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/system/SystemConsumer.html#stop--">stop()</a></span> - Method in interface org.apache.samza.system.<a href="org/apache/samza/system/SystemConsumer.html" title="interface in org.apache.samza.system">SystemConsumer</a></dt> <dd> <div class="block">Tells the SystemConsumer to close all connections, release all resource, @@ -2030,10 +2135,6 @@ <dd> <div class="block">Stop the SystemProducer.</div> </dd> -<dt><span class="memberNameLink"><a href="org/apache/samza/table/TableProvider.html#stop--">stop()</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/TableProvider.html" title="interface in org.apache.samza.table">TableProvider</a></dt> -<dd> -<div class="block">Stop the underlying table</div> -</dd> <dt><a href="org/apache/samza/storage/StorageEngine.html" title="interface in org.apache.samza.storage"><span class="typeNameLink">StorageEngine</span></a> - Interface in <a href="org/apache/samza/storage/package-summary.html">org.apache.samza.storage</a></dt> <dd> <div class="block">A storage engine for managing state maintained by a stream processor.</div> @@ -2079,7 +2180,7 @@ <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/system/StreamSpec.html#StreamSpec-java.lang.String-java.lang.String-java.lang.String-boolean-java.util.Map-">StreamSpec(String, String, String, boolean, Map<String, String>)</a></span> - Constructor for class org.apache.samza.system.<a href="org/apache/samza/system/StreamSpec.html" title="class in org.apache.samza.system">StreamSpec</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/samza/system/StreamSpec.html#StreamSpec-java.lang.String-java.lang.String-java.lang.String-int-boolean-java.util.Map-">StreamSpec(String, String, String, int, boolean, Map<String, String>)</a></span> - Constructor for class org.apache.samza.system.<a href="org/apache/samza/system/StreamSpec.html" title="class in org.apache.samza.system">StreamSpec</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/samza/system/StreamSpec.html#StreamSpec-java.lang.String-java.lang.String-java.lang.String-int-boolean-boolean-java.util.Map-">StreamSpec(String, String, String, int, boolean, boolean, Map<String, String>)</a></span> - Constructor for class org.apache.samza.system.<a href="org/apache/samza/system/StreamSpec.html" title="class in org.apache.samza.system">StreamSpec</a></dt> <dd> </dd> <dt><a href="org/apache/samza/operators/functions/StreamTableJoinFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">StreamTableJoinFunction</span></a><<a href="org/apache/samza/operators/functions/StreamTableJoinFunction.html" title="type parameter in StreamTableJoinFunction">K</a>,<a href="org/apache/samza/operators/functions/StreamTableJoinFunction.html" title="type parameter in StreamTableJoinFunction">M</a>,<a href="org/apache/samza/operators/functions/StreamTableJoinFunction.html" title="type parameter in StreamTableJoinFunction">R</a>,<a href="org/apache/samza/operators/functions/StreamTableJoinFunction.html" title="type parameter in StreamTableJoinFunction">JM</a>> - Interface in <a href="org/apache/samza/operators/functions/package-summary.html">org.apache.samza.operators.functions</a></dt> <dd> @@ -2312,6 +2413,18 @@ <dd> <div class="block">Construct a <a href="org/apache/samza/metrics/Timer.html" title="class in org.apache.samza.metrics"><code>Timer</code></a> with given <a href="org/apache/samza/metrics/Reservoir.html" title="interface in org.apache.samza.metrics"><code>Reservoir</code></a></div> </dd> +<dt><a href="org/apache/samza/task/TimerCallback.html" title="interface in org.apache.samza.task"><span class="typeNameLink">TimerCallback</span></a><<a href="org/apache/samza/task/TimerCallback.html" title="type parameter in TimerCallback">K</a>> - Interface in <a href="org/apache/samza/task/package-summary.html">org.apache.samza.task</a></dt> +<dd> +<div class="block">The callback that is invoked when its corresponding timer registered via <a href="org/apache/samza/task/TaskContext.html" title="interface in org.apache.samza.task"><code>TaskContext</code></a> fires.</div> +</dd> +<dt><a href="org/apache/samza/operators/functions/TimerFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">TimerFunction</span></a><<a href="org/apache/samza/operators/functions/TimerFunction.html" title="type parameter in TimerFunction">K</a>,<a href="org/apache/samza/operators/functions/TimerFunction.html" title="type parameter in TimerFunction">OM</a>> - Interface in <a href="org/apache/samza/operators/functions/package-summary.html">org.apache.samza.operators.functions</a></dt> +<dd> +<div class="block">Allows timer registration with a key and is invoked when the timer is fired.</div> +</dd> +<dt><a href="org/apache/samza/operators/TimerRegistry.html" title="interface in org.apache.samza.operators"><span class="typeNameLink">TimerRegistry</span></a><<a href="org/apache/samza/operators/TimerRegistry.html" title="type parameter in TimerRegistry">K</a>> - Interface in <a href="org/apache/samza/operators/package-summary.html">org.apache.samza.operators</a></dt> +<dd> +<div class="block">Allows registering epoch-time timer callbacks from the operators.</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/operators/triggers/Triggers.html#timeSinceFirstMessage-java.time.Duration-">timeSinceFirstMessage(Duration)</a></span> - Static method in class org.apache.samza.operators.triggers.<a href="org/apache/samza/operators/triggers/Triggers.html" title="class in org.apache.samza.operators.triggers">Triggers</a></dt> <dd> <div class="block">Creates a trigger that fires after the specified duration has passed since the first message in @@ -2553,6 +2666,14 @@ the order they are declared.</div> <dd> <div class="block">Block on this job until either it finishes or reaches its timeout value</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/runtime/ApplicationRunner.html#waitForFinish--">waitForFinish()</a></span> - Method in class org.apache.samza.runtime.<a href="org/apache/samza/runtime/ApplicationRunner.html" title="class in org.apache.samza.runtime">ApplicationRunner</a></dt> +<dd> +<div class="block">Waits until the application finishes.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/runtime/ApplicationRunner.html#waitForFinish-java.time.Duration-">waitForFinish(Duration)</a></span> - Method in class org.apache.samza.runtime.<a href="org/apache/samza/runtime/ApplicationRunner.html" title="class in org.apache.samza.runtime">ApplicationRunner</a></dt> +<dd> +<div class="block">Waits for <code>timeout</code> duration for the application to finish.</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/job/StreamJob.html#waitForStatus-org.apache.samza.job.ApplicationStatus-long-">waitForStatus(ApplicationStatus, long)</a></span> - Method in interface org.apache.samza.job.<a href="org/apache/samza/job/StreamJob.html" title="interface in org.apache.samza.job">StreamJob</a></dt> <dd> <div class="block">Block on this job until either it transitions to the specified status or reaches it timeout value</div>
Modified: samza/site/learn/documentation/latest/api/javadocs/index.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/index.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/index.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/index.html Fri May 25 22:28:38 2018 @@ -2,8 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:02:53 PST 2018 --> -<title>samza-api 0.14.1-SNAPSHOT API</title> +<!-- Generated by javadoc (1.8.0_121) on Thu May 24 12:04:07 PDT 2018 --> +<title>samza-api 0.14.1 API</title> <script type="text/javascript"> tmpTargetPage = "" + window.location.search; if (tmpTargetPage != "" && tmpTargetPage != "undefined") Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/Partition.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/Partition.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/Partition.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/Partition.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:02:52 PST 2018 --> -<title>Partition (samza-api 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Thu May 24 12:04:06 PDT 2018 --> +<title>Partition (samza-api 0.14.1 API)</title> +<meta name="date" content="2018-05-24"> <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="Partition (samza-api 0.14.1-SNAPSHOT API)"; + parent.document.title="Partition (samza-api 0.14.1 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/SamzaException.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/SamzaException.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/SamzaException.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/SamzaException.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:02:52 PST 2018 --> -<title>SamzaException (samza-api 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Thu May 24 12:04:06 PDT 2018 --> +<title>SamzaException (samza-api 0.14.1 API)</title> +<meta name="date" content="2018-05-24"> <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="SamzaException (samza-api 0.14.1-SNAPSHOT API)"; + parent.document.title="SamzaException (samza-api 0.14.1 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/InterfaceStability.Evolving.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/InterfaceStability.Evolving.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/InterfaceStability.Evolving.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/InterfaceStability.Evolving.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:02:52 PST 2018 --> -<title>InterfaceStability.Evolving (samza-api 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Thu May 24 12:04:06 PDT 2018 --> +<title>InterfaceStability.Evolving (samza-api 0.14.1 API)</title> +<meta name="date" content="2018-05-24"> <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="InterfaceStability.Evolving (samza-api 0.14.1-SNAPSHOT API)"; + parent.document.title="InterfaceStability.Evolving (samza-api 0.14.1 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/InterfaceStability.Stable.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/InterfaceStability.Stable.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/InterfaceStability.Stable.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/InterfaceStability.Stable.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:02:52 PST 2018 --> -<title>InterfaceStability.Stable (samza-api 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Thu May 24 12:04:06 PDT 2018 --> +<title>InterfaceStability.Stable (samza-api 0.14.1 API)</title> +<meta name="date" content="2018-05-24"> <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="InterfaceStability.Stable (samza-api 0.14.1-SNAPSHOT API)"; + parent.document.title="InterfaceStability.Stable (samza-api 0.14.1 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/InterfaceStability.Unstable.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/InterfaceStability.Unstable.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/InterfaceStability.Unstable.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/InterfaceStability.Unstable.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:02:52 PST 2018 --> -<title>InterfaceStability.Unstable (samza-api 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Thu May 24 12:04:06 PDT 2018 --> +<title>InterfaceStability.Unstable (samza-api 0.14.1 API)</title> +<meta name="date" content="2018-05-24"> <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="InterfaceStability.Unstable (samza-api 0.14.1-SNAPSHOT API)"; + parent.document.title="InterfaceStability.Unstable (samza-api 0.14.1 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/InterfaceStability.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/InterfaceStability.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/InterfaceStability.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/InterfaceStability.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:02:52 PST 2018 --> -<title>InterfaceStability (samza-api 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Thu May 24 12:04:06 PDT 2018 --> +<title>InterfaceStability (samza-api 0.14.1 API)</title> +<meta name="date" content="2018-05-24"> <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="InterfaceStability (samza-api 0.14.1-SNAPSHOT API)"; + parent.document.title="InterfaceStability (samza-api 0.14.1 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/package-frame.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/package-frame.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/package-frame.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/package-frame.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:02:53 PST 2018 --> -<title>org.apache.samza.annotation (samza-api 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Thu May 24 12:04:07 PDT 2018 --> +<title>org.apache.samza.annotation (samza-api 0.14.1 API)</title> +<meta name="date" content="2018-05-24"> <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/annotation/package-summary.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/package-summary.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/package-summary.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/package-summary.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:02:53 PST 2018 --> -<title>org.apache.samza.annotation (samza-api 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Thu May 24 12:04:07 PDT 2018 --> +<title>org.apache.samza.annotation (samza-api 0.14.1 API)</title> +<meta name="date" content="2018-05-24"> <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.annotation (samza-api 0.14.1-SNAPSHOT API)"; + parent.document.title="org.apache.samza.annotation (samza-api 0.14.1 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/package-tree.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/package-tree.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/package-tree.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/package-tree.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:02:53 PST 2018 --> -<title>org.apache.samza.annotation Class Hierarchy (samza-api 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Thu May 24 12:04:07 PDT 2018 --> +<title>org.apache.samza.annotation Class Hierarchy (samza-api 0.14.1 API)</title> +<meta name="date" content="2018-05-24"> <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.annotation Class Hierarchy (samza-api 0.14.1-SNAPSHOT API)"; + parent.document.title="org.apache.samza.annotation Class Hierarchy (samza-api 0.14.1 API)"; } } catch(err) { @@ -86,9 +86,9 @@ </ul> <h2 title="Annotation Type Hierarchy">Annotation Type Hierarchy</h2> <ul> -<li type="circle">org.apache.samza.annotation.<a href="../../../../org/apache/samza/annotation/InterfaceStability.Stable.html" title="annotation in org.apache.samza.annotation"><span class="typeNameLink">InterfaceStability.Stable</span></a> (implements java.lang.annotation.Annotation)</li> <li type="circle">org.apache.samza.annotation.<a href="../../../../org/apache/samza/annotation/InterfaceStability.Evolving.html" title="annotation in org.apache.samza.annotation"><span class="typeNameLink">InterfaceStability.Evolving</span></a> (implements java.lang.annotation.Annotation)</li> <li type="circle">org.apache.samza.annotation.<a href="../../../../org/apache/samza/annotation/InterfaceStability.Unstable.html" title="annotation in org.apache.samza.annotation"><span class="typeNameLink">InterfaceStability.Unstable</span></a> (implements java.lang.annotation.Annotation)</li> +<li type="circle">org.apache.samza.annotation.<a href="../../../../org/apache/samza/annotation/InterfaceStability.Stable.html" title="annotation in org.apache.samza.annotation"><span class="typeNameLink">InterfaceStability.Stable</span></a> (implements java.lang.annotation.Annotation)</li> </ul> </div> <!-- ======= START OF BOTTOM NAVBAR ====== --> Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/StreamApplication.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/StreamApplication.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/StreamApplication.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/StreamApplication.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:02:53 PST 2018 --> -<title>StreamApplication (samza-api 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Thu May 24 12:04:07 PDT 2018 --> +<title>StreamApplication (samza-api 0.14.1 API)</title> +<meta name="date" content="2018-05-24"> <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="StreamApplication (samza-api 0.14.1-SNAPSHOT API)"; + parent.document.title="StreamApplication (samza-api 0.14.1 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/package-frame.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/package-frame.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/package-frame.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/package-frame.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:02:53 PST 2018 --> -<title>org.apache.samza.application (samza-api 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Thu May 24 12:04:07 PDT 2018 --> +<title>org.apache.samza.application (samza-api 0.14.1 API)</title> +<meta name="date" content="2018-05-24"> <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/application/package-summary.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/package-summary.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/package-summary.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/package-summary.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:02:53 PST 2018 --> -<title>org.apache.samza.application (samza-api 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Thu May 24 12:04:07 PDT 2018 --> +<title>org.apache.samza.application (samza-api 0.14.1 API)</title> +<meta name="date" content="2018-05-24"> <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.application (samza-api 0.14.1-SNAPSHOT API)"; + parent.document.title="org.apache.samza.application (samza-api 0.14.1 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/package-tree.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/package-tree.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/package-tree.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/package-tree.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:02:53 PST 2018 --> -<title>org.apache.samza.application Class Hierarchy (samza-api 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Thu May 24 12:04:07 PDT 2018 --> +<title>org.apache.samza.application Class Hierarchy (samza-api 0.14.1 API)</title> +<meta name="date" content="2018-05-24"> <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.application Class Hierarchy (samza-api 0.14.1-SNAPSHOT API)"; + parent.document.title="org.apache.samza.application Class Hierarchy (samza-api 0.14.1 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/checkpoint/Checkpoint.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/checkpoint/Checkpoint.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/checkpoint/Checkpoint.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/checkpoint/Checkpoint.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:02:52 PST 2018 --> -<title>Checkpoint (samza-api 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Thu May 24 12:04:06 PDT 2018 --> +<title>Checkpoint (samza-api 0.14.1 API)</title> +<meta name="date" content="2018-05-24"> <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="Checkpoint (samza-api 0.14.1-SNAPSHOT API)"; + parent.document.title="Checkpoint (samza-api 0.14.1 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/checkpoint/CheckpointListener.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/checkpoint/CheckpointListener.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/checkpoint/CheckpointListener.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/checkpoint/CheckpointListener.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:02:52 PST 2018 --> -<title>CheckpointListener (samza-api 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Thu May 24 12:04:06 PDT 2018 --> +<title>CheckpointListener (samza-api 0.14.1 API)</title> +<meta name="date" content="2018-05-24"> <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="CheckpointListener (samza-api 0.14.1-SNAPSHOT API)"; + parent.document.title="CheckpointListener (samza-api 0.14.1 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/checkpoint/CheckpointManager.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/checkpoint/CheckpointManager.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/checkpoint/CheckpointManager.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/checkpoint/CheckpointManager.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:02:52 PST 2018 --> -<title>CheckpointManager (samza-api 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Thu May 24 12:04:06 PDT 2018 --> +<title>CheckpointManager (samza-api 0.14.1 API)</title> +<meta name="date" content="2018-05-24"> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../script.js"></script> </head> @@ -12,13 +12,13 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="CheckpointManager (samza-api 0.14.1-SNAPSHOT API)"; + parent.document.title="CheckpointManager (samza-api 0.14.1 API)"; } } catch(err) { } //--> -var methods = {"i0":18,"i1":6,"i2":6,"i3":6,"i4":6,"i5":6}; +var methods = {"i0":18,"i1":18,"i2":6,"i3":6,"i4":6,"i5":6,"i6":6}; var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],4:["t3","Abstract Methods"],16:["t5","Default Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -128,28 +128,36 @@ var activeTableTab = "activeTableTab"; </td> </tr> <tr id="i1" class="rowColor"> +<td class="colFirst"><code>default void</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/checkpoint/CheckpointManager.html#createResources--">createResources</a></span>()</code> +<div class="block">Creates checkpoint stream.</div> +</td> +</tr> +<tr id="i2" class="altColor"> <td class="colFirst"><code><a href="../../../../org/apache/samza/checkpoint/Checkpoint.html" title="class in org.apache.samza.checkpoint">Checkpoint</a></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/checkpoint/CheckpointManager.html#readLastCheckpoint-org.apache.samza.container.TaskName-">readLastCheckpoint</a></span>(<a href="../../../../org/apache/samza/container/TaskName.html" title="class in org.apache.samza.container">TaskName</a> taskName)</code> <div class="block">Returns the last recorded checkpoint for a specified taskName.</div> </td> </tr> -<tr id="i2" class="altColor"> +<tr id="i3" class="rowColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/checkpoint/CheckpointManager.html#register-org.apache.samza.container.TaskName-">register</a></span>(<a href="../../../../org/apache/samza/container/TaskName.html" title="class in org.apache.samza.container">TaskName</a> taskName)</code> <div class="block">Registers this manager to write checkpoints of a specific Samza stream partition.</div> </td> </tr> -<tr id="i3" class="rowColor"> +<tr id="i4" class="altColor"> <td class="colFirst"><code>void</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/checkpoint/CheckpointManager.html#start--">start</a></span>()</code> </td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/checkpoint/CheckpointManager.html#start--">start</a></span>()</code> +<div class="block">Perform startup operations.</div> +</td> </tr> -<tr id="i4" class="altColor"> +<tr id="i5" class="rowColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/checkpoint/CheckpointManager.html#stop--">stop</a></span>()</code> <div class="block">Perform teardown operations for the Manager.</div> </td> </tr> -<tr id="i5" class="rowColor"> +<tr id="i6" class="altColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/checkpoint/CheckpointManager.html#writeCheckpoint-org.apache.samza.container.TaskName-org.apache.samza.checkpoint.Checkpoint-">writeCheckpoint</a></span>(<a href="../../../../org/apache/samza/container/TaskName.html" title="class in org.apache.samza.container">TaskName</a> taskName, <a href="../../../../org/apache/samza/checkpoint/Checkpoint.html" title="class in org.apache.samza.checkpoint">Checkpoint</a> checkpoint)</code> @@ -171,6 +179,16 @@ var activeTableTab = "activeTableTab"; <!-- --> </a> <h3>Method Detail</h3> +<a name="createResources--"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>createResources</h4> +<pre>default void createResources()</pre> +<div class="block">Creates checkpoint stream.</div> +</li> +</ul> <a name="start--"> <!-- --> </a> @@ -178,6 +196,7 @@ var activeTableTab = "activeTableTab"; <li class="blockList"> <h4>start</h4> <pre>void start()</pre> +<div class="block">Perform startup operations.</div> </li> </ul> <a name="register-org.apache.samza.container.TaskName-"> Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/checkpoint/CheckpointManagerFactory.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/checkpoint/CheckpointManagerFactory.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/checkpoint/CheckpointManagerFactory.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/checkpoint/CheckpointManagerFactory.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:02:52 PST 2018 --> -<title>CheckpointManagerFactory (samza-api 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Thu May 24 12:04:06 PDT 2018 --> +<title>CheckpointManagerFactory (samza-api 0.14.1 API)</title> +<meta name="date" content="2018-05-24"> <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="CheckpointManagerFactory (samza-api 0.14.1-SNAPSHOT API)"; + parent.document.title="CheckpointManagerFactory (samza-api 0.14.1 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/checkpoint/package-frame.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/checkpoint/package-frame.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/checkpoint/package-frame.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/checkpoint/package-frame.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:02:53 PST 2018 --> -<title>org.apache.samza.checkpoint (samza-api 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Thu May 24 12:04:07 PDT 2018 --> +<title>org.apache.samza.checkpoint (samza-api 0.14.1 API)</title> +<meta name="date" content="2018-05-24"> <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/checkpoint/package-summary.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/checkpoint/package-summary.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/checkpoint/package-summary.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/checkpoint/package-summary.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:02:53 PST 2018 --> -<title>org.apache.samza.checkpoint (samza-api 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Thu May 24 12:04:07 PDT 2018 --> +<title>org.apache.samza.checkpoint (samza-api 0.14.1 API)</title> +<meta name="date" content="2018-05-24"> <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.checkpoint (samza-api 0.14.1-SNAPSHOT API)"; + parent.document.title="org.apache.samza.checkpoint (samza-api 0.14.1 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/checkpoint/package-tree.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/checkpoint/package-tree.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/checkpoint/package-tree.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/checkpoint/package-tree.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:02:53 PST 2018 --> -<title>org.apache.samza.checkpoint Class Hierarchy (samza-api 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Thu May 24 12:04:07 PDT 2018 --> +<title>org.apache.samza.checkpoint Class Hierarchy (samza-api 0.14.1 API)</title> +<meta name="date" content="2018-05-24"> <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.checkpoint Class Hierarchy (samza-api 0.14.1-SNAPSHOT API)"; + parent.document.title="org.apache.samza.checkpoint Class Hierarchy (samza-api 0.14.1 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/config/Config.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/config/Config.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/config/Config.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/config/Config.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:02:52 PST 2018 --> -<title>Config (samza-api 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Thu May 24 12:04:06 PDT 2018 --> +<title>Config (samza-api 0.14.1 API)</title> +<meta name="date" content="2018-05-24"> <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="Config (samza-api 0.14.1-SNAPSHOT API)"; + parent.document.title="Config (samza-api 0.14.1 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/config/ConfigException.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/config/ConfigException.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/config/ConfigException.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/config/ConfigException.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:02:52 PST 2018 --> -<title>ConfigException (samza-api 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Thu May 24 12:04:06 PDT 2018 --> +<title>ConfigException (samza-api 0.14.1 API)</title> +<meta name="date" content="2018-05-24"> <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="ConfigException (samza-api 0.14.1-SNAPSHOT API)"; + parent.document.title="ConfigException (samza-api 0.14.1 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/config/ConfigFactory.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/config/ConfigFactory.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/config/ConfigFactory.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/config/ConfigFactory.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:02:52 PST 2018 --> -<title>ConfigFactory (samza-api 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Thu May 24 12:04:06 PDT 2018 --> +<title>ConfigFactory (samza-api 0.14.1 API)</title> +<meta name="date" content="2018-05-24"> <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="ConfigFactory (samza-api 0.14.1-SNAPSHOT API)"; + parent.document.title="ConfigFactory (samza-api 0.14.1 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/config/ConfigRewriter.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/config/ConfigRewriter.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/config/ConfigRewriter.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/config/ConfigRewriter.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:02:52 PST 2018 --> -<title>ConfigRewriter (samza-api 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Thu May 24 12:04:06 PDT 2018 --> +<title>ConfigRewriter (samza-api 0.14.1 API)</title> +<meta name="date" content="2018-05-24"> <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="ConfigRewriter (samza-api 0.14.1-SNAPSHOT API)"; + parent.document.title="ConfigRewriter (samza-api 0.14.1 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/config/MapConfig.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/config/MapConfig.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/config/MapConfig.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/config/MapConfig.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:02:52 PST 2018 --> -<title>MapConfig (samza-api 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Thu May 24 12:04:06 PDT 2018 --> +<title>MapConfig (samza-api 0.14.1 API)</title> +<meta name="date" content="2018-05-24"> <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="MapConfig (samza-api 0.14.1-SNAPSHOT API)"; + parent.document.title="MapConfig (samza-api 0.14.1 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/config/package-frame.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/config/package-frame.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/config/package-frame.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/config/package-frame.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:02:53 PST 2018 --> -<title>org.apache.samza.config (samza-api 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Thu May 24 12:04:07 PDT 2018 --> +<title>org.apache.samza.config (samza-api 0.14.1 API)</title> +<meta name="date" content="2018-05-24"> <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/config/package-summary.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/config/package-summary.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/config/package-summary.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/config/package-summary.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:02:53 PST 2018 --> -<title>org.apache.samza.config (samza-api 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Thu May 24 12:04:07 PDT 2018 --> +<title>org.apache.samza.config (samza-api 0.14.1 API)</title> +<meta name="date" content="2018-05-24"> <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.config (samza-api 0.14.1-SNAPSHOT API)"; + parent.document.title="org.apache.samza.config (samza-api 0.14.1 API)"; } } catch(err) {
