Serialized Form

Package com.hazelcast.jet

Class com.hazelcast.jet.CombinedJetException extends RuntimeException implements Serializable

Serialized Fields

errors

List<E> errors

Class com.hazelcast.jet.JetException extends RuntimeException implements Serializable

Package com.hazelcast.jet.config

Class com.hazelcast.jet.config.ApplicationConfig extends Object implements Serializable

Serialized Fields

properties

Properties properties

localizationDirectory

String localizationDirectory

applicationDirectoryCreationAttemptsCount

int applicationDirectoryCreationAttemptsCount

secondsToAwait

int secondsToAwait

ringbufferSize

int ringbufferSize

chunkSize

int chunkSize

tcpBufferSize

int tcpBufferSize

shufflingBatchSizeBytes

int shufflingBatchSizeBytes

name

String name

Package com.hazelcast.jet.container

Package com.hazelcast.jet.counters

Package com.hazelcast.jet.dag

Class com.hazelcast.jet.dag.Edge extends Object implements Serializable

Serialized Fields

to

Vertex to

name

String name

from

Vertex from

shuffled

boolean shuffled

hashingStrategy

HashingStrategy<O,K> hashingStrategy

shufflingStrategy

ShufflingStrategy shufflingStrategy

processingStrategy

ProcessingStrategy processingStrategy

partitioningStrategy

com.hazelcast.core.PartitioningStrategy<K> partitioningStrategy

dataTransferringStrategy

DataTransferringStrategy<T> dataTransferringStrategy

Class com.hazelcast.jet.dag.Vertex extends Object implements Serializable

Serialized Fields

name

String name

descriptor

ProcessorDescriptor descriptor

inputEdges

List<E> inputEdges

outputEdges

List<E> outputEdges

sinks

List<E> sinks

inputVertices

List<E> inputVertices

sources

List<E> sources

outputVertices

List<E> outputVertices

Package com.hazelcast.jet.dag.tap

Class com.hazelcast.jet.dag.tap.FileSink extends Object implements Serializable

Serialized Fields

filename

String filename

fileOutputStream

com.hazelcast.jet.impl.dag.tap.sink.FileOutputStream fileOutputStream

Class com.hazelcast.jet.dag.tap.FileSource extends Object implements Serializable

Serialized Fields

name

String name

Class com.hazelcast.jet.dag.tap.ListSink extends Object implements Serializable

Serialized Fields

name

String name

Class com.hazelcast.jet.dag.tap.ListSource extends Object implements Serializable

Serialized Fields

name

String name

Class com.hazelcast.jet.dag.tap.MapSink extends Object implements Serializable

Serialized Fields

name

String name

Class com.hazelcast.jet.dag.tap.MapSource extends Object implements Serializable

Serialized Fields

name

String name

Class com.hazelcast.jet.dag.tap.MultiMapSink extends MapSink implements Serializable

Class com.hazelcast.jet.dag.tap.MultiMapSource extends MapSource implements Serializable

Package com.hazelcast.jet.processor

Class com.hazelcast.jet.processor.ProcessorDescriptor extends Object implements Serializable

Serialized Fields

taskCount

int taskCount

Package com.hazelcast.jet.strategy

Class com.hazelcast.jet.strategy.IListBasedShufflingStrategy extends Object implements Serializable

Serialized Fields

listName

String listName

Package com.hazelcast.jet.stream

Class com.hazelcast.jet.stream.Distributed.Optional extends Object implements Serializable

Serialized Fields

value

Object value

If non-null, the value; if null, indicates no value is present