Serialized Form

Package org.apache.samza

Class org.apache.samza.SamzaException extends java.lang.RuntimeException implements Serializable

serialVersionUID:

1L

Package org.apache.samza.config

Class org.apache.samza.config.Config extends java.lang.Object implements Serializable

Class org.apache.samza.config.ConfigException extends SamzaException implements Serializable

serialVersionUID:

1L

Class org.apache.samza.config.MapConfig extends Config implements Serializable

Serialized Fields

map

java.util.Map<K,V> map

Package org.apache.samza.context

Package org.apache.samza.metrics

Class org.apache.samza.metrics.MetricsValidationFailureException extends java.lang.Exception implements Serializable

Package org.apache.samza.operators.functions

Package org.apache.samza.operators.triggers

Class org.apache.samza.operators.triggers.AnyTrigger extends java.lang.Object implements Serializable

Serialized Fields

triggers

java.util.ArrayList<E> triggers

Class org.apache.samza.operators.triggers.CountTrigger extends java.lang.Object implements Serializable

Serialized Fields

count

long count

Class org.apache.samza.operators.triggers.RepeatingTrigger extends java.lang.Object implements Serializable

Serialized Fields

trigger

Trigger<M> trigger

Class org.apache.samza.operators.triggers.TimeSinceFirstMessageTrigger extends java.lang.Object implements Serializable

Serialized Fields

duration

java.time.Duration duration

characteristic

DurationCharacteristic characteristic

Class org.apache.samza.operators.triggers.TimeSinceLastMessageTrigger extends java.lang.Object implements Serializable

Serialized Fields

duration

java.time.Duration duration

characteristic

DurationCharacteristic characteristic

Class org.apache.samza.operators.triggers.TimeTrigger extends java.lang.Object implements Serializable

Serialized Fields

duration

java.time.Duration duration

characteristic

DurationCharacteristic characteristic

Package org.apache.samza.operators.windows

Package org.apache.samza.operators.windows.internal

Class org.apache.samza.operators.windows.internal.WindowInternal extends java.lang.Object implements Serializable

Serialized Fields

defaultTrigger

Trigger<M> defaultTrigger

initializer

SupplierFunction<T> initializer

The supplier of initial value to be used for windowed aggregations

foldLeftFunction

FoldLeftFunction<M,WV> foldLeftFunction

keyExtractor

MapFunction<M,OM> keyExtractor

eventTimeExtractor

MapFunction<M,OM> eventTimeExtractor

windowType

WindowType windowType

The type of this window. Tumbling and Session windows are supported for now.

earlyTrigger

Trigger<M> earlyTrigger

lateTrigger

Trigger<M> lateTrigger

mode

AccumulationMode mode

Package org.apache.samza.runtime

Package org.apache.samza.serializers

Class org.apache.samza.serializers.ByteBufferSerde extends java.lang.Object implements Serializable

Class org.apache.samza.serializers.ByteSerde extends java.lang.Object implements Serializable

Class org.apache.samza.serializers.DoubleSerde extends java.lang.Object implements Serializable

Class org.apache.samza.serializers.IntegerSerde extends java.lang.Object implements Serializable

Class org.apache.samza.serializers.JsonSerdeV2 extends java.lang.Object implements Serializable

Serialization Methods

readObject

private void readObject(java.io.ObjectInputStream in)
                 throws java.io.IOException,
                        java.lang.ClassNotFoundException

Throws:

java.io.IOException

java.lang.ClassNotFoundException

Serialized Fields

clazz

java.lang.Class<T> clazz

Class org.apache.samza.serializers.KVSerde extends java.lang.Object implements Serializable

Serialized Fields

keySerde

Serde<T> keySerde

valueSerde

Serde<T> valueSerde

Class org.apache.samza.serializers.LongSerde extends java.lang.Object implements Serializable

Class org.apache.samza.serializers.NoOpSerde extends java.lang.Object implements Serializable

Class org.apache.samza.serializers.SerializableSerde extends java.lang.Object implements Serializable

Class org.apache.samza.serializers.StringSerde extends java.lang.Object implements Serializable

Serialized Fields

encoding

java.lang.String encoding

Class org.apache.samza.serializers.UUIDSerde extends java.lang.Object implements Serializable

Package org.apache.samza.sql

Class org.apache.samza.sql.SamzaSqlRelRecord extends java.lang.Object implements Serializable

Serialized Fields

fieldNames

java.util.ArrayList<E> fieldNames

fieldValues

java.util.ArrayList<E> fieldValues

Package org.apache.samza.storage

Package org.apache.samza.system

Class org.apache.samza.system.StreamSpec extends java.lang.Object implements Serializable

Serialized Fields

id

java.lang.String id

Unique identifier for the stream in a Samza application. This identifier is used as a key for stream properties in the job config and to distinguish between streams in a graph.

systemName

java.lang.String systemName

The System name on which this stream will exist. Corresponds to a named implementation of the Samza System abstraction.

physicalName

java.lang.String physicalName

The physical identifier for the stream. This is the identifier that will be used in remote systems to identify the stream. In Kafka this would be the topic name whereas in HDFS it might be a file URN.

partitionCount

int partitionCount

The number of partitions for the stream.

config

java.util.Map<K,V> config

A set of all system-specific configurations for the stream.

Class org.apache.samza.system.StreamValidationException extends SamzaException implements Serializable

serialVersionUID:

1L

Class org.apache.samza.system.SystemProducerException extends SamzaException implements Serializable

serialVersionUID:

1L

Package org.apache.samza.system.descriptors

Package org.apache.samza.table

Class org.apache.samza.table.TableSpec extends java.lang.Object implements Serializable

Serialized Fields

id

java.lang.String id

tableProviderFactoryClassName

java.lang.String tableProviderFactoryClassName

Package org.apache.samza.task

Package org.apache.samza.util