Download samza-api.jar - @org.apache.samza

Table Of Contents

Latest Version
All Versions
View Java Class Source Code in JAR file

Latest Version

Download org.apache.samza : samza-api JAR file - Latest Versions:

Latest Stable: 1.8.0.jar

All Versions

Download org.apache.samza : samza-api JAR file - All Versions:

Version	Vulnerabilities	Size	Updated
1.8.x	samza-api-1.8.0.jar		248.99 KB	Jan 13, 2023
1.7.x	samza-api-1.7.0.jar		244.35 KB	Mar 09, 2022
1.6.x	samza-api-1.6.0.jar		228.51 KB	Jan 07, 2021
1.5.x	samza-api-1.5.1.jar		224.40 KB	Aug 19, 2020
samza-api-1.5.0.jar		223.47 KB	Jun 09, 2020
1.4.x	samza-api-1.4.0.jar		223.46 KB	Mar 11, 2020
1.3.x	samza-api-1.3.1.jar		217.19 KB	Feb 13, 2020
samza-api-1.3.0.jar		217 KB	Nov 27, 2019
1.2.x	samza-api-1.2.0.jar		209.67 KB	Jun 06, 2019
1.1.x	samza-api-1.1.0.jar		204.91 KB	Mar 09, 2019
1.0.x	samza-api-1.0.0.jar		158.77 KB	Nov 01, 2018
0.14.x	samza-api-0.14.1.jar		125.18 KB	May 18, 2018
samza-api-0.14.0.jar		117.01 KB	Dec 21, 2017
0.13.x	samza-api-0.13.1.jar		94.44 KB	Aug 24, 2017
samza-api-0.13.0.jar		93.67 KB	Jun 05, 2017
0.12.x	samza-api-0.12.0.jar		85.72 KB	Feb 06, 2017
0.11.x	samza-api-0.11.0.jar		62.65 KB	Oct 10, 2016
0.10.x	samza-api-0.10.1.jar		61.98 KB	Jul 30, 2016
samza-api-0.10.0.jar		55.31 KB	Dec 08, 2015
0.9.x	samza-api-0.9.1.jar		53.37 KB	Jun 28, 2015
samza-api-0.9.0.jar		53.31 KB	Mar 24, 2015
0.8.x	samza-api-0.8.0.jar		53.44 KB	Nov 25, 2014
0.7.x	samza-api-0.7.0.jar		45.99 KB	Jun 27, 2014

Version

Vulnerabilities

Size

Updated

1.8.x

samza-api-1.8.0.jar

248.99 KB

Jan 13, 2023

1.7.x

samza-api-1.7.0.jar

244.35 KB

Mar 09, 2022

1.6.x

samza-api-1.6.0.jar

228.51 KB

Jan 07, 2021

1.5.x

samza-api-1.5.1.jar

224.40 KB

Aug 19, 2020

samza-api-1.5.0.jar

223.47 KB

Jun 09, 2020

1.4.x

samza-api-1.4.0.jar

223.46 KB

Mar 11, 2020

1.3.x

samza-api-1.3.1.jar

217.19 KB

Feb 13, 2020

samza-api-1.3.0.jar

217 KB

Nov 27, 2019

1.2.x

samza-api-1.2.0.jar

209.67 KB

Jun 06, 2019

1.1.x

samza-api-1.1.0.jar

204.91 KB

Mar 09, 2019

1.0.x

samza-api-1.0.0.jar

158.77 KB

Nov 01, 2018

0.14.x

samza-api-0.14.1.jar

125.18 KB

May 18, 2018

samza-api-0.14.0.jar

117.01 KB

Dec 21, 2017

0.13.x

samza-api-0.13.1.jar

94.44 KB

Aug 24, 2017

samza-api-0.13.0.jar

93.67 KB

Jun 05, 2017

0.12.x

samza-api-0.12.0.jar

85.72 KB

Feb 06, 2017

0.11.x

samza-api-0.11.0.jar

62.65 KB

Oct 10, 2016

0.10.x

samza-api-0.10.1.jar

61.98 KB

Jul 30, 2016

