Modified: samza/site/learn/documentation/versioned/api/javadocs/index-all.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/api/javadocs/index-all.html?rev=1855804&r1=1855803&r2=1855804&view=diff ============================================================================== --- samza/site/learn/documentation/versioned/api/javadocs/index-all.html (original) +++ samza/site/learn/documentation/versioned/api/javadocs/index-all.html Tue Mar 19 05:31:11 2019 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_181) on Sat Dec 08 21:12:57 PST 2018 --> -<title>Index (samza-api 1.0.0 API)</title> -<meta name="date" content="2018-12-08"> +<!-- Generated by javadoc (1.8.0_202) on Mon Mar 18 22:29:01 PDT 2019 --> +<title>Index (samza-api 1.0.1-SNAPSHOT API)</title> +<meta name="date" content="2019-03-18"> <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 1.0.0 API)"; + parent.document.title="Index (samza-api 1.0.1-SNAPSHOT API)"; } } catch(err) { @@ -101,6 +101,24 @@ <dd> <div class="block">Add a value to the list.</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/sql/schema/SqlSchemaBuilder.html#addField-java.lang.String-org.apache.samza.sql.schema.SqlFieldSchema-">addField(String, SqlFieldSchema)</a></span> - Method in class org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SqlSchemaBuilder.html" title="class in org.apache.samza.sql.schema">SqlSchemaBuilder</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/LocalTableDescriptor.html#addStoreConfig-java.lang.String-java.lang.String-java.util.Map-">addStoreConfig(String, String, Map<String, String>)</a></span> - Method in class org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/LocalTableDescriptor.html" title="class in org.apache.samza.table.descriptors">LocalTableDescriptor</a></dt> +<dd> +<div class="block">Helper method to add a store level config item to table configuration</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/BaseTableDescriptor.html#addTableConfig-java.lang.String-java.lang.String-java.util.Map-">addTableConfig(String, String, Map<String, String>)</a></span> - Method in class org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/BaseTableDescriptor.html" title="class in org.apache.samza.table.descriptors">BaseTableDescriptor</a></dt> +<dd> +<div class="block">Helper method to add a config item to table configuration</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/RemoteTableDescriptor.html#addTablePartConfig-org.apache.samza.table.remote.TablePart-org.apache.samza.config.Config-java.util.Map-">addTablePartConfig(TablePart, Config, Map<String, String>)</a></span> - Method in class org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a></dt> +<dd> +<div class="block">Helper method to add table part config items to table configuration</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/checkpoint/CheckpointListener.html#afterCheckpoint-java.util.Map-">afterCheckpoint(Map<SystemStreamPartition, String>)</a></span> - Method in interface org.apache.samza.checkpoint.<a href="org/apache/samza/checkpoint/CheckpointListener.html" title="interface in org.apache.samza.checkpoint">CheckpointListener</a></dt> +<dd> +<div class="block">Called after writing the checkpoint for each Task in the Container processing SSPs on this system.</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/runtime/ProcessorLifecycleListener.html#afterFailure-java.lang.Throwable-">afterFailure(Throwable)</a></span> - Method in interface org.apache.samza.runtime.<a href="org/apache/samza/runtime/ProcessorLifecycleListener.html" title="interface in org.apache.samza.runtime">ProcessorLifecycleListener</a></dt> <dd> <div class="block">User defined callback after a StreamProcessor is stopped with failure</div> @@ -113,6 +131,8 @@ <dd> <div class="block">User defined callback after a StreamProcessor is stopped successfully</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/metadatastore/InMemoryMetadataStore.html#all--">all()</a></span> - Method in class org.apache.samza.metadatastore.<a href="org/apache/samza/metadatastore/InMemoryMetadataStore.html" title="class in org.apache.samza.metadatastore">InMemoryMetadataStore</a></dt> +<dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/metadatastore/MetadataStore.html#all--">all()</a></span> - Method in interface org.apache.samza.metadatastore.<a href="org/apache/samza/metadatastore/MetadataStore.html" title="interface in org.apache.samza.metadatastore">MetadataStore</a></dt> <dd> <div class="block">Returns all the entries in this metadata store.</div> @@ -197,6 +217,21 @@ <dd> <div class="block">Joins the provided messages and table record, returns the joined message.</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/Startpoint.html#apply-org.apache.samza.system.SystemStreamPartition-org.apache.samza.startpoint.StartpointVisitor-">apply(SystemStreamPartition, StartpointVisitor)</a></span> - Method in class org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/Startpoint.html" title="class in org.apache.samza.startpoint">Startpoint</a></dt> +<dd> +<div class="block">Apply the visitor <a href="org/apache/samza/startpoint/StartpointVisitor.html" title="interface in org.apache.samza.startpoint"><code>StartpointVisitor</code></a>'s register methods to the instance of this <a href="org/apache/samza/startpoint/Startpoint.html" title="class in org.apache.samza.startpoint"><code>Startpoint</code></a> + class.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/StartpointCustom.html#apply-org.apache.samza.system.SystemStreamPartition-org.apache.samza.startpoint.StartpointVisitor-">apply(SystemStreamPartition, StartpointVisitor)</a></span> - Method in class org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointCustom.html" title="class in org.apache.samza.startpoint">StartpointCustom</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/StartpointOldest.html#apply-org.apache.samza.system.SystemStreamPartition-org.apache.samza.startpoint.StartpointVisitor-">apply(SystemStreamPartition, StartpointVisitor)</a></span> - Method in class org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointOldest.html" title="class in org.apache.samza.startpoint">StartpointOldest</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/StartpointSpecific.html#apply-org.apache.samza.system.SystemStreamPartition-org.apache.samza.startpoint.StartpointVisitor-">apply(SystemStreamPartition, StartpointVisitor)</a></span> - Method in class org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointSpecific.html" title="class in org.apache.samza.startpoint">StartpointSpecific</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/StartpointTimestamp.html#apply-org.apache.samza.system.SystemStreamPartition-org.apache.samza.startpoint.StartpointVisitor-">apply(SystemStreamPartition, StartpointVisitor)</a></span> - Method in class org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointTimestamp.html" title="class in org.apache.samza.startpoint">StartpointTimestamp</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/StartpointUpcoming.html#apply-org.apache.samza.system.SystemStreamPartition-org.apache.samza.startpoint.StartpointVisitor-">apply(SystemStreamPartition, StartpointVisitor)</a></span> - Method in class org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointUpcoming.html" title="class in org.apache.samza.startpoint">StartpointUpcoming</a></dt> +<dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/system/descriptors/InputTransformer.html#apply-org.apache.samza.system.IncomingMessageEnvelope-">apply(IncomingMessageEnvelope)</a></span> - Method in interface org.apache.samza.system.descriptors.<a href="org/apache/samza/system/descriptors/InputTransformer.html" title="interface in org.apache.samza.system.descriptors">InputTransformer</a></dt> <dd> <div class="block">Transforms the provided <a href="org/apache/samza/system/IncomingMessageEnvelope.html" title="class in org.apache.samza.system"><code>IncomingMessageEnvelope</code></a> with deserialized key and message into another message @@ -207,6 +242,12 @@ <div class="block">Expands the provided <a href="org/apache/samza/system/descriptors/InputDescriptor.html" title="class in org.apache.samza.system.descriptors"><code>InputDescriptor</code></a> to a sub-DAG of one or more operators on the <a href="org/apache/samza/application/descriptors/StreamApplicationDescriptor.html" title="interface in org.apache.samza.application.descriptors"><code>StreamApplicationDescriptor</code></a>, and returns a new <a href="org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> with the combined results.</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/RemoteTableDescriptor.html#ASYNC_CALLBACK_POOL_SIZE">ASYNC_CALLBACK_POOL_SIZE</a></span> - Static variable in class org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a></dt> +<dd> </dd> +<dt><a href="org/apache/samza/table/AsyncReadWriteTable.html" title="interface in org.apache.samza.table"><span class="typeNameLink">AsyncReadWriteTable</span></a><<a href="org/apache/samza/table/AsyncReadWriteTable.html" title="type parameter in AsyncReadWriteTable">K</a>,<a href="org/apache/samza/table/AsyncReadWriteTable.html" title="type parameter in AsyncReadWriteTable">V</a>> - Interface in <a href="org/apache/samza/table/package-summary.html">org.apache.samza.table</a></dt> +<dd> +<div class="block">A table that supports asynchronous get, put and delete by one or more keys</div> +</dd> <dt><a href="org/apache/samza/task/AsyncStreamTask.html" title="interface in org.apache.samza.task"><span class="typeNameLink">AsyncStreamTask</span></a> - Interface in <a href="org/apache/samza/task/package-summary.html">org.apache.samza.task</a></dt> <dd> <div class="block">An AsyncStreamTask is the basic class to support multithreading execution in Samza container.</div> @@ -228,6 +269,18 @@ </dd> <dt><span class="memberNameLink"><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><a href="org/apache/samza/table/descriptors/BaseTableDescriptor.html" title="class in org.apache.samza.table.descriptors"><span class="typeNameLink">BaseTableDescriptor</span></a><<a href="org/apache/samza/table/descriptors/BaseTableDescriptor.html" title="type parameter in BaseTableDescriptor">K</a>,<a href="org/apache/samza/table/descriptors/BaseTableDescriptor.html" title="type parameter in BaseTableDescriptor">V</a>,<a href="org/apache/samza/table/descriptors/BaseTableDescriptor.html" title="type parameter in BaseTableDescriptor">D</a> extends <a href="org/apache/samza/table/descriptors/BaseTableDescriptor.html" title="class in org.apache.samza.table.descriptors">BaseTableDescriptor</a><<a href="org/apache/samza/table/descriptors/BaseTableDescriptor.html" title="type parameter in BaseTableDescriptor">K</a>,<a href="org/apache/samza/table/descriptors/BaseTableDescriptor.html" title="type parameter in BaseTableDescriptor">V</a>,<a href="org/apache/samza/table/descriptors /BaseTableDescriptor.html" title="type parameter in BaseTableDescriptor">D</a>>> - Class in <a href="org/apache/samza/table/descriptors/package-summary.html">org.apache.samza.table.descriptors</a></dt> +<dd> +<div class="block">Base class for all table descriptor implementations.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/BaseTableDescriptor.html#BaseTableDescriptor-java.lang.String-">BaseTableDescriptor(String)</a></span> - Constructor for class org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/BaseTableDescriptor.html" title="class in org.apache.samza.table.descriptors">BaseTableDescriptor</a></dt> +<dd> +<div class="block">Constructs a table descriptor instance</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/checkpoint/CheckpointListener.html#beforeCheckpoint-java.util.Map-">beforeCheckpoint(Map<SystemStreamPartition, String>)</a></span> - Method in interface org.apache.samza.checkpoint.<a href="org/apache/samza/checkpoint/CheckpointListener.html" title="interface in org.apache.samza.checkpoint">CheckpointListener</a></dt> +<dd> +<div class="block">Called before writing the checkpoint for each Task in the Container processing SSPs on this system.</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/runtime/ProcessorLifecycleListener.html#beforeStart--">beforeStart()</a></span> - Method in interface org.apache.samza.runtime.<a href="org/apache/samza/runtime/ProcessorLifecycleListener.html" title="interface in org.apache.samza.runtime">ProcessorLifecycleListener</a></dt> <dd> <div class="block">User defined initialization before a StreamProcessor is started</div> @@ -269,6 +322,8 @@ <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> <dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/sql/schema/SqlSchemaBuilder.html#build--">build()</a></span> - Method in class org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SqlSchemaBuilder.html" title="class in org.apache.samza.sql.schema">SqlSchemaBuilder</a></dt> +<dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/storage/StoreProperties.StorePropertiesBuilder.html#build--">build()</a></span> - Method in class org.apache.samza.storage.<a href="org/apache/samza/storage/StoreProperties.StorePropertiesBuilder.html" title="class in org.apache.samza.storage">StoreProperties.StorePropertiesBuilder</a></dt> <dd> </dd> <dt><span class="memberNameLink"><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> @@ -279,6 +334,12 @@ </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/job/CommandBuilder.html#buildEnvironment--">buildEnvironment()</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> +<dt><span class="memberNameLink"><a href="org/apache/samza/sql/schema/SqlSchemaBuilder.html#builder--">builder()</a></span> - Static method in class org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SqlSchemaBuilder.html" title="class in org.apache.samza.sql.schema">SqlSchemaBuilder</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/config/JavaTableConfig.html#buildKey-java.lang.String-java.lang.String-">buildKey(String, String)</a></span> - Static method in class org.apache.samza.config.<a href="org/apache/samza/config/JavaTableConfig.html" title="class in org.apache.samza.config">JavaTableConfig</a></dt> +<dd> +<div class="block">Build complete config key for a config item</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/system/IncomingMessageEnvelope.html#buildWatermarkEnvelope-org.apache.samza.system.SystemStreamPartition-long-">buildWatermarkEnvelope(SystemStreamPartition, long)</a></span> - Static method in class org.apache.samza.system.<a href="org/apache/samza/system/IncomingMessageEnvelope.html" title="class in org.apache.samza.system">IncomingMessageEnvelope</a></dt> <dd> </dd> <dt><a href="org/apache/samza/serializers/ByteBufferSerde.html" title="class in org.apache.samza.serializers"><span class="typeNameLink">ByteBufferSerde</span></a> - Class in <a href="org/apache/samza/serializers/package-summary.html">org.apache.samza.serializers</a></dt> @@ -307,10 +368,31 @@ </a> <h2 class="title">C</h2> <dl> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/CachingTableDescriptor.html#CACHE_SIZE">CACHE_SIZE</a></span> - Static variable in class org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/CachingTableDescriptor.html" title="class in org.apache.samza.table.descriptors">CachingTableDescriptor</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/CachingTableDescriptor.html#CACHE_TABLE_ID">CACHE_TABLE_ID</a></span> - Static variable in class org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/CachingTableDescriptor.html" title="class in org.apache.samza.table.descriptors">CachingTableDescriptor</a></dt> +<dd> </dd> +<dt><a href="org/apache/samza/table/descriptors/CachingTableDescriptor.html" title="class in org.apache.samza.table.descriptors"><span class="typeNameLink">CachingTableDescriptor</span></a><<a href="org/apache/samza/table/descriptors/CachingTableDescriptor.html" title="type parameter in CachingTableDescriptor">K</a>,<a href="org/apache/samza/table/descriptors/CachingTableDescriptor.html" title="type parameter in CachingTableDescriptor">V</a>> - Class in <a href="org/apache/samza/table/descriptors/package-summary.html">org.apache.samza.table.descriptors</a></dt> +<dd> +<div class="block">Table descriptor for a caching table.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/CachingTableDescriptor.html#CachingTableDescriptor-java.lang.String-org.apache.samza.table.descriptors.TableDescriptor-">CachingTableDescriptor(String, TableDescriptor<K, V, ?>)</a></span> - Constructor for class org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/CachingTableDescriptor.html" title="class in org.apache.samza.table.descriptors">CachingTableDescriptor</a></dt> +<dd> +<div class="block">Constructs a table descriptor instance with internal cache</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/CachingTableDescriptor.html#CachingTableDescriptor-java.lang.String-org.apache.samza.table.descriptors.TableDescriptor-org.apache.samza.table.descriptors.TableDescriptor-">CachingTableDescriptor(String, TableDescriptor<K, V, ?>, TableDescriptor<K, V, ?>)</a></span> - Constructor for class org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/CachingTableDescriptor.html" title="class in org.apache.samza.table.descriptors">CachingTableDescriptor</a></dt> +<dd> +<div class="block">Constructs a table descriptor instance and specify a cache (as Table descriptor) + to be used for caching.</div> +</dd> <dt><a href="org/apache/samza/scheduler/CallbackScheduler.html" title="interface in org.apache.samza.scheduler"><span class="typeNameLink">CallbackScheduler</span></a> - Interface in <a href="org/apache/samza/scheduler/package-summary.html">org.apache.samza.scheduler</a></dt> <dd> <div class="block">Provides a way for applications to register some logic to be executed at a future time.</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/LocalTableDescriptor.html#changelogReplicationFactor">changelogReplicationFactor</a></span> - Variable in class org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/LocalTableDescriptor.html" title="class in org.apache.samza.table.descriptors">LocalTableDescriptor</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/LocalTableDescriptor.html#changelogStream">changelogStream</a></span> - Variable in class org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/LocalTableDescriptor.html" title="class in org.apache.samza.table.descriptors">LocalTableDescriptor</a></dt> +<dd> </dd> <dt><a href="org/apache/samza/checkpoint/Checkpoint.html" title="class in org.apache.samza.checkpoint"><span class="typeNameLink">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> @@ -321,8 +403,8 @@ </dd> <dt><a href="org/apache/samza/checkpoint/CheckpointListener.html" title="interface in org.apache.samza.checkpoint"><span class="typeNameLink">CheckpointListener</span></a> - Interface in <a href="org/apache/samza/checkpoint/package-summary.html">org.apache.samza.checkpoint</a></dt> <dd> -<div class="block">This interface should be implemented by SystemConsumers which want to be notified about checkpoint values - of the most recent checkpoint.</div> +<div class="block">SystemConsumers that want to be notified about checkpoints for their SSPs and potentially modify them may + implement this interface.</div> </dd> <dt><a href="org/apache/samza/checkpoint/CheckpointManager.html" title="interface in org.apache.samza.checkpoint"><span class="typeNameLink">CheckpointManager</span></a> - Interface in <a href="org/apache/samza/checkpoint/package-summary.html">org.apache.samza.checkpoint</a></dt> <dd> @@ -366,6 +448,8 @@ <dd> <div class="block"><span class="deprecatedLabel">Deprecated.</span></div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/metadatastore/InMemoryMetadataStore.html#close--">close()</a></span> - Method in class org.apache.samza.metadatastore.<a href="org/apache/samza/metadatastore/InMemoryMetadataStore.html" title="class in org.apache.samza.metadatastore">InMemoryMetadataStore</a></dt> +<dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/metadatastore/MetadataStore.html#close--">close()</a></span> - Method in interface org.apache.samza.metadatastore.<a href="org/apache/samza/metadatastore/MetadataStore.html" title="interface in org.apache.samza.metadatastore">MetadataStore</a></dt> <dd> <div class="block">Closes the metadata store, if applicable, relinquishing all the underlying resources @@ -389,13 +473,13 @@ <dd> <div class="block">Closes this key-value store, if applicable, relinquishing any underlying resources.</div> </dd> -<dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/TableProvider.html#close--">close()</a></span> - Method in interface org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/TableProvider.html" title="interface in org.apache.samza.table.descriptors">TableProvider</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/AsyncReadWriteTable.html#close--">close()</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/AsyncReadWriteTable.html" title="interface in org.apache.samza.table">AsyncReadWriteTable</a></dt> <dd> -<div class="block">Shutdown the underlying table</div> +<div class="block">Close the table and release any resources acquired</div> </dd> -<dt><span class="memberNameLink"><a href="org/apache/samza/table/ReadableTable.html#close--">close()</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> +<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">Close the table and release any resources acquired</div> +<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> @@ -441,6 +525,8 @@ <dd> </dd> <dt><span class="memberNameLink"><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><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/BaseTableDescriptor.html#config">config</a></span> - Variable in class org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/BaseTableDescriptor.html" title="class in org.apache.samza.table.descriptors">BaseTableDescriptor</a></dt> +<dd> </dd> <dt><a href="org/apache/samza/config/ConfigException.html" title="class in org.apache.samza.config"><span class="typeNameLink">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> @@ -510,14 +596,24 @@ <div class="block">A <a href="org/apache/samza/operators/triggers/Trigger.html" title="interface in org.apache.samza.operators.triggers"><code>Trigger</code></a> that fires when the number of messages in the <a href="org/apache/samza/operators/windows/WindowPane.html" title="class in org.apache.samza.operators.windows"><code>WindowPane</code></a> reaches the specified count.</div> </dd> -<dt><span class="memberNameLink"><a href="org/apache/samza/context/ApplicationContainerContextFactory.html#create-org.apache.samza.context.JobContext-org.apache.samza.context.ContainerContext-">create(JobContext, ContainerContext)</a></span> - Method in interface org.apache.samza.context.<a href="org/apache/samza/context/ApplicationContainerContextFactory.html" title="interface in org.apache.samza.context">ApplicationContainerContextFactory</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/samza/context/ApplicationContainerContextFactory.html#create-org.apache.samza.context.ExternalContext-org.apache.samza.context.JobContext-org.apache.samza.context.ContainerContext-">create(ExternalContext, JobContext, ContainerContext)</a></span> - Method in interface org.apache.samza.context.<a href="org/apache/samza/context/ApplicationContainerContextFactory.html" title="interface in org.apache.samza.context">ApplicationContainerContextFactory</a></dt> <dd> <div class="block">Creates an instance of the application-defined <a href="org/apache/samza/context/ApplicationContainerContext.html" title="interface in org.apache.samza.context"><code>ApplicationContainerContext</code></a>.</div> </dd> -<dt><span class="memberNameLink"><a href="org/apache/samza/context/ApplicationTaskContextFactory.html#create-org.apache.samza.context.JobContext-org.apache.samza.context.ContainerContext-org.apache.samza.context.TaskContext-org.apache.samza.context.ApplicationContainerContext-">create(JobContext, ContainerContext, TaskContext, ApplicationContainerContext)</a></span> - Method in interface org.apache.samza.context.<a href="org/apache/samza/context/ApplicationTaskContextFactory.html" title="interface in org.apache.samza.context">ApplicationTaskContextFactory</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/samza/context/ApplicationContainerContextFactory.html#create-org.apache.samza.context.JobContext-org.apache.samza.context.ContainerContext-">create(JobContext, ContainerContext)</a></span> - Method in interface org.apache.samza.context.<a href="org/apache/samza/context/ApplicationContainerContextFactory.html" title="interface in org.apache.samza.context">ApplicationContainerContextFactory</a></dt> +<dd> +<div class="block"><span class="deprecatedLabel">Deprecated.</span></div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/context/ApplicationTaskContextFactory.html#create-org.apache.samza.context.ExternalContext-org.apache.samza.context.JobContext-org.apache.samza.context.ContainerContext-org.apache.samza.context.TaskContext-org.apache.samza.context.ApplicationContainerContext-">create(ExternalContext, JobContext, ContainerContext, TaskContext, ApplicationContainerContext)</a></span> - Method in interface org.apache.samza.context.<a href="org/apache/samza/context/ApplicationTaskContextFactory.html" title="interface in org.apache.samza.context">ApplicationTaskContextFactory</a></dt> <dd> <div class="block">Creates an instance of the application-defined <a href="org/apache/samza/context/ApplicationTaskContext.html" title="interface in org.apache.samza.context"><code>ApplicationTaskContext</code></a>.</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/context/ApplicationTaskContextFactory.html#create-org.apache.samza.context.JobContext-org.apache.samza.context.ContainerContext-org.apache.samza.context.TaskContext-org.apache.samza.context.ApplicationContainerContext-">create(JobContext, ContainerContext, TaskContext, ApplicationContainerContext)</a></span> - Method in interface org.apache.samza.context.<a href="org/apache/samza/context/ApplicationTaskContextFactory.html" title="interface in org.apache.samza.context">ApplicationTaskContextFactory</a></dt> +<dd> +<div class="block"><span class="deprecatedLabel">Deprecated.</span></div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/sql/schema/SqlFieldSchema.html#createArraySchema-org.apache.samza.sql.schema.SqlFieldSchema-">createArraySchema(SqlFieldSchema)</a></span> - Static method in class org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SqlFieldSchema.html" title="class in org.apache.samza.sql.schema">SqlFieldSchema</a></dt> +<dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/system/StreamSpec.html#createChangeLogStreamSpec-java.lang.String-java.lang.String-int-">createChangeLogStreamSpec(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/system/StreamSpec.html#createCheckpointStreamSpec-java.lang.String-java.lang.String-">createCheckpointStreamSpec(String, String)</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> @@ -532,10 +628,18 @@ <dd> <div class="block">Create instance of task</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/sql/schema/SqlFieldSchema.html#createMapSchema-org.apache.samza.sql.schema.SqlFieldSchema-">createMapSchema(SqlFieldSchema)</a></span> - Static method in class org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SqlFieldSchema.html" title="class in org.apache.samza.sql.schema">SqlFieldSchema</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/sql/schema/SqlFieldSchema.html#createPrimitiveSchema-org.apache.samza.sql.schema.SamzaSqlFieldType-">createPrimitiveSchema(SamzaSqlFieldType)</a></span> - Static method in class org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SqlFieldSchema.html" title="class in org.apache.samza.sql.schema">SqlFieldSchema</a></dt> +<dd> +<div class="block">Create a primitive fi</div> +</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/sql/schema/SqlFieldSchema.html#createRowFieldSchema-org.apache.samza.sql.schema.SqlSchema-">createRowFieldSchema(SqlSchema)</a></span> - Static method in class org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SqlFieldSchema.html" title="class in org.apache.samza.sql.schema">SqlFieldSchema</a></dt> +<dd> </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> @@ -554,7 +658,11 @@ <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/metadatastore/MetadataStore.html#delete-byte:A-">delete(byte[])</a></span> - Method in interface org.apache.samza.metadatastore.<a href="org/apache/samza/metadatastore/MetadataStore.html" title="interface in org.apache.samza.metadatastore">MetadataStore</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/RemoteTableDescriptor.html#DEFAULT_RATE_LIMITER_CLASS_NAME">DEFAULT_RATE_LIMITER_CLASS_NAME</a></span> - Static variable in class org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/metadatastore/InMemoryMetadataStore.html#delete-java.lang.String-">delete(String)</a></span> - Method in class org.apache.samza.metadatastore.<a href="org/apache/samza/metadatastore/InMemoryMetadataStore.html" title="class in org.apache.samza.metadatastore">InMemoryMetadataStore</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/metadatastore/MetadataStore.html#delete-java.lang.String-">delete(String)</a></span> - Method in interface org.apache.samza.metadatastore.<a href="org/apache/samza/metadatastore/MetadataStore.html" title="interface in org.apache.samza.metadatastore">MetadataStore</a></dt> <dd> <div class="block">Deletes the mapping for the specified <code>key</code> from this metadata store (if such mapping exists).</div> </dd> @@ -570,6 +678,10 @@ <dd> <div class="block">Deletes the mapping for the specified <code>key</code> from this table (if such mapping exists).</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/TableWriteFunction.html#delete-K-">delete(K)</a></span> - Method in interface org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableWriteFunction.html" title="interface in org.apache.samza.table.remote">TableWriteFunction</a></dt> +<dd> +<div class="block">Delete the <code>record</code> with specified <code>key</code> from the remote store.</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/storage/kv/KeyValueStore.html#deleteAll-java.util.List-">deleteAll(List<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 mappings for the specified <code>keys</code> from this key-value store (if such mappings exist).</div> @@ -578,14 +690,27 @@ <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/table/ReadWriteTable.html#deleteAllAsync-java.util.List-">deleteAllAsync(List<K>)</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/ReadWriteTable.html" title="interface in org.apache.samza.table">ReadWriteTable</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/TableWriteFunction.html#deleteAll-java.util.Collection-">deleteAll(Collection<K>)</a></span> - Method in interface org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableWriteFunction.html" title="interface in org.apache.samza.table.remote">TableWriteFunction</a></dt> +<dd> +<div class="block">Delete all <code>records</code> with the specified <code>keys</code> from the remote store + The default implementation calls deleteAllAsync and blocks on the completion afterwards.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/AsyncReadWriteTable.html#deleteAllAsync-java.util.List-">deleteAllAsync(List<K>)</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/AsyncReadWriteTable.html" title="interface in org.apache.samza.table">AsyncReadWriteTable</a></dt> <dd> <div class="block">Asynchronously deletes the mappings for the specified <code>keys</code> from this table.</div> </dd> -<dt><span class="memberNameLink"><a href="org/apache/samza/table/ReadWriteTable.html#deleteAsync-K-">deleteAsync(K)</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/ReadWriteTable.html" title="interface in org.apache.samza.table">ReadWriteTable</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/TableWriteFunction.html#deleteAllAsync-java.util.Collection-">deleteAllAsync(Collection<K>)</a></span> - Method in interface org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableWriteFunction.html" title="interface in org.apache.samza.table.remote">TableWriteFunction</a></dt> +<dd> +<div class="block">Asynchronously delete all <code>records</code> with the specified <code>keys</code> from the remote store.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/AsyncReadWriteTable.html#deleteAsync-K-">deleteAsync(K)</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/AsyncReadWriteTable.html" title="interface in org.apache.samza.table">AsyncReadWriteTable</a></dt> <dd> <div class="block">Asynchronously deletes the mapping for the specified <code>key</code> from this table (if such mapping exists).</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/TableWriteFunction.html#deleteAsync-K-">deleteAsync(K)</a></span> - Method in interface org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableWriteFunction.html" title="interface in org.apache.samza.table.remote">TableWriteFunction</a></dt> +<dd> +<div class="block">Asynchronously delete the <code>record</code> with specified <code>key</code> from the remote store</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/scheduler/CallbackScheduler.html#deleteCallback-K-">deleteCallback(K)</a></span> - Method in interface org.apache.samza.scheduler.<a href="org/apache/samza/scheduler/CallbackScheduler.html" title="interface in org.apache.samza.scheduler">CallbackScheduler</a></dt> <dd> <div class="block">Delete the scheduled <code>callback</code> for the <code>key</code>.</div> @@ -598,6 +723,10 @@ <dd> <div class="block">Describes the inputs, outputs, state, configuration and processing logic using the provided <code>appDescriptor</code>.</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/utils/SerdeUtils.html#deserialize-java.lang.String-java.lang.String-">deserialize(String, String)</a></span> - Static method in class org.apache.samza.table.utils.<a href="org/apache/samza/table/utils/SerdeUtils.html" title="class in org.apache.samza.table.utils">SerdeUtils</a></dt> +<dd> +<div class="block">Helper method to deserialize Java objects from Base64 strings</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 @@ -623,6 +752,8 @@ </a> <h2 class="title">E</h2> <dl> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/LocalTableDescriptor.html#enableChangelog">enableChangelog</a></span> - Variable in class org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/LocalTableDescriptor.html" title="class in org.apache.samza.table.descriptors">LocalTableDescriptor</a></dt> +<dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/system/IncomingMessageEnvelope.html#END_OF_STREAM_OFFSET">END_OF_STREAM_OFFSET</a></span> - Static variable in class org.apache.samza.system.<a href="org/apache/samza/system/IncomingMessageEnvelope.html" title="class in org.apache.samza.system">IncomingMessageEnvelope</a></dt> <dd> </dd> <dt><a href="org/apache/samza/task/EndOfStreamListenerTask.html" title="interface in org.apache.samza.task"><span class="typeNameLink">EndOfStreamListenerTask</span></a> - Interface in <a href="org/apache/samza/task/package-summary.html">org.apache.samza.task</a></dt> @@ -667,6 +798,12 @@ <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/sql/SamzaSqlRelRecord.html#equals-java.lang.Object-">equals(Object)</a></span> - Method in class org.apache.samza.sql.<a href="org/apache/samza/sql/SamzaSqlRelRecord.html" title="class in org.apache.samza.sql">SamzaSqlRelRecord</a></dt> <dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/Startpoint.html#equals-java.lang.Object-">equals(Object)</a></span> - Method in class org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/Startpoint.html" title="class in org.apache.samza.startpoint">Startpoint</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/StartpointSpecific.html#equals-java.lang.Object-">equals(Object)</a></span> - Method in class org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointSpecific.html" title="class in org.apache.samza.startpoint">StartpointSpecific</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/StartpointTimestamp.html#equals-java.lang.Object-">equals(Object)</a></span> - Method in class org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointTimestamp.html" title="class in org.apache.samza.startpoint">StartpointTimestamp</a></dt> +<dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/system/ControlMessage.html#equals-java.lang.Object-">equals(Object)</a></span> - Method in 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/IncomingMessageEnvelope.html#equals-java.lang.Object-">equals(Object)</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/IncomingMessageEnvelope.html" title="class in org.apache.samza.system">IncomingMessageEnvelope</a></dt> @@ -685,23 +822,17 @@ <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/system/WatermarkMessage.html#equals-java.lang.Object-">equals(Object)</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/WatermarkMessage.html" title="class in org.apache.samza.system">WatermarkMessage</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/samza/table/TableSpec.html#equals-java.lang.Object-">equals(Object)</a></span> - Method in class org.apache.samza.table.<a href="org/apache/samza/table/TableSpec.html" title="class in org.apache.samza.table">TableSpec</a></dt> -<dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/util/TimestampedValue.html#equals-java.lang.Object-">equals(Object)</a></span> - Method in class org.apache.samza.util.<a href="org/apache/samza/util/TimestampedValue.html" title="class in org.apache.samza.util">TimestampedValue</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/samza/sql/udfs/ScalarUdf.html#execute-java.lang.Object...-">execute(Object...)</a></span> - Method in interface org.apache.samza.sql.udfs.<a href="org/apache/samza/sql/udfs/ScalarUdf.html" title="interface in org.apache.samza.sql.udfs">ScalarUdf</a></dt> -<dd> -<div class="block">Actual implementation of the udf function</div> -</dd> <dt><a href="org/apache/samza/system/descriptors/ExpandingInputDescriptorProvider.html" title="interface in org.apache.samza.system.descriptors"><span class="typeNameLink">ExpandingInputDescriptorProvider</span></a><<a href="org/apache/samza/system/descriptors/ExpandingInputDescriptorProvider.html" title="type parameter in ExpandingInputDescriptorProvider">StreamExpanderType</a>> - Interface in <a href="org/apache/samza/system/descriptors/package-summary.html">org.apache.samza.system.descriptors</a></dt> <dd> <div class="block">Interface for advanced <code>SystemDescriptor</code>s that constrain the type of returned <code>InputDescriptor</code>s to their own <code>StreamExpander</code> function result types.</div> </dd> -<dt><a href="org/apache/samza/system/ExtendedSystemAdmin.html" title="interface in org.apache.samza.system"><span class="typeNameLink">ExtendedSystemAdmin</span></a> - Interface in <a href="org/apache/samza/system/package-summary.html">org.apache.samza.system</a></dt> +<dt><a href="org/apache/samza/context/ExternalContext.html" title="interface in org.apache.samza.context"><span class="typeNameLink">ExternalContext</span></a> - Interface in <a href="org/apache/samza/context/package-summary.html">org.apache.samza.context</a></dt> <dd> -<div class="block">Interface extends the more generic SystemAdmin interface - TODO: Merge this interface method with SystemAdmin when we upgrade to JDK 1.8</div> +<div class="block">An <a href="org/apache/samza/context/ExternalContext.html" title="interface in org.apache.samza.context"><code>ExternalContext</code></a> can be used to pass components created and managed outside of Samza into a Samza + application.</div> </dd> </dl> <a name="I:F"> @@ -737,6 +868,8 @@ <dd> <div class="block">Transforms an input message into a collection of 0 or more messages, possibly of a different type.</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/metadatastore/InMemoryMetadataStore.html#flush--">flush()</a></span> - Method in class org.apache.samza.metadatastore.<a href="org/apache/samza/metadatastore/InMemoryMetadataStore.html" title="class in org.apache.samza.metadatastore">InMemoryMetadataStore</a></dt> +<dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/metadatastore/MetadataStore.html#flush--">flush()</a></span> - Method in interface org.apache.samza.metadatastore.<a href="org/apache/samza/metadatastore/MetadataStore.html" title="interface in org.apache.samza.metadatastore">MetadataStore</a></dt> <dd> <div class="block">Flushes the metadata store, if applicable.</div> @@ -754,10 +887,14 @@ <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> -<dt><span class="memberNameLink"><a href="org/apache/samza/table/ReadWriteTable.html#flush--">flush()</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/ReadWriteTable.html" title="interface in org.apache.samza.table">ReadWriteTable</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/AsyncReadWriteTable.html#flush--">flush()</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/AsyncReadWriteTable.html" title="interface in org.apache.samza.table">AsyncReadWriteTable</a></dt> <dd> <div class="block">Flushes the underlying store of this table, if applicable.</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/TableWriteFunction.html#flush--">flush()</a></span> - Method in interface org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableWriteFunction.html" title="interface in org.apache.samza.table.remote">TableWriteFunction</a></dt> +<dd> +<div class="block">Flush the remote store (optional)</div> +</dd> <dt><a href="org/apache/samza/operators/functions/FoldLeftFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">FoldLeftFunction</span></a><<a href="org/apache/samza/operators/functions/FoldLeftFunction.html" title="type parameter in FoldLeftFunction">M</a>,<a href="org/apache/samza/operators/functions/FoldLeftFunction.html" title="type parameter in FoldLeftFunction">WV</a>> - Interface in <a href="org/apache/samza/operators/functions/package-summary.html">org.apache.samza.operators.functions</a></dt> <dd> <div class="block">Incrementally updates the aggregated value as messages are added.</div> @@ -803,12 +940,6 @@ <dd> </dd> <dt><span class="memberNameLink"><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="memberNameLink"><a href="org/apache/samza/table/descriptors/TableProvider.html#generateConfig-org.apache.samza.config.Config-java.util.Map-">generateConfig(Config, Map<String, String>)</a></span> - Method in interface org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/TableProvider.html" title="interface in org.apache.samza.table.descriptors">TableProvider</a></dt> -<dd> -<div class="block">Generate any configuration for this table, the generated configuration - is used by Samza container to construct this table and any components - necessary.</div> -</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/runtime/ProcessorIdGenerator.html#generateProcessorId-org.apache.samza.config.Config-">generateProcessorId(Config)</a></span> - Method in interface org.apache.samza.runtime.<a href="org/apache/samza/runtime/ProcessorIdGenerator.html" title="interface in org.apache.samza.runtime">ProcessorIdGenerator</a></dt> <dd> <div class="block">Generates a String representation to identify a single instance of StreamProcessor.</div> @@ -836,7 +967,9 @@ <dd> </dd> <dt><span class="memberNameLink"><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="memberNameLink"><a href="org/apache/samza/metadatastore/MetadataStore.html#get-byte:A-">get(byte[])</a></span> - Method in interface org.apache.samza.metadatastore.<a href="org/apache/samza/metadatastore/MetadataStore.html" title="interface in org.apache.samza.metadatastore">MetadataStore</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/samza/metadatastore/InMemoryMetadataStore.html#get-java.lang.String-">get(String)</a></span> - Method in class org.apache.samza.metadatastore.<a href="org/apache/samza/metadatastore/InMemoryMetadataStore.html" title="class in org.apache.samza.metadatastore">InMemoryMetadataStore</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/metadatastore/MetadataStore.html#get-java.lang.String-">get(String)</a></span> - Method in interface org.apache.samza.metadatastore.<a href="org/apache/samza/metadatastore/MetadataStore.html" title="interface in org.apache.samza.metadatastore">MetadataStore</a></dt> <dd> <div class="block">Gets the value associated with the specified <code>key</code>.</div> </dd> @@ -850,10 +983,14 @@ </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/system/StreamSpec.html#get-java.lang.String-">get(String)</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/table/ReadableTable.html#get-K-">get(K)</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> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/ReadWriteTable.html#get-K-">get(K)</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/ReadWriteTable.html" title="interface in org.apache.samza.table">ReadWriteTable</a></dt> <dd> <div class="block">Gets the value associated with the specified <code>key</code>.</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/TableReadFunction.html#get-K-">get(K)</a></span> - Method in interface org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableReadFunction.html" title="interface in org.apache.samza.table.remote">TableReadFunction</a></dt> +<dd> +<div class="block">Fetch single table record for a specified <code>key</code>.</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/internal/WindowInternal.html#getAccumulationMode--">getAccumulationMode()</a></span> - Method in class org.apache.samza.operators.windows.internal.<a href="org/apache/samza/operators/windows/internal/WindowInternal.html" title="class in org.apache.samza.operators.windows.internal">WindowInternal</a></dt> <dd> </dd> <dt><span class="memberNameLink"><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> @@ -862,14 +999,26 @@ <dd> <div class="block">Gets the values with which the specified <code>keys</code> are associated.</div> </dd> -<dt><span class="memberNameLink"><a href="org/apache/samza/table/ReadableTable.html#getAll-java.util.List-">getAll(List<K>)</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> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/ReadWriteTable.html#getAll-java.util.List-">getAll(List<K>)</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/ReadWriteTable.html" title="interface in org.apache.samza.table">ReadWriteTable</a></dt> <dd> <div class="block">Gets the values with which the specified <code>keys</code> are associated.</div> </dd> -<dt><span class="memberNameLink"><a href="org/apache/samza/table/ReadableTable.html#getAllAsync-java.util.List-">getAllAsync(List<K>)</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> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/TableReadFunction.html#getAll-java.util.Collection-">getAll(Collection<K>)</a></span> - Method in interface org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableReadFunction.html" title="interface in org.apache.samza.table.remote">TableReadFunction</a></dt> +<dd> +<div class="block">Fetch the table <code>records</code> for specified <code>keys</code>.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/AsyncReadWriteTable.html#getAllAsync-java.util.List-">getAllAsync(List<K>)</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/AsyncReadWriteTable.html" title="interface in org.apache.samza.table">AsyncReadWriteTable</a></dt> <dd> <div class="block">Asynchronously gets the values with which the specified <code>keys</code> are associated.</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/TableReadFunction.html#getAllAsync-java.util.Collection-">getAllAsync(Collection<K>)</a></span> - Method in interface org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableReadFunction.html" title="interface in org.apache.samza.table.remote">TableReadFunction</a></dt> +<dd> +<div class="block">Asynchronously fetch the table <code>records</code> for specified <code>keys</code>.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/system/SystemAdmin.html#getAllSystemStreams--">getAllSystemStreams()</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">Fetch the set of all available streams</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/context/Context.html#getApplicationContainerContext--">getApplicationContainerContext()</a></span> - Method in interface org.apache.samza.context.<a href="org/apache/samza/context/Context.html" title="interface in org.apache.samza.context">Context</a></dt> <dd> <div class="block">Gets the application-defined context for the current container.</div> @@ -882,14 +1031,24 @@ <dd> <div class="block">Gets the application-defined task context for the current task.</div> </dd> -<dt><span class="memberNameLink"><a href="org/apache/samza/table/ReadableTable.html#getAsync-K-">getAsync(K)</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> +<dt><span class="memberNameLink"><a href="org/apache/samza/system/IncomingMessageEnvelope.html#getArrivalTime--">getArrivalTime()</a></span> - Method in 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">Getter for arrival time</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/AsyncReadWriteTable.html#getAsync-K-">getAsync(K)</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/AsyncReadWriteTable.html" title="interface in org.apache.samza.table">AsyncReadWriteTable</a></dt> <dd> <div class="block">Asynchronously gets the value associated with the specified <code>key</code>.</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/TableReadFunction.html#getAsync-K-">getAsync(K)</a></span> - Method in interface org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableReadFunction.html" title="interface in org.apache.samza.table.remote">TableReadFunction</a></dt> +<dd> +<div class="block">Asynchronously fetch single table record for a specified <code>key</code>.</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/metrics/Snapshot.html#getAverage--">getAverage()</a></span> - Method in class org.apache.samza.metrics.<a href="org/apache/samza/metrics/Snapshot.html" title="class in org.apache.samza.metrics">Snapshot</a></dt> <dd> <div class="block">Get the average of the values in the collection</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/retry/TableRetryPolicy.html#getBackoffType--">getBackoffType()</a></span> - Method in class org.apache.samza.table.retry.<a href="org/apache/samza/table/retry/TableRetryPolicy.html" title="class in org.apache.samza.table.retry">TableRetryPolicy</a></dt> +<dd> </dd> <dt><span class="memberNameLink"><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> <dd> </dd> <dt><span class="memberNameLink"><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> @@ -929,10 +1088,6 @@ </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/system/StreamSpec.html#getConfig--">getConfig()</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/table/TableSpec.html#getConfig--">getConfig()</a></span> - Method in class org.apache.samza.table.<a href="org/apache/samza/table/TableSpec.html" title="class in org.apache.samza.table">TableSpec</a></dt> -<dd> -<div class="block">Get implementation configuration for the table</div> -</dd> <dt><span class="memberNameLink"><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="memberNameLink"><a href="org/apache/samza/context/Context.html#getContainerContext--">getContainerContext()</a></span> - Method in interface org.apache.samza.context.<a href="org/apache/samza/context/Context.html" title="interface in org.apache.samza.context">Context</a></dt> @@ -956,6 +1111,14 @@ <dd> <div class="block">Get the values of a counter</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/Startpoint.html#getCreationTimestamp--">getCreationTimestamp()</a></span> - Method in class org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/Startpoint.html" title="class in org.apache.samza.startpoint">Startpoint</a></dt> +<dd> +<div class="block">The timestamp when this <a href="org/apache/samza/startpoint/Startpoint.html" title="class in org.apache.samza.startpoint"><code>Startpoint</code></a> was written to the storage layer.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/TableRateLimiter.CreditFunction.html#getCredits-K-V-">getCredits(K, V)</a></span> - Method in interface org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableRateLimiter.CreditFunction.html" title="interface in org.apache.samza.table.remote">TableRateLimiter.CreditFunction</a></dt> +<dd> +<div class="block">Get the number of credits required for the <code>key</code> and <code>value</code> pair.</div> +</dd> <dt><span class="memberNameLink"><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="memberNameLink"><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> @@ -984,18 +1147,44 @@ <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/internal/WindowInternal.html#getEarlyTrigger--">getEarlyTrigger()</a></span> - Method in class org.apache.samza.operators.windows.internal.<a href="org/apache/samza/operators/windows/internal/WindowInternal.html" title="class in org.apache.samza.operators.windows.internal">WindowInternal</a></dt> <dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/sql/schema/SqlFieldSchema.html#getElementSchema--">getElementSchema()</a></span> - Method in class org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SqlFieldSchema.html" title="class in org.apache.samza.sql.schema">SqlFieldSchema</a></dt> +<dd> +<div class="block">Get the element schema if the field type is <a href="org/apache/samza/sql/schema/SamzaSqlFieldType.html#ARRAY"><code>SamzaSqlFieldType.ARRAY</code></a></div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/system/IncomingMessageEnvelope.html#getEventTime--">getEventTime()</a></span> - Method in 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">Getter for event time</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/internal/WindowInternal.html#getEventTimeExtractor--">getEventTimeExtractor()</a></span> - Method in class org.apache.samza.operators.windows.internal.<a href="org/apache/samza/operators/windows/internal/WindowInternal.html" title="class in org.apache.samza.operators.windows.internal">WindowInternal</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/system/descriptors/SystemDescriptor.html#getExpander--">getExpander()</a></span> - Method in class org.apache.samza.system.descriptors.<a href="org/apache/samza/system/descriptors/SystemDescriptor.html" title="class in org.apache.samza.system.descriptors">SystemDescriptor</a></dt> <dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/retry/TableRetryPolicy.html#getExponentialFactor--">getExponentialFactor()</a></span> - Method in class org.apache.samza.table.retry.<a href="org/apache/samza/table/retry/TableRetryPolicy.html" title="class in org.apache.samza.table.retry">TableRetryPolicy</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/retry/TableRetryPolicy.html#getExponentialMaxSleep--">getExponentialMaxSleep()</a></span> - Method in class org.apache.samza.table.retry.<a href="org/apache/samza/table/retry/TableRetryPolicy.html" title="class in org.apache.samza.table.retry">TableRetryPolicy</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/context/Context.html#getExternalContext--">getExternalContext()</a></span> - Method in interface org.apache.samza.context.<a href="org/apache/samza/context/Context.html" title="interface in org.apache.samza.context">Context</a></dt> +<dd> +<div class="block">Gets the <a href="org/apache/samza/context/ExternalContext.html" title="interface in org.apache.samza.context"><code>ExternalContext</code></a> that was created outside of the application.</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/sql/SamzaSqlRelRecord.html#getField-java.lang.String-">getField(String)</a></span> - Method in class org.apache.samza.sql.<a href="org/apache/samza/sql/SamzaSqlRelRecord.html" title="class in org.apache.samza.sql">SamzaSqlRelRecord</a></dt> <dd> <div class="block">Get the value of the field corresponding to the field name.</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/sql/schema/SqlSchema.SqlField.html#getFieldName--">getFieldName()</a></span> - Method in class org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SqlSchema.SqlField.html" title="class in org.apache.samza.sql.schema">SqlSchema.SqlField</a></dt> +<dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/sql/SamzaSqlRelRecord.html#getFieldNames--">getFieldNames()</a></span> - Method in class org.apache.samza.sql.<a href="org/apache/samza/sql/SamzaSqlRelRecord.html" title="class in org.apache.samza.sql">SamzaSqlRelRecord</a></dt> <dd> <div class="block">Get the field names of all the columns in the relational message.</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/sql/schema/SqlSchema.html#getFields--">getFields()</a></span> - Method in class org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SqlSchema.html" title="class in org.apache.samza.sql.schema">SqlSchema</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/sql/schema/SqlSchema.SqlField.html#getFieldSchema--">getFieldSchema()</a></span> - Method in class org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SqlSchema.SqlField.html" title="class in org.apache.samza.sql.schema">SqlSchema.SqlField</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/sql/schema/SqlFieldSchema.html#getFieldType--">getFieldType()</a></span> - Method in class org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SqlFieldSchema.html" title="class in org.apache.samza.sql.schema">SqlFieldSchema</a></dt> +<dd> +<div class="block">Get teh Type of the Samza SQL Field.</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/sql/SamzaSqlRelRecord.html#getFieldValues--">getFieldValues()</a></span> - Method in class org.apache.samza.sql.<a href="org/apache/samza/sql/SamzaSqlRelRecord.html" title="class in org.apache.samza.sql">SamzaSqlRelRecord</a></dt> <dd> <div class="block">Get the field values of all the columns in the relational message.</div> @@ -1008,6 +1197,14 @@ </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/internal/WindowInternal.html#getFoldLeftFunction--">getFoldLeftFunction()</a></span> - Method in class org.apache.samza.operators.windows.internal.<a href="org/apache/samza/operators/windows/internal/WindowInternal.html" title="class in org.apache.samza.operators.windows.internal">WindowInternal</a></dt> <dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/config/JavaTableConfig.html#getForTable-java.lang.String-java.lang.String-java.lang.String-">getForTable(String, String, String)</a></span> - Method in class org.apache.samza.config.<a href="org/apache/samza/config/JavaTableConfig.html" title="class in org.apache.samza.config">JavaTableConfig</a></dt> +<dd> +<div class="block">Get table config value for a key</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/config/JavaTableConfig.html#getForTable-java.lang.String-java.lang.String-">getForTable(String, String)</a></span> - Method in class org.apache.samza.config.<a href="org/apache/samza/config/JavaTableConfig.html" title="class in org.apache.samza.config">JavaTableConfig</a></dt> +<dd> +<div class="block">Get table config value for a key</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/metrics/MetricsAccessor.html#getGaugeValues-java.lang.String-java.lang.String-">getGaugeValues(String, String)</a></span> - Method in interface org.apache.samza.metrics.<a href="org/apache/samza/metrics/MetricsAccessor.html" title="interface in org.apache.samza.metrics">MetricsAccessor</a></dt> <dd> <div class="block">Get the values of a gauge</div> @@ -1024,10 +1221,6 @@ <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/system/StreamSpec.html#getId--">getId()</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/table/TableSpec.html#getId--">getId()</a></span> - Method in class org.apache.samza.table.<a href="org/apache/samza/table/TableSpec.html" title="class in org.apache.samza.table">TableSpec</a></dt> -<dd> -<div class="block">Get the Id of the table</div> -</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/internal/WindowInternal.html#getInitializer--">getInitializer()</a></span> - Method in class org.apache.samza.operators.windows.internal.<a href="org/apache/samza/operators/windows/internal/WindowInternal.html" title="class in org.apache.samza.operators.windows.internal">WindowInternal</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/system/descriptors/ExpandingInputDescriptorProvider.html#getInputDescriptor-java.lang.String-org.apache.samza.serializers.Serde-">getInputDescriptor(String, Serde)</a></span> - Method in interface org.apache.samza.system.descriptors.<a href="org/apache/samza/system/descriptors/ExpandingInputDescriptorProvider.html" title="interface in org.apache.samza.system.descriptors">ExpandingInputDescriptorProvider</a></dt> @@ -1052,6 +1245,10 @@ <dd> </dd> <dt><span class="memberNameLink"><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> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/retry/TableRetryPolicy.html#getJitter--">getJitter()</a></span> - Method in class org.apache.samza.table.retry.<a href="org/apache/samza/table/retry/TableRetryPolicy.html" title="class in org.apache.samza.table.retry">TableRetryPolicy</a></dt> +<dd> +<div class="block">Introduce randomness to the sleepTime time.</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/job/StreamJobFactory.html#getJob-org.apache.samza.config.Config-">getJob(Config)</a></span> - Method in interface org.apache.samza.job.<a href="org/apache/samza/job/StreamJobFactory.html" title="interface in org.apache.samza.job">StreamJobFactory</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/context/Context.html#getJobContext--">getJobContext()</a></span> - Method in interface org.apache.samza.context.<a href="org/apache/samza/context/Context.html" title="interface in org.apache.samza.context">Context</a></dt> @@ -1080,6 +1277,10 @@ <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/internal/WindowInternal.html#getKeyExtractor--">getKeyExtractor()</a></span> - Method in class org.apache.samza.operators.windows.internal.<a href="org/apache/samza/operators/windows/internal/WindowInternal.html" title="class in org.apache.samza.operators.windows.internal">WindowInternal</a></dt> <dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/config/JavaTableConfig.html#getKeySerde-java.lang.String-">getKeySerde(String)</a></span> - Method in class org.apache.samza.config.<a href="org/apache/samza/config/JavaTableConfig.html" title="class in org.apache.samza.config">JavaTableConfig</a></dt> +<dd> +<div class="block">Get registry keys of key serde for this table</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/internal/WindowInternal.html#getKeySerde--">getKeySerde()</a></span> - Method in class org.apache.samza.operators.windows.internal.<a href="org/apache/samza/operators/windows/internal/WindowInternal.html" title="class in org.apache.samza.operators.windows.internal">WindowInternal</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/serializers/KVSerde.html#getKeySerde--">getKeySerde()</a></span> - Method in class org.apache.samza.serializers.<a href="org/apache/samza/serializers/KVSerde.html" title="class in org.apache.samza.serializers">KVSerde</a></dt> @@ -1104,6 +1305,14 @@ <dd> <div class="block">Get the maximum value in the collection</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/retry/TableRetryPolicy.html#getMaxAttempts--">getMaxAttempts()</a></span> - Method in class org.apache.samza.table.retry.<a href="org/apache/samza/table/retry/TableRetryPolicy.html" title="class in org.apache.samza.table.retry">TableRetryPolicy</a></dt> +<dd> +<div class="block">Termination after a fix number of attempts.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/retry/TableRetryPolicy.html#getMaxDuration--">getMaxDuration()</a></span> - Method in class org.apache.samza.table.retry.<a href="org/apache/samza/table/retry/TableRetryPolicy.html" title="class in org.apache.samza.table.retry">TableRetryPolicy</a></dt> +<dd> +<div class="block">Termination after a fixed duration.</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/WindowPane.html#getMessage--">getMessage()</a></span> - Method in class org.apache.samza.operators.windows.<a href="org/apache/samza/operators/windows/WindowPane.html" title="class in org.apache.samza.operators.windows">WindowPane</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/system/IncomingMessageEnvelope.html#getMessage--">getMessage()</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/IncomingMessageEnvelope.html" title="class in org.apache.samza.system">IncomingMessageEnvelope</a></dt> @@ -1118,6 +1327,8 @@ <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/util/BlockingEnvelopeMap.html#getMessagesSizeInQueue-org.apache.samza.system.SystemStreamPartition-">getMessagesSizeInQueue(SystemStreamPartition)</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="memberNameLink"><a href="org/apache/samza/metadatastore/InMemoryMetadataStoreFactory.html#getMetadataStore-java.lang.String-org.apache.samza.config.Config-org.apache.samza.metrics.MetricsRegistry-">getMetadataStore(String, Config, MetricsRegistry)</a></span> - Method in class org.apache.samza.metadatastore.<a href="org/apache/samza/metadatastore/InMemoryMetadataStoreFactory.html" title="class in org.apache.samza.metadatastore">InMemoryMetadataStoreFactory</a></dt> +<dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/metadatastore/MetadataStoreFactory.html#getMetadataStore-java.lang.String-org.apache.samza.config.Config-org.apache.samza.metrics.MetricsRegistry-">getMetadataStore(String, Config, MetricsRegistry)</a></span> - Method in interface org.apache.samza.metadatastore.<a href="org/apache/samza/metadatastore/MetadataStoreFactory.html" title="interface in org.apache.samza.metadatastore">MetadataStoreFactory</a></dt> <dd> </dd> <dt><span class="memberNameLink"><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> @@ -1128,6 +1339,10 @@ </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/internal/WindowInternal.html#getMode--">getMode()</a></span> - Method in class org.apache.samza.operators.windows.internal.<a href="org/apache/samza/operators/windows/internal/WindowInternal.html" title="class in org.apache.samza.operators.windows.internal">WindowInternal</a></dt> <dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/config/JavaTableConfig.html#getMsgSerde-java.lang.String-">getMsgSerde(String)</a></span> - Method in class org.apache.samza.config.<a href="org/apache/samza/config/JavaTableConfig.html" title="class in org.apache.samza.config">JavaTableConfig</a></dt> +<dd> +<div class="block">Get registry keys of value serde for this table</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/internal/WindowInternal.html#getMsgSerde--">getMsgSerde()</a></span> - Method in class org.apache.samza.operators.windows.internal.<a href="org/apache/samza/operators/windows/internal/WindowInternal.html" title="class in org.apache.samza.operators.windows.internal">WindowInternal</a></dt> <dd> </dd> <dt><span class="memberNameLink"><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> @@ -1142,10 +1357,6 @@ <dd> <div class="block">Get the name of the timer</div> </dd> -<dt><span class="memberNameLink"><a href="org/apache/samza/system/ExtendedSystemAdmin.html#getNewestOffset-org.apache.samza.system.SystemStreamPartition-java.lang.Integer-">getNewestOffset(SystemStreamPartition, Integer)</a></span> - Method in interface org.apache.samza.system.<a href="org/apache/samza/system/ExtendedSystemAdmin.html" title="interface in org.apache.samza.system">ExtendedSystemAdmin</a></dt> -<dd> -<div class="block"><span class="deprecatedLabel">Deprecated.</span></div> -</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/system/SystemStreamMetadata.SystemStreamPartitionMetadata.html#getNewestOffset--">getNewestOffset()</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/SystemStreamMetadata.SystemStreamPartitionMetadata.html" title="class in org.apache.samza.system">SystemStreamMetadata.SystemStreamPartitionMetadata</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/config/Config.html#getNewInstance-java.lang.String-">getNewInstance(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> @@ -1153,7 +1364,9 @@ <dt><span class="memberNameLink"><a href="org/apache/samza/util/BlockingEnvelopeMap.html#getNumMessagesInQueue-org.apache.samza.system.SystemStreamPartition-">getNumMessagesInQueue(SystemStreamPartition)</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="memberNameLink"><a href="org/apache/samza/system/IncomingMessageEnvelope.html#getOffset--">getOffset()</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/IncomingMessageEnvelope.html" title="class in org.apache.samza.system">IncomingMessageEnvelope</a></dt> -<dd> </dd> +<dd> +<div class="block">Offset associated with this message, provided by the system consumer that consumed the message.</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/system/SystemStreamMetadata.SystemStreamPartitionMetadata.html#getOffset-org.apache.samza.system.SystemStreamMetadata.OffsetType-">getOffset(SystemStreamMetadata.OffsetType)</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/SystemStreamMetadata.SystemStreamPartitionMetadata.html" title="class in org.apache.samza.system">SystemStreamMetadata.SystemStreamPartitionMetadata</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/checkpoint/Checkpoint.html#getOffsets--">getOffsets()</a></span> - Method in class org.apache.samza.checkpoint.<a href="org/apache/samza/checkpoint/Checkpoint.html" title="class in org.apache.samza.checkpoint">Checkpoint</a></dt> @@ -1200,12 +1413,39 @@ <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/system/StreamSpec.html#getPhysicalName--">getPhysicalName()</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/sql/schema/SqlSchema.SqlField.html#getPosition--">getPosition()</a></span> - Method in class org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SqlSchema.SqlField.html" title="class in org.apache.samza.sql.schema">SqlSchema.SqlField</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/container/grouper/stream/SystemStreamPartitionMapper.html#getPreviousSSP-org.apache.samza.system.SystemStreamPartition-int-int-">getPreviousSSP(SystemStreamPartition, int, int)</a></span> - Method in interface org.apache.samza.container.grouper.stream.<a href="org/apache/samza/container/grouper/stream/SystemStreamPartitionMapper.html" title="interface in org.apache.samza.container.grouper.stream">SystemStreamPartitionMapper</a></dt> +<dd> +<div class="block">Determines the previous <a href="org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system"><code>SystemStreamPartition</code></a> for a <a href="org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system"><code>SystemStreamPartition</code></a> + of a input stream after the stream expansion or contraction.</div> +</dd> <dt><span class="memberNameLink"><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> <dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/BaseTableDescriptor.html#getProviderFactoryClassName--">getProviderFactoryClassName()</a></span> - Method in class org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/BaseTableDescriptor.html" title="class in org.apache.samza.table.descriptors">BaseTableDescriptor</a></dt> +<dd> +<div class="block">Return the fully qualified class name of the <a href="org/apache/samza/table/TableProviderFactory.html" title="interface in org.apache.samza.table"><code>TableProviderFactory</code></a></div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/CachingTableDescriptor.html#getProviderFactoryClassName--">getProviderFactoryClassName()</a></span> - Method in class org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/CachingTableDescriptor.html" title="class in org.apache.samza.table.descriptors">CachingTableDescriptor</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/GuavaCacheTableDescriptor.html#getProviderFactoryClassName--">getProviderFactoryClassName()</a></span> - Method in class org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/GuavaCacheTableDescriptor.html" title="class in org.apache.samza.table.descriptors">GuavaCacheTableDescriptor</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/RemoteTableDescriptor.html#getProviderFactoryClassName--">getProviderFactoryClassName()</a></span> - Method in class org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/retry/TableRetryPolicy.html#getRandomMax--">getRandomMax()</a></span> - Method in class org.apache.samza.table.retry.<a href="org/apache/samza/table/retry/TableRetryPolicy.html" title="class in org.apache.samza.table.retry">TableRetryPolicy</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/retry/TableRetryPolicy.html#getRandomMin--">getRandomMin()</a></span> - Method in class org.apache.samza.table.retry.<a href="org/apache/samza/table/retry/TableRetryPolicy.html" title="class in org.apache.samza.table.retry">TableRetryPolicy</a></dt> +<dd> </dd>
[... 1204 lines stripped ...]
