Modified: samza/site/learn/documentation/versioned/api/javadocs/overview-tree.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/api/javadocs/overview-tree.html?rev=1855804&r1=1855803&r2=1855804&view=diff ============================================================================== --- samza/site/learn/documentation/versioned/api/javadocs/overview-tree.html (original) +++ samza/site/learn/documentation/versioned/api/javadocs/overview-tree.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>Class Hierarchy (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>Class Hierarchy (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="Class Hierarchy (samza-api 1.0.0 API)"; + parent.document.title="Class Hierarchy (samza-api 1.0.1-SNAPSHOT API)"; } } catch(err) { @@ -94,7 +94,9 @@ <li><a href="org/apache/samza/scheduler/package-tree.html">org.apache.samza.scheduler</a>, </li> <li><a href="org/apache/samza/serializers/package-tree.html">org.apache.samza.serializers</a>, </li> <li><a href="org/apache/samza/sql/package-tree.html">org.apache.samza.sql</a>, </li> +<li><a href="org/apache/samza/sql/schema/package-tree.html">org.apache.samza.sql.schema</a>, </li> <li><a href="org/apache/samza/sql/udfs/package-tree.html">org.apache.samza.sql.udfs</a>, </li> +<li><a href="org/apache/samza/startpoint/package-tree.html">org.apache.samza.startpoint</a>, </li> <li><a href="org/apache/samza/storage/package-tree.html">org.apache.samza.storage</a>, </li> <li><a href="org/apache/samza/storage/kv/package-tree.html">org.apache.samza.storage.kv</a>, </li> <li><a href="org/apache/samza/system/package-tree.html">org.apache.samza.system</a>, </li> @@ -102,6 +104,9 @@ <li><a href="org/apache/samza/system/descriptors/package-tree.html">org.apache.samza.system.descriptors</a>, </li> <li><a href="org/apache/samza/table/package-tree.html">org.apache.samza.table</a>, </li> <li><a href="org/apache/samza/table/descriptors/package-tree.html">org.apache.samza.table.descriptors</a>, </li> +<li><a href="org/apache/samza/table/remote/package-tree.html">org.apache.samza.table.remote</a>, </li> +<li><a href="org/apache/samza/table/retry/package-tree.html">org.apache.samza.table.retry</a>, </li> +<li><a href="org/apache/samza/table/utils/package-tree.html">org.apache.samza.table.utils</a>, </li> <li><a href="org/apache/samza/task/package-tree.html">org.apache.samza.task</a>, </li> <li><a href="org/apache/samza/util/package-tree.html">org.apache.samza.util</a></li> </ul> @@ -115,6 +120,18 @@ <li type="circle">org.apache.samza.runtime.<a href="org/apache/samza/runtime/ApplicationRunners.html" title="class in org.apache.samza.runtime"><span class="typeNameLink">ApplicationRunners</span></a></li> <li type="circle">org.apache.samza.job.<a href="org/apache/samza/job/ApplicationStatus.html" title="class in org.apache.samza.job"><span class="typeNameLink">ApplicationStatus</span></a></li> <li type="circle">org.apache.samza.system.chooser.<a href="org/apache/samza/system/chooser/BaseMessageChooser.html" title="class in org.apache.samza.system.chooser"><span class="typeNameLink">BaseMessageChooser</span></a> (implements org.apache.samza.system.chooser.<a href="org/apache/samza/system/chooser/MessageChooser.html" title="interface in org.apache.samza.system.chooser">MessageChooser</a>)</li> +<li type="circle">org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/BaseTableDescriptor.html" title="class in org.apache.samza.table.descriptors"><span class="typeNameLink">BaseTableDescriptor</span></a><K,V,D> (implements org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/TableDescriptor.html" title="interface in org.apache.samza.table.descriptors">TableDescriptor</a><K,V,D>) +<ul> +<li type="circle">org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/GuavaCacheTableDescriptor.html" title="class in org.apache.samza.table.descriptors"><span class="typeNameLink">GuavaCacheTableDescriptor</span></a><K,V></li> +<li type="circle">org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/HybridTableDescriptor.html" title="class in org.apache.samza.table.descriptors"><span class="typeNameLink">HybridTableDescriptor</span></a><K,V,D> +<ul> +<li type="circle">org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/CachingTableDescriptor.html" title="class in org.apache.samza.table.descriptors"><span class="typeNameLink">CachingTableDescriptor</span></a><K,V></li> +</ul> +</li> +<li type="circle">org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/LocalTableDescriptor.html" title="class in org.apache.samza.table.descriptors"><span class="typeNameLink">LocalTableDescriptor</span></a><K,V,D></li> +<li type="circle">org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors"><span class="typeNameLink">RemoteTableDescriptor</span></a><K,V></li> +</ul> +</li> <li type="circle">org.apache.samza.util.<a href="org/apache/samza/util/BlockingEnvelopeMap.html" title="class in org.apache.samza.util"><span class="typeNameLink">BlockingEnvelopeMap</span></a> (implements org.apache.samza.system.<a href="org/apache/samza/system/SystemConsumer.html" title="interface in org.apache.samza.system">SystemConsumer</a>)</li> <li type="circle">org.apache.samza.util.<a href="org/apache/samza/util/BlockingEnvelopeMap.BlockingEnvelopeMapMetrics.html" title="class in org.apache.samza.util"><span class="typeNameLink">BlockingEnvelopeMap.BlockingEnvelopeMapMetrics</span></a></li> <li type="circle">org.apache.samza.serializers.<a href="org/apache/samza/serializers/ByteBufferSerde.html" title="class in org.apache.samza.serializers"><span class="typeNameLink">ByteBufferSerde</span></a> (implements org.apache.samza.serializers.<a href="org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><T>)</li> @@ -125,7 +142,11 @@ <li type="circle">org.apache.samza.job.<a href="org/apache/samza/job/CommandBuilder.html" title="class in org.apache.samza.job"><span class="typeNameLink">CommandBuilder</span></a></li> <li type="circle">org.apache.samza.config.<a href="org/apache/samza/config/Config.html" title="class in org.apache.samza.config"><span class="typeNameLink">Config</span></a> (implements java.util.Map<K,V>, java.io.Serializable) <ul> -<li type="circle">org.apache.samza.config.<a href="org/apache/samza/config/MapConfig.html" title="class in org.apache.samza.config"><span class="typeNameLink">MapConfig</span></a></li> +<li type="circle">org.apache.samza.config.<a href="org/apache/samza/config/MapConfig.html" title="class in org.apache.samza.config"><span class="typeNameLink">MapConfig</span></a> +<ul> +<li type="circle">org.apache.samza.config.<a href="org/apache/samza/config/JavaTableConfig.html" title="class in org.apache.samza.config"><span class="typeNameLink">JavaTableConfig</span></a></li> +</ul> +</li> </ul> </li> <li type="circle">org.apache.samza.job.model.<a href="org/apache/samza/job/model/ContainerModel.html" title="class in org.apache.samza.job.model"><span class="typeNameLink">ContainerModel</span></a></li> @@ -147,6 +168,8 @@ </ul> </li> <li type="circle">org.apache.samza.system.<a href="org/apache/samza/system/IncomingMessageEnvelope.html" title="class in org.apache.samza.system"><span class="typeNameLink">IncomingMessageEnvelope</span></a></li> +<li type="circle">org.apache.samza.metadatastore.<a href="org/apache/samza/metadatastore/InMemoryMetadataStore.html" title="class in org.apache.samza.metadatastore"><span class="typeNameLink">InMemoryMetadataStore</span></a> (implements org.apache.samza.metadatastore.<a href="org/apache/samza/metadatastore/MetadataStore.html" title="interface in org.apache.samza.metadatastore">MetadataStore</a>)</li> +<li type="circle">org.apache.samza.metadatastore.<a href="org/apache/samza/metadatastore/InMemoryMetadataStoreFactory.html" title="class in org.apache.samza.metadatastore"><span class="typeNameLink">InMemoryMetadataStoreFactory</span></a> (implements org.apache.samza.metadatastore.<a href="org/apache/samza/metadatastore/MetadataStoreFactory.html" title="interface in org.apache.samza.metadatastore">MetadataStoreFactory</a>)</li> <li type="circle">org.apache.samza.serializers.<a href="org/apache/samza/serializers/IntegerSerde.html" title="class in org.apache.samza.serializers"><span class="typeNameLink">IntegerSerde</span></a> (implements org.apache.samza.serializers.<a href="org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><T>)</li> <li type="circle">org.apache.samza.serializers.<a href="org/apache/samza/serializers/IntegerSerdeFactory.html" title="class in org.apache.samza.serializers"><span class="typeNameLink">IntegerSerdeFactory</span></a> (implements org.apache.samza.serializers.<a href="org/apache/samza/serializers/SerdeFactory.html" title="interface in org.apache.samza.serializers">SerdeFactory</a><T>)</li> <li type="circle">org.apache.samza.annotation.<a href="org/apache/samza/annotation/InterfaceStability.html" title="class in org.apache.samza.annotation"><span class="typeNameLink">InterfaceStability</span></a></li> @@ -164,12 +187,27 @@ <li type="circle">org.apache.samza.system.<a href="org/apache/samza/system/OutgoingMessageEnvelope.html" title="class in org.apache.samza.system"><span class="typeNameLink">OutgoingMessageEnvelope</span></a></li> <li type="circle">org.apache.samza.<a href="org/apache/samza/Partition.html" title="class in org.apache.samza"><span class="typeNameLink">Partition</span></a> (implements java.lang.Comparable<T>)</li> <li type="circle">org.apache.samza.operators.triggers.<a href="org/apache/samza/operators/triggers/RepeatingTrigger.html" title="class in org.apache.samza.operators.triggers"><span class="typeNameLink">RepeatingTrigger</span></a><M> (implements org.apache.samza.operators.triggers.<a href="org/apache/samza/operators/triggers/Trigger.html" title="interface in org.apache.samza.operators.triggers">Trigger</a><M>)</li> +<li type="circle">org.apache.samza.metrics.<a href="org/apache/samza/metrics/SamzaHistogram.html" title="class in org.apache.samza.metrics"><span class="typeNameLink">SamzaHistogram</span></a></li> <li type="circle">org.apache.samza.sql.<a href="org/apache/samza/sql/SamzaSqlRelRecord.html" title="class in org.apache.samza.sql"><span class="typeNameLink">SamzaSqlRelRecord</span></a> (implements java.io.Serializable)</li> +<li type="circle">org.apache.samza.table.utils.<a href="org/apache/samza/table/utils/SerdeUtils.html" title="class in org.apache.samza.table.utils"><span class="typeNameLink">SerdeUtils</span></a></li> <li type="circle">org.apache.samza.serializers.<a href="org/apache/samza/serializers/SerializableSerde.html" title="class in org.apache.samza.serializers"><span class="typeNameLink">SerializableSerde</span></a><T> (implements org.apache.samza.serializers.<a href="org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><T>)</li> <li type="circle">org.apache.samza.serializers.<a href="org/apache/samza/serializers/SerializableSerdeFactory.html" title="class in org.apache.samza.serializers"><span class="typeNameLink">SerializableSerdeFactory</span></a><T> (implements org.apache.samza.serializers.<a href="org/apache/samza/serializers/SerdeFactory.html" title="interface in org.apache.samza.serializers">SerdeFactory</a><T>)</li> <li type="circle">org.apache.samza.util.<a href="org/apache/samza/util/SinglePartitionWithoutOffsetsSystemAdmin.html" title="class in org.apache.samza.util"><span class="typeNameLink">SinglePartitionWithoutOffsetsSystemAdmin</span></a> (implements org.apache.samza.system.<a href="org/apache/samza/system/SystemAdmin.html" title="interface in org.apache.samza.system">SystemAdmin</a>)</li> <li type="circle">org.apache.samza.metrics.<a href="org/apache/samza/metrics/SlidingTimeWindowReservoir.html" title="class in org.apache.samza.metrics"><span class="typeNameLink">SlidingTimeWindowReservoir</span></a> (implements org.apache.samza.metrics.<a href="org/apache/samza/metrics/Reservoir.html" title="interface in org.apache.samza.metrics">Reservoir</a>)</li> <li type="circle">org.apache.samza.metrics.<a href="org/apache/samza/metrics/Snapshot.html" title="class in org.apache.samza.metrics"><span class="typeNameLink">Snapshot</span></a></li> +<li type="circle">org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SqlFieldSchema.html" title="class in org.apache.samza.sql.schema"><span class="typeNameLink">SqlFieldSchema</span></a></li> +<li type="circle">org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SqlSchema.html" title="class in org.apache.samza.sql.schema"><span class="typeNameLink">SqlSchema</span></a></li> +<li type="circle">org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SqlSchema.SqlField.html" title="class in org.apache.samza.sql.schema"><span class="typeNameLink">SqlSchema.SqlField</span></a></li> +<li type="circle">org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SqlSchemaBuilder.html" title="class in org.apache.samza.sql.schema"><span class="typeNameLink">SqlSchemaBuilder</span></a></li> +<li type="circle">org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/Startpoint.html" title="class in org.apache.samza.startpoint"><span class="typeNameLink">Startpoint</span></a> +<ul> +<li type="circle">org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointCustom.html" title="class in org.apache.samza.startpoint"><span class="typeNameLink">StartpointCustom</span></a></li> +<li type="circle">org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointOldest.html" title="class in org.apache.samza.startpoint"><span class="typeNameLink">StartpointOldest</span></a></li> +<li type="circle">org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointSpecific.html" title="class in org.apache.samza.startpoint"><span class="typeNameLink">StartpointSpecific</span></a></li> +<li type="circle">org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointTimestamp.html" title="class in org.apache.samza.startpoint"><span class="typeNameLink">StartpointTimestamp</span></a></li> +<li type="circle">org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointUpcoming.html" title="class in org.apache.samza.startpoint"><span class="typeNameLink">StartpointUpcoming</span></a></li> +</ul> +</li> <li type="circle">org.apache.samza.storage.<a href="org/apache/samza/storage/StoreProperties.html" title="class in org.apache.samza.storage"><span class="typeNameLink">StoreProperties</span></a></li> <li type="circle">org.apache.samza.storage.<a href="org/apache/samza/storage/StoreProperties.StorePropertiesBuilder.html" title="class in org.apache.samza.storage"><span class="typeNameLink">StoreProperties.StorePropertiesBuilder</span></a></li> <li type="circle">org.apache.samza.system.descriptors.<a href="org/apache/samza/system/descriptors/StreamDescriptor.html" title="class in org.apache.samza.system.descriptors"><span class="typeNameLink">StreamDescriptor</span></a><StreamMessageType,SubClass> @@ -202,7 +240,8 @@ <li type="circle">org.apache.samza.system.<a href="org/apache/samza/system/SystemStreamMetadata.html" title="class in org.apache.samza.system"><span class="typeNameLink">SystemStreamMetadata</span></a></li> <li type="circle">org.apache.samza.system.<a href="org/apache/samza/system/SystemStreamMetadata.SystemStreamPartitionMetadata.html" title="class in org.apache.samza.system"><span class="typeNameLink">SystemStreamMetadata.SystemStreamPartitionMetadata</span></a></li> <li type="circle">org.apache.samza.system.<a href="org/apache/samza/system/SystemStreamPartitionIterator.html" title="class in org.apache.samza.system"><span class="typeNameLink">SystemStreamPartitionIterator</span></a> (implements java.util.Iterator<E>)</li> -<li type="circle">org.apache.samza.table.<a href="org/apache/samza/table/TableSpec.html" title="class in org.apache.samza.table"><span class="typeNameLink">TableSpec</span></a> (implements java.io.Serializable)</li> +<li type="circle">org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableRateLimiter.html" title="class in org.apache.samza.table.remote"><span class="typeNameLink">TableRateLimiter</span></a><K,V></li> +<li type="circle">org.apache.samza.table.retry.<a href="org/apache/samza/table/retry/TableRetryPolicy.html" title="class in org.apache.samza.table.retry"><span class="typeNameLink">TableRetryPolicy</span></a> (implements java.io.Serializable, org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TablePart.html" title="interface in org.apache.samza.table.remote">TablePart</a>)</li> <li type="circle">org.apache.samza.job.model.<a href="org/apache/samza/job/model/TaskModel.html" title="class in org.apache.samza.job.model"><span class="typeNameLink">TaskModel</span></a> (implements java.lang.Comparable<T>)</li> <li type="circle">org.apache.samza.container.<a href="org/apache/samza/container/TaskName.html" title="class in org.apache.samza.container"><span class="typeNameLink">TaskName</span></a> (implements java.lang.Comparable<T>)</li> <li type="circle">java.lang.Throwable (implements java.io.Serializable) @@ -268,6 +307,8 @@ <li type="circle">org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/SinkFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">SinkFunction</span></a><M> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a>, java.io.Serializable)</li> <li type="circle">org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/StreamTableJoinFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">StreamTableJoinFunction</span></a><K,M,R,JM> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a>, java.io.Serializable)</li> <li type="circle">org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/SupplierFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">SupplierFunction</span></a><T> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a>, java.io.Serializable)</li> +<li type="circle">org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableReadFunction.html" title="interface in org.apache.samza.table.remote"><span class="typeNameLink">TableReadFunction</span></a><K,V> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a>, java.io.Serializable, org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TablePart.html" title="interface in org.apache.samza.table.remote">TablePart</a>)</li> +<li type="circle">org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableWriteFunction.html" title="interface in org.apache.samza.table.remote"><span class="typeNameLink">TableWriteFunction</span></a><K,V> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a>, java.io.Serializable, org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TablePart.html" title="interface in org.apache.samza.table.remote">TablePart</a>)</li> </ul> </li> <li type="circle">org.apache.samza.task.<a href="org/apache/samza/task/ClosableTask.html" title="interface in org.apache.samza.task"><span class="typeNameLink">ClosableTask</span></a></li> @@ -282,6 +323,7 @@ </li> <li type="circle">org.apache.samza.task.<a href="org/apache/samza/task/EndOfStreamListenerTask.html" title="interface in org.apache.samza.task"><span class="typeNameLink">EndOfStreamListenerTask</span></a></li> <li type="circle">org.apache.samza.system.descriptors.<a href="org/apache/samza/system/descriptors/ExpandingInputDescriptorProvider.html" title="interface in org.apache.samza.system.descriptors"><span class="typeNameLink">ExpandingInputDescriptorProvider</span></a><StreamExpanderType></li> +<li type="circle">org.apache.samza.context.<a href="org/apache/samza/context/ExternalContext.html" title="interface in org.apache.samza.context"><span class="typeNameLink">ExternalContext</span></a></li> <li type="circle">org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">InitableFunction</span></a> <ul> <li type="circle">org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/FilterFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">FilterFunction</span></a><M> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/ClosableFunction.html" title="interface in org.apache.samza.operators.functions">ClosableFunction</a>, java.io.Serializable)</li> @@ -293,6 +335,8 @@ <li type="circle">org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/SinkFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">SinkFunction</span></a><M> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/ClosableFunction.html" title="interface in org.apache.samza.operators.functions">ClosableFunction</a>, java.io.Serializable)</li> <li type="circle">org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/StreamTableJoinFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">StreamTableJoinFunction</span></a><K,M,R,JM> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/ClosableFunction.html" title="interface in org.apache.samza.operators.functions">ClosableFunction</a>, java.io.Serializable)</li> <li type="circle">org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/SupplierFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">SupplierFunction</span></a><T> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/ClosableFunction.html" title="interface in org.apache.samza.operators.functions">ClosableFunction</a>, java.io.Serializable)</li> +<li type="circle">org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableReadFunction.html" title="interface in org.apache.samza.table.remote"><span class="typeNameLink">TableReadFunction</span></a><K,V> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/ClosableFunction.html" title="interface in org.apache.samza.operators.functions">ClosableFunction</a>, java.io.Serializable, org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TablePart.html" title="interface in org.apache.samza.table.remote">TablePart</a>)</li> +<li type="circle">org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableWriteFunction.html" title="interface in org.apache.samza.table.remote"><span class="typeNameLink">TableWriteFunction</span></a><K,V> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/ClosableFunction.html" title="interface in org.apache.samza.operators.functions">ClosableFunction</a>, java.io.Serializable, org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TablePart.html" title="interface in org.apache.samza.table.remote">TablePart</a>)</li> </ul> </li> <li type="circle">org.apache.samza.task.<a href="org/apache/samza/task/InitableTask.html" title="interface in org.apache.samza.task"><span class="typeNameLink">InitableTask</span></a></li> @@ -324,6 +368,11 @@ <li type="circle">org.apache.samza.metrics.<a href="org/apache/samza/metrics/MetricsValidator.html" title="interface in org.apache.samza.metrics"><span class="typeNameLink">MetricsValidator</span></a></li> <li type="circle">org.apache.samza.system.descriptors.<a href="org/apache/samza/system/descriptors/OutputDescriptorProvider.html" title="interface in org.apache.samza.system.descriptors"><span class="typeNameLink">OutputDescriptorProvider</span></a></li> <li type="circle">org.apache.samza.operators.<a href="org/apache/samza/operators/OutputStream.html" title="interface in org.apache.samza.operators"><span class="typeNameLink">OutputStream</span></a><M></li> +<li type="circle">java.util.function.Predicate<T> +<ul> +<li type="circle">org.apache.samza.table.retry.<a href="org/apache/samza/table/retry/TableRetryPolicy.RetryPredicate.html" title="interface in org.apache.samza.table.retry"><span class="typeNameLink">TableRetryPolicy.RetryPredicate</span></a> (also extends java.io.Serializable)</li> +</ul> +</li> <li type="circle">org.apache.samza.runtime.<a href="org/apache/samza/runtime/ProcessorContext.html" title="interface in org.apache.samza.runtime"><span class="typeNameLink">ProcessorContext</span></a></li> <li type="circle">org.apache.samza.runtime.<a href="org/apache/samza/runtime/ProcessorIdGenerator.html" title="interface in org.apache.samza.runtime"><span class="typeNameLink">ProcessorIdGenerator</span></a></li> <li type="circle">org.apache.samza.runtime.<a href="org/apache/samza/runtime/ProcessorLifecycleListener.html" title="interface in org.apache.samza.runtime"><span class="typeNameLink">ProcessorLifecycleListener</span></a></li> @@ -335,7 +384,7 @@ <li type="circle">org.apache.samza.application.<a href="org/apache/samza/application/TaskApplication.html" title="interface in org.apache.samza.application"><span class="typeNameLink">TaskApplication</span></a></li> </ul> </li> -<li type="circle">org.apache.samza.sql.udfs.<a href="org/apache/samza/sql/udfs/ScalarUdf.html" title="interface in org.apache.samza.sql.udfs"><span class="typeNameLink">ScalarUdf</span></a><T></li> +<li type="circle">org.apache.samza.sql.udfs.<a href="org/apache/samza/sql/udfs/ScalarUdf.html" title="interface in org.apache.samza.sql.udfs"><span class="typeNameLink">ScalarUdf</span></a></li> <li type="circle">org.apache.samza.scheduler.<a href="org/apache/samza/scheduler/ScheduledCallback.html" title="interface in org.apache.samza.scheduler"><span class="typeNameLink">ScheduledCallback</span></a><K></li> <li type="circle">org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/ScheduledFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">ScheduledFunction</span></a><K,OM></li> <li type="circle">org.apache.samza.operators.<a href="org/apache/samza/operators/Scheduler.html" title="interface in org.apache.samza.operators"><span class="typeNameLink">Scheduler</span></a><K></li> @@ -360,6 +409,10 @@ <li type="circle">org.apache.samza.system.descriptors.<a href="org/apache/samza/system/descriptors/StreamExpander.html" title="interface in org.apache.samza.system.descriptors"><span class="typeNameLink">StreamExpander</span></a><OM></li> <li type="circle">org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/StreamTableJoinFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">StreamTableJoinFunction</span></a><K,M,R,JM> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/ClosableFunction.html" title="interface in org.apache.samza.operators.functions">ClosableFunction</a>, org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a>)</li> <li type="circle">org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/SupplierFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">SupplierFunction</span></a><T> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/ClosableFunction.html" title="interface in org.apache.samza.operators.functions">ClosableFunction</a>, org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a>)</li> +<li type="circle">org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableRateLimiter.CreditFunction.html" title="interface in org.apache.samza.table.remote"><span class="typeNameLink">TableRateLimiter.CreditFunction</span></a><K,V> (also extends org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TablePart.html" title="interface in org.apache.samza.table.remote">TablePart</a>)</li> +<li type="circle">org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableReadFunction.html" title="interface in org.apache.samza.table.remote"><span class="typeNameLink">TableReadFunction</span></a><K,V> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/ClosableFunction.html" title="interface in org.apache.samza.operators.functions">ClosableFunction</a>, org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a>, org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TablePart.html" title="interface in org.apache.samza.table.remote">TablePart</a>)</li> +<li type="circle">org.apache.samza.table.retry.<a href="org/apache/samza/table/retry/TableRetryPolicy.RetryPredicate.html" title="interface in org.apache.samza.table.retry"><span class="typeNameLink">TableRetryPolicy.RetryPredicate</span></a> (also extends java.util.function.Predicate<T>)</li> +<li type="circle">org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableWriteFunction.html" title="interface in org.apache.samza.table.remote"><span class="typeNameLink">TableWriteFunction</span></a><K,V> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/ClosableFunction.html" title="interface in org.apache.samza.operators.functions">ClosableFunction</a>, org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a>, org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TablePart.html" title="interface in org.apache.samza.table.remote">TablePart</a>)</li> <li type="circle">org.apache.samza.task.<a href="org/apache/samza/task/TaskFactory.html" title="interface in org.apache.samza.task"><span class="typeNameLink">TaskFactory</span></a><T> <ul> <li type="circle">org.apache.samza.task.<a href="org/apache/samza/task/AsyncStreamTaskFactory.html" title="interface in org.apache.samza.task"><span class="typeNameLink">AsyncStreamTaskFactory</span></a></li> @@ -380,25 +433,24 @@ </ul> </li> <li type="circle">org.apache.samza.system.descriptors.<a href="org/apache/samza/system/descriptors/SimpleInputDescriptorProvider.html" title="interface in org.apache.samza.system.descriptors"><span class="typeNameLink">SimpleInputDescriptorProvider</span></a></li> +<li type="circle">org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointVisitor.html" title="interface in org.apache.samza.startpoint"><span class="typeNameLink">StartpointVisitor</span></a></li> <li type="circle">org.apache.samza.storage.<a href="org/apache/samza/storage/StorageEngine.html" title="interface in org.apache.samza.storage"><span class="typeNameLink">StorageEngine</span></a></li> <li type="circle">org.apache.samza.storage.<a href="org/apache/samza/storage/StorageEngineFactory.html" title="interface in org.apache.samza.storage"><span class="typeNameLink">StorageEngineFactory</span></a><K,V></li> <li type="circle">org.apache.samza.job.<a href="org/apache/samza/job/StreamJob.html" title="interface in org.apache.samza.job"><span class="typeNameLink">StreamJob</span></a></li> <li type="circle">org.apache.samza.job.<a href="org/apache/samza/job/StreamJobFactory.html" title="interface in org.apache.samza.job"><span class="typeNameLink">StreamJobFactory</span></a></li> <li type="circle">org.apache.samza.task.<a href="org/apache/samza/task/StreamTask.html" title="interface in org.apache.samza.task"><span class="typeNameLink">StreamTask</span></a></li> -<li type="circle">org.apache.samza.system.<a href="org/apache/samza/system/SystemAdmin.html" title="interface in org.apache.samza.system"><span class="typeNameLink">SystemAdmin</span></a> -<ul> -<li type="circle">org.apache.samza.system.<a href="org/apache/samza/system/ExtendedSystemAdmin.html" title="interface in org.apache.samza.system"><span class="typeNameLink">ExtendedSystemAdmin</span></a></li> -</ul> -</li> +<li type="circle">org.apache.samza.system.<a href="org/apache/samza/system/SystemAdmin.html" title="interface in org.apache.samza.system"><span class="typeNameLink">SystemAdmin</span></a></li> <li type="circle">org.apache.samza.system.<a href="org/apache/samza/system/SystemConsumer.html" title="interface in org.apache.samza.system"><span class="typeNameLink">SystemConsumer</span></a></li> <li type="circle">org.apache.samza.system.<a href="org/apache/samza/system/SystemFactory.html" title="interface in org.apache.samza.system"><span class="typeNameLink">SystemFactory</span></a></li> <li type="circle">org.apache.samza.system.<a href="org/apache/samza/system/SystemProducer.html" title="interface in org.apache.samza.system"><span class="typeNameLink">SystemProducer</span></a></li> <li type="circle">org.apache.samza.container.grouper.stream.<a href="org/apache/samza/container/grouper/stream/SystemStreamPartitionGrouper.html" title="interface in org.apache.samza.container.grouper.stream"><span class="typeNameLink">SystemStreamPartitionGrouper</span></a></li> <li type="circle">org.apache.samza.container.grouper.stream.<a href="org/apache/samza/container/grouper/stream/SystemStreamPartitionGrouperFactory.html" title="interface in org.apache.samza.container.grouper.stream"><span class="typeNameLink">SystemStreamPartitionGrouperFactory</span></a></li> +<li type="circle">org.apache.samza.container.grouper.stream.<a href="org/apache/samza/container/grouper/stream/SystemStreamPartitionMapper.html" title="interface in org.apache.samza.container.grouper.stream"><span class="typeNameLink">SystemStreamPartitionMapper</span></a></li> +<li type="circle">org.apache.samza.container.grouper.stream.<a href="org/apache/samza/container/grouper/stream/SystemStreamPartitionMapperFactory.html" title="interface in org.apache.samza.container.grouper.stream"><span class="typeNameLink">SystemStreamPartitionMapperFactory</span></a></li> <li type="circle">org.apache.samza.system.<a href="org/apache/samza/system/SystemStreamPartitionMatcher.html" title="interface in org.apache.samza.system"><span class="typeNameLink">SystemStreamPartitionMatcher</span></a></li> <li type="circle">org.apache.samza.table.<a href="org/apache/samza/table/Table.html" title="interface in org.apache.samza.table"><span class="typeNameLink">Table</span></a><R> <ul> -<li type="circle">org.apache.samza.table.<a href="org/apache/samza/table/ReadableTable.html" title="interface in org.apache.samza.table"><span class="typeNameLink">ReadableTable</span></a><K,V> +<li type="circle">org.apache.samza.table.<a href="org/apache/samza/table/AsyncReadWriteTable.html" title="interface in org.apache.samza.table"><span class="typeNameLink">AsyncReadWriteTable</span></a><K,V> <ul> <li type="circle">org.apache.samza.table.<a href="org/apache/samza/table/ReadWriteTable.html" title="interface in org.apache.samza.table"><span class="typeNameLink">ReadWriteTable</span></a><K,V></li> </ul> @@ -407,8 +459,15 @@ </ul> </li> <li type="circle">org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/TableDescriptor.html" title="interface in org.apache.samza.table.descriptors"><span class="typeNameLink">TableDescriptor</span></a><K,V,D></li> -<li type="circle">org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/TableProvider.html" title="interface in org.apache.samza.table.descriptors"><span class="typeNameLink">TableProvider</span></a></li> -<li type="circle">org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/TableProviderFactory.html" title="interface in org.apache.samza.table.descriptors"><span class="typeNameLink">TableProviderFactory</span></a></li> +<li type="circle">org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TablePart.html" title="interface in org.apache.samza.table.remote"><span class="typeNameLink">TablePart</span></a> +<ul> +<li type="circle">org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableRateLimiter.CreditFunction.html" title="interface in org.apache.samza.table.remote"><span class="typeNameLink">TableRateLimiter.CreditFunction</span></a><K,V> (also extends java.io.Serializable)</li> +<li type="circle">org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableReadFunction.html" title="interface in org.apache.samza.table.remote"><span class="typeNameLink">TableReadFunction</span></a><K,V> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/ClosableFunction.html" title="interface in org.apache.samza.operators.functions">ClosableFunction</a>, org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a>, java.io.Serializable)</li> +<li type="circle">org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableWriteFunction.html" title="interface in org.apache.samza.table.remote"><span class="typeNameLink">TableWriteFunction</span></a><K,V> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/ClosableFunction.html" title="interface in org.apache.samza.operators.functions">ClosableFunction</a>, org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a>, java.io.Serializable)</li> +</ul> +</li> +<li type="circle">org.apache.samza.table.<a href="org/apache/samza/table/TableProvider.html" title="interface in org.apache.samza.table"><span class="typeNameLink">TableProvider</span></a></li> +<li type="circle">org.apache.samza.table.<a href="org/apache/samza/table/TableProviderFactory.html" title="interface in org.apache.samza.table"><span class="typeNameLink">TableProviderFactory</span></a></li> <li type="circle">org.apache.samza.task.<a href="org/apache/samza/task/TaskCallback.html" title="interface in org.apache.samza.task"><span class="typeNameLink">TaskCallback</span></a></li> <li type="circle">org.apache.samza.context.<a href="org/apache/samza/context/TaskContext.html" title="interface in org.apache.samza.context"><span class="typeNameLink">TaskContext</span></a></li> <li type="circle">org.apache.samza.task.<a href="org/apache/samza/task/TaskCoordinator.html" title="interface in org.apache.samza.task"><span class="typeNameLink">TaskCoordinator</span></a></li> @@ -421,6 +480,8 @@ <li type="circle">org.apache.samza.annotation.<a href="org/apache/samza/annotation/InterfaceStability.Stable.html" title="annotation in org.apache.samza.annotation"><span class="typeNameLink">InterfaceStability.Stable</span></a> (implements java.lang.annotation.Annotation)</li> <li type="circle">org.apache.samza.annotation.<a href="org/apache/samza/annotation/InterfaceStability.Evolving.html" title="annotation in org.apache.samza.annotation"><span class="typeNameLink">InterfaceStability.Evolving</span></a> (implements java.lang.annotation.Annotation)</li> <li type="circle">org.apache.samza.annotation.<a href="org/apache/samza/annotation/InterfaceStability.Unstable.html" title="annotation in org.apache.samza.annotation"><span class="typeNameLink">InterfaceStability.Unstable</span></a> (implements java.lang.annotation.Annotation)</li> +<li type="circle">org.apache.samza.sql.udfs.<a href="org/apache/samza/sql/udfs/SamzaSqlUdf.html" title="annotation in org.apache.samza.sql.udfs"><span class="typeNameLink">SamzaSqlUdf</span></a> (implements java.lang.annotation.Annotation)</li> +<li type="circle">org.apache.samza.sql.udfs.<a href="org/apache/samza/sql/udfs/SamzaSqlUdfMethod.html" title="annotation in org.apache.samza.sql.udfs"><span class="typeNameLink">SamzaSqlUdfMethod</span></a> (implements java.lang.annotation.Annotation)</li> </ul> <h2 title="Enum Hierarchy">Enum Hierarchy</h2> <ul> @@ -432,10 +493,13 @@ <li type="circle">org.apache.samza.operators.triggers.<a href="org/apache/samza/operators/triggers/FiringType.html" title="enum in org.apache.samza.operators.triggers"><span class="typeNameLink">FiringType</span></a></li> <li type="circle">org.apache.samza.operators.windows.<a href="org/apache/samza/operators/windows/AccumulationMode.html" title="enum in org.apache.samza.operators.windows"><span class="typeNameLink">AccumulationMode</span></a></li> <li type="circle">org.apache.samza.operators.windows.internal.<a href="org/apache/samza/operators/windows/internal/WindowType.html" title="enum in org.apache.samza.operators.windows.internal"><span class="typeNameLink">WindowType</span></a></li> +<li type="circle">org.apache.samza.storage.<a href="org/apache/samza/storage/StorageEngineFactory.StoreMode.html" title="enum in org.apache.samza.storage"><span class="typeNameLink">StorageEngineFactory.StoreMode</span></a></li> <li type="circle">org.apache.samza.system.<a href="org/apache/samza/system/SystemStreamMetadata.OffsetType.html" title="enum in org.apache.samza.system"><span class="typeNameLink">SystemStreamMetadata.OffsetType</span></a></li> <li type="circle">org.apache.samza.system.<a href="org/apache/samza/system/MessageType.html" title="enum in org.apache.samza.system"><span class="typeNameLink">MessageType</span></a></li> <li type="circle">org.apache.samza.task.<a href="org/apache/samza/task/TaskCoordinator.RequestScope.html" title="enum in org.apache.samza.task"><span class="typeNameLink">TaskCoordinator.RequestScope</span></a></li> <li type="circle">org.apache.samza.job.<a href="org/apache/samza/job/ApplicationStatus.StatusCode.html" title="enum in org.apache.samza.job"><span class="typeNameLink">ApplicationStatus.StatusCode</span></a></li> +<li type="circle">org.apache.samza.job.model.<a href="org/apache/samza/job/model/TaskMode.html" title="enum in org.apache.samza.job.model"><span class="typeNameLink">TaskMode</span></a></li> +<li type="circle">org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SamzaSqlFieldType.html" title="enum in org.apache.samza.sql.schema"><span class="typeNameLink">SamzaSqlFieldType</span></a></li> </ul> </li> </ul>
Modified: samza/site/learn/documentation/versioned/api/javadocs/package-list URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/api/javadocs/package-list?rev=1855804&r1=1855803&r2=1855804&view=diff ============================================================================== --- samza/site/learn/documentation/versioned/api/javadocs/package-list (original) +++ samza/site/learn/documentation/versioned/api/javadocs/package-list Tue Mar 19 05:31:11 2019 @@ -20,7 +20,9 @@ org.apache.samza.runtime org.apache.samza.scheduler org.apache.samza.serializers org.apache.samza.sql +org.apache.samza.sql.schema org.apache.samza.sql.udfs +org.apache.samza.startpoint org.apache.samza.storage org.apache.samza.storage.kv org.apache.samza.system @@ -28,5 +30,8 @@ org.apache.samza.system.chooser org.apache.samza.system.descriptors org.apache.samza.table org.apache.samza.table.descriptors +org.apache.samza.table.remote +org.apache.samza.table.retry +org.apache.samza.table.utils org.apache.samza.task org.apache.samza.util Modified: samza/site/learn/documentation/versioned/api/javadocs/serialized-form.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/api/javadocs/serialized-form.html?rev=1855804&r1=1855803&r2=1855804&view=diff ============================================================================== --- samza/site/learn/documentation/versioned/api/javadocs/serialized-form.html (original) +++ samza/site/learn/documentation/versioned/api/javadocs/serialized-form.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>Serialized Form (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>Serialized Form (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="Serialized Form (samza-api 1.0.0 API)"; + parent.document.title="Serialized Form (samza-api 1.0.1-SNAPSHOT API)"; } } catch(err) { @@ -104,6 +104,11 @@ <dd>1L</dd> </dl> </li> +<li class="blockList"><a name="org.apache.samza.config.JavaTableConfig"> +<!-- --> +</a> +<h3>Class <a href="org/apache/samza/config/JavaTableConfig.html" title="class in org.apache.samza.config">org.apache.samza.config.JavaTableConfig</a> extends <a href="org/apache/samza/config/MapConfig.html" title="class in org.apache.samza.config">MapConfig</a> implements Serializable</h3> +</li> <li class="blockList"><a name="org.apache.samza.config.MapConfig"> <!-- --> </a> @@ -440,10 +445,14 @@ <h4>fieldNames</h4> <pre>java.util.ArrayList<E> fieldNames</pre> </li> -<li class="blockListLast"> +<li class="blockList"> <h4>fieldValues</h4> <pre>java.util.ArrayList<E> fieldValues</pre> </li> +<li class="blockListLast"> +<h4>hashCode</h4> +<pre>int hashCode</pre> +</li> </ul> </li> </ul> @@ -522,23 +531,58 @@ <h2 title="Package">Package org.apache.samza.system.descriptors</h2> </li> <li class="blockList"> -<h2 title="Package">Package org.apache.samza.table</h2> +<h2 title="Package">Package org.apache.samza.table.remote</h2> +</li> +<li class="blockList"> +<h2 title="Package">Package org.apache.samza.table.retry</h2> <ul class="blockList"> -<li class="blockList"><a name="org.apache.samza.table.TableSpec"> +<li class="blockList"><a name="org.apache.samza.table.retry.TableRetryPolicy"> <!-- --> </a> -<h3>Class <a href="org/apache/samza/table/TableSpec.html" title="class in org.apache.samza.table">org.apache.samza.table.TableSpec</a> extends java.lang.Object implements Serializable</h3> +<h3>Class <a href="org/apache/samza/table/retry/TableRetryPolicy.html" title="class in org.apache.samza.table.retry">org.apache.samza.table.retry.TableRetryPolicy</a> extends java.lang.Object implements Serializable</h3> <ul class="blockList"> <li class="blockList"> <h3>Serialized Fields</h3> <ul class="blockList"> <li class="blockList"> -<h4>id</h4> -<pre>java.lang.String id</pre> +<h4>sleepTime</h4> +<pre>java.time.Duration sleepTime</pre> +</li> +<li class="blockList"> +<h4>randomMin</h4> +<pre>java.time.Duration randomMin</pre> +</li> +<li class="blockList"> +<h4>randomMax</h4> +<pre>java.time.Duration randomMax</pre> +</li> +<li class="blockList"> +<h4>exponentialFactor</h4> +<pre>double exponentialFactor</pre> +</li> +<li class="blockList"> +<h4>exponentialMaxSleep</h4> +<pre>java.time.Duration exponentialMaxSleep</pre> +</li> +<li class="blockList"> +<h4>jitter</h4> +<pre>java.time.Duration jitter</pre> +</li> +<li class="blockList"> +<h4>maxAttempts</h4> +<pre>java.lang.Integer maxAttempts</pre> +</li> +<li class="blockList"> +<h4>maxDuration</h4> +<pre>java.time.Duration maxDuration</pre> +</li> +<li class="blockList"> +<h4>backoffType</h4> +<pre>org.apache.samza.table.retry.TableRetryPolicy.BackoffType backoffType</pre> </li> <li class="blockListLast"> -<h4>tableProviderFactoryClassName</h4> -<pre>java.lang.String tableProviderFactoryClassName</pre> +<h4>retryPredicate</h4> +<pre><a href="org/apache/samza/table/retry/TableRetryPolicy.RetryPredicate.html" title="interface in org.apache.samza.table.retry">TableRetryPolicy.RetryPredicate</a> retryPredicate</pre> </li> </ul> </li> Modified: samza/site/learn/documentation/versioned/api/low-level-api.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/api/low-level-api.html?rev=1855804&r1=1855803&r2=1855804&view=diff ============================================================================== --- samza/site/learn/documentation/versioned/api/low-level-api.html (original) +++ samza/site/learn/documentation/versioned/api/low-level-api.html Tue Mar 19 05:31:11 2019 @@ -836,7 +836,7 @@ whether they’re provided by the fr <h3 id="legacy-applications">Legacy Applications</h3> -<p>For legacy Low Level API applications, you can continue specifying your system, stream and store properties along with your task.class in configuration. An incomplete example of configuration for legacy task application looks like this (see the <a href="../jobs/configuration.md">configuration</a> documentation for more detail):</p> +<p>For legacy Low Level API applications, you can continue specifying your system, stream and store properties along with your task.class in configuration. An incomplete example of configuration for legacy task application looks like this (see the <a href="../jobs/configuration.html">configuration</a> documentation for more detail):</p> <figure class="highlight"><pre><code class="language-jproperties" data-lang="jproperties"><span></span> <span class="c"># This is the Task class that Samza will instantiate when the job is run</span> <span class="na"> task.class</span><span class="o">=</span><span class="s">com.example.samza.PageViewFilterTask</span> Modified: samza/site/learn/documentation/versioned/api/programming-model.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/api/programming-model.html?rev=1855804&r1=1855803&r2=1855804&view=diff ============================================================================== --- samza/site/learn/documentation/versioned/api/programming-model.html (original) +++ samza/site/learn/documentation/versioned/api/programming-model.html Tue Mar 19 05:31:11 2019 @@ -591,10 +591,10 @@ <li>Java APIs: Samza’s provides two Java programming APIs that are ideal for building advanced Stream Processing applications. <ol> -<li><a href="high-level-api.md">High Level Streams API</a>: Samza’s flexible High Level Streams API lets you describe your complex stream processing pipeline in the form of a Directional Acyclic Graph (DAG) of operations on message streams. It provides a rich set of built-in operators that simplify common stream processing operations such as filtering, projection, repartitioning, joins, and windows.</li> -<li><a href="low-level-api.md">Low Level Task API</a>: Samza’s powerful Low Level Task API lets you write your application in terms of processing logic for each incoming message. </li> +<li><a href="high-level-api.html">High Level Streams API</a>: Samza’s flexible High Level Streams API lets you describe your complex stream processing pipeline in the form of a Directional Acyclic Graph (DAG) of operations on message streams. It provides a rich set of built-in operators that simplify common stream processing operations such as filtering, projection, repartitioning, joins, and windows.</li> +<li><a href="low-level-api.html">Low Level Task API</a>: Samza’s powerful Low Level Task API lets you write your application in terms of processing logic for each incoming message. </li> </ol></li> -<li><a href="samza-sql.md">Samza SQL</a>: Samza SQL provides a declarative query language for describing your stream processing logic. It lets you manipulate streams using SQL predicates and UDFs instead of working with the physical implementation details.</li> +<li><a href="samza-sql.html">Samza SQL</a>: Samza SQL provides a declarative query language for describing your stream processing logic. It lets you manipulate streams using SQL predicates and UDFs instead of working with the physical implementation details.</li> <li>Apache Beam API: Samza also provides a <a href="https://beam.apache.org/documentation/runners/capability-matrix/";>Apache Beam runner</a> to run applications written using the Apache Beam API. This is considered as an extension to the operators supported by the High Level Streams API in Samza.</li> </ol> Modified: samza/site/learn/documentation/versioned/api/samza-sql.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/api/samza-sql.html?rev=1855804&r1=1855803&r2=1855804&view=diff ============================================================================== --- samza/site/learn/documentation/versioned/api/samza-sql.html (original) +++ samza/site/learn/documentation/versioned/api/samza-sql.html Tue Mar 19 05:31:11 2019 @@ -583,46 +583,100 @@ limitations under the License. --> -<h3 id="overview">Overview</h3> +<h3 id="table-of-contents">Table Of Contents</h3> -<p>Samza SQL allows you to define your stream processing logic declaratively as a a SQL query. -This allows you to create streaming pipelines without Java code or configuration unless you require user-defined functions (UDFs). Support for SQL internally uses Apache Calcite, which provides SQL parsing and query planning. The query is automatically translated to Samza’s high level API and runs on Samza’s execution engine.</p> +<ul> +<li><a href="#introduction">Introduction</a></li> +<li><a href="#code-examples">Code Examples</a></li> +<li><a href="#key-concepts">Key Concepts</a> + +<ul> +<li><a href="#sql-representation">SQL Representation</a></li> +<li><a href="#sql-grammar">SQL Grammar</a></li> +<li><a href="#udfs">UDFs</a></li> +<li><a href="#udf-polymorphism">UDF Polymorphism</a></li> +</ul></li> +<li><a href="#known-limitations">Known Limitations</a></li> +</ul> + +<h3 id="introduction">Introduction</h3> + +<p>Samza SQL allows you to define your stream processing logic +declaratively as a a SQL query. This allows you to create streaming +pipelines without Java code or configuration unless you require +user-defined functions (UDFs). </p> + +<h3 id="code-examples">Code Examples</h3> + +<p>The <a href="https://github.com/apache/samza-hello-samza/tree/master/src/main/java/samza/examples/sql";>Hello Samza</a> +SQL examples demonstrate how to use Samza SQL API. </p> + +<ul> +<li><p>The <a href="https://github.com/apache/samza-hello-samza/tree/master/src/main/java/samza/examples/sql/samza-sql-filter";>filter</a> +demonstrates filtering and insert Samza SQL job.</p></li> +<li><p>The <a href="https://github.com/apache/samza-hello-samza/tree/master/src/main/java/samza/examples/sql/samza-sql-casewhen/src/main/sql";>Case-When</a> +shows how to use <code>CASE WHEN</code> statement, along with <code>UDF</code> to identify qualifying events.</p></li> +<li><p>The <a href="https://github.com/apache/samza-hello-samza/tree/master/src/main/java/samza/examples/sql/samza-sql-stream-table-join";>join</a> +demonstrates how to peform a stream-table join. Please note that join operation is currently not +fully cooked, and we are actively working on stabilizing it. </p></li> +<li><p>The <a href="https://github.com/apache/samza-hello-samza/tree/master/src/main/java/samza/examples/sql/samza-sql-groupby";>group by</a> +show how to do group by. Similar to Join, Group By is being actively stabilized. </p></li> +</ul> + +<h3 id="key-concepts">Key Concepts</h3> + +<p>Each Samza SQL job consists of one or more Samza SQL statements. +Each statement represents a single streaming pipeline.</p> + +<h4 id="sql-representation">SQL Representation</h4> + +<p>Support for SQL internally uses Apache Calcite, which provides +SQL parsing and query planning. The query is automatically translated +to Samza’s high level API and runs on Samza’s execution engine.</p> + +<p>The mapping from SQL to the Samza’s high level API is a simple +deterministic one-to-one mapping. For example, <code>Select</code>, i.e., +projections, maps to a filter operation, while <code>from</code> maps to +a scan(s) and join(s) - if selecting from multiple streams and tables +- operators, and so on. </p> + +<p>The table below lists the supported SQL operations.</p> + +<table><thead> +<tr> +<th>Operation</th> +<th>Syntax hints</th> +<th>Comments</th> +</tr> +</thead><tbody> +<tr> +<td>PROJECTION</td> +<td>SELECT/INSERT/UPSERT</td> +<td>See <a href="#sql-grammar">SQL Grammar</a> below</td> +</tr> +<tr> +<td>FILTERING</td> +<td>WHERE expression</td> +<td>See <a href="#sql-grammar">SQL Grammar</a> below</td> +</tr> +<tr> +<td>UDFs</td> +<td>udf_name(args)</td> +<td>In both SELECT and WHERE clause</td> +</tr> +<tr> +<td>JOIN</td> +<td>[LEFT/RIGHT] JOIN .. ON ..</td> +<td>Stream-table inner, left- or right-outer joins. Currently not fully stable.</td> +</tr> +<tr> +<td>AGGREGATION</td> +<td>COUNT ( …) .. GROUP BY</td> +<td>Currently only COUNT is supported, using processing-time based window.</td> +</tr> +</tbody></table> -<p>You can run Samza SQL locally on your machine or on a YARN cluster.</p> - -<h3 id="running-samza-sql-on-your-local-machine">Running Samza SQL on your local machine</h3> - -<p>The <a href="https://samza.apache.org/learn/tutorials/0.14/samza-tools.html";>Samza SQL console</a> allows you to experiment with Samza SQL locally on your machine. </p> - -<h4 id="setup-kafka">Setup Kafka</h4> - -<p>Follow the instructions from the <a href="http://kafka.apache.org/quickstart";>Kafka quickstart</a> to start the zookeeper and Kafka server.</p> - -<p>Let us create a Kafka topic named âProfileChangeStreamâ for this demo.</p> -<div class="highlight"><pre><code class="language-bash" data-lang="bash"><span></span>>./deploy/kafka/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor <span class="m">1</span> --partitions <span class="m">1</span> --topic ProfileChangeStream -</code></pre></div> -<p>Download the Samza tools package from <a href="https://samza.apache.org/learn/tutorials/0.14/samza-tools.html";>here</a> and use the <code>generate-kafka-events</code> script populate the stream with sample data.</p> -<div class="highlight"><pre><code class="language-bash" data-lang="bash"><span></span>> <span class="nb">cd</span> samza-tools-<version> -> ./scripts/generate-kafka-events.sh -t ProfileChangeStream -e ProfileChange -</code></pre></div> -<h4 id="using-the-samza-sql-console">Using the Samza SQL Console</h4> - -<p>The simplest SQL query is to read all events from a Kafka topic <code>ProfileChangeStream</code> and print them to the console.</p> -<div class="highlight"><pre><code class="language-bash" data-lang="bash"><span></span>> ./scripts/samza-sql-console.sh --sql <span class="s2">"insert into log.consoleoutput select * from kafka.ProfileChangeStream"</span> -</code></pre></div> -<p>Next, let us project a few fields from the input stream.</p> -<div class="highlight"><pre><code class="language-bash" data-lang="bash"><span></span>> ./scripts/samza-sql-console.sh --sql <span class="s2">"insert into log.consoleoutput select Name, OldCompany, NewCompany from kafka.ProfileChangeStream"</span> -</code></pre></div> -<p>You can also filter messages in the input stream based on some predicate. In this example, we filter profiles currently working at LinkedIn, whose previous employer matches the regex <code>.*soft</code>. The function <code>RegexMatch(regex, company)</code> is an example of -a UDF that defines a predicate. </p> -<div class="highlight"><pre><code class="language-bash" data-lang="bash"><span></span>> ./scripts/samza-sql-console.sh --sql <span class="s2">"insert into log.consoleoutput select Name as __key__, Name, NewCompany, RegexMatch('.*soft', OldCompany) from kafka.ProfileChangeStream where NewCompany = 'LinkedIn'"</span> -</code></pre></div> -<h3 id="running-samza-sql-on-yarn">Running Samza SQL on YARN</h3> - -<p>The <a href="https://github.com/apache/samza-hello-samza";>hello-samza</a> project has examples to get started with Samza on YARN. You can define your SQL query in a <a href="https://github.com/apache/samza-hello-samza/blob/master/src/main/config/pageview-filter-sql.properties";>configuration file</a> and submit it to a YARN cluster.</p> -<div class="highlight"><pre><code class="language-bash" data-lang="bash"><span></span>> ./deploy/samza/bin/run-app.sh --config-factory<span class="o">=</span>org.apache.samza.config.factories.PropertiesConfigFactory --config-path<span class="o">=</span>file://<span class="nv">$PWD</span>/deploy/samza/config/page-view-filter-sql.properties -</code></pre></div> -<h3 id="sql-grammar">SQL Grammar</h3> +<h4 id="sql-grammar">SQL Grammar</h4> <p>Samza SQL’s grammar is a subset of capabilities supported by Calcite’s SQL parser.</p> <div class="highlight"><pre><code class="language-text" data-lang="text"><span></span>statement: @@ -669,9 +723,33 @@ tablePrimary: values: VALUES expression [, expression ]* </code></pre></div> +<h4 id="udfs">UDFs</h4> + +<p>In addition to existing SQL logical operations, Samza SQL +allows the user to extend its functionality by running +user-code through User Defined Functions (UDFs) as part of the Stream processing +pipeline corresponding to the SQL.</p> + +<h4 id="udf-polymorphism">UDF Polymorphism</h4> + +<p>Since UDF’s execute method takes an array of generic objects as +parameter, Samza SQL UDF framework is flexible enough to +support polymorphic udf functions with varying sets of arguments +as long as UDF implementations support them.</p> + +<p>For example in the below sql statement, UDF will be passed an +object array of size 2 with first element containing id of type<br> +“LONG” and second element name of type “String”. The type of the +objects that are passed depends on the type of those fields in Samza +SQL message format.</p> + +<figure class="highlight"><pre><code class="language-sql" data-lang="sql"><span></span><span class="k">select</span> <span class="n">myudf</span><span class="p">(</span><span class="n">id</span><span class="p">,</span> <span class="n">name</span><span class="p">)</span> <span class="k">from</span> <span class="k">identity</span><span class="p">.</span><span class="n">profile</span></code></pre></figure> + <h3 id="known-limitations">Known Limitations</h3> -<p>Samza SQL only supports simple stateless queries including selections and projections. We are actively working on supporting stateful operations such as aggregations, windows and joins.</p> +<p>Samza SQL only supports simple stateless queries including selections +and projections. We are actively working on supporting stateful operations +such as aggregations, windows and joins.</p> </div> Modified: samza/site/learn/documentation/versioned/api/table-api.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/api/table-api.html?rev=1855804&r1=1855803&r2=1855804&view=diff ============================================================================== --- samza/site/learn/documentation/versioned/api/table-api.html (original) +++ samza/site/learn/documentation/versioned/api/table-api.html Tue Mar 19 05:31:11 2019 @@ -830,6 +830,11 @@ method.</p> <td>Count of <code>getAll/getAllAsync()</code> operations</td> </tr> <tr> +<td><code>num-missed-lookups</code></td> +<td><code>ReadableTable</code></td> +<td>Count of missed get/getAll() operations</td> +</tr> +<tr> <td><code>put-ns</code></td> <td><code>ReadWriteTable</code></td> <td>Average latency of <code>put/putAsync()</code> operations</td>