samza-api-0.10.0.jar

55.31 KB

Dec 08, 2015

0.9.x

samza-api-0.9.1.jar

53.37 KB

Jun 28, 2015

samza-api-0.9.0.jar

53.31 KB

Mar 24, 2015

0.8.x

samza-api-0.8.0.jar

53.44 KB

Nov 25, 2014

0.7.x

samza-api-0.7.0.jar

45.99 KB

Jun 27, 2014

View Java Class Source Code in JAR file

Download JD-GUI to open JAR file and explore Java source code file (.class .java)
Click menu "File → Open File..." or just drag-and-drop the JAR file in the JD-GUI window samza-api-1.8.0.jar file.
Once you open a JAR file, all the java classes in the JAR file will be displayed.

org.apache.samza.table

├─ org.apache.samza.table.AsyncReadWriteUpdateTable.class - [JAR]

├─ org.apache.samza.table.ReadWriteTable.class - [JAR]

├─ org.apache.samza.table.ReadWriteUpdateTable.class - [JAR]

├─ org.apache.samza.table.RecordNotFoundException.class - [JAR]

├─ org.apache.samza.table.Table.class - [JAR]

├─ org.apache.samza.table.TableProvider.class - [JAR]

├─ org.apache.samza.table.TableProviderFactory.class - [JAR]

org.apache.samza.operators

├─ org.apache.samza.operators.KV.class - [JAR]

├─ org.apache.samza.operators.MessageStream.class - [JAR]

├─ org.apache.samza.operators.OutputStream.class - [JAR]

├─ org.apache.samza.operators.Scheduler.class - [JAR]

├─ org.apache.samza.operators.UpdateMessage.class - [JAR]

├─ org.apache.samza.operators.UpdateOptions.class - [JAR]

org.apache.samza.system

├─ org.apache.samza.system.BoundedSSPIterator.class - [JAR]

├─ org.apache.samza.system.ChangelogSSPIterator.class - [JAR]

├─ org.apache.samza.system.ControlMessage.class - [JAR]

├─ org.apache.samza.system.DrainMessage.class - [JAR]

├─ org.apache.samza.system.EndOfStreamMessage.class - [JAR]

├─ org.apache.samza.system.IncomingMessageEnvelope.class - [JAR]

├─ org.apache.samza.system.MessageType.class - [JAR]

├─ org.apache.samza.system.OutgoingMessageEnvelope.class - [JAR]

├─ org.apache.samza.system.StreamSpec.class - [JAR]

├─ org.apache.samza.system.StreamValidationException.class - [JAR]

├─ org.apache.samza.system.SystemAdmin.class - [JAR]

├─ org.apache.samza.system.SystemConsumer.class - [JAR]

├─ org.apache.samza.system.SystemFactory.class - [JAR]

├─ org.apache.samza.system.SystemProducer.class - [JAR]

├─ org.apache.samza.system.SystemProducerException.class - [JAR]

├─ org.apache.samza.system.SystemStream.class - [JAR]

├─ org.apache.samza.system.SystemStreamMetadata.class - [JAR]

├─ org.apache.samza.system.SystemStreamPartition.class - [JAR]

├─ org.apache.samza.system.SystemStreamPartitionIterator.class - [JAR]

├─ org.apache.samza.system.SystemStreamPartitionMatcher.class - [JAR]

├─ org.apache.samza.system.WatermarkMessage.class - [JAR]

org.apache.samza

├─ org.apache.samza.Partition.class - [JAR]

├─ org.apache.samza.SamzaException.class - [JAR]

org.apache.samza.checkpoint

├─ org.apache.samza.checkpoint.Checkpoint.class - [JAR]

├─ org.apache.samza.checkpoint.CheckpointId.class - [JAR]

├─ org.apache.samza.checkpoint.CheckpointListener.class - [JAR]

├─ org.apache.samza.checkpoint.CheckpointManager.class - [JAR]

├─ org.apache.samza.checkpoint.CheckpointManagerFactory.class - [JAR]

├─ org.apache.samza.checkpoint.CheckpointV1.class - [JAR]

