Author: jagadish
Date: Wed Mar 20 23:07:06 2019
New Revision: 1855951
URL: http://svn.apache.org/viewvc?rev=1855951&view=rev
Log:
publishing website for 1.0
Added:
samza/site/learn/documentation/latest/api/beam-api.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/remote/TablePart.html
samza/site/startup/code-examples/latest/beam.html
samza/site/startup/code-examples/latest/samza.html
samza/site/startup/quick-start/latest/beam.html
Modified:
samza/site/blog/TEMPLATE.html
samza/site/community/committers.html
samza/site/contribute/tests.html
samza/site/learn/documentation/latest/api/javadocs/allclasses-frame.html
samza/site/learn/documentation/latest/api/javadocs/allclasses-noframe.html
samza/site/learn/documentation/latest/api/javadocs/constant-values.html
samza/site/learn/documentation/latest/api/javadocs/deprecated-list.html
samza/site/learn/documentation/latest/api/javadocs/help-doc.html
samza/site/learn/documentation/latest/api/javadocs/index-all.html
samza/site/learn/documentation/latest/api/javadocs/index.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/Partition.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/SamzaException.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/InterfaceStability.Evolving.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/InterfaceStability.Stable.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/InterfaceStability.Unstable.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/InterfaceStability.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/package-frame.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/package-summary.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/package-tree.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/SamzaApplication.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/StreamApplication.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/TaskApplication.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/descriptors/ApplicationDescriptor.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/descriptors/StreamApplicationDescriptor.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/descriptors/TaskApplicationDescriptor.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/descriptors/package-frame.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/descriptors/package-summary.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/descriptors/package-tree.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/package-frame.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/package-summary.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/package-tree.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/checkpoint/Checkpoint.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/checkpoint/CheckpointListener.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/checkpoint/CheckpointManager.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/checkpoint/CheckpointManagerFactory.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/checkpoint/package-frame.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/checkpoint/package-summary.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/checkpoint/package-tree.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/config/Config.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/config/ConfigException.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/config/ConfigFactory.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/config/ConfigRewriter.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/config/JavaTableConfig.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/config/MapConfig.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/config/package-frame.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/config/package-summary.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/config/package-tree.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/container/TaskName.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/container/grouper/stream/SystemStreamPartitionGrouper.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/container/grouper/stream/SystemStreamPartitionGrouperFactory.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/container/grouper/stream/SystemStreamPartitionMapper.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/container/grouper/stream/SystemStreamPartitionMapperFactory.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/container/grouper/stream/package-frame.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/container/grouper/stream/package-summary.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/container/grouper/stream/package-tree.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/container/package-frame.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/container/package-summary.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/container/package-tree.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/context/ApplicationContainerContext.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/context/ApplicationContainerContextFactory.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/context/ApplicationTaskContext.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/context/ApplicationTaskContextFactory.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/context/ContainerContext.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/context/Context.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/context/ExternalContext.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/context/JobContext.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/context/TaskContext.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/context/package-frame.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/context/package-summary.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/context/package-tree.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/job/ApplicationStatus.StatusCode.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/job/ApplicationStatus.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/job/CommandBuilder.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/job/StreamJob.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/job/StreamJobFactory.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/job/model/ContainerModel.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/job/model/TaskMode.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/job/model/TaskModel.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/job/model/package-frame.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/job/model/package-summary.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/job/model/package-tree.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/job/package-frame.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/job/package-summary.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/job/package-tree.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metadatastore/InMemoryMetadataStore.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metadatastore/InMemoryMetadataStoreFactory.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metadatastore/MetadataStore.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metadatastore/MetadataStoreFactory.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metadatastore/package-frame.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metadatastore/package-summary.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metadatastore/package-tree.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/Counter.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/Gauge.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/ListGauge.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/Metric.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/MetricsAccessor.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/MetricsRegistry.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/MetricsReporter.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/MetricsReporterFactory.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/MetricsValidationFailureException.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/MetricsValidator.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/MetricsVisitor.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/ReadableMetricsRegistry.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/ReadableMetricsRegistryListener.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/Reservoir.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/SamzaHistogram.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/SlidingTimeWindowReservoir.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/Snapshot.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/Timer.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/package-frame.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/package-summary.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/metrics/package-tree.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/KV.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/MessageStream.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/OutputStream.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/Scheduler.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/functions/ClosableFunction.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/functions/FilterFunction.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/functions/FlatMapFunction.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/functions/FoldLeftFunction.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/functions/InitableFunction.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/functions/JoinFunction.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/functions/MapFunction.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/functions/ScheduledFunction.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/functions/SinkFunction.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/functions/StreamTableJoinFunction.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/functions/SupplierFunction.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/functions/WatermarkFunction.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/functions/package-frame.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/functions/package-summary.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/functions/package-tree.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/package-frame.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/package-summary.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/package-tree.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/AnyTrigger.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/CountTrigger.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/DurationCharacteristic.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/FiringType.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/RepeatingTrigger.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/TimeBasedTrigger.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/TimeSinceFirstMessageTrigger.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/TimeSinceLastMessageTrigger.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/TimeTrigger.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/Trigger.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/Triggers.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/package-frame.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/package-summary.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/package-tree.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/windows/AccumulationMode.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/windows/Window.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/windows/WindowKey.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/windows/WindowPane.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/windows/Windows.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/windows/internal/WindowInternal.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/windows/internal/WindowType.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/windows/internal/package-frame.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/windows/internal/package-summary.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/windows/internal/package-tree.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/windows/package-frame.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/windows/package-summary.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/windows/package-tree.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/package-frame.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/package-summary.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/package-tree.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/runtime/ApplicationRunner.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/runtime/ApplicationRunners.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/runtime/LocationId.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/runtime/LocationIdProvider.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/runtime/LocationIdProviderFactory.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/runtime/ProcessorContext.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/runtime/ProcessorIdGenerator.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/runtime/ProcessorLifecycleListener.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/runtime/ProcessorLifecycleListenerFactory.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/runtime/package-frame.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/runtime/package-summary.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/runtime/package-tree.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/scheduler/CallbackScheduler.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/scheduler/ScheduledCallback.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/scheduler/package-frame.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/scheduler/package-summary.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/scheduler/package-tree.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/serializers/ByteBufferSerde.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/serializers/ByteBufferSerdeFactory.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/serializers/ByteSerde.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/serializers/ByteSerdeFactory.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/serializers/Deserializer.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/serializers/DoubleSerde.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/serializers/DoubleSerdeFactory.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/serializers/IntegerSerde.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/serializers/IntegerSerdeFactory.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/serializers/JsonSerdeV2.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/serializers/JsonSerdeV2Factory.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/serializers/KVSerde.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/serializers/LongSerde.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/serializers/LongSerdeFactory.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/serializers/NoOpSerde.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/serializers/Serde.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/serializers/SerdeFactory.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/serializers/SerializableSerde.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/serializers/SerializableSerdeFactory.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/serializers/Serializer.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/serializers/StringSerde.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/serializers/StringSerdeFactory.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/serializers/UUIDSerde.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/serializers/UUIDSerdeFactory.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/serializers/package-frame.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/serializers/package-summary.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/serializers/package-tree.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/sql/SamzaSqlRelRecord.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/sql/package-frame.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/sql/package-summary.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/sql/package-tree.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/sql/schema/SamzaSqlFieldType.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/sql/schema/SqlFieldSchema.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/sql/schema/SqlSchema.SqlField.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/sql/schema/SqlSchema.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/sql/schema/SqlSchemaBuilder.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/sql/schema/package-frame.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/sql/schema/package-summary.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/sql/schema/package-tree.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/sql/udfs/SamzaSqlUdf.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/sql/udfs/SamzaSqlUdfMethod.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/sql/udfs/ScalarUdf.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/sql/udfs/package-frame.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/sql/udfs/package-summary.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/sql/udfs/package-tree.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/startpoint/Startpoint.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/startpoint/StartpointCustom.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/startpoint/StartpointOldest.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/startpoint/StartpointSpecific.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/startpoint/StartpointTimestamp.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/startpoint/StartpointUpcoming.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/startpoint/StartpointVisitor.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/startpoint/package-frame.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/startpoint/package-summary.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/startpoint/package-tree.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/storage/SideInputsProcessor.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/storage/SideInputsProcessorFactory.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/storage/StorageEngine.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/storage/StorageEngineFactory.StoreMode.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/storage/StorageEngineFactory.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/storage/StoreProperties.StorePropertiesBuilder.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/storage/StoreProperties.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/storage/kv/ClosableIterator.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/storage/kv/Entry.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/storage/kv/KeyValueIterator.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/storage/kv/KeyValueSnapshot.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/storage/kv/KeyValueStore.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/storage/kv/package-frame.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/storage/kv/package-summary.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/storage/kv/package-tree.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/storage/package-frame.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/storage/package-summary.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/storage/package-tree.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/ControlMessage.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/EndOfStreamMessage.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/IncomingMessageEnvelope.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/MessageType.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/OutgoingMessageEnvelope.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/StreamSpec.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/StreamValidationException.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemAdmin.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemConsumer.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemFactory.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemProducer.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemProducerException.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemStream.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemStreamMetadata.OffsetType.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemStreamMetadata.SystemStreamPartitionMetadata.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemStreamMetadata.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemStreamPartition.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemStreamPartitionIterator.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemStreamPartitionMatcher.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/WatermarkMessage.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/chooser/BaseMessageChooser.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/chooser/MessageChooser.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/chooser/MessageChooserFactory.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/chooser/package-frame.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/chooser/package-summary.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/chooser/package-tree.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/descriptors/ExpandingInputDescriptorProvider.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/descriptors/GenericInputDescriptor.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/descriptors/GenericOutputDescriptor.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/descriptors/GenericSystemDescriptor.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/descriptors/InputDescriptor.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/descriptors/InputTransformer.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/descriptors/OutputDescriptor.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/descriptors/OutputDescriptorProvider.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/descriptors/SimpleInputDescriptorProvider.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/descriptors/StreamDescriptor.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/descriptors/StreamExpander.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/descriptors/SystemDescriptor.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/descriptors/TransformingInputDescriptorProvider.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/descriptors/package-frame.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/descriptors/package-summary.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/descriptors/package-tree.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/package-frame.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/package-summary.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/package-tree.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/AsyncReadWriteTable.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/ReadWriteTable.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/Table.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/TableProvider.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/TableProviderFactory.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/descriptors/BaseTableDescriptor.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/descriptors/CachingTableDescriptor.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/descriptors/GuavaCacheTableDescriptor.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/descriptors/HybridTableDescriptor.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/descriptors/LocalTableDescriptor.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/descriptors/RemoteTableDescriptor.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/descriptors/TableDescriptor.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/descriptors/package-frame.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/descriptors/package-summary.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/descriptors/package-tree.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/package-frame.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/package-summary.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/package-tree.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/remote/TableRateLimiter.CreditFunction.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/remote/TableRateLimiter.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/remote/TableReadFunction.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/remote/TableWriteFunction.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/remote/package-frame.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/remote/package-summary.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/remote/package-tree.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/retry/TableRetryPolicy.RetryPredicate.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/retry/TableRetryPolicy.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/retry/package-frame.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/retry/package-summary.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/retry/package-tree.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/utils/SerdeUtils.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/utils/package-frame.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/utils/package-summary.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/utils/package-tree.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/AsyncStreamTask.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/AsyncStreamTaskFactory.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/ClosableTask.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/EndOfStreamListenerTask.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/InitableTask.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/MessageCollector.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/StreamTask.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/StreamTaskFactory.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/TaskCallback.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/TaskCoordinator.RequestScope.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/TaskCoordinator.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/TaskFactory.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/WindowableTask.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/package-frame.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/package-summary.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/package-tree.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/BlockingEnvelopeMap.BlockingEnvelopeMapMetrics.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/BlockingEnvelopeMap.BufferGauge.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/BlockingEnvelopeMap.BufferSizeGauge.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/BlockingEnvelopeMap.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/Clock.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/NoOpMetricsRegistry.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/RateLimiter.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/SinglePartitionWithoutOffsetsSystemAdmin.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/TimestampedValue.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/package-frame.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/package-summary.html
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/package-tree.html
samza/site/learn/documentation/latest/api/javadocs/overview-frame.html
samza/site/learn/documentation/latest/api/javadocs/overview-summary.html
samza/site/learn/documentation/latest/api/javadocs/overview-tree.html
samza/site/learn/documentation/latest/api/javadocs/serialized-form.html
samza/site/learn/documentation/latest/api/low-level-api.html
samza/site/learn/documentation/latest/api/programming-model.html
samza/site/learn/documentation/latest/connectors/eventhubs.html
samza/site/learn/documentation/latest/core-concepts/core-concepts.html
samza/site/learn/documentation/latest/index.html
samza/site/learn/documentation/latest/jobs/samza-configurations.html
samza/site/learn/documentation/latest/rest/javadocs/allclasses-frame.html
samza/site/learn/documentation/latest/rest/javadocs/allclasses-noframe.html
samza/site/learn/documentation/latest/rest/javadocs/constant-values.html
samza/site/learn/documentation/latest/rest/javadocs/deprecated-list.html
samza/site/learn/documentation/latest/rest/javadocs/help-doc.html
samza/site/learn/documentation/latest/rest/javadocs/index-all.html
samza/site/learn/documentation/latest/rest/javadocs/index.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/JobsClient.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/LocalStoreMonitor.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/LocalStoreMonitorConfig.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/LocalStoreMonitorFactory.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/LocalStoreMonitorMetrics.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/Monitor.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/MonitorConfig.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/MonitorFactory.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/MonitorLoader.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/SamzaMonitorService.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/ScheduledExecutorSchedulingProvider.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/SchedulingProvider.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/package-frame.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/package-summary.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/package-tree.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/SamzaRestApplication.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/SamzaRestConfig.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/SamzaRestService.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/model/Job.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/model/JobStatus.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/model/Partition.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/model/Task.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/model/package-frame.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/model/package-summary.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/model/package-tree.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/model/yarn/YarnApplicationInfo.YarnApplication.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/model/yarn/YarnApplicationInfo.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/model/yarn/package-frame.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/model/yarn/package-summary.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/model/yarn/package-tree.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/package-frame.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/package-summary.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/package-tree.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/proxy/installation/InstallationFinder.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/proxy/installation/InstallationRecord.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/proxy/installation/SimpleInstallationFinder.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/proxy/installation/package-frame.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/proxy/installation/package-summary.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/proxy/installation/package-tree.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/proxy/job/AbstractJobProxy.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/proxy/job/JobInstance.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/proxy/job/JobProxy.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/proxy/job/JobProxyFactory.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/proxy/job/JobStatusProvider.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/proxy/job/ScriptJobProxy.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/proxy/job/SimpleYarnJobProxy.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/proxy/job/SimpleYarnJobProxyFactory.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/proxy/job/YarnRestJobStatusProvider.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/proxy/job/package-frame.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/proxy/job/package-summary.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/proxy/job/package-tree.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/proxy/task/SamzaTaskProxy.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/proxy/task/SamzaTaskProxyFactory.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/proxy/task/TaskProxy.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/proxy/task/TaskProxyFactory.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/proxy/task/TaskResourceConfig.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/proxy/task/package-frame.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/proxy/task/package-summary.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/proxy/task/package-tree.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/resources/BaseResourceConfig.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/resources/DefaultResourceFactory.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/resources/JobsResource.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/resources/JobsResourceConfig.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/resources/ResourceConstants.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/resources/ResourceFactory.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/resources/Responses.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/resources/TasksResource.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/resources/YarnJobResourceConfig.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/resources/package-frame.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/resources/package-summary.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/resources/package-tree.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/script/ScriptOutputHandler.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/script/ScriptPathProvider.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/script/ScriptRunner.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/script/package-frame.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/script/package-summary.html
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/script/package-tree.html
samza/site/learn/documentation/latest/rest/javadocs/overview-frame.html
samza/site/learn/documentation/latest/rest/javadocs/overview-summary.html
samza/site/learn/documentation/latest/rest/javadocs/overview-tree.html
samza/site/learn/documentation/latest/rest/javadocs/serialized-form.html
samza/site/learn/documentation/latest/rest/monitors.html
samza/site/learn/tutorials/latest/remote-debugging-samza.html
samza/site/sitemap.xml
samza/site/startup/code-examples/latest/index.html
samza/site/startup/quick-start/latest/index.html
Modified: samza/site/blog/TEMPLATE.html
URL:
http://svn.apache.org/viewvc/samza/site/blog/TEMPLATE.html?rev=1855951&r1=1855950&r2=1855951&view=diff
==============================================================================
--- samza/site/blog/TEMPLATE.html (original)
+++ samza/site/blog/TEMPLATE.html Wed Mar 20 23:07:06 2019
@@ -523,7 +523,7 @@
<div class="breadcrumbs-list-container">
- <span>March 18, 2019</span>
+ <span>March 20, 2019</span>
<ul class="breadcrumbs-list">
<li class=""><a href="/news/">News</a></li>
Modified: samza/site/community/committers.html
URL:
http://svn.apache.org/viewvc/samza/site/community/committers.html?rev=1855951&r1=1855950&r2=1855951&view=diff
==============================================================================
--- samza/site/community/committers.html (original)
+++ samza/site/community/committers.html Wed Mar 20 23:07:06 2019
@@ -1365,6 +1365,142 @@
</li>
+
+
+ <li class="committer">
+
+ <span class="committer-image" title="Hai Lu">
+
+
+ <a href="https://github.com/lhaiesp"; target="_blank"
rel="nofollow"><span style="background-image:
url('https://github.com/lhaiesp.png?size=256');"></span></a>
+
+
+ </span>
+ <div class="committer-info">
+ <div class="committer-name">
+ Hai Lu
+ </div>
+ <div class="committer-roles">
+
+
+
+
+
+
+ <span>Committer</span>
+ </div>
+ <div class="committer-links">
+
+
+
+
+ <a href="https://www.linkedin.com/in/hai-lu-a9a80857";
class="committer-link" rel="nofollow" target="_blank">
+ <i class="committer-icon icon ion-logo-linkedin"></i>
+ </a>
+
+
+
+
+ </div>
+
+
+
+ </div>
+ </li>
+
+
+
+
+ <li class="committer">
+
+ <span class="committer-image" title="Aditya Toomula">
+
+
+ <a href="https://github.com/atoomula"; target="_blank"
rel="nofollow"><span style="background-image:
url('https://github.com/atoomula.png?size=256');"></span></a>
+
+
+ </span>
+ <div class="committer-info">
+ <div class="committer-name">
+ Aditya Toomula
+ </div>
+ <div class="committer-roles">
+
+
+
+
+
+
+ <span>Committer</span>
+ </div>
+ <div class="committer-links">
+
+
+
+
+ <a href="https://www.linkedin.com/in/aditya-toomula-210b961/";
class="committer-link" rel="nofollow" target="_blank">
+ <i class="committer-icon icon ion-logo-linkedin"></i>
+ </a>
+
+
+
+
+ </div>
+
+
+
+ </div>
+ </li>
+
+
+
+
+ <li class="committer">
+
+ <span class="committer-image" title="Shanthoosh Venkataraman">
+
+
+ <a href="https://github.com/shanthoosh"; target="_blank"
rel="nofollow"><span style="background-image:
url('https://github.com/shanthoosh.png?size=256');"></span></a>
+
+
+ </span>
+ <div class="committer-info">
+ <div class="committer-name">
+ Shanthoosh Venkataraman
+ </div>
+ <div class="committer-roles">
+
+
+
+
+
+
+ <span>Committer</span>
+ </div>
+ <div class="committer-links">
+
+
+
+
+ <a
href="https://www.linkedin.com/in/shanthoosh-venkataraman-13857222/";
class="committer-link" rel="nofollow" target="_blank">
+ <i class="committer-icon icon ion-logo-linkedin"></i>
+ </a>
+
+
+
+ <a href="https://twitter.com/santhoshvenkat"; class="committer-link"
rel="nofollow" target="_blank">
+ <i class="committer-icon icon ion-logo-twitter"></i>
+ </a>
+
+
+ </div>
+
+
+
+ </div>
+ </li>
+
+
</ul>
Modified: samza/site/contribute/tests.html
URL:
http://svn.apache.org/viewvc/samza/site/contribute/tests.html?rev=1855951&r1=1855950&r2=1855951&view=diff
==============================================================================
--- samza/site/contribute/tests.html (original)
+++ samza/site/contribute/tests.html Wed Mar 20 23:07:06 2019
@@ -539,7 +539,7 @@
<p>Samza’s unit tests can also be run against all supported permutations
of Scala and Java. </p>
<p>To run the tests against a specific combination:</p>
-<div class="highlight"><pre><code class="language-text"
data-lang="text"><span></span>./gradlew -PscalaVersion=2.10 -PyarnVersion=2.4.0
clean check
+<div class="highlight"><pre><code class="language-text"
data-lang="text"><span></span>./gradlew -PscalaSuffix=2.11 -PyarnVersion=2.4.0
clean check
</code></pre></div>
<p>To run Samza’s unit tests against all permutations, run:</p>
<div class="highlight"><pre><code class="language-text"
data-lang="text"><span></span>bin/check-all.sh
Added: samza/site/learn/documentation/latest/api/beam-api.html
URL:
http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/beam-api.html?rev=1855951&view=auto
==============================================================================
--- samza/site/learn/documentation/latest/api/beam-api.html (added)
+++ samza/site/learn/documentation/latest/api/beam-api.html Wed Mar 20 23:07:06
2019
@@ -0,0 +1,754 @@
+<!DOCTYPE html>
+<!--
+ Licensed to the Apache Software Foundation (ASF) under one or more
+ contributor license agreements. See the NOTICE file distributed with
+ this work for additional information regarding copyright ownership.
+ The ASF licenses this file to You under the Apache License, Version 2.0
+ (the "License"); you may not use this file except in compliance with
+ the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+-->
+<html lang="en">
+
+<head>
+ <meta http-equiv="X-UA-Compatible" content="IE=edge">
+ <meta name="viewport" content="width=device-width, initial-scale=1,
shrink-to-fit=no">
+ <meta charset="utf-8">
+ <title>Samza - Apache Beam API</title>
+ <link rel="apple-touch-icon-precomposed" sizes="57x57"
href="/img/favicon/apple-touch-icon-57x57.png" />
+ <link rel="apple-touch-icon-precomposed" sizes="114x114"
href="/img/favicon/apple-touch-icon-114x114.png" />
+ <link rel="apple-touch-icon-precomposed" sizes="72x72"
href="/img/favicon/apple-touch-icon-72x72.png" />
+ <link rel="apple-touch-icon-precomposed" sizes="144x144"
href="/img/favicon/apple-touch-icon-144x144.png" />
+ <link rel="apple-touch-icon-precomposed" sizes="60x60"
href="/img/favicon/apple-touch-icon-60x60.png" />
+ <link rel="apple-touch-icon-precomposed" sizes="120x120"
href="/img/favicon/apple-touch-icon-120x120.png" />
+ <link rel="apple-touch-icon-precomposed" sizes="76x76"
href="/img/favicon/apple-touch-icon-76x76.png" />
+ <link rel="apple-touch-icon-precomposed" sizes="152x152"
href="/img/favicon/apple-touch-icon-152x152.png" />
+ <link rel="icon" type="image/png" href="/img/favicon/favicon-196x196.png"
sizes="196x196" />
+ <link rel="icon" type="image/png" href="/img/favicon/favicon-96x96.png"
sizes="96x96" />
+ <link rel="icon" type="image/png" href="/img/favicon/favicon-32x32.png"
sizes="32x32" />
+ <link rel="icon" type="image/png" href="/img/favicon/favicon-16x16.png"
sizes="16x16" />
+ <link rel="icon" type="image/png" href="/img/favicon/favicon-128.png"
sizes="128x128" />
+ <meta name="application-name" content="https://samza.apache.org"; />
+ <meta name="msapplication-TileColor" content="#FFFFFF" />
+ <meta name="msapplication-TileImage"
content="/img/favicon/mstile-144x144.png" />
+ <meta name="msapplication-square70x70logo"
content="/img/favicon/mstile-70x70.png" />
+ <meta name="msapplication-square150x150logo"
content="/img/favicon/mstile-150x150.png" />
+ <meta name="msapplication-wide310x150logo"
content="/img/favicon/mstile-310x150.png" />
+ <meta name="msapplication-square310x310logo"
content="/img/favicon/mstile-310x310.png" />
+ <link href="/css/ionicons.min.css" rel="stylesheet">
+ <link href="/css/google-fonts.css" rel="stylesheet">
+ <link href="/css/syntax.css" rel="stylesheet"/>
+ <link rel="stylesheet" href="/css/main.new.css" />
+</head>
+
+<body class="page">
+ <!--
+ Licensed to the Apache Software Foundation (ASF) under one or more
+ contributor license agreements. See the NOTICE file distributed with
+ this work for additional information regarding copyright ownership.
+ The ASF licenses this file to You under the Apache License, Version 2.0
+ (the "License"); you may not use this file except in compliance with
+ the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+-->
+<div class="main-navigation" data-plugin="menu">
+ <div class="main-navigation__toggle" data-menu-closed>
+ <i class="icon ion-md-menu"></i>
+ </div>
+ <div class="main-navigation__toggle main-navigation__toggle--opened"
data-menu-opened>
+ <i class="icon ion-md-close"></i>
+ </div>
+ <div class="main-navigation__inner">
+ <div class="main-navigation__logo">
+ <a href="/">
+ <img class="main-navigation__logo-img" src="/img/samza-logo.png"
srcset="/img/samza-logo.png 1x, /img/samza-l...@2x.png 2x"
+ alt="Samza Logo" />
+ </a>
+ </div>
+ <div class="main-navigation__items" data-menu-opened>
+ <a class="main-navigation__item" href="/">Home</a>
+ <a class="main-navigation__item"
href="/learn/documentation/latest/core-concepts/core-concepts.html">Docs</a>
+ <a class="main-navigation__item" href="/powered-by/">Powered By</a>
+ <a class="main-navigation__item" href="/startup/download/">Downloads</a>
+ <a class="main-navigation__item" href="/blog/">Blog</a>
+ <div class="main-navigation__item main-navigation__item--group">
+ <div class="main-navigation__item-group-title">
+ Community
+ <i class="icon ion-md-arrow-dropdown"></i>
+ </div>
+ <div class="main-navigation__item-group-list">
+ <a class="main-navigation__item"
href="/community/contact-us.html">Contact Us</a>
+ <a class="main-navigation__item"
href="/contribute/contributors-corner.html">Contributor's Corner</a>
+ <a class="main-navigation__item"
href="/community/committers.html">PMC Members and committers</a>
+ <a class="main-navigation__item" href="/meetups/">Talks and
Meetups</a>
+ </div>
+ </div>
+ </div>
+ </div>
+</div>
+
+ <div class="container">
+ <div class="container__toggle">
+ <i class="icon ion-md-arrow-dropleft-circle
container__toggle-icon"></i>
+ <i class="icon ion-md-arrow-dropright-circle container__toggle-icon
container__toggle-icon--opened"></i>
+ </div>
+
+ <!-- There is only one menu, but made it as a no-output collection to
grab data only -->
+
+ <!--
+ Licensed to the Apache Software Foundation (ASF) under one or more
+ contributor license agreements. See the NOTICE file distributed with
+ this work for additional information regarding copyright ownership.
+ The ASF licenses this file to You under the Apache License, Version 2.0
+ (the "License"); you may not use this file except in compliance with
+ the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+-->
+
+
+<div class="side-navigation">
+
+
+
+
+
+
+ <!-- Start Group -->
+
+ <div class="side-navigation__group side-navigation__group--has-nested"
data-plugin="sub-menu"
data-sub-menu-show-class="side-navigation__group--has-nested-visible">
+
+
+ <!-- Make menu_title, and start items group if needed -->
+
+ <div class="side-navigation__group-title">
+ <i class="side-navigation__group-title-icon icon
ion-md-arrow-dropdown"></i>
+ Getting Started
+ </div>
+ <div class="side-navigation__group-items " data-sub-menu >
+
+
+ <!-- Handle sub navigation items from data -->
+
+
+
+ <a class="side-navigation__group-item" data-match-active=""
href="/startup/quick-start/latest/">QuickStart</a>
+
+
+ <a class="side-navigation__group-item" data-match-active=""
href="/startup/code-examples/latest/">Code Examples</a>
+
+
+
+
+ <!-- Handle sub nagivation from site collections -->
+
+
+ <!-- Close sub nav group -->
+
+ </div>
+
+
+ <!-- Close menu group -->
+ </div>
+
+
+
+
+
+
+ <!-- Start Group -->
+
+ <div class="side-navigation__group side-navigation__group--has-nested"
data-plugin="sub-menu"
data-sub-menu-show-class="side-navigation__group--has-nested-visible">
+
+
+ <!-- Make menu_title, and start items group if needed -->
+
+ <div class="side-navigation__group-title">
+ <i class="side-navigation__group-title-icon icon
ion-md-arrow-dropdown"></i>
+ Documentation
+ </div>
+ <div class="side-navigation__group-items
side-navigation__group-has-submenus" data-sub-menu
data-documentation="/learn/documentation/latest/">
+
+
+ <!-- Handle sub navigation items from data -->
+
+
+ <!-- Handle sub nagivation from site collections -->
+
+
+ <!-- Close sub nav group -->
+
+ </div>
+
+
+ <!-- Close menu group -->
+ </div>
+
+
+
+
+
+
+ <!-- Start Group -->
+
+ <div class="side-navigation__group side-navigation__group--has-nested"
data-plugin="sub-menu"
data-sub-menu-show-class="side-navigation__group--has-nested-visible">
+
+
+ <!-- Make menu_title, and start items group if needed -->
+
+ <div class="side-navigation__group-title">
+ <i class="side-navigation__group-title-icon icon
ion-md-arrow-dropdown"></i>
+ Releases
+ </div>
+ <div class="side-navigation__group-items " data-sub-menu >
+
+
+ <!-- Handle sub navigation items from data -->
+
+
+
+ <a class="side-navigation__group-item" data-match-active=""
href="/releases/1.0.0">1.0.0</a>
+
+
+ <a class="side-navigation__group-item" data-match-active=""
href="/releases/0.14">0.14</a>
+
+
+ <a class="side-navigation__group-item" data-match-active=""
href="/releases/0.13">0.13</a>
+
+
+ <a class="side-navigation__group-item" data-match-active=""
href="/releases/0.12">0.12</a>
+
+
+ <a class="side-navigation__group-item" data-match-active=""
href="/releases/0.11">0.11</a>
+
+
+ <a class="side-navigation__group-item" data-match-active=""
href="/releases/0.10">0.10</a>
+
+
+
+
+ <!-- Handle sub nagivation from site collections -->
+
+
+ <!-- Close sub nav group -->
+
+ </div>
+
+
+ <!-- Close menu group -->
+ </div>
+
+
+
+
+
+
+ <!-- Start Group -->
+
+ <div class="side-navigation__group">
+
+
+ <!-- Make menu_title, and start items group if needed -->
+
+ <a class="side-navigation__group-title" data-plugin="top-menu"
data-match-active="" href="/blog/">
+ Blog
+ </a>
+
+
+ <!-- Handle sub navigation items from data -->
+
+
+ <!-- Handle sub nagivation from site collections -->
+
+
+ <!-- Close sub nav group -->
+
+
+ <!-- Close menu group -->
+ </div>
+
+
+
+
+
+
+ <!-- Start Group -->
+
+ <div class="side-navigation__group side-navigation__group--has-nested"
data-plugin="sub-menu"
data-sub-menu-show-class="side-navigation__group--has-nested-visible">
+
+
+ <!-- Make menu_title, and start items group if needed -->
+
+ <div class="side-navigation__group-title">
+ <i class="side-navigation__group-title-icon icon
ion-md-arrow-dropdown"></i>
+ Community
+ </div>
+ <div class="side-navigation__group-items " data-sub-menu >
+
+
+ <!-- Handle sub navigation items from data -->
+
+
+
+ <a class="side-navigation__group-item" data-match-active=""
href="/community/contact-us.html">Contact Us</a>
+
+
+ <a class="side-navigation__group-item" data-match-active=""
href="/contribute/contributors-corner.html">Contributor's Corner</a>
+
+
+ <a class="side-navigation__group-item" data-match-active=""
href="/contribute/enhancement-proposal.html">Enhancement Proposal</a>
+
+
+ <a class="side-navigation__group-item" data-match-active=""
href="/community/committers.html">PMC members & Committers</a>
+
+
+ <a class="side-navigation__group-item" data-match-active=""
href="/meetups/">Talks and Meetups</a>
+
+
+
+
+ <!-- Handle sub nagivation from site collections -->
+
+
+ <!-- Close sub nav group -->
+
+ </div>
+
+
+ <!-- Close menu group -->
+ </div>
+
+
+
+
+
+
+ <!-- Start Group -->
+
+ <div class="side-navigation__group side-navigation__group--has-nested"
data-plugin="sub-menu"
data-sub-menu-show-class="side-navigation__group--has-nested-visible">
+
+
+ <!-- Make menu_title, and start items group if needed -->
+
+ <div class="side-navigation__group-title">
+ <i class="side-navigation__group-title-icon icon
ion-md-arrow-dropdown"></i>
+ Case Studies
+ </div>
+ <div class="side-navigation__group-items " data-sub-menu >
+
+
+ <!-- Handle sub navigation items from data -->
+
+
+
+ <a class="side-navigation__group-item" data-match-active="exact"
href="/case-studies/">View All</a>
+
+
+ <hr>
+
+
+
+
+ <!-- Handle sub nagivation from site collections -->
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ <a class="side-navigation__group-item" href="/case-studies/ebay"
data-match-active="">eBay</a>
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ <a class="side-navigation__group-item" href="/case-studies/tripadvisor"
data-match-active="">TripAdvisor</a>
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ <a class="side-navigation__group-item" href="/case-studies/slack"
data-match-active="">Slack</a>
+
+
+
+
+
+
+
+
+
+
+
+
+
+ <a class="side-navigation__group-item" href="/case-studies/optimizely"
data-match-active="">Optimizely</a>
+
+
+
+
+
+
+
+
+
+
+
+
+
+ <a class="side-navigation__group-item" href="/case-studies/redfin"
data-match-active="">Redfin</a>
+
+
+
+
+
+
+
+
+
+
+
+
+
+ <a class="side-navigation__group-item" href="/case-studies/linkedin"
data-match-active="">LinkedIn</a>
+
+
+
+
+
+
+
+
+
+
+ <!-- Close sub nav group -->
+
+ </div>
+
+
+ <!-- Close menu group -->
+ </div>
+
+
+
+</div>
+
+
+
+ <div class="section">
+ <div class="content">
+
+ <h2>Apache Beam API</h2>
+
+
+
+
+ <div class="releases-list-container">
+
+ <span>Releases</span>
+
+ <ul class="releases-list" data-releases-list>
+ <li class="hide"><a
href="/learn/documentation/latest/api/beam-api">latest</a></li>
+
+
+
+
+ <li class="hide"><a
href="/learn/documentation/0.14/api/beam-api">0.14</a></li>
+
+
+
+ <li class="hide"><a
href="/learn/documentation/0.13/api/beam-api">0.13</a></li>
+
+
+
+ <li class="hide"><a
href="/learn/documentation/0.12/api/beam-api">0.12</a></li>
+
+
+
+ <li class="hide"><a
href="/learn/documentation/0.11/api/beam-api">0.11</a></li>
+
+
+
+ <li class="hide"><a
href="/learn/documentation/0.10/api/beam-api">0.10</a></li>
+
+
+
+ <li class="hide"><a
href="/learn/documentation/1.0/api/beam-api">1.0</a></li>
+
+
+
+ <li class="hide"><a
href="/learn/documentation/0.9/api/beam-api">0.9</a></li>
+
+
+
+ <li class="hide"><a
href="/learn/documentation/0.8/api/beam-api">0.8</a></li>
+
+
+
+ <li class="hide"><a
href="/learn/documentation/0.7/api/beam-api">0.7</a></li>
+
+
+
+ <li class="hide"><a
href="/learn/documentation/0.7.0/api/beam-api">0.7.0</a></li>
+
+
+
+ <li class="hide"><a
href="/learn/documentation/-1000/api/beam-api">-1000</a></li>
+
+
+
+ </ul>
+
+ </div>
+
+ <hr class="releases-list-divider">
+
+
+
+ <!--
+ Licensed to the Apache Software Foundation (ASF) under one or more
+ contributor license agreements. See the NOTICE file distributed with
+ this work for additional information regarding copyright ownership.
+ The ASF licenses this file to You under the Apache License, Version 2.0
+ (the "License"); you may not use this file except in compliance with
+ the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+-->
+
+<h3 id="table-of-contents">Table Of Contents</h3>
+
+<ul>
+<li><a href="#introduction">Introduction</a></li>
+<li><a href="#basic-concepts">Basic Concepts</a></li>
+<li><a href="#apache-beam---a-samza%E2%80%99s-perspective">Apache Beam - A
Samzaâs Perspective</a></li>
+</ul>
+
+<h3 id="introduction">Introduction</h3>
+
+<p>Apache Beam brings an easy-to-usen but powerful API and model for
state-of-art stream and batch data processing with portability across a variety
of languages. The Beam API and model has the following characteristics:</p>
+
+<ul>
+<li><p><em>Simple constructs, powerful semantics</em>: the whole beam API can
be simply described by a <code>Pipeline</code> object, which captures all your
data processing steps from input to output. Beam SDK supports over <a
href="https://beam.apache.org/documentation/io/built-in/";>20 data IOs</a>, and
data transformations from simple <a
href="https://beam.apache.org/releases/javadoc/2.11.0/org/apache/beam/sdk/transforms/MapElements.html";>Map</a>
to complex <a
href="https://beam.apache.org/releases/javadoc/2.11.0/index.html?org/apache/beam/sdk/transforms/Combine.html";>Combines
and Joins</a>.</p></li>
+<li><p><em>Strong consistency via event-time</em>: Beam provides advanced <a
href="https://beam.apache.org/documentation/programming-guide/#watermarks-and-late-data";>event-time
support</a> so you can perform windowing and aggregations based on when the
events happen, instead of when they arrive. The event-time mechanism improves
the accuracy of processing results, and guarantees repeatability in results
when reprocessing the same data set.</p></li>
+<li><p><em>Comprehensive stream processing semantics</em>: Beam supports an
up-to-date stream processing model, including <a
href="https://beam.apache.org/documentation/programming-guide/#windowing";>tumbling/sliding/session
windows</a>, joins and aggregations. It provides <a
href="https://beam.apache.org/documentation/programming-guide/#triggers";>triggers</a>
based on conditions of early and late firings, and late arrival handling with
accumulation mode and allowed lateness.</p></li>
+<li><p><em>Portability with multiple programming languages</em>: Beam supports
a consistent API in multiple languages, including <a
href="https://beam.apache.org/roadmap/portability/";>Java, Python and Go</a>.
This allows you to leverage the rich ecosystem built for different languages,
e.g. ML libs for Python.</p></li>
+</ul>
+
+<h3 id="basic-concepts">Basic Concepts</h3>
+
+<p>Let’s walk through the WordCount example to illustrate the Beam basic
concepts. A Beam program often starts by creating a <a
href="https://beam.apache.org/releases/javadoc/2.11.0/org/apache/beam/sdk/Pipeline.html";>Pipeline</a>
object in your <code>main()</code> function.</p>
+
+<figure class="highlight"><pre><code class="language-java"
data-lang="java"><span></span><span class="c1">// Start by defining the options
for the pipeline.</span>
+<span class="n">PipelineOptions</span> <span class="n">options</span> <span
class="o">=</span> <span class="n">PipelineOptionsFactory</span><span
class="o">.</span><span class="na">create</span><span class="o">();</span>
+
+<span class="c1">// Then create the pipeline.</span>
+<span class="n">Pipeline</span> <span class="n">p</span> <span
class="o">=</span> <span class="n">Pipeline</span><span class="o">.</span><span
class="na">create</span><span class="o">(</span><span
class="n">options</span><span class="o">);</span></code></pre></figure>
+
+<p>The <code>PipelineOptions</code> supported by SamzaRunner is documented in
detail <a
href="https://beam.apache.org/documentation/runners/samza/";>here</a>.</p>
+
+<p>Let’s apply the first data transform to read from a text file using
<a
href="https://beam.apache.org/releases/javadoc/2.11.0/org/apache/beam/sdk/io/TextIO.html";>TextIO.read()</a>:</p>
+
+<figure class="highlight"><pre><code class="language-java"
data-lang="java"><span></span><span class="n">PCollection</span><span
class="o"><</span><span class="n">String</span><span class="o">></span>
<span class="n">lines</span> <span class="o">=</span> <span
class="n">p</span><span class="o">.</span><span class="na">apply</span><span
class="o">(</span>
+ <span class="s">"ReadLines"</span><span class="o">,</span> <span
class="n">TextIO</span><span class="o">.</span><span
class="na">read</span><span class="o">().</span><span
class="na">from</span><span class="o">(</span><span
class="s">"/path/to/inputData"</span><span
class="o">));</span></code></pre></figure>
+
+<p>To break down each line into words, you can use a <a
href="https://beam.apache.org/releases/javadoc/2.11.0/org/apache/beam/sdk/transforms/FlatMapElements.html";>FlatMap</a>:</p>
+
+<figure class="highlight"><pre><code class="language-java"
data-lang="java"><span></span><span class="n">PCollection</span><span
class="o"><</span><span class="n">String</span><span class="o">></span>
<span class="n">words</span> <span class="o">=</span> <span
class="n">lines</span><span class="o">.</span><span
class="na">apply</span><span class="o">(</span>
+ <span class="n">FlatMapElements</span><span class="o">.</span><span
class="na">into</span><span class="o">(</span><span
class="n">TypeDescriptors</span><span class="o">.</span><span
class="na">strings</span><span class="o">())</span>
+ <span class="o">.</span><span class="na">via</span><span
class="o">((</span><span class="n">String</span> <span
class="n">word</span><span class="o">)</span> <span class="o">-></span>
<span class="n">Arrays</span><span class="o">.</span><span
class="na">asList</span><span class="o">(</span><span
class="n">word</span><span class="o">.</span><span class="na">split</span><span
class="o">(</span><span class="s">"\\W+"</span><span
class="o">))));</span></code></pre></figure>
+
+<p>Beam provides a build-in transform <a
href="https://beam.apache.org/releases/javadoc/2.11.0/org/apache/beam/sdk/transforms/Count.html";>Count.perElement</a>
to count the number of elements based on each value. Let’s use it here
to count the words:</p>
+
+<figure class="highlight"><pre><code class="language-java"
data-lang="java"><span></span><span class="n">PCollection</span><span
class="o"><</span><span class="n">KV</span><span class="o"><</span><span
class="n">String</span><span class="o">,</span> <span
class="n">Long</span><span class="o">>></span> <span
class="n">counts</span> <span class="o">=</span> <span
class="n">pipeline</span><span class="o">.</span><span
class="na">apply</span><span class="o">(</span><span
class="n">Count</span><span class="o">.</span><span
class="na">perElement</span><span class="o">());</span></code></pre></figure>
+
+<p>Finally we format the counts into strings and write to a file using
<code>TextIO.write()</code>:</p>
+
+<figure class="highlight"><pre><code class="language-java"
data-lang="java"><span></span><span class="n">counts</span><span
class="o">.</span><span class="na">apply</span><span class="o">(</span><span
class="n">ToString</span><span class="o">.</span><span
class="na">kvs</span><span class="o">())</span>
+ <span class="o">.</span><span class="na">apply</span><span
class="o">(</span><span class="n">TextIO</span><span class="o">.</span><span
class="na">write</span><span class="o">().</span><span
class="na">to</span><span class="o">(</span><span
class="s">"/path/to/output"</span><span class="o">).</span><span
class="na">withoutSharding</span><span
class="o">());</span></code></pre></figure>
+
+<p>To run your pipeline and wait for the results, just do:</p>
+
+<figure class="highlight"><pre><code class="language-java"
data-lang="java"><span></span><span class="n">pipeline</span><span
class="o">.</span><span class="na">run</span><span class="o">().</span><span
class="na">waitUntilFinish</span><span
class="o">();</span></code></pre></figure>
+
+<p>Or you can run your pipeline asynchronously, e.g. when you submit it to a
remote cluster:</p>
+
+<figure class="highlight"><pre><code class="language-java"
data-lang="java"><span></span><span class="n">pipeline</span><span
class="o">.</span><span class="na">run</span><span
class="o">();</span></code></pre></figure>
+
+<p>To run this Beam program with Samza, you can simply provide
“–runner=SamzaRunner” as a program argument. You can follow
our <a href="/startup/quick-start/latest/beam.html">quick start</a> to set up
your project and run different examples. For more details on writing the Beam
program, please refer the <a
href="https://beam.apache.org/documentation/programming-guide/";>Beam
programming guide</a>.</p>
+
+<h3 id="apache-beam-a-samza-s-perspective">Apache Beam - A Samzaâs
Perspective</h3>
+
+<p>The goal of Samza is to provide large-scale streaming processing
capabilities with first-class state support. This does not contradict with
Beam. In fact, while Samza lays out a solid foundation for large-scale stateful
stream processing, Beam adds the cutting-edge stream processing API and model
on top of it. The Beam API and model allows further optimization in the Samza
platform, including multi-stage distributed computation and parallel processing
on the per-key basis. The performance enhancements from these optimizations
will benefit both Samza and its users. Samza can also further improve Beam
model by providing various use cases. We firmly believe Samza will benefit from
collaborating with Beam.</p>
+
+
+ </div>
+ </div>
+
+ </div>
+
+
+ <!-- footer starts here -->
+
+ <!--
+ Licensed to the Apache Software Foundation (ASF) under one or more
+ contributor license agreements. See the NOTICE file distributed with
+ this work for additional information regarding copyright ownership.
+ The ASF licenses this file to You under the Apache License, Version 2.0
+ (the "License"); you may not use this file except in compliance with
+ the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+-->
+
+<footer>
+ <div class="footer-inner">
+ <div class="side-by-side">
+ <div>
+ <div class="footer__heading">Learn More</div>
+ <div class="footer__items">
+ <a class="footer__item" href="/meetups/">Meetups</a>
+ <a class="footer__item" href="/blog/">Blog</a>
+ <a class="footer__item"
href="/learn/documentation/latest/introduction/background.html">About</a>
+ </div>
+ </div>
+ <div>
+ <div class="footer__heading">Community</div>
+ <div class="footer__items">
+ <a class="footer__item" href="/community/contact-us.html">Contact
Us</a>
+ <a class="footer__item"
href="/contribute/contributors-corner.html">Contributors' Corner</a>
+ <a class="footer__item" href="/community/committers.html">PMC
members and committers</a>
+ <a class="footer__item" href="/powered-by/">Powered By</a>
+ </div>
+ </div>
+
+ <div>
+ <div class="quick-links">
+ <a class="quick-link" href="/startup/download" target="_blank">
+ <i class="icon ion-md-download"></i>
+ </a>
+ <a class="quick-link"
href="https://git-wip-us.apache.org/repos/asf?p=samza.git;a=tree";
target="_blank">
+ <i class="icon ion-md-code"></i>
+ </a>
+ <a class="quick-link" href="https://twitter.com/samzastream";
target="_blank">
+ <i class="icon ion-logo-twitter"></i>
+ </a>
+ </div>
+
+ <p>
+ <script>document.write(new Date().getFullYear());</script> ©
samza.apache.org</p>
+ </div>
+
+ </div>
+ </div>
+
+</footer>
+
+
+<script>
+ var tryFile = function (url, cb) {
+ var myRequest = new Request(url);
+ fetch(myRequest).then((response, cb) => {
+ console.log(response.status); // returns 200
+ cb(response.status != 404);
+ });
+ }
+
+ tryFile(window.location.pathname, function (status) {
+ // do something with the status
+ console.log(status);
+ });
+</script>
+
+
+<!-- Google Analytics -->
+<script>
+ (function (i, s, o, g, r, a, m) {
+ i['GoogleAnalyticsObject'] = r; i[r] = i[r] || function () {
+ (i[r].q = i[r].q || []).push(arguments)
+ }, i[r].l = 1 * new Date(); a = s.createElement(o),
+ m = s.getElementsByTagName(o)[0]; a.async = 1; a.src = g;
m.parentNode.insertBefore(a, m)
+ })(window, document, 'script', '//www.google-analytics.com/analytics.js',
'ga');
+
+ ga('create', 'UA-43122768-1', 'apache.org');
+ ga('send', 'pageview');
+
+</script>
+<script src="/js/main.new.js"></script>
+
+</body>
+
+</html>
\ No newline at end of file
Modified:
samza/site/learn/documentation/latest/api/javadocs/allclasses-frame.html
URL:
http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/allclasses-frame.html?rev=1855951&r1=1855950&r2=1855951&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/allclasses-frame.html
(original)
+++ samza/site/learn/documentation/latest/api/javadocs/allclasses-frame.html
Wed Mar 20 23:07:06 2019
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_181) on Fri Feb 01 11:33:47 PST 2019 -->
+<!-- Generated by javadoc (1.8.0_202) on Mon Mar 18 23:22:04 PDT 2019 -->
<title>All Classes (samza-api 1.0.1-SNAPSHOT API)</title>
-<meta name="date" content="2019-02-01">
+<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>
@@ -71,7 +71,6 @@
<li><a href="org/apache/samza/system/descriptors/GenericInputDescriptor.html"
title="class in org.apache.samza.system.descriptors"
target="classFrame">GenericInputDescriptor</a></li>
<li><a href="org/apache/samza/system/descriptors/GenericOutputDescriptor.html"
title="class in org.apache.samza.system.descriptors"
target="classFrame">GenericOutputDescriptor</a></li>
<li><a href="org/apache/samza/system/descriptors/GenericSystemDescriptor.html"
title="class in org.apache.samza.system.descriptors"
target="classFrame">GenericSystemDescriptor</a></li>
-<li><a href="org/apache/samza/container/grouper/stream/GrouperContext.html"
title="class in org.apache.samza.container.grouper.stream"
target="classFrame">GrouperContext</a></li>
<li><a
href="org/apache/samza/table/descriptors/GuavaCacheTableDescriptor.html"
title="class in org.apache.samza.table.descriptors"
target="classFrame">GuavaCacheTableDescriptor</a></li>
<li><a href="org/apache/samza/table/descriptors/HybridTableDescriptor.html"
title="class in org.apache.samza.table.descriptors"
target="classFrame">HybridTableDescriptor</a></li>
<li><a href="org/apache/samza/system/IncomingMessageEnvelope.html"
title="class in org.apache.samza.system"
target="classFrame">IncomingMessageEnvelope</a></li>
@@ -212,6 +211,7 @@
<li><a href="org/apache/samza/system/SystemStreamPartitionMatcher.html"
title="interface in org.apache.samza.system" target="classFrame"><span
class="interfaceName">SystemStreamPartitionMatcher</span></a></li>
<li><a href="org/apache/samza/table/Table.html" title="interface in
org.apache.samza.table" target="classFrame"><span
class="interfaceName">Table</span></a></li>
<li><a href="org/apache/samza/table/descriptors/TableDescriptor.html"
title="interface in org.apache.samza.table.descriptors"
target="classFrame"><span class="interfaceName">TableDescriptor</span></a></li>
+<li><a href="org/apache/samza/table/remote/TablePart.html" title="interface in
org.apache.samza.table.remote" target="classFrame"><span
class="interfaceName">TablePart</span></a></li>
<li><a href="org/apache/samza/table/TableProvider.html" title="interface in
org.apache.samza.table" target="classFrame"><span
class="interfaceName">TableProvider</span></a></li>
<li><a href="org/apache/samza/table/TableProviderFactory.html"
title="interface in org.apache.samza.table" target="classFrame"><span
class="interfaceName">TableProviderFactory</span></a></li>
<li><a href="org/apache/samza/table/remote/TableRateLimiter.html" title="class
in org.apache.samza.table.remote" target="classFrame">TableRateLimiter</a></li>
