You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by cr...@apache.org on 2014/07/09 18:34:26 UTC
svn commit: r1609230 [2/9] - in /incubator/samza/site: ./ community/
contribute/ css/ learn/documentation/0.7.0/ learn/documentation/0.7.0/api/
learn/documentation/0.7.0/api/javadocs/
learn/documentation/0.7.0/api/javadocs/org/apache/samza/ learn/docum...
Modified: incubator/samza/site/learn/documentation/0.7.0/api/javadocs/index-all.html
URL: http://svn.apache.org/viewvc/incubator/samza/site/learn/documentation/0.7.0/api/javadocs/index-all.html?rev=1609230&r1=1609229&r2=1609230&view=diff
==============================================================================
--- incubator/samza/site/learn/documentation/0.7.0/api/javadocs/index-all.html (original)
+++ incubator/samza/site/learn/documentation/0.7.0/api/javadocs/index-all.html Wed Jul 9 16:34:23 2014
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_51) on Wed Jun 18 18:05:18 PDT 2014 -->
+<!-- Generated by javadoc (version 1.7.0_60) on Wed Jul 09 09:32:50 PDT 2014 -->
<title>Index (samza-api 0.7.0 API)</title>
-<meta name="date" content="2014-06-18">
+<meta name="date" content="2014-07-09">
<link rel="stylesheet" type="text/css" href="./stylesheet.css" title="Style">
</head>
<body>
@@ -66,22 +66,20 @@
</a>
<h2 class="title">A</h2>
<dl>
-<dt><span class="strong"><a href="./org/apache/samza/task/TaskLifecycleListener.html#afterClose(org.apache.samza.config.Config, org.apache.samza.task.TaskContext)">afterClose(Config, TaskContext)</a></span> - Method in interface org.apache.samza.task.<a href="./org/apache/samza/task/TaskLifecycleListener.html" title="interface in org.apache.samza.task">TaskLifecycleListener</a></dt>
+<dt><span class="strong"><a href="./org/apache/samza/task/TaskLifecycleListener.html#afterClose(org.apache.samza.config.Config,%20org.apache.samza.task.TaskContext)">afterClose(Config, TaskContext)</a></span> - Method in interface org.apache.samza.task.<a href="./org/apache/samza/task/TaskLifecycleListener.html" title="interface in org.apache.samza.task">TaskLifecycleListener</a></dt>
<dd>
<div class="block">Called after all tasks in TaskRunner are closed.</div>
</dd>
-<dt><span class="strong"><a href="./org/apache/samza/task/TaskLifecycleListener.html#afterInit(org.apache.samza.config.Config, org.apache.samza.task.TaskContext)">afterInit(Config, TaskContext)</a></span> - Method in interface org.apache.samza.task.<a href="./org/apache/samza/task/TaskLifecycleListener.html" title="interface in org.apache.samza.task">TaskLifecycleListener</a></dt>
+<dt><span class="strong"><a href="./org/apache/samza/task/TaskLifecycleListener.html#afterInit(org.apache.samza.config.Config,%20org.apache.samza.task.TaskContext)">afterInit(Config, TaskContext)</a></span> - Method in interface org.apache.samza.task.<a href="./org/apache/samza/task/TaskLifecycleListener.html" title="interface in org.apache.samza.task">TaskLifecycleListener</a></dt>
<dd>
<div class="block">Called after all tasks in TaskRunner are initialized.</div>
</dd>
-<dt><span class="strong"><a href="./org/apache/samza/task/TaskLifecycleListener.html#afterProcess(org.apache.samza.system.IncomingMessageEnvelope, org.apache.samza.config.Config, org.apache.samza.task.TaskContext)">afterProcess(IncomingMessageEnvelope, Config, TaskContext)</a></span> - Method in interface org.apache.samza.task.<a href="./org/apache/samza/task/TaskLifecycleListener.html" title="interface in org.apache.samza.task">TaskLifecycleListener</a></dt>
+<dt><span class="strong"><a href="./org/apache/samza/task/TaskLifecycleListener.html#afterProcess(org.apache.samza.system.IncomingMessageEnvelope,%20org.apache.samza.config.Config,%20org.apache.samza.task.TaskContext)">afterProcess(IncomingMessageEnvelope, Config, TaskContext)</a></span> - Method in interface org.apache.samza.task.<a href="./org/apache/samza/task/TaskLifecycleListener.html" title="interface in org.apache.samza.task">TaskLifecycleListener</a></dt>
<dd>
<div class="block">Called after a message is processed by a task.</div>
</dd>
<dt><a href="./org/apache/samza/job/ApplicationStatus.html" title="enum in org.apache.samza.job"><span class="strong">ApplicationStatus</span></a> - Enum in <a href="./org/apache/samza/job/package-summary.html">org.apache.samza.job</a></dt>
-<dd>
-<div class="block">Status of a <a href="./org/apache/samza/job/StreamJob.html" title="interface in org.apache.samza.job"><code>StreamJob</code></a> during and after its run.</div>
-</dd>
+<dd> </dd>
</dl>
<a name="_B_">
<!-- -->
@@ -95,15 +93,15 @@
</dd>
<dt><span class="strong"><a href="./org/apache/samza/system/chooser/BaseMessageChooser.html#BaseMessageChooser()">BaseMessageChooser()</a></span> - Constructor for 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="strong"><a href="./org/apache/samza/task/TaskLifecycleListener.html#beforeClose(org.apache.samza.config.Config, org.apache.samza.task.TaskContext)">beforeClose(Config, TaskContext)</a></span> - Method in interface org.apache.samza.task.<a href="./org/apache/samza/task/TaskLifecycleListener.html" title="interface in org.apache.samza.task">TaskLifecycleListener</a></dt>
+<dt><span class="strong"><a href="./org/apache/samza/task/TaskLifecycleListener.html#beforeClose(org.apache.samza.config.Config,%20org.apache.samza.task.TaskContext)">beforeClose(Config, TaskContext)</a></span> - Method in interface org.apache.samza.task.<a href="./org/apache/samza/task/TaskLifecycleListener.html" title="interface in org.apache.samza.task">TaskLifecycleListener</a></dt>
<dd>
<div class="block">Called before all tasks in TaskRunner are closed.</div>
</dd>
-<dt><span class="strong"><a href="./org/apache/samza/task/TaskLifecycleListener.html#beforeInit(org.apache.samza.config.Config, org.apache.samza.task.TaskContext)">beforeInit(Config, TaskContext)</a></span> - Method in interface org.apache.samza.task.<a href="./org/apache/samza/task/TaskLifecycleListener.html" title="interface in org.apache.samza.task">TaskLifecycleListener</a></dt>
+<dt><span class="strong"><a href="./org/apache/samza/task/TaskLifecycleListener.html#beforeInit(org.apache.samza.config.Config,%20org.apache.samza.task.TaskContext)">beforeInit(Config, TaskContext)</a></span> - Method in interface org.apache.samza.task.<a href="./org/apache/samza/task/TaskLifecycleListener.html" title="interface in org.apache.samza.task">TaskLifecycleListener</a></dt>
<dd>
<div class="block">Called before all tasks in TaskRunner are initialized.</div>
</dd>
-<dt><span class="strong"><a href="./org/apache/samza/task/TaskLifecycleListener.html#beforeProcess(org.apache.samza.system.IncomingMessageEnvelope, org.apache.samza.config.Config, org.apache.samza.task.TaskContext)">beforeProcess(IncomingMessageEnvelope, Config, TaskContext)</a></span> - Method in interface org.apache.samza.task.<a href="./org/apache/samza/task/TaskLifecycleListener.html" title="interface in org.apache.samza.task">TaskLifecycleListener</a></dt>
+<dt><span class="strong"><a href="./org/apache/samza/task/TaskLifecycleListener.html#beforeProcess(org.apache.samza.system.IncomingMessageEnvelope,%20org.apache.samza.config.Config,%20org.apache.samza.task.TaskContext)">beforeProcess(IncomingMessageEnvelope, Config, TaskContext)</a></span> - Method in interface org.apache.samza.task.<a href="./org/apache/samza/task/TaskLifecycleListener.html" title="interface in org.apache.samza.task">TaskLifecycleListener</a></dt>
<dd>
<div class="block">Called before a message is processed by a task.</div>
</dd>
@@ -126,17 +124,17 @@
<dd> </dd>
<dt><span class="strong"><a href="./org/apache/samza/util/BlockingEnvelopeMap.html#BlockingEnvelopeMap(org.apache.samza.metrics.MetricsRegistry)">BlockingEnvelopeMap(MetricsRegistry)</a></span> - Constructor for class org.apache.samza.util.<a href="./org/apache/samza/util/BlockingEnvelopeMap.html" title="class in org.apache.samza.util">BlockingEnvelopeMap</a></dt>
<dd> </dd>
-<dt><span class="strong"><a href="./org/apache/samza/util/BlockingEnvelopeMap.html#BlockingEnvelopeMap(org.apache.samza.metrics.MetricsRegistry, org.apache.samza.util.Clock)">BlockingEnvelopeMap(MetricsRegistry, Clock)</a></span> - Constructor for class org.apache.samza.util.<a href="./org/apache/samza/util/BlockingEnvelopeMap.html" title="class in org.apache.samza.util">BlockingEnvelopeMap</a></dt>
+<dt><span class="strong"><a href="./org/apache/samza/util/BlockingEnvelopeMap.html#BlockingEnvelopeMap(org.apache.samza.metrics.MetricsRegistry,%20org.apache.samza.util.Clock)">BlockingEnvelopeMap(MetricsRegistry, Clock)</a></span> - Constructor for class org.apache.samza.util.<a href="./org/apache/samza/util/BlockingEnvelopeMap.html" title="class in org.apache.samza.util">BlockingEnvelopeMap</a></dt>
<dd> </dd>
-<dt><span class="strong"><a href="./org/apache/samza/util/BlockingEnvelopeMap.html#BlockingEnvelopeMap(org.apache.samza.metrics.MetricsRegistry, org.apache.samza.util.Clock, java.lang.String)">BlockingEnvelopeMap(MetricsRegistry, Clock, String)</a></span> - Constructor for class org.apache.samza.util.<a href="./org/apache/samza/util/BlockingEnvelopeMap.html" title="class in org.apache.samza.util">BlockingEnvelopeMap</a></dt>
+<dt><span class="strong"><a href="./org/apache/samza/util/BlockingEnvelopeMap.html#BlockingEnvelopeMap(org.apache.samza.metrics.MetricsRegistry,%20org.apache.samza.util.Clock,%20java.lang.String)">BlockingEnvelopeMap(MetricsRegistry, Clock, String)</a></span> - Constructor for class org.apache.samza.util.<a href="./org/apache/samza/util/BlockingEnvelopeMap.html" title="class in org.apache.samza.util">BlockingEnvelopeMap</a></dt>
<dd> </dd>
<dt><a href="./org/apache/samza/util/BlockingEnvelopeMap.BlockingEnvelopeMapMetrics.html" title="class in org.apache.samza.util"><span class="strong">BlockingEnvelopeMap.BlockingEnvelopeMapMetrics</span></a> - Class in <a href="./org/apache/samza/util/package-summary.html">org.apache.samza.util</a></dt>
<dd> </dd>
-<dt><span class="strong"><a href="./org/apache/samza/util/BlockingEnvelopeMap.BlockingEnvelopeMapMetrics.html#BlockingEnvelopeMap.BlockingEnvelopeMapMetrics(java.lang.String, org.apache.samza.metrics.MetricsRegistry)">BlockingEnvelopeMap.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>
+<dt><span class="strong"><a href="./org/apache/samza/util/BlockingEnvelopeMap.BlockingEnvelopeMapMetrics.html#BlockingEnvelopeMap.BlockingEnvelopeMapMetrics(java.lang.String,%20org.apache.samza.metrics.MetricsRegistry)">BlockingEnvelopeMap.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><a href="./org/apache/samza/util/BlockingEnvelopeMap.BufferGauge.html" title="class in org.apache.samza.util"><span class="strong">BlockingEnvelopeMap.BufferGauge</span></a> - Class in <a href="./org/apache/samza/util/package-summary.html">org.apache.samza.util</a></dt>
<dd> </dd>
-<dt><span class="strong"><a href="./org/apache/samza/util/BlockingEnvelopeMap.BufferGauge.html#BlockingEnvelopeMap.BufferGauge(org.apache.samza.system.SystemStreamPartition, java.lang.String)">BlockingEnvelopeMap.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>
+<dt><span class="strong"><a href="./org/apache/samza/util/BlockingEnvelopeMap.BufferGauge.html#BlockingEnvelopeMap.BufferGauge(org.apache.samza.system.SystemStreamPartition,%20java.lang.String)">BlockingEnvelopeMap.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="strong"><a href="./org/apache/samza/job/CommandBuilder.html#buildCommand()">buildCommand()</a></span> - Method in class org.apache.samza.job.<a href="./org/apache/samza/job/CommandBuilder.html" title="class in org.apache.samza.job">CommandBuilder</a></dt>
<dd> </dd>
@@ -150,7 +148,7 @@
<dl>
<dt><a href="./org/apache/samza/checkpoint/Checkpoint.html" title="class in org.apache.samza.checkpoint"><span class="strong">Checkpoint</span></a> - Class in <a href="./org/apache/samza/checkpoint/package-summary.html">org.apache.samza.checkpoint</a></dt>
<dd>
-<div class="block">A checkpoint is a mapping of all the streams a job is consuming and the most recent current offset for each.</div>
+<div class="block">Used to represent a checkpoint in the running of a Samza system.</div>
</dd>
<dt><span class="strong"><a href="./org/apache/samza/checkpoint/Checkpoint.html#Checkpoint(java.util.Map)">Checkpoint(Map<SystemStream, String>)</a></span> - Constructor for class org.apache.samza.checkpoint.<a href="./org/apache/samza/checkpoint/Checkpoint.html" title="class in org.apache.samza.checkpoint">Checkpoint</a></dt>
<dd>
@@ -158,13 +156,10 @@
</dd>
<dt><a href="./org/apache/samza/checkpoint/CheckpointManager.html" title="interface in org.apache.samza.checkpoint"><span class="strong">CheckpointManager</span></a> - Interface in <a href="./org/apache/samza/checkpoint/package-summary.html">org.apache.samza.checkpoint</a></dt>
<dd>
-<div class="block">CheckpointManagers read and write <a href="./org/apache/samza/checkpoint/Checkpoint.html" title="class in org.apache.samza.checkpoint"><code>Checkpoint</code></a> to some
- implementation-specific location.</div>
+<div class="block">Used as a standard interface for writing out checkpoints for a specified partition.</div>
</dd>
<dt><a href="./org/apache/samza/checkpoint/CheckpointManagerFactory.html" title="interface in org.apache.samza.checkpoint"><span class="strong">CheckpointManagerFactory</span></a> - Interface in <a href="./org/apache/samza/checkpoint/package-summary.html">org.apache.samza.checkpoint</a></dt>
-<dd>
-<div class="block">Build a <a href="./org/apache/samza/checkpoint/CheckpointManager.html" title="interface in org.apache.samza.checkpoint"><code>CheckpointManager</code></a>.</div>
-</dd>
+<dd> </dd>
<dt><span class="strong"><a href="./org/apache/samza/system/chooser/MessageChooser.html#choose()">choose()</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>
<dd>
<div class="block">The choose method is invoked when the SamzaContainer is ready to process a
@@ -175,22 +170,13 @@
<dt><span class="strong"><a href="./org/apache/samza/metrics/Counter.html#clear()">clear()</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><a href="./org/apache/samza/util/Clock.html" title="interface in org.apache.samza.util"><span class="strong">Clock</span></a> - Interface in <a href="./org/apache/samza/util/package-summary.html">org.apache.samza.util</a></dt>
-<dd>
-<div class="block">Mockable interface for tracking time.</div>
-</dd>
+<dd> </dd>
<dt><a href="./org/apache/samza/task/ClosableTask.html" title="interface in org.apache.samza.task"><span class="strong">ClosableTask</span></a> - Interface in <a href="./org/apache/samza/task/package-summary.html">org.apache.samza.task</a></dt>
-<dd>
-<div class="block">A ClosableTask augments <a href="./org/apache/samza/task/StreamTask.html" title="interface in org.apache.samza.task"><code>StreamTask</code></a>, allowing the method implementer to specify
- code that will be called when the StreamTask is being shut down by the framework, providing to emit final metrics,
- clean or close resources, etc.</div>
-</dd>
+<dd> </dd>
<dt><span class="strong"><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="strong">CommandBuilder</span></a> - Class in <a href="./org/apache/samza/job/package-summary.html">org.apache.samza.job</a></dt>
-<dd>
-<div class="block">CommandBuilders are used to customize the command necessary to launch a Samza Job for a particular framework,
- such as YARN or the LocalJobRunner.</div>
-</dd>
+<dd> </dd>
<dt><span class="strong"><a href="./org/apache/samza/job/CommandBuilder.html#CommandBuilder()">CommandBuilder()</a></span> - Constructor for class org.apache.samza.job.<a href="./org/apache/samza/job/CommandBuilder.html" title="class in org.apache.samza.job">CommandBuilder</a></dt>
<dd> </dd>
<dt><span class="strong"><a href="./org/apache/samza/task/TaskCoordinator.html#commit(org.apache.samza.task.TaskCoordinator.RequestScope)">commit(TaskCoordinator.RequestScope)</a></span> - Method in interface org.apache.samza.task.<a href="./org/apache/samza/task/TaskCoordinator.html" title="interface in org.apache.samza.task">TaskCoordinator</a></dt>
@@ -198,12 +184,10 @@
<div class="block">Requests that Samza should write out a checkpoint, from which a task can restart
after failure.</div>
</dd>
-<dt><span class="strong"><a href="./org/apache/samza/metrics/Gauge.html#compareAndSet(T, T)">compareAndSet(T, T)</a></span> - Method in class org.apache.samza.metrics.<a href="./org/apache/samza/metrics/Gauge.html" title="class in org.apache.samza.metrics">Gauge</a></dt>
+<dt><span class="strong"><a href="./org/apache/samza/metrics/Gauge.html#compareAndSet(T,%20T)">compareAndSet(T, T)</a></span> - Method in class org.apache.samza.metrics.<a href="./org/apache/samza/metrics/Gauge.html" title="class in org.apache.samza.metrics">Gauge</a></dt>
<dd> </dd>
<dt><a href="./org/apache/samza/config/Config.html" title="class in org.apache.samza.config"><span class="strong">Config</span></a> - Class in <a href="./org/apache/samza/config/package-summary.html">org.apache.samza.config</a></dt>
-<dd>
-<div class="block">Store and retrieve named, typed values as configuration for classes implementing this interface.</div>
-</dd>
+<dd> </dd>
<dt><span class="strong"><a href="./org/apache/samza/config/Config.html#Config()">Config()</a></span> - Constructor for 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="strong"><a href="./org/apache/samza/container/SamzaContainerContext.html#config">config</a></span> - Variable in class org.apache.samza.container.<a href="./org/apache/samza/container/SamzaContainerContext.html" title="class in org.apache.samza.container">SamzaContainerContext</a></dt>
@@ -211,23 +195,18 @@
<dt><span class="strong"><a href="./org/apache/samza/job/CommandBuilder.html#config">config</a></span> - Variable in class org.apache.samza.job.<a href="./org/apache/samza/job/CommandBuilder.html" title="class in org.apache.samza.job">CommandBuilder</a></dt>
<dd> </dd>
<dt><a href="./org/apache/samza/config/ConfigException.html" title="class in org.apache.samza.config"><span class="strong">ConfigException</span></a> - Exception in <a href="./org/apache/samza/config/package-summary.html">org.apache.samza.config</a></dt>
-<dd>
-<div class="block">Specific <a href="./org/apache/samza/SamzaException.html" title="class in org.apache.samza"><code>SamzaException</code></a>s thrown from <a href="./org/apache/samza/config/Config.html" title="class in org.apache.samza.config"><code>Config</code></a></div>
-</dd>
+<dd> </dd>
<dt><span class="strong"><a href="./org/apache/samza/config/ConfigException.html#ConfigException(java.lang.Throwable)">ConfigException(Throwable)</a></span> - Constructor for exception org.apache.samza.config.<a href="./org/apache/samza/config/ConfigException.html" title="class in org.apache.samza.config">ConfigException</a></dt>
<dd> </dd>
<dt><span class="strong"><a href="./org/apache/samza/config/ConfigException.html#ConfigException(java.lang.String)">ConfigException(String)</a></span> - Constructor for exception org.apache.samza.config.<a href="./org/apache/samza/config/ConfigException.html" title="class in org.apache.samza.config">ConfigException</a></dt>
<dd> </dd>
-<dt><span class="strong"><a href="./org/apache/samza/config/ConfigException.html#ConfigException(java.lang.String, java.lang.Throwable)">ConfigException(String, Throwable)</a></span> - Constructor for exception org.apache.samza.config.<a href="./org/apache/samza/config/ConfigException.html" title="class in org.apache.samza.config">ConfigException</a></dt>
+<dt><span class="strong"><a href="./org/apache/samza/config/ConfigException.html#ConfigException(java.lang.String,%20java.lang.Throwable)">ConfigException(String, Throwable)</a></span> - Constructor for exception org.apache.samza.config.<a href="./org/apache/samza/config/ConfigException.html" title="class in org.apache.samza.config">ConfigException</a></dt>
<dd> </dd>
<dt><a href="./org/apache/samza/config/ConfigFactory.html" title="interface in org.apache.samza.config"><span class="strong">ConfigFactory</span></a> - Interface in <a href="./org/apache/samza/config/package-summary.html">org.apache.samza.config</a></dt>
-<dd>
-<div class="block">Build a <a href="./org/apache/samza/config/Config.html" title="class in org.apache.samza.config"><code>Config</code></a></div>
-</dd>
+<dd> </dd>
<dt><a href="./org/apache/samza/config/ConfigRewriter.html" title="interface in org.apache.samza.config"><span class="strong">ConfigRewriter</span></a> - Interface in <a href="./org/apache/samza/config/package-summary.html">org.apache.samza.config</a></dt>
<dd>
-<div class="block">A ConfigRewriter receives the job's config during job startup and may re-write it to provide new configs,
- remove existing configs or audit and verify the config is correct or permitted.</div>
+<div class="block">Re-write the job's config before the job is submitted.</div>
</dd>
<dt><span class="strong"><a href="./org/apache/samza/config/MapConfig.html#containsKey(java.lang.Object)">containsKey(Object)</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>
@@ -235,7 +214,7 @@
<dd> </dd>
<dt><a href="./org/apache/samza/metrics/Counter.html" title="class in org.apache.samza.metrics"><span class="strong">Counter</span></a> - Class in <a href="./org/apache/samza/metrics/package-summary.html">org.apache.samza.metrics</a></dt>
<dd>
-<div class="block">A counter is a <a href="./org/apache/samza/metrics/Metric.html" title="interface in org.apache.samza.metrics"><code>Metric</code></a> that represents a cumulative value.</div>
+<div class="block">A counter is a metric that represents a cumulative value.</div>
</dd>
<dt><span class="strong"><a href="./org/apache/samza/metrics/Counter.html#Counter(java.lang.String)">Counter(String)</a></span> - Constructor for 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>
@@ -249,6 +228,8 @@
</a>
<h2 class="title">D</h2>
<dl>
+<dt><a href="./org/apache/samza/metrics/DataType.html" title="enum in org.apache.samza.metrics"><span class="strong">DataType</span></a> - Enum in <a href="./org/apache/samza/metrics/package-summary.html">org.apache.samza.metrics</a></dt>
+<dd> </dd>
<dt><span class="strong"><a href="./org/apache/samza/metrics/Counter.html#dec()">dec()</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="strong"><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>
@@ -295,10 +276,7 @@
<div class="block">Flush any cached messages</div>
</dd>
<dt><span class="strong"><a href="./org/apache/samza/system/SystemProducer.html#flush(java.lang.String)">flush(String)</a></span> - Method in interface org.apache.samza.system.<a href="./org/apache/samza/system/SystemProducer.html" title="interface in org.apache.samza.system">SystemProducer</a></dt>
-<dd>
-<div class="block">If the SystemProducer buffers messages before sending them to its underlying system, it should flush those
- messages and leave no messages remaining to be sent.</div>
-</dd>
+<dd> </dd>
<dt><span class="strong"><a href="./org/apache/samza/serializers/Deserializer.html#fromBytes(byte[])">fromBytes(byte[])</a></span> - Method in interface org.apache.samza.serializers.<a href="./org/apache/samza/serializers/Deserializer.html" title="interface in org.apache.samza.serializers">Deserializer</a></dt>
<dd>
<div class="block">Deserializes given serialized object from an array of bytes to its original form.</div>
@@ -310,51 +288,46 @@
<h2 class="title">G</h2>
<dl>
<dt><a href="./org/apache/samza/metrics/Gauge.html" title="class in org.apache.samza.metrics"><span class="strong">Gauge</span></a><<a href="./org/apache/samza/metrics/Gauge.html" title="type parameter in Gauge">T</a>> - Class in <a href="./org/apache/samza/metrics/package-summary.html">org.apache.samza.metrics</a></dt>
-<dd>
-<div class="block">A Gauge is a <a href="./org/apache/samza/metrics/Metric.html" title="interface in org.apache.samza.metrics"><code>Metric</code></a> that wraps some instance of T in a thread-safe
- reference and allows it to be set or retrieved.</div>
-</dd>
-<dt><span class="strong"><a href="./org/apache/samza/metrics/Gauge.html#Gauge(java.lang.String, T)">Gauge(String, T)</a></span> - Constructor for class org.apache.samza.metrics.<a href="./org/apache/samza/metrics/Gauge.html" title="class in org.apache.samza.metrics">Gauge</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/samza/metrics/Gauge.html#Gauge(java.lang.String,%20T)">Gauge(String, T)</a></span> - Constructor for class org.apache.samza.metrics.<a href="./org/apache/samza/metrics/Gauge.html" title="class in org.apache.samza.metrics">Gauge</a></dt>
<dd> </dd>
<dt><span class="strong"><a href="./org/apache/samza/metrics/MetricsVisitor.html#gauge(org.apache.samza.metrics.Gauge)">gauge(Gauge<T>)</a></span> - Method in class org.apache.samza.metrics.<a href="./org/apache/samza/metrics/MetricsVisitor.html" title="class in org.apache.samza.metrics">MetricsVisitor</a></dt>
<dd> </dd>
-<dt><span class="strong"><a href="./org/apache/samza/config/Config.html#get(java.lang.String, java.lang.String)">get(String, String)</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>
+<dt><span class="strong"><a href="./org/apache/samza/config/Config.html#get(java.lang.String,%20java.lang.String)">get(String, String)</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="strong"><a href="./org/apache/samza/config/MapConfig.html#get(java.lang.Object)">get(Object)</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><span class="strong"><a href="./org/apache/samza/system/SystemFactory.html#getAdmin(java.lang.String, org.apache.samza.config.Config)">getAdmin(String, Config)</a></span> - Method in interface org.apache.samza.system.<a href="./org/apache/samza/system/SystemFactory.html" title="interface in org.apache.samza.system">SystemFactory</a></dt>
+<dt><span class="strong"><a href="./org/apache/samza/system/SystemFactory.html#getAdmin(java.lang.String,%20org.apache.samza.config.Config)">getAdmin(String, Config)</a></span> - Method in interface org.apache.samza.system.<a href="./org/apache/samza/system/SystemFactory.html" title="interface in org.apache.samza.system">SystemFactory</a></dt>
<dd> </dd>
-<dt><span class="strong"><a href="./org/apache/samza/config/Config.html#getBoolean(java.lang.String, boolean)">getBoolean(String, boolean)</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>
+<dt><span class="strong"><a href="./org/apache/samza/config/Config.html#getBoolean(java.lang.String,%20boolean)">getBoolean(String, boolean)</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="strong"><a href="./org/apache/samza/config/Config.html#getBoolean(java.lang.String)">getBoolean(String)</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="strong"><a href="./org/apache/samza/checkpoint/CheckpointManagerFactory.html#getCheckpointManager(org.apache.samza.config.Config, org.apache.samza.metrics.MetricsRegistry)">getCheckpointManager(Config, MetricsRegistry)</a></span> - Method in interface org.apache.samza.checkpoint.<a href="./org/apache/samza/checkpoint/CheckpointManagerFactory.html" title="interface in org.apache.samza.checkpoint">CheckpointManagerFactory</a></dt>
+<dt><span class="strong"><a href="./org/apache/samza/checkpoint/CheckpointManagerFactory.html#getCheckpointManager(org.apache.samza.config.Config,%20org.apache.samza.metrics.MetricsRegistry)">getCheckpointManager(Config, MetricsRegistry)</a></span> - Method in interface org.apache.samza.checkpoint.<a href="./org/apache/samza/checkpoint/CheckpointManagerFactory.html" title="interface in org.apache.samza.checkpoint">CheckpointManagerFactory</a></dt>
<dd> </dd>
-<dt><span class="strong"><a href="./org/apache/samza/system/chooser/MessageChooserFactory.html#getChooser(org.apache.samza.config.Config, org.apache.samza.metrics.MetricsRegistry)">getChooser(Config, MetricsRegistry)</a></span> - Method in interface org.apache.samza.system.chooser.<a href="./org/apache/samza/system/chooser/MessageChooserFactory.html" title="interface in org.apache.samza.system.chooser">MessageChooserFactory</a></dt>
+<dt><span class="strong"><a href="./org/apache/samza/system/chooser/MessageChooserFactory.html#getChooser(org.apache.samza.config.Config,%20org.apache.samza.metrics.MetricsRegistry)">getChooser(Config, MetricsRegistry)</a></span> - Method in interface org.apache.samza.system.chooser.<a href="./org/apache/samza/system/chooser/MessageChooserFactory.html" title="interface in org.apache.samza.system.chooser">MessageChooserFactory</a></dt>
<dd> </dd>
<dt><span class="strong"><a href="./org/apache/samza/config/Config.html#getClass(java.lang.String)">getClass(String)</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="strong"><a href="./org/apache/samza/config/ConfigFactory.html#getConfig(java.net.URI)">getConfig(URI)</a></span> - Method in interface org.apache.samza.config.<a href="./org/apache/samza/config/ConfigFactory.html" title="interface in org.apache.samza.config">ConfigFactory</a></dt>
-<dd>
-<div class="block">Build a specific Config.</div>
-</dd>
-<dt><span class="strong"><a href="./org/apache/samza/system/SystemFactory.html#getConsumer(java.lang.String, org.apache.samza.config.Config, org.apache.samza.metrics.MetricsRegistry)">getConsumer(String, Config, MetricsRegistry)</a></span> - Method in interface org.apache.samza.system.<a href="./org/apache/samza/system/SystemFactory.html" title="interface in org.apache.samza.system">SystemFactory</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/samza/system/SystemFactory.html#getConsumer(java.lang.String,%20org.apache.samza.config.Config,%20org.apache.samza.metrics.MetricsRegistry)">getConsumer(String, Config, MetricsRegistry)</a></span> - Method in interface org.apache.samza.system.<a href="./org/apache/samza/system/SystemFactory.html" title="interface in org.apache.samza.system">SystemFactory</a></dt>
<dd> </dd>
<dt><span class="strong"><a href="./org/apache/samza/metrics/Counter.html#getCount()">getCount()</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="strong"><a href="./org/apache/samza/config/Config.html#getDate(java.lang.String)">getDate(String)</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="strong"><a href="./org/apache/samza/config/Config.html#getDate(java.lang.String, java.lang.String)">getDate(String, String)</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>
+<dt><span class="strong"><a href="./org/apache/samza/config/Config.html#getDate(java.lang.String,%20java.lang.String)">getDate(String, String)</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="strong"><a href="./org/apache/samza/config/Config.html#getDate(java.lang.String, java.text.SimpleDateFormat)">getDate(String, SimpleDateFormat)</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>
+<dt><span class="strong"><a href="./org/apache/samza/config/Config.html#getDate(java.lang.String,%20java.text.SimpleDateFormat)">getDate(String, SimpleDateFormat)</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="strong"><a href="./org/apache/samza/config/Config.html#getDate(java.lang.String, java.util.Date)">getDate(String, Date)</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>
+<dt><span class="strong"><a href="./org/apache/samza/config/Config.html#getDate(java.lang.String,%20java.util.Date)">getDate(String, Date)</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="strong"><a href="./org/apache/samza/config/Config.html#getDate(java.lang.String, java.lang.String, java.util.Date)">getDate(String, String, Date)</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>
+<dt><span class="strong"><a href="./org/apache/samza/config/Config.html#getDate(java.lang.String,%20java.lang.String,%20java.util.Date)">getDate(String, String, Date)</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="strong"><a href="./org/apache/samza/config/Config.html#getDate(java.lang.String, java.text.SimpleDateFormat, java.util.Date)">getDate(String, SimpleDateFormat, Date)</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>
+<dt><span class="strong"><a href="./org/apache/samza/config/Config.html#getDate(java.lang.String,%20java.text.SimpleDateFormat,%20java.util.Date)">getDate(String, SimpleDateFormat, Date)</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="strong"><a href="./org/apache/samza/config/Config.html#getDouble(java.lang.String, double)">getDouble(String, double)</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>
+<dt><span class="strong"><a href="./org/apache/samza/config/Config.html#getDouble(java.lang.String,%20double)">getDouble(String, double)</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="strong"><a href="./org/apache/samza/config/Config.html#getDouble(java.lang.String)">getDouble(String)</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>
@@ -362,7 +335,7 @@
<dd> </dd>
<dt><span class="strong"><a href="./org/apache/samza/metrics/ReadableMetricsRegistry.html#getGroups()">getGroups()</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><span class="strong"><a href="./org/apache/samza/config/Config.html#getInt(java.lang.String, int)">getInt(String, int)</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>
+<dt><span class="strong"><a href="./org/apache/samza/config/Config.html#getInt(java.lang.String,%20int)">getInt(String, int)</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="strong"><a href="./org/apache/samza/config/Config.html#getInt(java.lang.String)">getInt(String)</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>
@@ -374,13 +347,13 @@
<dd> </dd>
<dt><span class="strong"><a href="./org/apache/samza/system/OutgoingMessageEnvelope.html#getKeySerializerName()">getKeySerializerName()</a></span> - Method in class org.apache.samza.system.<a href="./org/apache/samza/system/OutgoingMessageEnvelope.html" title="class in org.apache.samza.system">OutgoingMessageEnvelope</a></dt>
<dd> </dd>
-<dt><span class="strong"><a href="./org/apache/samza/task/TaskLifecycleListenerFactory.html#getLifecyleListener(java.lang.String, org.apache.samza.config.Config)">getLifecyleListener(String, Config)</a></span> - Method in interface org.apache.samza.task.<a href="./org/apache/samza/task/TaskLifecycleListenerFactory.html" title="interface in org.apache.samza.task">TaskLifecycleListenerFactory</a></dt>
+<dt><span class="strong"><a href="./org/apache/samza/task/TaskLifecycleListenerFactory.html#getLifecyleListener(java.lang.String,%20org.apache.samza.config.Config)">getLifecyleListener(String, Config)</a></span> - Method in interface org.apache.samza.task.<a href="./org/apache/samza/task/TaskLifecycleListenerFactory.html" title="interface in org.apache.samza.task">TaskLifecycleListenerFactory</a></dt>
<dd> </dd>
-<dt><span class="strong"><a href="./org/apache/samza/config/Config.html#getList(java.lang.String, java.util.List)">getList(String, List<String>)</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>
+<dt><span class="strong"><a href="./org/apache/samza/config/Config.html#getList(java.lang.String,%20java.util.List)">getList(String, List<String>)</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="strong"><a href="./org/apache/samza/config/Config.html#getList(java.lang.String)">getList(String)</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="strong"><a href="./org/apache/samza/config/Config.html#getLong(java.lang.String, long)">getLong(String, long)</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>
+<dt><span class="strong"><a href="./org/apache/samza/config/Config.html#getLong(java.lang.String,%20long)">getLong(String, long)</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="strong"><a href="./org/apache/samza/config/Config.html#getLong(java.lang.String)">getLong(String)</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>
@@ -392,7 +365,7 @@
<dd> </dd>
<dt><span class="strong"><a href="./org/apache/samza/task/TaskContext.html#getMetricsRegistry()">getMetricsRegistry()</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> </dd>
-<dt><span class="strong"><a href="./org/apache/samza/metrics/MetricsReporterFactory.html#getMetricsReporter(java.lang.String, java.lang.String, org.apache.samza.config.Config)">getMetricsReporter(String, String, Config)</a></span> - Method in interface org.apache.samza.metrics.<a href="./org/apache/samza/metrics/MetricsReporterFactory.html" title="interface in org.apache.samza.metrics">MetricsReporterFactory</a></dt>
+<dt><span class="strong"><a href="./org/apache/samza/metrics/MetricsReporterFactory.html#getMetricsReporter(java.lang.String,%20java.lang.String,%20org.apache.samza.config.Config)">getMetricsReporter(String, String, Config)</a></span> - Method in interface org.apache.samza.metrics.<a href="./org/apache/samza/metrics/MetricsReporterFactory.html" title="interface in org.apache.samza.metrics">MetricsReporterFactory</a></dt>
<dd> </dd>
<dt><span class="strong"><a href="./org/apache/samza/metrics/Counter.html#getName()">getName()</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>
@@ -429,19 +402,17 @@
<dd> </dd>
<dt><span class="strong"><a href="./org/apache/samza/system/OutgoingMessageEnvelope.html#getPartitionKey()">getPartitionKey()</a></span> - Method in class org.apache.samza.system.<a href="./org/apache/samza/system/OutgoingMessageEnvelope.html" title="class in org.apache.samza.system">OutgoingMessageEnvelope</a></dt>
<dd> </dd>
-<dt><span class="strong"><a href="./org/apache/samza/system/SystemFactory.html#getProducer(java.lang.String, org.apache.samza.config.Config, org.apache.samza.metrics.MetricsRegistry)">getProducer(String, Config, MetricsRegistry)</a></span> - Method in interface org.apache.samza.system.<a href="./org/apache/samza/system/SystemFactory.html" title="interface in org.apache.samza.system">SystemFactory</a></dt>
+<dt><span class="strong"><a href="./org/apache/samza/system/SystemFactory.html#getProducer(java.lang.String,%20org.apache.samza.config.Config,%20org.apache.samza.metrics.MetricsRegistry)">getProducer(String, Config, MetricsRegistry)</a></span> - Method in interface org.apache.samza.system.<a href="./org/apache/samza/system/SystemFactory.html" title="interface in org.apache.samza.system">SystemFactory</a></dt>
<dd> </dd>
-<dt><span class="strong"><a href="./org/apache/samza/serializers/SerdeFactory.html#getSerde(java.lang.String, org.apache.samza.config.Config)">getSerde(String, Config)</a></span> - Method in interface org.apache.samza.serializers.<a href="./org/apache/samza/serializers/SerdeFactory.html" title="interface in org.apache.samza.serializers">SerdeFactory</a></dt>
+<dt><span class="strong"><a href="./org/apache/samza/serializers/SerdeFactory.html#getSerde(java.lang.String,%20org.apache.samza.config.Config)">getSerde(String, Config)</a></span> - Method in interface org.apache.samza.serializers.<a href="./org/apache/samza/serializers/SerdeFactory.html" title="interface in org.apache.samza.serializers">SerdeFactory</a></dt>
<dd> </dd>
-<dt><span class="strong"><a href="./org/apache/samza/config/Config.html#getShort(java.lang.String, short)">getShort(String, short)</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>
+<dt><span class="strong"><a href="./org/apache/samza/config/Config.html#getShort(java.lang.String,%20short)">getShort(String, short)</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="strong"><a href="./org/apache/samza/config/Config.html#getShort(java.lang.String)">getShort(String)</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="strong"><a href="./org/apache/samza/job/StreamJob.html#getStatus()">getStatus()</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">Get current <a href="./org/apache/samza/job/ApplicationStatus.html" title="enum in org.apache.samza.job"><code>ApplicationStatus</code></a> of the job</div>
-</dd>
-<dt><span class="strong"><a href="./org/apache/samza/storage/StorageEngineFactory.html#getStorageEngine(java.lang.String, java.io.File, org.apache.samza.serializers.Serde, org.apache.samza.serializers.Serde, org.apache.samza.task.MessageCollector, org.apache.samza.metrics.MetricsRegistry, org.apache.samza.system.SystemStreamPartition, org.apache.samza.container.SamzaContainerContext)">getStorageEngine(String, File, Serde<K>, Serde<V>, MessageCollector, MetricsRegistry, SystemStreamPartition, SamzaContainerContext)</a></span> - Method in interface org.apache.samza.storage.<a href="./org/apache/samza/storage/StorageEngineFactory.html" title="interface in org.apache.samza.storage">StorageEngineFactory</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/samza/storage/StorageEngineFactory.html#getStorageEngine(java.lang.String,%20java.io.File,%20org.apache.samza.serializers.Serde,%20org.apache.samza.serializers.Serde,%20org.apache.samza.task.MessageCollector,%20org.apache.samza.metrics.MetricsRegistry,%20org.apache.samza.system.SystemStreamPartition,%20org.apache.samza.container.SamzaContainerContext)">getStorageEngine(String, File, Serde<K>, Serde<V>, MessageCollector, MetricsRegistry, SystemStreamPartition, SamzaContainerContext)</a></span> - Method in interface org.apache.samza.storage.<a href="./org/apache/samza/storage/StorageEngineFactory.html" title="interface in org.apache.samza.storage">StorageEngineFactory</a></dt>
<dd>
<div class="block">Create an instance of the given storage engine.</div>
</dd>
@@ -520,13 +491,13 @@
<div class="block">This class represents a message envelope that is received by a StreamTask for each message that is received from a
partition of a specific input stream.</div>
</dd>
-<dt><span class="strong"><a href="./org/apache/samza/system/IncomingMessageEnvelope.html#IncomingMessageEnvelope(org.apache.samza.system.SystemStreamPartition, java.lang.String, java.lang.Object, java.lang.Object)">IncomingMessageEnvelope(SystemStreamPartition, String, Object, Object)</a></span> - Constructor for class org.apache.samza.system.<a href="./org/apache/samza/system/IncomingMessageEnvelope.html" title="class in org.apache.samza.system">IncomingMessageEnvelope</a></dt>
+<dt><span class="strong"><a href="./org/apache/samza/system/IncomingMessageEnvelope.html#IncomingMessageEnvelope(org.apache.samza.system.SystemStreamPartition,%20java.lang.String,%20java.lang.Object,%20java.lang.Object)">IncomingMessageEnvelope(SystemStreamPartition, String, Object, Object)</a></span> - Constructor for class org.apache.samza.system.<a href="./org/apache/samza/system/IncomingMessageEnvelope.html" title="class in org.apache.samza.system">IncomingMessageEnvelope</a></dt>
<dd>
<div class="block">Constructs a new IncomingMessageEnvelope from specified components.</div>
</dd>
<dt><span class="strong"><a href="./org/apache/samza/util/BlockingEnvelopeMap.BlockingEnvelopeMapMetrics.html#incPoll()">incPoll()</a></span> - Method in 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="strong"><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>
+<dt><span class="strong"><a href="./org/apache/samza/task/InitableTask.html#init(org.apache.samza.config.Config,%20org.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>
@@ -550,9 +521,7 @@
<dt><span class="strong"><a href="./org/apache/samza/config/MapConfig.html#keySet()">keySet()</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><span class="strong"><a href="./org/apache/samza/job/StreamJob.html#kill()">kill()</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">Kill this job immediately.</div>
-</dd>
+<dd> </dd>
</dl>
<a name="_L_">
<!-- -->
@@ -568,9 +537,7 @@
<h2 class="title">M</h2>
<dl>
<dt><a href="./org/apache/samza/config/MapConfig.html" title="class in org.apache.samza.config"><span class="strong">MapConfig</span></a> - Class in <a href="./org/apache/samza/config/package-summary.html">org.apache.samza.config</a></dt>
-<dd>
-<div class="block">A <a href="./org/apache/samza/config/Config.html" title="class in org.apache.samza.config"><code>Config</code></a> backed by a Java <code>Map</code></div>
-</dd>
+<dd> </dd>
<dt><span class="strong"><a href="./org/apache/samza/config/MapConfig.html#MapConfig()">MapConfig()</a></span> - Constructor for 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><span class="strong"><a href="./org/apache/samza/config/MapConfig.html#MapConfig(java.util.Map)">MapConfig(Map<String, String>)</a></span> - Constructor for class org.apache.samza.config.<a href="./org/apache/samza/config/MapConfig.html" title="class in org.apache.samza.config">MapConfig</a></dt>
@@ -583,9 +550,7 @@
stream consumption.</div>
</dd>
<dt><a href="./org/apache/samza/system/chooser/MessageChooserFactory.html" title="interface in org.apache.samza.system.chooser"><span class="strong">MessageChooserFactory</span></a> - Interface in <a href="./org/apache/samza/system/chooser/package-summary.html">org.apache.samza.system.chooser</a></dt>
-<dd>
-<div class="block">Build an instance of a <a href="./org/apache/samza/system/chooser/MessageChooser.html" title="interface in org.apache.samza.system.chooser"><code>MessageChooser</code></a></div>
-</dd>
+<dd> </dd>
<dt><a href="./org/apache/samza/task/MessageCollector.html" title="interface in org.apache.samza.task"><span class="strong">MessageCollector</span></a> - Interface in <a href="./org/apache/samza/task/package-summary.html">org.apache.samza.task</a></dt>
<dd>
<div class="block">Used as an interface for the means of sending message envelopes to an output stream.</div>
@@ -595,23 +560,16 @@
<div class="block">Metric class that allows metric visitors to visit it to get its information.</div>
</dd>
<dt><a href="./org/apache/samza/metrics/MetricsRegistry.html" title="interface in org.apache.samza.metrics"><span class="strong">MetricsRegistry</span></a> - Interface in <a href="./org/apache/samza/metrics/package-summary.html">org.apache.samza.metrics</a></dt>
-<dd>
-<div class="block">A MetricsRegistry allows its users to create new <a href="./org/apache/samza/metrics/Metric.html" title="interface in org.apache.samza.metrics"><code>Metric</code></a>s and
- have those metrics wired to specific metrics systems, such as JMX, provided by <a href="./org/apache/samza/metrics/MetricsReporter.html" title="interface in org.apache.samza.metrics"><code>MetricsReporter</code></a>s.</div>
-</dd>
+<dd> </dd>
<dt><a href="./org/apache/samza/metrics/MetricsReporter.html" title="interface in org.apache.samza.metrics"><span class="strong">MetricsReporter</span></a> - Interface in <a href="./org/apache/samza/metrics/package-summary.html">org.apache.samza.metrics</a></dt>
-<dd>
-<div class="block">A MetricsReporter is the interface that different metrics sinks, such as JMX, implement to receive
- metrics from the Samza framework and Samza jobs.</div>
-</dd>
+<dd> </dd>
<dt><a href="./org/apache/samza/metrics/MetricsReporterFactory.html" title="interface in org.apache.samza.metrics"><span class="strong">MetricsReporterFactory</span></a> - Interface in <a href="./org/apache/samza/metrics/package-summary.html">org.apache.samza.metrics</a></dt>
-<dd>
-<div class="block">Build a <a href="./org/apache/samza/metrics/MetricsReporter.html" title="interface in org.apache.samza.metrics"><code>MetricsReporter</code></a></div>
-</dd>
+<dd> </dd>
+<dt><a href="./org/apache/samza/metrics/MetricsType.html" title="enum in org.apache.samza.metrics"><span class="strong">MetricsType</span></a> - Enum in <a href="./org/apache/samza/metrics/package-summary.html">org.apache.samza.metrics</a></dt>
+<dd> </dd>
<dt><a href="./org/apache/samza/metrics/MetricsVisitor.html" title="class in org.apache.samza.metrics"><span class="strong">MetricsVisitor</span></a> - Class in <a href="./org/apache/samza/metrics/package-summary.html">org.apache.samza.metrics</a></dt>
<dd>
-<div class="block">A MetricsVisitor can be used to process each metric in a <a href="./org/apache/samza/metrics/ReadableMetricsRegistry.html" title="interface in org.apache.samza.metrics"><code>ReadableMetricsRegistry</code></a>,
- encapsulating the logic of what to be done with each metric in the counter and gauge methods.</div>
+<div class="block">A metric visitor visits a metric, before metrics are flushed to a metrics stream.</div>
</dd>
<dt><span class="strong"><a href="./org/apache/samza/metrics/MetricsVisitor.html#MetricsVisitor()">MetricsVisitor()</a></span> - Constructor for class org.apache.samza.metrics.<a href="./org/apache/samza/metrics/MetricsVisitor.html" title="class in org.apache.samza.metrics">MetricsVisitor</a></dt>
<dd> </dd>
@@ -627,37 +585,26 @@
<dd> </dd>
<dt><span class="strong"><a href="./org/apache/samza/util/BlockingEnvelopeMap.html#newBlockingQueue()">newBlockingQueue()</a></span> - Method in class org.apache.samza.util.<a href="./org/apache/samza/util/BlockingEnvelopeMap.html" title="class in org.apache.samza.util">BlockingEnvelopeMap</a></dt>
<dd> </dd>
-<dt><span class="strong"><a href="./org/apache/samza/metrics/MetricsRegistry.html#newCounter(java.lang.String, java.lang.String)">newCounter(String, String)</a></span> - Method in interface org.apache.samza.metrics.<a href="./org/apache/samza/metrics/MetricsRegistry.html" title="interface in org.apache.samza.metrics">MetricsRegistry</a></dt>
-<dd>
-<div class="block">Create and register a new <a href="./org/apache/samza/metrics/Counter.html" title="class in org.apache.samza.metrics"><code>Counter</code></a></div>
-</dd>
-<dt><span class="strong"><a href="./org/apache/samza/metrics/MetricsRegistry.html#newCounter(java.lang.String, org.apache.samza.metrics.Counter)">newCounter(String, Counter)</a></span> - Method in interface org.apache.samza.metrics.<a href="./org/apache/samza/metrics/MetricsRegistry.html" title="interface in org.apache.samza.metrics">MetricsRegistry</a></dt>
-<dd>
-<div class="block">Register existing <a href="./org/apache/samza/metrics/Counter.html" title="class in org.apache.samza.metrics"><code>Counter</code></a> with this registry</div>
-</dd>
-<dt><span class="strong"><a href="./org/apache/samza/util/NoOpMetricsRegistry.html#newCounter(java.lang.String, java.lang.String)">newCounter(String, String)</a></span> - Method in class org.apache.samza.util.<a href="./org/apache/samza/util/NoOpMetricsRegistry.html" title="class in org.apache.samza.util">NoOpMetricsRegistry</a></dt>
+<dt><span class="strong"><a href="./org/apache/samza/metrics/MetricsRegistry.html#newCounter(java.lang.String,%20java.lang.String)">newCounter(String, String)</a></span> - Method in interface org.apache.samza.metrics.<a href="./org/apache/samza/metrics/MetricsRegistry.html" title="interface in org.apache.samza.metrics">MetricsRegistry</a></dt>
<dd> </dd>
-<dt><span class="strong"><a href="./org/apache/samza/util/NoOpMetricsRegistry.html#newCounter(java.lang.String, org.apache.samza.metrics.Counter)">newCounter(String, Counter)</a></span> - Method in class org.apache.samza.util.<a href="./org/apache/samza/util/NoOpMetricsRegistry.html" title="class in org.apache.samza.util">NoOpMetricsRegistry</a></dt>
+<dt><span class="strong"><a href="./org/apache/samza/metrics/MetricsRegistry.html#newCounter(java.lang.String,%20org.apache.samza.metrics.Counter)">newCounter(String, Counter)</a></span> - Method in interface org.apache.samza.metrics.<a href="./org/apache/samza/metrics/MetricsRegistry.html" title="interface in org.apache.samza.metrics">MetricsRegistry</a></dt>
<dd> </dd>
-<dt><span class="strong"><a href="./org/apache/samza/metrics/MetricsRegistry.html#newGauge(java.lang.String, java.lang.String, T)">newGauge(String, String, T)</a></span> - Method in interface org.apache.samza.metrics.<a href="./org/apache/samza/metrics/MetricsRegistry.html" title="interface in org.apache.samza.metrics">MetricsRegistry</a></dt>
-<dd>
-<div class="block">Create and register a new <a href="./org/apache/samza/metrics/Gauge.html" title="class in org.apache.samza.metrics"><code>Gauge</code></a></div>
-</dd>
-<dt><span class="strong"><a href="./org/apache/samza/metrics/MetricsRegistry.html#newGauge(java.lang.String, org.apache.samza.metrics.Gauge)">newGauge(String, Gauge<T>)</a></span> - Method in interface org.apache.samza.metrics.<a href="./org/apache/samza/metrics/MetricsRegistry.html" title="interface in org.apache.samza.metrics">MetricsRegistry</a></dt>
-<dd>
-<div class="block">Register an existing <a href="./org/apache/samza/metrics/Gauge.html" title="class in org.apache.samza.metrics"><code>Gauge</code></a></div>
-</dd>
-<dt><span class="strong"><a href="./org/apache/samza/util/NoOpMetricsRegistry.html#newGauge(java.lang.String, java.lang.String, T)">newGauge(String, String, T)</a></span> - Method in class org.apache.samza.util.<a href="./org/apache/samza/util/NoOpMetricsRegistry.html" title="class in org.apache.samza.util">NoOpMetricsRegistry</a></dt>
+<dt><span class="strong"><a href="./org/apache/samza/util/NoOpMetricsRegistry.html#newCounter(java.lang.String,%20java.lang.String)">newCounter(String, String)</a></span> - Method in class org.apache.samza.util.<a href="./org/apache/samza/util/NoOpMetricsRegistry.html" title="class in org.apache.samza.util">NoOpMetricsRegistry</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/samza/util/NoOpMetricsRegistry.html#newCounter(java.lang.String,%20org.apache.samza.metrics.Counter)">newCounter(String, Counter)</a></span> - Method in class org.apache.samza.util.<a href="./org/apache/samza/util/NoOpMetricsRegistry.html" title="class in org.apache.samza.util">NoOpMetricsRegistry</a></dt>
<dd> </dd>
-<dt><span class="strong"><a href="./org/apache/samza/util/NoOpMetricsRegistry.html#newGauge(java.lang.String, org.apache.samza.metrics.Gauge)">newGauge(String, Gauge<T>)</a></span> - Method in class org.apache.samza.util.<a href="./org/apache/samza/util/NoOpMetricsRegistry.html" title="class in org.apache.samza.util">NoOpMetricsRegistry</a></dt>
+<dt><span class="strong"><a href="./org/apache/samza/metrics/MetricsRegistry.html#newGauge(java.lang.String,%20java.lang.String,%20T)">newGauge(String, String, T)</a></span> - Method in interface org.apache.samza.metrics.<a href="./org/apache/samza/metrics/MetricsRegistry.html" title="interface in org.apache.samza.metrics">MetricsRegistry</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/samza/metrics/MetricsRegistry.html#newGauge(java.lang.String,%20org.apache.samza.metrics.Gauge)">newGauge(String, Gauge<T>)</a></span> - Method in interface org.apache.samza.metrics.<a href="./org/apache/samza/metrics/MetricsRegistry.html" title="interface in org.apache.samza.metrics">MetricsRegistry</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/samza/util/NoOpMetricsRegistry.html#newGauge(java.lang.String,%20java.lang.String,%20T)">newGauge(String, String, T)</a></span> - Method in class org.apache.samza.util.<a href="./org/apache/samza/util/NoOpMetricsRegistry.html" title="class in org.apache.samza.util">NoOpMetricsRegistry</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/samza/util/NoOpMetricsRegistry.html#newGauge(java.lang.String,%20org.apache.samza.metrics.Gauge)">newGauge(String, Gauge<T>)</a></span> - Method in class org.apache.samza.util.<a href="./org/apache/samza/util/NoOpMetricsRegistry.html" title="class in org.apache.samza.util">NoOpMetricsRegistry</a></dt>
<dd> </dd>
<dt><span class="strong"><a href="./org/apache/samza/system/SystemStreamPartitionIterator.html#next()">next()</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>
<dd> </dd>
<dt><a href="./org/apache/samza/util/NoOpMetricsRegistry.html" title="class in org.apache.samza.util"><span class="strong">NoOpMetricsRegistry</span></a> - Class in <a href="./org/apache/samza/util/package-summary.html">org.apache.samza.util</a></dt>
-<dd>
-<div class="block"><a href="./org/apache/samza/metrics/MetricsRegistry.html" title="interface in org.apache.samza.metrics"><code>MetricsRegistry</code></a> implementation for when no actual metrics need to be
- recorded but a registry is still required.</div>
-</dd>
+<dd> </dd>
<dt><span class="strong"><a href="./org/apache/samza/util/NoOpMetricsRegistry.html#NoOpMetricsRegistry()">NoOpMetricsRegistry()</a></span> - Constructor for class org.apache.samza.util.<a href="./org/apache/samza/util/NoOpMetricsRegistry.html" title="class in org.apache.samza.util">NoOpMetricsRegistry</a></dt>
<dd> </dd>
</dl>
@@ -666,9 +613,9 @@
</a>
<h2 class="title">O</h2>
<dl>
-<dt><span class="strong"><a href="./org/apache/samza/metrics/ReadableMetricsRegistryListener.html#onCounter(java.lang.String, org.apache.samza.metrics.Counter)">onCounter(String, Counter)</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>
+<dt><span class="strong"><a href="./org/apache/samza/metrics/ReadableMetricsRegistryListener.html#onCounter(java.lang.String,%20org.apache.samza.metrics.Counter)">onCounter(String, Counter)</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="strong"><a href="./org/apache/samza/metrics/ReadableMetricsRegistryListener.html#onGauge(java.lang.String, org.apache.samza.metrics.Gauge)">onGauge(String, Gauge<?>)</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>
+<dt><span class="strong"><a href="./org/apache/samza/metrics/ReadableMetricsRegistryListener.html#onGauge(java.lang.String,%20org.apache.samza.metrics.Gauge)">onGauge(String, Gauge<?>)</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><a href="./org/apache/samza/package-summary.html">org.apache.samza</a> - package org.apache.samza</dt>
<dd> </dd>
@@ -696,22 +643,21 @@
<dd> </dd>
<dt><a href="./org/apache/samza/system/OutgoingMessageEnvelope.html" title="class in org.apache.samza.system"><span class="strong">OutgoingMessageEnvelope</span></a> - Class in <a href="./org/apache/samza/system/package-summary.html">org.apache.samza.system</a></dt>
<dd>
-<div class="block">An OutgoingMessageEnvelope is sent to a specified <a href="./org/apache/samza/system/SystemStream.html" title="class in org.apache.samza.system"><code>SystemStream</code></a> via the appropriate <a href="./org/apache/samza/system/SystemProducer.html" title="interface in org.apache.samza.system"><code>SystemProducer</code></a>
- from the user's <a href="./org/apache/samza/task/StreamTask.html" title="interface in org.apache.samza.task"><code>StreamTask</code></a>.</div>
+<div class="block">This class represents a message envelope that is sent by a StreamTask.</div>
</dd>
-<dt><span class="strong"><a href="./org/apache/samza/system/OutgoingMessageEnvelope.html#OutgoingMessageEnvelope(org.apache.samza.system.SystemStream, java.lang.String, java.lang.String, java.lang.Object, java.lang.Object, java.lang.Object)">OutgoingMessageEnvelope(SystemStream, String, String, Object, Object, Object)</a></span> - Constructor for class org.apache.samza.system.<a href="./org/apache/samza/system/OutgoingMessageEnvelope.html" title="class in org.apache.samza.system">OutgoingMessageEnvelope</a></dt>
+<dt><span class="strong"><a href="./org/apache/samza/system/OutgoingMessageEnvelope.html#OutgoingMessageEnvelope(org.apache.samza.system.SystemStream,%20java.lang.String,%20java.lang.String,%20java.lang.Object,%20java.lang.Object,%20java.lang.Object)">OutgoingMessageEnvelope(SystemStream, String, String, Object, Object, Object)</a></span> - Constructor for class org.apache.samza.system.<a href="./org/apache/samza/system/OutgoingMessageEnvelope.html" title="class in org.apache.samza.system">OutgoingMessageEnvelope</a></dt>
<dd>
<div class="block">Constructs a new OutgoingMessageEnvelope from specified components.</div>
</dd>
-<dt><span class="strong"><a href="./org/apache/samza/system/OutgoingMessageEnvelope.html#OutgoingMessageEnvelope(org.apache.samza.system.SystemStream, java.lang.Object, java.lang.Object, java.lang.Object)">OutgoingMessageEnvelope(SystemStream, Object, Object, Object)</a></span> - Constructor for class org.apache.samza.system.<a href="./org/apache/samza/system/OutgoingMessageEnvelope.html" title="class in org.apache.samza.system">OutgoingMessageEnvelope</a></dt>
+<dt><span class="strong"><a href="./org/apache/samza/system/OutgoingMessageEnvelope.html#OutgoingMessageEnvelope(org.apache.samza.system.SystemStream,%20java.lang.Object,%20java.lang.Object,%20java.lang.Object)">OutgoingMessageEnvelope(SystemStream, Object, Object, Object)</a></span> - Constructor for class org.apache.samza.system.<a href="./org/apache/samza/system/OutgoingMessageEnvelope.html" title="class in org.apache.samza.system">OutgoingMessageEnvelope</a></dt>
<dd>
<div class="block">Constructs a new OutgoingMessageEnvelope from specified components.</div>
</dd>
-<dt><span class="strong"><a href="./org/apache/samza/system/OutgoingMessageEnvelope.html#OutgoingMessageEnvelope(org.apache.samza.system.SystemStream, java.lang.Object, java.lang.Object)">OutgoingMessageEnvelope(SystemStream, Object, Object)</a></span> - Constructor for class org.apache.samza.system.<a href="./org/apache/samza/system/OutgoingMessageEnvelope.html" title="class in org.apache.samza.system">OutgoingMessageEnvelope</a></dt>
+<dt><span class="strong"><a href="./org/apache/samza/system/OutgoingMessageEnvelope.html#OutgoingMessageEnvelope(org.apache.samza.system.SystemStream,%20java.lang.Object,%20java.lang.Object)">OutgoingMessageEnvelope(SystemStream, Object, Object)</a></span> - Constructor for class org.apache.samza.system.<a href="./org/apache/samza/system/OutgoingMessageEnvelope.html" title="class in org.apache.samza.system">OutgoingMessageEnvelope</a></dt>
<dd>
<div class="block">Constructs a new OutgoingMessageEnvelope from specified components.</div>
</dd>
-<dt><span class="strong"><a href="./org/apache/samza/system/OutgoingMessageEnvelope.html#OutgoingMessageEnvelope(org.apache.samza.system.SystemStream, java.lang.Object)">OutgoingMessageEnvelope(SystemStream, Object)</a></span> - Constructor for class org.apache.samza.system.<a href="./org/apache/samza/system/OutgoingMessageEnvelope.html" title="class in org.apache.samza.system">OutgoingMessageEnvelope</a></dt>
+<dt><span class="strong"><a href="./org/apache/samza/system/OutgoingMessageEnvelope.html#OutgoingMessageEnvelope(org.apache.samza.system.SystemStream,%20java.lang.Object)">OutgoingMessageEnvelope(SystemStream, Object)</a></span> - Constructor for class org.apache.samza.system.<a href="./org/apache/samza/system/OutgoingMessageEnvelope.html" title="class in org.apache.samza.system">OutgoingMessageEnvelope</a></dt>
<dd>
<div class="block">Constructs a new OutgoingMessageEnvelope from specified components.</div>
</dd>
@@ -723,7 +669,7 @@
<dl>
<dt><a href="./org/apache/samza/Partition.html" title="class in org.apache.samza"><span class="strong">Partition</span></a> - Class in <a href="./org/apache/samza/package-summary.html">org.apache.samza</a></dt>
<dd>
-<div class="block">A numbered, ordered partition of a stream.</div>
+<div class="block">Used to represent a Samza stream partition.</div>
</dd>
<dt><span class="strong"><a href="./org/apache/samza/Partition.html#Partition(int)">Partition(int)</a></span> - Constructor for class org.apache.samza.<a href="./org/apache/samza/Partition.html" title="class in org.apache.samza">Partition</a></dt>
<dd>
@@ -733,24 +679,24 @@
<dd> </dd>
<dt><span class="strong"><a href="./org/apache/samza/container/SamzaContainerContext.html#partitions">partitions</a></span> - Variable in class org.apache.samza.container.<a href="./org/apache/samza/container/SamzaContainerContext.html" title="class in org.apache.samza.container">SamzaContainerContext</a></dt>
<dd> </dd>
-<dt><span class="strong"><a href="./org/apache/samza/system/SystemConsumer.html#poll(java.util.Map, long)">poll(Map<SystemStreamPartition, Integer>, long)</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>
+<dt><span class="strong"><a href="./org/apache/samza/system/SystemConsumer.html#poll(java.util.Map,%20long)">poll(Map<SystemStreamPartition, Integer>, long)</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">Poll the SystemConsumer to get any available messages from the underlying
system.</div>
</dd>
-<dt><span class="strong"><a href="./org/apache/samza/util/BlockingEnvelopeMap.html#poll(java.util.Map, long)">poll(Map<SystemStreamPartition, Integer>, long)</a></span> - Method in class org.apache.samza.util.<a href="./org/apache/samza/util/BlockingEnvelopeMap.html" title="class in org.apache.samza.util">BlockingEnvelopeMap</a></dt>
+<dt><span class="strong"><a href="./org/apache/samza/util/BlockingEnvelopeMap.html#poll(java.util.Map,%20long)">poll(Map<SystemStreamPartition, Integer>, long)</a></span> - Method in class org.apache.samza.util.<a href="./org/apache/samza/util/BlockingEnvelopeMap.html" title="class in org.apache.samza.util">BlockingEnvelopeMap</a></dt>
<dd> </dd>
-<dt><span class="strong"><a href="./org/apache/samza/task/StreamTask.html#process(org.apache.samza.system.IncomingMessageEnvelope, org.apache.samza.task.MessageCollector, org.apache.samza.task.TaskCoordinator)">process(IncomingMessageEnvelope, MessageCollector, TaskCoordinator)</a></span> - Method in interface org.apache.samza.task.<a href="./org/apache/samza/task/StreamTask.html" title="interface in org.apache.samza.task">StreamTask</a></dt>
+<dt><span class="strong"><a href="./org/apache/samza/task/StreamTask.html#process(org.apache.samza.system.IncomingMessageEnvelope,%20org.apache.samza.task.MessageCollector,%20org.apache.samza.task.TaskCoordinator)">process(IncomingMessageEnvelope, MessageCollector, TaskCoordinator)</a></span> - Method in interface org.apache.samza.task.<a href="./org/apache/samza/task/StreamTask.html" title="interface in org.apache.samza.task">StreamTask</a></dt>
<dd>
<div class="block">Called once for each message that this StreamTask receives.</div>
</dd>
-<dt><span class="strong"><a href="./org/apache/samza/config/Config.html#put(java.lang.String, java.lang.String)">put(String, String)</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>
+<dt><span class="strong"><a href="./org/apache/samza/config/Config.html#put(java.lang.String,%20java.lang.String)">put(String, String)</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="strong"><a href="./org/apache/samza/util/BlockingEnvelopeMap.html#put(org.apache.samza.system.SystemStreamPartition, org.apache.samza.system.IncomingMessageEnvelope)">put(SystemStreamPartition, IncomingMessageEnvelope)</a></span> - Method in class org.apache.samza.util.<a href="./org/apache/samza/util/BlockingEnvelopeMap.html" title="class in org.apache.samza.util">BlockingEnvelopeMap</a></dt>
+<dt><span class="strong"><a href="./org/apache/samza/util/BlockingEnvelopeMap.html#put(org.apache.samza.system.SystemStreamPartition,%20org.apache.samza.system.IncomingMessageEnvelope)">put(SystemStreamPartition, IncomingMessageEnvelope)</a></span> - Method in class org.apache.samza.util.<a href="./org/apache/samza/util/BlockingEnvelopeMap.html" title="class in org.apache.samza.util">BlockingEnvelopeMap</a></dt>
<dd> </dd>
<dt><span class="strong"><a href="./org/apache/samza/config/Config.html#putAll(java.util.Map)">putAll(Map<? extends String, ? extends String>)</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="strong"><a href="./org/apache/samza/util/BlockingEnvelopeMap.html#putAll(org.apache.samza.system.SystemStreamPartition, java.util.List)">putAll(SystemStreamPartition, List<IncomingMessageEnvelope>)</a></span> - Method in class org.apache.samza.util.<a href="./org/apache/samza/util/BlockingEnvelopeMap.html" title="class in org.apache.samza.util">BlockingEnvelopeMap</a></dt>
+<dt><span class="strong"><a href="./org/apache/samza/util/BlockingEnvelopeMap.html#putAll(org.apache.samza.system.SystemStreamPartition,%20java.util.List)">putAll(SystemStreamPartition, List<IncomingMessageEnvelope>)</a></span> - Method in class org.apache.samza.util.<a href="./org/apache/samza/util/BlockingEnvelopeMap.html" title="class in org.apache.samza.util">BlockingEnvelopeMap</a></dt>
<dd> </dd>
</dl>
<a name="_R_">
@@ -759,10 +705,7 @@
<h2 class="title">R</h2>
<dl>
<dt><a href="./org/apache/samza/metrics/ReadableMetricsRegistry.html" title="interface in org.apache.samza.metrics"><span class="strong">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
- allows read access to the metrics for which it is responsible.</div>
-</dd>
+<dd> </dd>
<dt><a href="./org/apache/samza/metrics/ReadableMetricsRegistryListener.html" title="interface in org.apache.samza.metrics"><span class="strong">ReadableMetricsRegistryListener</span></a> - Interface in <a href="./org/apache/samza/metrics/package-summary.html">org.apache.samza.metrics</a></dt>
<dd> </dd>
<dt><span class="strong"><a href="./org/apache/samza/checkpoint/CheckpointManager.html#readLastCheckpoint(org.apache.samza.Partition)">readLastCheckpoint(Partition)</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>
@@ -773,16 +716,16 @@
<dd>
<div class="block">Registers this manager to write checkpoints of a specific Samza stream partition.</div>
</dd>
-<dt><span class="strong"><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>
+<dt><span class="strong"><a href="./org/apache/samza/metrics/MetricsReporter.html#register(java.lang.String,%20org.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="strong"><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>
+<dt><span class="strong"><a href="./org/apache/samza/system/chooser/BaseMessageChooser.html#register(org.apache.samza.system.SystemStreamPartition,%20java.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="strong"><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>
+<dt><span class="strong"><a href="./org/apache/samza/system/chooser/MessageChooser.html#register(org.apache.samza.system.SystemStreamPartition,%20java.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>
<dd>
<div class="block">Called before start, to let the chooser know that it will be handling
envelopes from the given SystemStreamPartition.</div>
</dd>
-<dt><span class="strong"><a href="./org/apache/samza/system/SystemConsumer.html#register(org.apache.samza.system.SystemStreamPartition, java.lang.String)">register(SystemStreamPartition, String)</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>
+<dt><span class="strong"><a href="./org/apache/samza/system/SystemConsumer.html#register(org.apache.samza.system.SystemStreamPartition,%20java.lang.String)">register(SystemStreamPartition, String)</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">Register a SystemStreamPartition to this SystemConsumer.</div>
</dd>
@@ -790,17 +733,15 @@
<dd>
<div class="block">Registers this producer to send messages from a specified Samza source, such as a StreamTask.</div>
</dd>
-<dt><span class="strong"><a href="./org/apache/samza/util/BlockingEnvelopeMap.html#register(org.apache.samza.system.SystemStreamPartition, java.lang.String)">register(SystemStreamPartition, String)</a></span> - Method in class org.apache.samza.util.<a href="./org/apache/samza/util/BlockingEnvelopeMap.html" title="class in org.apache.samza.util">BlockingEnvelopeMap</a></dt>
+<dt><span class="strong"><a href="./org/apache/samza/util/BlockingEnvelopeMap.html#register(org.apache.samza.system.SystemStreamPartition,%20java.lang.String)">register(SystemStreamPartition, String)</a></span> - Method in class org.apache.samza.util.<a href="./org/apache/samza/util/BlockingEnvelopeMap.html" title="class in org.apache.samza.util">BlockingEnvelopeMap</a></dt>
<dd> </dd>
<dt><span class="strong"><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="strong"><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>
<dd> </dd>
<dt><span class="strong"><a href="./org/apache/samza/storage/StorageEngine.html#restore(java.util.Iterator)">restore(Iterator<IncomingMessageEnvelope>)</a></span> - Method in interface org.apache.samza.storage.<a href="./org/apache/samza/storage/StorageEngine.html" title="interface in org.apache.samza.storage">StorageEngine</a></dt>
-<dd>
-<div class="block">Restore the content of this StorageEngine from the changelog.</div>
-</dd>
-<dt><span class="strong"><a href="./org/apache/samza/config/ConfigRewriter.html#rewrite(java.lang.String, org.apache.samza.config.Config)">rewrite(String, Config)</a></span> - Method in interface org.apache.samza.config.<a href="./org/apache/samza/config/ConfigRewriter.html" title="interface in org.apache.samza.config">ConfigRewriter</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/samza/config/ConfigRewriter.html#rewrite(java.lang.String,%20org.apache.samza.config.Config)">rewrite(String, Config)</a></span> - Method in interface org.apache.samza.config.<a href="./org/apache/samza/config/ConfigRewriter.html" title="interface in org.apache.samza.config">ConfigRewriter</a></dt>
<dd> </dd>
</dl>
<a name="_S_">
@@ -809,10 +750,8 @@
<h2 class="title">S</h2>
<dl>
<dt><a href="./org/apache/samza/container/SamzaContainerContext.html" title="class in org.apache.samza.container"><span class="strong">SamzaContainerContext</span></a> - Class in <a href="./org/apache/samza/container/package-summary.html">org.apache.samza.container</a></dt>
-<dd>
-<div class="block">A SamzaContainerContext maintains per-container information for the tasks it executes.</div>
-</dd>
-<dt><span class="strong"><a href="./org/apache/samza/container/SamzaContainerContext.html#SamzaContainerContext(java.lang.String, org.apache.samza.config.Config, java.util.Collection)">SamzaContainerContext(String, Config, Collection<Partition>)</a></span> - Constructor for class org.apache.samza.container.<a href="./org/apache/samza/container/SamzaContainerContext.html" title="class in org.apache.samza.container">SamzaContainerContext</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/samza/container/SamzaContainerContext.html#SamzaContainerContext(java.lang.String,%20org.apache.samza.config.Config,%20java.util.Collection)">SamzaContainerContext(String, Config, Collection<Partition>)</a></span> - Constructor for class org.apache.samza.container.<a href="./org/apache/samza/container/SamzaContainerContext.html" title="class in org.apache.samza.container">SamzaContainerContext</a></dt>
<dd>
<div class="block">An immutable context object that can passed to tasks to give them information
about the container in which they are executing.</div>
@@ -823,13 +762,13 @@
</dd>
<dt><span class="strong"><a href="./org/apache/samza/SamzaException.html#SamzaException()">SamzaException()</a></span> - Constructor for exception org.apache.samza.<a href="./org/apache/samza/SamzaException.html" title="class in org.apache.samza">SamzaException</a></dt>
<dd> </dd>
-<dt><span class="strong"><a href="./org/apache/samza/SamzaException.html#SamzaException(java.lang.String, java.lang.Throwable)">SamzaException(String, Throwable)</a></span> - Constructor for exception org.apache.samza.<a href="./org/apache/samza/SamzaException.html" title="class in org.apache.samza">SamzaException</a></dt>
+<dt><span class="strong"><a href="./org/apache/samza/SamzaException.html#SamzaException(java.lang.String,%20java.lang.Throwable)">SamzaException(String, Throwable)</a></span> - Constructor for exception org.apache.samza.<a href="./org/apache/samza/SamzaException.html" title="class in org.apache.samza">SamzaException</a></dt>
<dd> </dd>
<dt><span class="strong"><a href="./org/apache/samza/SamzaException.html#SamzaException(java.lang.String)">SamzaException(String)</a></span> - Constructor for exception org.apache.samza.<a href="./org/apache/samza/SamzaException.html" title="class in org.apache.samza">SamzaException</a></dt>
<dd> </dd>
<dt><span class="strong"><a href="./org/apache/samza/SamzaException.html#SamzaException(java.lang.Throwable)">SamzaException(Throwable)</a></span> - Constructor for exception org.apache.samza.<a href="./org/apache/samza/SamzaException.html" title="class in org.apache.samza">SamzaException</a></dt>
<dd> </dd>
-<dt><span class="strong"><a href="./org/apache/samza/system/SystemProducer.html#send(java.lang.String, org.apache.samza.system.OutgoingMessageEnvelope)">send(String, OutgoingMessageEnvelope)</a></span> - Method in interface org.apache.samza.system.<a href="./org/apache/samza/system/SystemProducer.html" title="interface in org.apache.samza.system">SystemProducer</a></dt>
+<dt><span class="strong"><a href="./org/apache/samza/system/SystemProducer.html#send(java.lang.String,%20org.apache.samza.system.OutgoingMessageEnvelope)">send(String, OutgoingMessageEnvelope)</a></span> - Method in interface org.apache.samza.system.<a href="./org/apache/samza/system/SystemProducer.html" title="interface in org.apache.samza.system">SystemProducer</a></dt>
<dd>
<div class="block">Sends a specified message envelope from a specified Samza source.</div>
</dd>
@@ -838,15 +777,9 @@
<div class="block">Sends message envelope out onto specified stream.</div>
</dd>
<dt><a href="./org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers"><span class="strong">Serde</span></a><<a href="./org/apache/samza/serializers/Serde.html" title="type parameter in Serde">T</a>> - Interface in <a href="./org/apache/samza/serializers/package-summary.html">org.apache.samza.serializers</a></dt>
-<dd>
[... 278 lines stripped ...]