├─ org.apache.samza.checkpoint.CheckpointV2.class - [JAR]

org.apache.samza.context

├─ org.apache.samza.context.ApplicationContainerContext.class - [JAR]

├─ org.apache.samza.context.ApplicationContainerContextFactory.class - [JAR]

├─ org.apache.samza.context.ApplicationTaskContext.class - [JAR]

├─ org.apache.samza.context.ApplicationTaskContextFactory.class - [JAR]

├─ org.apache.samza.context.ContainerContext.class - [JAR]

├─ org.apache.samza.context.Context.class - [JAR]

├─ org.apache.samza.context.ExternalContext.class - [JAR]

├─ org.apache.samza.context.JobContext.class - [JAR]

├─ org.apache.samza.context.TaskContext.class - [JAR]

org.apache.samza.sql.udfs

├─ org.apache.samza.sql.udfs.SamzaSqlUdf.class - [JAR]

├─ org.apache.samza.sql.udfs.SamzaSqlUdfMethod.class - [JAR]

├─ org.apache.samza.sql.udfs.ScalarUdf.class - [JAR]

org.apache.samza.config

├─ org.apache.samza.config.Config.class - [JAR]

├─ org.apache.samza.config.ConfigException.class - [JAR]

├─ org.apache.samza.config.ConfigFactory.class - [JAR]

├─ org.apache.samza.config.ConfigLoader.class - [JAR]

├─ org.apache.samza.config.ConfigLoaderFactory.class - [JAR]

├─ org.apache.samza.config.ConfigRewriter.class - [JAR]

├─ org.apache.samza.config.JavaTableConfig.class - [JAR]

├─ org.apache.samza.config.MapConfig.class - [JAR]

org.apache.samza.drain

├─ org.apache.samza.drain.DrainMode.class - [JAR]

├─ org.apache.samza.drain.DrainNotification.class - [JAR]

org.apache.samza.startpoint

├─ org.apache.samza.startpoint.Startpoint.class - [JAR]

├─ org.apache.samza.startpoint.StartpointOldest.class - [JAR]

├─ org.apache.samza.startpoint.StartpointSpecific.class - [JAR]

├─ org.apache.samza.startpoint.StartpointTimestamp.class - [JAR]

├─ org.apache.samza.startpoint.StartpointUpcoming.class - [JAR]

├─ org.apache.samza.startpoint.StartpointVisitor.class - [JAR]

org.apache.samza.storage

├─ org.apache.samza.storage.BlobStoreAdminFactory.class - [JAR]

├─ org.apache.samza.storage.KafkaChangelogRestoreParams.class - [JAR]

├─ org.apache.samza.storage.SideInputsProcessor.class - [JAR]

├─ org.apache.samza.storage.SideInputsProcessorFactory.class - [JAR]

├─ org.apache.samza.storage.StateBackendAdmin.class - [JAR]

├─ org.apache.samza.storage.StateBackendFactory.class - [JAR]

├─ org.apache.samza.storage.StorageEngine.class - [JAR]

├─ org.apache.samza.storage.StorageEngineFactory.class - [JAR]

├─ org.apache.samza.storage.StoreProperties.class - [JAR]

├─ org.apache.samza.storage.TaskBackupManager.class - [JAR]

├─ org.apache.samza.storage.TaskRestoreManager.class - [JAR]

org.apache.samza.table.retry

├─ org.apache.samza.table.retry.TableRetryPolicy.class - [JAR]

org.apache.samza.table.batching

├─ org.apache.samza.table.batching.Batch.class - [JAR]

├─ org.apache.samza.table.batching.BatchProvider.class - [JAR]

├─ org.apache.samza.table.batching.Operation.class - [JAR]

org.apache.samza.sql.schema

├─ org.apache.samza.sql.schema.SamzaSqlFieldType.class - [JAR]

├─ org.apache.samza.sql.schema.SqlFieldSchema.class - [JAR]

├─ org.apache.samza.sql.schema.SqlSchema.class - [JAR]

├─ org.apache.samza.sql.schema.SqlSchemaBuilder.class - [JAR]

org.apache.samza.container.placement

├─ org.apache.samza.container.placement.ContainerPlacementMessage.class - [JAR]

├─ org.apache.samza.container.placement.ContainerPlacementRequestMessage.class - [JAR]

├─ org.apache.samza.container.placement.ContainerPlacementResponseMessage.class - [JAR]

org.apache.samza.application.descriptors

├─ org.apache.samza.application.descriptors.ApplicationDescriptor.class - [JAR]

├─ org.apache.samza.application.descriptors.StreamApplicationDescriptor.class - [JAR]

├─ org.apache.samza.application.descriptors.TaskApplicationDescriptor.class - [JAR]

org.apache.samza.sql

├─ org.apache.samza.sql.SamzaSqlRelRecord.class - [JAR]

org.apache.samza.scheduler

├─ org.apache.samza.scheduler.CallbackScheduler.class - [JAR]

├─ org.apache.samza.scheduler.ScheduledCallback.class - [JAR]

org.apache.samza.container.grouper.stream

├─ org.apache.samza.container.grouper.stream.SystemStreamPartitionGrouper.class - [JAR]

├─ org.apache.samza.container.grouper.stream.SystemStreamPartitionGrouperFactory.class - [JAR]

├─ org.apache.samza.container.grouper.stream.SystemStreamPartitionMapper.class - [JAR]

├─ org.apache.samza.container.grouper.stream.SystemStreamPartitionMapperFactory.class - [JAR]

org.apache.samza.serializers

├─ org.apache.samza.serializers.ByteBufferSerde.class - [JAR]

├─ org.apache.samza.serializers.ByteBufferSerdeFactory.class - [JAR]

├─ org.apache.samza.serializers.ByteSerde.class - [JAR]

├─ org.apache.samza.serializers.ByteSerdeFactory.class - [JAR]

├─ org.apache.samza.serializers.Deserializer.class - [JAR]

├─ org.apache.samza.serializers.DoubleSerde.class - [JAR]

├─ org.apache.samza.serializers.DoubleSerdeFactory.class - [JAR]

├─ org.apache.samza.serializers.IntegerSerde.class - [JAR]

├─ org.apache.samza.serializers.IntegerSerdeFactory.class - [JAR]

├─ org.apache.samza.serializers.JsonSerdeV2.class - [JAR]

├─ org.apache.samza.serializers.JsonSerdeV2Factory.class - [JAR]

├─ org.apache.samza.serializers.KVSerde.class - [JAR]

├─ org.apache.samza.serializers.LongSerde.class - [JAR]

├─ org.apache.samza.serializers.LongSerdeFactory.class - [JAR]

├─ org.apache.samza.serializers.NoOpSerde.class - [JAR]

├─ org.apache.samza.serializers.Serde.class - [JAR]

├─ org.apache.samza.serializers.SerdeFactory.class - [JAR]

├─ org.apache.samza.serializers.SerializableSerde.class - [JAR]

├─ org.apache.samza.serializers.SerializableSerdeFactory.class - [JAR]

├─ org.apache.samza.serializers.Serializer.class - [JAR]

├─ org.apache.samza.serializers.StringSerde.class - [JAR]

├─ org.apache.samza.serializers.StringSerdeFactory.class - [JAR]

├─ org.apache.samza.serializers.UUIDSerde.class - [JAR]

├─ org.apache.samza.serializers.UUIDSerdeFactory.class - [JAR]

org.apache.samza.table.utils

├─ org.apache.samza.table.utils.SerdeUtils.class - [JAR]

org.apache.samza.storage.blobstore.exceptions

├─ org.apache.samza.storage.blobstore.exceptions.DeletedException.class - [JAR]

├─ org.apache.samza.storage.blobstore.exceptions.RetriableException.class - [JAR]

org.apache.samza.metadatastore

├─ org.apache.samza.metadatastore.InMemoryMetadataStore.class - [JAR]

├─ org.apache.samza.metadatastore.InMemoryMetadataStoreFactory.class - [JAR]

├─ org.apache.samza.metadatastore.MetadataStore.class - [JAR]

├─ org.apache.samza.metadatastore.MetadataStoreFactory.class - [JAR]

org.apache.samza.application

├─ org.apache.samza.application.ApplicationApiType.class - [JAR]

├─ org.apache.samza.application.SamzaApplication.class - [JAR]

├─ org.apache.samza.application.StreamApplication.class - [JAR]

├─ org.apache.samza.application.TaskApplication.class - [JAR]

org.apache.samza.system.descriptors

├─ org.apache.samza.system.descriptors.ExpandingInputDescriptorProvider.class - [JAR]

├─ org.apache.samza.system.descriptors.GenericInputDescriptor.class - [JAR]

├─ org.apache.samza.system.descriptors.GenericOutputDescriptor.class - [JAR]

├─ org.apache.samza.system.descriptors.GenericSystemDescriptor.class - [JAR]

├─ org.apache.samza.system.descriptors.InputDescriptor.class - [JAR]

├─ org.apache.samza.system.descriptors.InputTransformer.class - [JAR]

├─ org.apache.samza.system.descriptors.OutputDescriptor.class - [JAR]

├─ org.apache.samza.system.descriptors.OutputDescriptorProvider.class - [JAR]

├─ org.apache.samza.system.descriptors.SimpleInputDescriptorProvider.class - [JAR]

├─ org.apache.samza.system.descriptors.StreamDescriptor.class - [JAR]

├─ org.apache.samza.system.descriptors.StreamExpander.class - [JAR]

├─ org.apache.samza.system.descriptors.SystemDescriptor.class - [JAR]

├─ org.apache.samza.system.descriptors.TransformingInputDescriptorProvider.class - [JAR]

org.apache.samza.table.remote

├─ org.apache.samza.table.remote.BaseTableFunction.class - [JAR]

├─ org.apache.samza.table.remote.TableFunction.class - [JAR]

├─ org.apache.samza.table.remote.TablePart.class - [JAR]

├─ org.apache.samza.table.remote.TableRateLimiter.class - [JAR]

├─ org.apache.samza.table.remote.TableReadFunction.class - [JAR]

├─ org.apache.samza.table.remote.TableWriteFunction.class - [JAR]

org.apache.samza.annotation

├─ org.apache.samza.annotation.InterfaceStability.class - [JAR]

org.apache.samza.runtime

├─ org.apache.samza.runtime.ApplicationRunner.class - [JAR]

├─ org.apache.samza.runtime.LocationId.class - [JAR]

├─ org.apache.samza.runtime.LocationIdProvider.class - [JAR]

├─ org.apache.samza.runtime.LocationIdProviderFactory.class - [JAR]

├─ org.apache.samza.runtime.ProcessorContext.class - [JAR]

├─ org.apache.samza.runtime.ProcessorIdGenerator.class - [JAR]

├─ org.apache.samza.runtime.ProcessorLifecycleListener.class - [JAR]

├─ org.apache.samza.runtime.ProcessorLifecycleListenerFactory.class - [JAR]

org.apache.samza.operators.functions

├─ org.apache.samza.operators.functions.AsyncFlatMapFunction.class - [JAR]

├─ org.apache.samza.operators.functions.ClosableFunction.class - [JAR]

├─ org.apache.samza.operators.functions.FilterFunction.class - [JAR]

├─ org.apache.samza.operators.functions.FlatMapFunction.class - [JAR]

├─ org.apache.samza.operators.functions.FoldLeftFunction.class - [JAR]

├─ org.apache.samza.operators.functions.InitableFunction.class - [JAR]

├─ org.apache.samza.operators.functions.JoinFunction.class - [JAR]

├─ org.apache.samza.operators.functions.MapFunction.class - [JAR]

├─ org.apache.samza.operators.functions.ScheduledFunction.class - [JAR]

├─ org.apache.samza.operators.functions.SinkFunction.class - [JAR]

├─ org.apache.samza.operators.functions.StreamTableJoinFunction.class - [JAR]

├─ org.apache.samza.operators.functions.SupplierFunction.class - [JAR]

├─ org.apache.samza.operators.functions.WatermarkFunction.class - [JAR]

org.apache.samza.util

├─ org.apache.samza.util.BlockingEnvelopeMap.class - [JAR]

├─ org.apache.samza.util.Clock.class - [JAR]

├─ org.apache.samza.util.NoOpMetricsRegistry.class - [JAR]

├─ org.apache.samza.util.RateLimiter.class - [JAR]

├─ org.apache.samza.util.SinglePartitionWithoutOffsetsSystemAdmin.class - [JAR]

├─ org.apache.samza.util.TimestampedValue.class - [JAR]

org.apache.samza.storage.blobstore

├─ org.apache.samza.storage.blobstore.BlobStoreManager.class - [JAR]

├─ org.apache.samza.storage.blobstore.BlobStoreManagerFactory.class - [JAR]

├─ org.apache.samza.storage.blobstore.Metadata.class - [JAR]

org.apache.samza.metrics

├─ org.apache.samza.metrics.Counter.class - [JAR]

├─ org.apache.samza.metrics.Gauge.class - [JAR]

├─ org.apache.samza.metrics.Metric.class - [JAR]

├─ org.apache.samza.metrics.MetricsAccessor.class - [JAR]

├─ org.apache.samza.metrics.MetricsRegistry.class - [JAR]

├─ org.apache.samza.metrics.MetricsRegistryWithSource.class - [JAR]

├─ org.apache.samza.metrics.MetricsReporter.class - [JAR]

├─ org.apache.samza.metrics.MetricsReporterFactory.class - [JAR]

├─ org.apache.samza.metrics.MetricsValidationFailureException.class - [JAR]

├─ org.apache.samza.metrics.MetricsValidator.class - [JAR]

├─ org.apache.samza.metrics.MetricsVisitor.class - [JAR]

├─ org.apache.samza.metrics.ReadableMetricsRegistry.class - [JAR]

├─ org.apache.samza.metrics.ReadableMetricsRegistryListener.class - [JAR]

├─ org.apache.samza.metrics.Reservoir.class - [JAR]

├─ org.apache.samza.metrics.SamzaHistogram.class - [JAR]

├─ org.apache.samza.metrics.SlidingTimeWindowReservoir.class - [JAR]

├─ org.apache.samza.metrics.Snapshot.class - [JAR]

├─ org.apache.samza.metrics.Timer.class - [JAR]

org.apache.samza.coordinator.lifecycle

├─ org.apache.samza.coordinator.lifecycle.JobRestartSignal.class - [JAR]

├─ org.apache.samza.coordinator.lifecycle.JobRestartSignalFactory.class - [JAR]

├─ org.apache.samza.coordinator.lifecycle.JobRestartSignalFactoryContext.class - [JAR]

org.apache.samza.task

├─ org.apache.samza.task.AsyncStreamTask.class - [JAR]

├─ org.apache.samza.task.AsyncStreamTaskFactory.class - [JAR]

├─ org.apache.samza.task.ClosableTask.class - [JAR]

├─ org.apache.samza.task.DrainListenerTask.class - [JAR]

├─ org.apache.samza.task.EndOfStreamListenerTask.class - [JAR]

├─ org.apache.samza.task.InitableTask.class - [JAR]

├─ org.apache.samza.task.MessageCollector.class - [JAR]

├─ org.apache.samza.task.StreamOperatorTaskFactory.class - [JAR]

├─ org.apache.samza.task.StreamTask.class - [JAR]

├─ org.apache.samza.task.StreamTaskFactory.class - [JAR]

├─ org.apache.samza.task.TaskCallback.class - [JAR]

├─ org.apache.samza.task.TaskCoordinator.class - [JAR]

├─ org.apache.samza.task.TaskExecutorFactory.class - [JAR]

├─ org.apache.samza.task.TaskFactory.class - [JAR]

├─ org.apache.samza.task.WindowableTask.class - [JAR]

org.apache.samza.operators.triggers

├─ org.apache.samza.operators.triggers.AnyTrigger.class - [JAR]

├─ org.apache.samza.operators.triggers.CountTrigger.class - [JAR]

├─ org.apache.samza.operators.triggers.DurationCharacteristic.class - [JAR]

├─ org.apache.samza.operators.triggers.FiringType.class - [JAR]

├─ org.apache.samza.operators.triggers.RepeatingTrigger.class - [JAR]

├─ org.apache.samza.operators.triggers.TimeBasedTrigger.class - [JAR]

├─ org.apache.samza.operators.triggers.TimeSinceFirstMessageTrigger.class - [JAR]

├─ org.apache.samza.operators.triggers.TimeSinceLastMessageTrigger.class - [JAR]

├─ org.apache.samza.operators.triggers.TimeTrigger.class - [JAR]

├─ org.apache.samza.operators.triggers.Trigger.class - [JAR]

├─ org.apache.samza.operators.triggers.Triggers.class - [JAR]

org.apache.samza.operators.windows.internal

├─ org.apache.samza.operators.windows.internal.WindowInternal.class - [JAR]

├─ org.apache.samza.operators.windows.internal.WindowType.class - [JAR]

org.apache.samza.operators.windows

├─ org.apache.samza.operators.windows.AccumulationMode.class - [JAR]

├─ org.apache.samza.operators.windows.Window.class - [JAR]

├─ org.apache.samza.operators.windows.WindowKey.class - [JAR]

├─ org.apache.samza.operators.windows.WindowPane.class - [JAR]

├─ org.apache.samza.operators.windows.Windows.class - [JAR]

org.apache.samza.job

├─ org.apache.samza.job.ApplicationStatus.class - [JAR]

├─ org.apache.samza.job.CommandBuilder.class - [JAR]

├─ org.apache.samza.job.JobCoordinatorMetadata.class - [JAR]

├─ org.apache.samza.job.JobMetadataChange.class - [JAR]

├─ org.apache.samza.job.StreamJob.class - [JAR]

├─ org.apache.samza.job.StreamJobFactory.class - [JAR]

org.apache.samza.container

├─ org.apache.samza.container.TaskName.class - [JAR]

org.apache.samza.table.descriptors

├─ org.apache.samza.table.descriptors.BaseTableDescriptor.class - [JAR]

├─ org.apache.samza.table.descriptors.CachingTableDescriptor.class - [JAR]

├─ org.apache.samza.table.descriptors.GuavaCacheTableDescriptor.class - [JAR]

├─ org.apache.samza.table.descriptors.HybridTableDescriptor.class - [JAR]

├─ org.apache.samza.table.descriptors.LocalTableDescriptor.class - [JAR]

├─ org.apache.samza.table.descriptors.RemoteTableDescriptor.class - [JAR]

├─ org.apache.samza.table.descriptors.TableDescriptor.class - [JAR]

org.apache.samza.system.chooser

├─ org.apache.samza.system.chooser.BaseMessageChooser.class - [JAR]

├─ org.apache.samza.system.chooser.MessageChooser.class - [JAR]

├─ org.apache.samza.system.chooser.MessageChooserFactory.class - [JAR]

org.apache.samza.job.model

├─ org.apache.samza.job.model.ContainerModel.class - [JAR]

├─ org.apache.samza.job.model.JobModel.class - [JAR]

├─ org.apache.samza.job.model.LocalityModel.class - [JAR]

├─ org.apache.samza.job.model.ProcessorLocality.class - [JAR]

├─ org.apache.samza.job.model.TaskMode.class - [JAR]

├─ org.apache.samza.job.model.TaskModel.class - [JAR]

org.apache.samza.storage.kv

├─ org.apache.samza.storage.kv.ClosableIterator.class - [JAR]

├─ org.apache.samza.storage.kv.Entry.class - [JAR]

├─ org.apache.samza.storage.kv.KeyValueIterator.class - [JAR]

├─ org.apache.samza.storage.kv.KeyValueSnapshot.class - [JAR]

├─ org.apache.samza.storage.kv.KeyValueStore.class - [JAR]

org.apache.samza : samza-api

Maven & Gradle

Apache Samza · A distributed stream processing framework built upon Apache Kafka and Apache Hadoop YARN.

Latest Version

All Versions

Download org.apache.samza : samza-api JAR file - All Versions:

View Java Class Source Code in JAR file