Serialized Form

Package edu.iu.dsc.tws.api
- Class edu.iu.dsc.tws.api.JobConfig extends java.util.HashMap<java.lang.String,java.lang.Object> implements Serializable
  
  serialVersionUID:
  
  6585146860991205058L
Package edu.iu.dsc.tws.api.comms.packing
- Class edu.iu.dsc.tws.api.comms.packing.PackerStore extends java.util.HashMap<java.lang.String,java.lang.Object> implements Serializable
Package edu.iu.dsc.tws.api.compute
Package edu.iu.dsc.tws.api.compute.exceptions
- Class edu.iu.dsc.tws.api.compute.exceptions.TaskSchedulerException extends Twister2RuntimeException implements Serializable
  
  serialVersionUID:
  
  6599628617518713638L
Package edu.iu.dsc.tws.api.compute.modifiers
- Class edu.iu.dsc.tws.api.compute.modifiers.IONames extends java.util.HashSet<java.lang.String> implements Serializable
Package edu.iu.dsc.tws.api.compute.nodes
- Class edu.iu.dsc.tws.api.compute.nodes.BaseCompute extends BaseNode implements Serializable
- Class edu.iu.dsc.tws.api.compute.nodes.BaseNode extends java.lang.Object implements Serializable
  - Serialized Fields
    - context
```
TaskContext context
```
    - config
```
Config config
```
- Class edu.iu.dsc.tws.api.compute.nodes.BaseSource extends BaseNode implements Serializable
Package edu.iu.dsc.tws.api.data
- Class edu.iu.dsc.tws.api.data.FileSystem extends java.lang.Object implements Serializable
- Class edu.iu.dsc.tws.api.data.Path extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - uri
```
java.net.URI uri
```
Package edu.iu.dsc.tws.api.dataset
- Class edu.iu.dsc.tws.api.dataset.EmptyDataObject extends java.lang.Object implements Serializable
- Class edu.iu.dsc.tws.api.dataset.EmptyDataPartition extends java.lang.Object implements Serializable
Package edu.iu.dsc.tws.api.exceptions
- Class edu.iu.dsc.tws.api.exceptions.JobFaultyException extends Twister2RuntimeException implements Serializable
- Class edu.iu.dsc.tws.api.exceptions.TimeoutException extends Twister2Exception implements Serializable
  
  serialVersionUID:
  
  -254264900110286748L
- Class edu.iu.dsc.tws.api.exceptions.Twister2Exception extends java.lang.Exception implements Serializable
- Class edu.iu.dsc.tws.api.exceptions.Twister2RuntimeException extends java.lang.RuntimeException implements Serializable
Package edu.iu.dsc.tws.api.exceptions.net
- Class edu.iu.dsc.tws.api.exceptions.net.BlockingSendException extends Twister2Exception implements Serializable
  
  serialVersionUID:
  
  7718828512143293558L
  - Serialized Fields
    - failureReason
```
BlockingSendFailureReason failureReason
```
Package edu.iu.dsc.tws.api.scheduler
- Class edu.iu.dsc.tws.api.scheduler.LauncherException extends Twister2RuntimeException implements Serializable
  
  serialVersionUID:
  
  8518462128140814098L
- Class edu.iu.dsc.tws.api.scheduler.UploaderException extends Twister2RuntimeException implements Serializable
  
  serialVersionUID:
  
  -254264900110286748L
Package edu.iu.dsc.tws.api.tset
- Class edu.iu.dsc.tws.api.tset.TSetContext extends java.lang.Object implements Serializable
  - Serialized Fields
    - tSetIndex
```
int tSetIndex
```
      tSet index, which goes from 0 up to the number of parallel tSets
    - tSetId
```
java.lang.String tSetId
```
      Unique id of the tSet
    - tSetName
```
java.lang.String tSetName
```
      Name of the tSet
    - parallelism
```
int parallelism
```
      Parallel instances of the tSet
    - configs
```
java.util.Map<K,V> configs
```
      tSet specific configurations
    - inputMap
```
java.util.Map<K,V> inputMap
```
      Inputs that are added to a TSet are stored in this map to be passed to functions
    - workerId
```
int workerId
```
      The worker id this tSet instance belongs to
    - config
```
Config config
```
      Configuration
Package edu.iu.dsc.tws.api.tset.fn
- Class edu.iu.dsc.tws.api.tset.fn.BaseApplyFunc extends BaseTFunction<T,T> implements Serializable
- Class edu.iu.dsc.tws.api.tset.fn.BaseComputeCollectorFunc extends BaseTFunction<O,I> implements Serializable
- Class edu.iu.dsc.tws.api.tset.fn.BaseComputeFunc extends BaseTFunction<O,I> implements Serializable
- Class edu.iu.dsc.tws.api.tset.fn.BaseMapFunc extends BaseTFunction<O,I> implements Serializable
- Class edu.iu.dsc.tws.api.tset.fn.BaseSinkFunc extends BaseTFunction<T,T> implements Serializable
- Class edu.iu.dsc.tws.api.tset.fn.BaseSourceFunc extends BaseTFunction<T,T> implements Serializable
- Class edu.iu.dsc.tws.api.tset.fn.BaseTFunction extends java.lang.Object implements Serializable
  - Serialized Fields
    - context
```
TSetContext context
```
      The runtime context that is made available to users who create functions that extend from the TBaseFunction abstract class
Package edu.iu.dsc.tws.api.tset.link
Package edu.iu.dsc.tws.api.tset.link.batch
Package edu.iu.dsc.tws.api.tset.link.streaming
Package edu.iu.dsc.tws.api.tset.sets
Package edu.iu.dsc.tws.api.tset.sets.batch
Package edu.iu.dsc.tws.api.tset.sets.streaming
Package edu.iu.dsc.tws.checkpointing.task
- Class edu.iu.dsc.tws.checkpointing.task.CheckpointingSGatherSink extends java.lang.Object implements Serializable
  - Serialized Fields
    - taskContext
```
TaskContext taskContext
```
    - parentTaskName
```
java.lang.String parentTaskName
```
    - parentTaskId
```
int parentTaskId
```
Package edu.iu.dsc.tws.common.logging
- Class edu.iu.dsc.tws.common.logging.LoggingHelper.StdOutErrLevel extends java.util.logging.Level implements Serializable
  
  serialVersionUID:
  
  -3442332825945855738L
  - Serialization Methods
    - readResolve
```
protected java.lang.Object readResolve()
                                throws java.io.ObjectStreamException
```
      Method to avoid creating duplicate instances when deserializing the object.
      
      Throws:
      
      java.io.ObjectStreamException - If unable to deserialize
Package edu.iu.dsc.tws.common.pojo
- Class edu.iu.dsc.tws.common.pojo.Time extends java.lang.Object implements Serializable
  - Serialized Fields
    - size
```
long size
```
    - unit
```
java.util.concurrent.TimeUnit unit
```
Package edu.iu.dsc.tws.comms.dfw.io
- Class edu.iu.dsc.tws.comms.dfw.io.AggregatedObjects extends java.util.ArrayList<T> implements Serializable
- Class edu.iu.dsc.tws.comms.dfw.io.SerializeState extends PackerStore implements Serializable
  - Serialized Fields
    - currentObjectIndex
```
int currentObjectIndex
```
    - bufferNo
```
int bufferNo
```
    - totalBytes
```
int totalBytes
```
    - currentHeaderLength
```
int currentHeaderLength
```
    - storedData1
```
SerializeState.StoredData storedData1
```
    - storedData2
```
SerializeState.StoredData storedData2
```
    - active
```
SerializeState.StoredData active
```
    - part
```
SerializeState.Part part
```
Package edu.iu.dsc.tws.comms.shuffle
- Class edu.iu.dsc.tws.comms.shuffle.RestorePoint extends java.util.HashMap<java.lang.String,java.lang.Object> implements Serializable
Package edu.iu.dsc.tws.connectors.kafka
- Class edu.iu.dsc.tws.connectors.kafka.KafkaSource extends java.lang.Object implements Serializable
  - Serialized Fields
    - kafkaConsumer
```
<any> kafkaConsumer
```
    - cfg
```
Config cfg
```
    - context
```
TaskContext context
```
    - partitionOffsets
```
java.util.HashMap<K,V> partitionOffsets
```
Package edu.iu.dsc.tws.dashboard.data_models.composite_ids
- Class edu.iu.dsc.tws.dashboard.data_models.composite_ids.ComputeResourceId extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - index
```
java.lang.Integer index
```
    - job
```
java.lang.String job
```
- Class edu.iu.dsc.tws.dashboard.data_models.composite_ids.NodeId extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ip
```
java.lang.String ip
```
    - dataCenter
```
java.lang.String dataCenter
```
    - rack
```
java.lang.String rack
```
- Class edu.iu.dsc.tws.dashboard.data_models.composite_ids.WorkerId extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - workerID
```
java.lang.Long workerID
```
    - job
```
java.lang.String job
```
Package edu.iu.dsc.tws.data.api
Package edu.iu.dsc.tws.data.api.assigner
- Class edu.iu.dsc.tws.data.api.assigner.LocatableInputSplitAssigner extends java.lang.Object implements Serializable
  - Serialized Fields
    - unassigned
```
java.util.Set<E> unassigned
```
    - localPerHost
```
java.util.concurrent.ConcurrentHashMap<K,V> localPerHost
```
    - remoteSplitChooser
```
edu.iu.dsc.tws.data.api.assigner.LocatableInputSplitAssigner.LocatableInputSplitChooser remoteSplitChooser
```
    - localAssignments
```
int localAssignments
```
    - remoteAssignments
```
int remoteAssignments
```
- Class edu.iu.dsc.tws.data.api.assigner.OrderedInputSplitAssigner extends java.lang.Object implements Serializable
  - Serialized Fields
    - splits
```
InputSplit<OT>[] splits
```
    - numTasks
```
int numTasks
```
    - next
```
java.util.Map<K,V> next
```
Package edu.iu.dsc.tws.data.api.formatters
- Class edu.iu.dsc.tws.data.api.formatters.BinaryInputPartitioner extends FileInputPartitioner<byte[]> implements Serializable
  
  serialVersionUID:
  
  -1L
- Class edu.iu.dsc.tws.data.api.formatters.CompleteArrowInputPartitioner extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - numSplits
```
int numSplits
```
      The desired number of splits, as set by the configure() method.
    - enumerateNestedFiles
```
boolean enumerateNestedFiles
```
      The flag to specify whether recursive traversal of the input directory structure is enabled.
    - filePath
```
Path filePath
```
      The path to the file that contains the input.
    - config
```
Config config
```
      Config file required for Hdfs connection
    - minSplitSize
```
long minSplitSize
```
      The minimal split size, set by the configure() method.
    - stream
```
FSDataInputStream stream
```
      The input data stream
    - dataSize
```
int dataSize
```
- Class edu.iu.dsc.tws.data.api.formatters.CompleteCSVInputPartitioner extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - numSplits
```
int numSplits
```
      The desired number of splits, as set by the configure() method.
    - enumerateNestedFiles
```
boolean enumerateNestedFiles
```
      The flag to specify whether recursive traversal of the input directory structure is enabled.
    - filePath
```
Path filePath
```
      The path to the file that contains the input.
    - config
```
Config config
```
      Config file required for Hdfs connection
    - minSplitSize
```
long minSplitSize
```
      The minimal split size, set by the configure() method.
    - stream
```
FSDataInputStream stream
```
      The input data stream
    - dataSize
```
int dataSize
```
- Class edu.iu.dsc.tws.data.api.formatters.CompleteFileInputPartitioner extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - numSplits
```
int numSplits
```
      The desired number of splits, as set by the configure() method.
    - enumerateNestedFiles
```
boolean enumerateNestedFiles
```
      The flag to specify whether recursive traversal of the input directory structure is enabled.
    - filePath
```
Path filePath
```
      The path to the file that contains the input.
    - config
```
Config config
```
      Config file required for Hdfs connection
    - minSplitSize
```
long minSplitSize
```
      The minimal split size, set by the configure() method.
    - stream
```
FSDataInputStream stream
```
      The input data stream
- Class edu.iu.dsc.tws.data.api.formatters.CSVInputPartitioner extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  -1L
  - Serialized Fields
    - filePath
```
Path filePath
```
    - config
```
Config config
```
    - dataSize
```
int dataSize
```
    - minSplitSize
```
long minSplitSize
```
    - enumerateNestedFiles
```
boolean enumerateNestedFiles
```
- Class edu.iu.dsc.tws.data.api.formatters.FileInputPartitioner extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - numSplits
```
int numSplits
```
      The desired number of splits, as set by the configure() method.
    - enumerateNestedFiles
```
boolean enumerateNestedFiles
```
      The flag to specify whether recursive traversal of the input directory structure is enabled.
    - filePath
```
Path filePath
```
      The path to the file that contains the input.
    - config
```
Config config
```
    - minSplitSize
```
long minSplitSize
```
      The minimal split size, set by the configure() method.
    - stream
```
FSDataInputStream stream
```
      The input data stream
- Class edu.iu.dsc.tws.data.api.formatters.FixedInputPartitioner extends java.lang.Object implements Serializable
  - Serialized Fields
    - numSplits
```
int numSplits
```
    - enumerateNestedFiles
```
boolean enumerateNestedFiles
```
    - filePath
```
Path filePath
```
    - config
```
Config config
```
    - minSplitSize
```
long minSplitSize
```
    - stream
```
FSDataInputStream stream
```
    - dataSize
```
int dataSize
```
- Class edu.iu.dsc.tws.data.api.formatters.LocalBinaryInputPartitioner extends BinaryInputPartitioner implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - numberOfTasks
```
int numberOfTasks
```
    - config
```
Config config
```
    - recordLength
```
int recordLength
```
    - assigner
```
LocatableInputSplitAssigner<T> assigner
```
- Class edu.iu.dsc.tws.data.api.formatters.LocalCompleteArrowInputPartitioner extends CompleteArrowInputPartitioner<java.lang.String> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - numberOfTasks
```
int numberOfTasks
```
    - assigner
```
OrderedInputSplitAssigner<T> assigner
```
    - cfg
```
Config cfg
```
- Class edu.iu.dsc.tws.data.api.formatters.LocalCompleteCSVInputPartitioner extends CompleteCSVInputPartitioner<java.lang.String> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - numberOfTasks
```
int numberOfTasks
```
    - assigner
```
OrderedInputSplitAssigner<T> assigner
```
- Class edu.iu.dsc.tws.data.api.formatters.LocalCompleteTextInputPartitioner extends CompleteFileInputPartitioner<java.lang.String> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - nTasks
```
int nTasks
```
    - assigner
```
OrderedInputSplitAssigner<T> assigner
```
- Class edu.iu.dsc.tws.data.api.formatters.LocalCSVInputPartitioner extends CSVInputPartitioner<java.lang.String> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - numberOfTasks
```
int numberOfTasks
```
    - assigner
```
OrderedInputSplitAssigner<T> assigner
```
- Class edu.iu.dsc.tws.data.api.formatters.LocalFixedInputPartitioner extends FixedInputPartitioner<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - nTasks
```
int nTasks
```
    - assigner
```
OrderedInputSplitAssigner<T> assigner
```
- Class edu.iu.dsc.tws.data.api.formatters.LocalTextInputPartitioner extends FileInputPartitioner<java.lang.String> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - nTasks
```
int nTasks
```
    - assigner
```
OrderedInputSplitAssigner<T> assigner
```
- Class edu.iu.dsc.tws.data.api.formatters.SharedTextInputPartitioner extends FileInputPartitioner<java.lang.String> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - assigner
```
LocatableInputSplitAssigner<T> assigner
```
Package edu.iu.dsc.tws.data.api.out
- Class edu.iu.dsc.tws.data.api.out.CSVOutputWriter extends FileOutputWriter<java.lang.String> implements Serializable
  - Serialized Fields
    - writerMap
```
java.util.Map<K,V> writerMap
```
    - allowedNullValues
```
boolean allowedNullValues
```
    - quoteStrings
```
boolean quoteStrings
```
    - charsetName
```
java.lang.String charsetName
```
    - headers
```
java.lang.String[] headers
```
    - path
```
Path path
```
    - outputStream
```
FSDataOutputStream outputStream
```
    - config
```
Config config
```
- Class edu.iu.dsc.tws.data.api.out.FileOutputWriter extends java.lang.Object implements Serializable
  - Serialized Fields
    - fs
```
FileSystem fs
```
      File system object
    - pw
```
java.io.PrintWriter pw
```
    - openStreams
```
java.util.Map<K,V> openStreams
```
      Opened streams
    - writeMode
```
FileSystem.WriteMode writeMode
```
      Write mode of the files
    - outPath
```
Path outPath
```
      File output path
- Class edu.iu.dsc.tws.data.api.out.TextOutputWriter extends FileOutputWriter<java.lang.String> implements Serializable
  - Serialized Fields
    - writerMap
```
java.util.Map<K,V> writerMap
```
    - headers
```
java.lang.String[] headers
```
    - path
```
Path path
```
    - outputStream
```
FSDataOutputStream outputStream
```
    - config
```
Config config
```
Package edu.iu.dsc.tws.data.api.splits
- Class edu.iu.dsc.tws.data.api.splits.ArrowInputSplit extends FileInputSplit<java.lang.Object> implements Serializable
- Class edu.iu.dsc.tws.data.api.splits.BinaryInputSplit extends FileInputSplit<byte[]> implements Serializable
  - Serialized Fields
    - endianess
```
java.nio.ByteOrder endianess
```
      Endianess of the binary file, or the byte order
    - bufferSize
```
int bufferSize
```
    - offset
```
long offset
```
    - config
```
Config config
```
- Class edu.iu.dsc.tws.data.api.splits.CSVInputSplit extends FileInputSplit<java.lang.Object> implements Serializable
  - Serialized Fields
    - charsetName
```
java.lang.String charsetName
```
    - delimiter
```
byte[] delimiter
```
    - delimiterString
```
java.lang.String delimiterString
```
    - lineLengthLimit
```
int lineLengthLimit
```
    - bufferSize
```
int bufferSize
```
    - offset
```
long offset
```
    - config
```
Config config
```
- Class edu.iu.dsc.tws.data.api.splits.DelimitedInputSplit extends FileInputSplit<OT> implements Serializable
  - Serialized Fields
    - charsetName
```
java.lang.String charsetName
```
    - delimiter
```
byte[] delimiter
```
    - delimiterString
```
java.lang.String delimiterString
```
    - lineLengthLimit
```
int lineLengthLimit
```
    - bufferSize
```
int bufferSize
```
    - offset
```
long offset
```
    - config
```
Config config
```
- Class edu.iu.dsc.tws.data.api.splits.FileInputSplit extends LocatableInputSplit<OT> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - file
```
Path file
```
      The path of the file this file split refers to.
    - start
```
long start
```
      The position of the first byte in the file to process.
    - length
```
long length
```
      The number of bytes in the file to process.
    - numSplits
```
int numSplits
```
      The desired number of splits, as set by the configure() method.
    - enumerateNestedFiles
```
boolean enumerateNestedFiles
```
      The flag to specify whether recursive traversal of the input directory structure is enabled.
    - minSplitSize
```
long minSplitSize
```
      The minimal split size, set by the configure() method.
    - splitStart
```
long splitStart
```
      Start point of the current split
    - splitLength
```
long splitLength
```
      Length of the current split
    - stream
```
FSDataInputStream stream
```
      The input data stream
    - openTimeout
```
long openTimeout
```
      Time to wait when opening a file.
    - config
```
Config config
```
- Class edu.iu.dsc.tws.data.api.splits.GenericCSVInputSplit extends DelimitedInputSplit<java.lang.String> implements Serializable
  - Serialized Fields
    - charsetName
```
java.lang.String charsetName
```
      The name of the charset to use for decoding.
- Class edu.iu.dsc.tws.data.api.splits.LocatableInputSplit extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - splitNumber
```
int splitNumber
```
      The number of the split.
    - hostnames
```
java.lang.String[] hostnames
```
      The names of the hosts storing the data this input split refers to.
- Class edu.iu.dsc.tws.data.api.splits.TextInputSplit extends DelimitedInputSplit<java.lang.String> implements Serializable
  - Serialized Fields
    - charsetName
```
java.lang.String charsetName
```
      The name of the charset to use for decoding.
Package edu.iu.dsc.tws.data.arrow
- Class edu.iu.dsc.tws.data.arrow.Twister2ArrowFileReader extends java.lang.Object implements Serializable
  - Serialized Fields
    - arrowInputFile
```
java.lang.String arrowInputFile
```
    - arrowSchema
```
java.lang.String arrowSchema
```
    - currentBlock
```
int currentBlock
```
    - intVector
```
IntVector intVector
```
    - bigIntVector
```
BigIntVector bigIntVector
```
    - fileInputStream
```
java.io.FileInputStream fileInputStream
```
    - fsDataInputStream
```
FSDataInputStream fsDataInputStream
```
    - fileSystem
```
FileSystem fileSystem
```
    - rootAllocator
```
RootAllocator rootAllocator
```
    - root
```
VectorSchemaRoot root
```
    - arrowFileReader
```
ArrowFileReader arrowFileReader
```
    - arrowBlocks
```
java.util.List<E> arrowBlocks
```
- Class edu.iu.dsc.tws.data.arrow.Twister2ArrowFileWriter extends java.lang.Object implements Serializable
  - Serialized Fields
    - arrowFile
```
java.lang.String arrowFile
```
    - arrowSchema
```
java.lang.String arrowSchema
```
    - batchSize
```
int batchSize
```
    - parallel
```
int parallel
```
    - dataList
```
java.util.List<E> dataList
```
    - useNullValues
```
boolean useNullValues
```
    - flag
```
boolean flag
```
    - twister2ArrowOutputStream
```
Twister2ArrowOutputStream twister2ArrowOutputStream
```
    - fsDataOutputStream
```
FSDataOutputStream fsDataOutputStream
```
    - fileSystem
```
FileSystem fileSystem
```
    - generatorMap
```
java.util.Map<K,V> generatorMap
```
- Class edu.iu.dsc.tws.data.arrow.Twister2ArrowOutputStream extends java.lang.Object implements Serializable
  - Serialized Fields
    - isOpen
```
boolean isOpen
```
    - tempBuffer
```
byte[] tempBuffer
```
    - bytesSoFar
```
long bytesSoFar
```
Package edu.iu.dsc.tws.data.fs.io
Package edu.iu.dsc.tws.data.fs.local
- Class edu.iu.dsc.tws.data.fs.local.LocalFileLocation extends java.lang.Object implements Serializable
  - Serialized Fields
    - hosts
```
java.lang.String[] hosts
```
- Class edu.iu.dsc.tws.data.fs.local.LocalFileSystem extends FileSystem implements Serializable
  - Serialized Fields
    - workingDir
```
java.lang.String workingDir
```
      Path pointing to the current working directory. Because Paths are not immutable, we cannot cache the proper path here
    - homeDir
```
java.lang.String homeDir
```
      Path pointing to the current working directory. Because Paths are not immutable, we cannot cache the proper path here
    - hostName
```
java.lang.String hostName
```
      The host name of this machine
Package edu.iu.dsc.tws.data.hdfs
- Class edu.iu.dsc.tws.data.hdfs.HadoopFileSystem extends FileSystem implements Serializable
  - Serialized Fields
    - conf
```
org.apache.hadoop.conf.Configuration conf
```
    - hadoopFileSystem
```
org.apache.hadoop.fs.FileSystem hadoopFileSystem
```
Package edu.iu.dsc.tws.dataset
- Class edu.iu.dsc.tws.dataset.DataObjectImpl extends java.lang.Object implements Serializable
  - Serialized Fields
    - partitions
```
java.util.Map<K,V> partitions
```
    - id
```
java.lang.String id
```
- Class edu.iu.dsc.tws.dataset.DataSource extends DataObjectImpl<T> implements Serializable
  - Serialized Fields
    - input
```
InputPartitioner<OT,T extends InputSplit<OT>> input
```
    - splits
```
InputSplit<OT>[] splits
```
    - config
```
Config config
```
Package edu.iu.dsc.tws.dataset.partition
- Class edu.iu.dsc.tws.dataset.partition.BufferedCollectionPartition extends CollectionPartition<T> implements Serializable
  - Serialized Fields
    - maxFramesInMemory
```
long maxFramesInMemory
```
    - dataType
```
MessageType<T,W> dataType
```
    - filesList
```
java.util.List<E> filesList
```
    - fileCounter
```
long fileCounter
```
    - buffers
```
java.util.List<E> buffers
```
    - bufferedBytes
```
long bufferedBytes
```
    - maxBufferedBytes
```
long maxBufferedBytes
```
    - fileSystem
```
FileSystem fileSystem
```
    - rootPath
```
Path rootPath
```
    - reference
```
java.lang.String reference
```
    - currentFileCache
```
java.util.List<E> currentFileCache
```
    - cachedFileIndex
```
int cachedFileIndex
```
- Class edu.iu.dsc.tws.dataset.partition.CollectionPartition extends java.lang.Object implements Serializable
  - Serialized Fields
    - dataList
```
java.util.List<E> dataList
```
    - id
```
int id
```
- Class edu.iu.dsc.tws.dataset.partition.DiskBackedCollectionPartition extends BufferedCollectionPartition<T> implements Serializable
- Class edu.iu.dsc.tws.dataset.partition.EntityPartition extends java.lang.Object implements Serializable
  - Serialized Fields
    - id
```
int id
```
    - value
```
java.lang.Object value
```
- Class edu.iu.dsc.tws.dataset.partition.HDFSBackedCollectionPartition extends BufferedCollectionPartition<T> implements Serializable
Package edu.iu.dsc.tws.deeplearning.common
- Class edu.iu.dsc.tws.deeplearning.common.ParameterTool extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  1L
  - 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
    - data
```
java.util.Map<K,V> data
```
Package edu.iu.dsc.tws.examples
- Class edu.iu.dsc.tws.examples.IntData extends java.lang.Object implements Serializable
  - Serialized Fields
    - data
```
int[] data
```
    - id
```
int id
```
    - time
```
long time
```
Package edu.iu.dsc.tws.examples.arrow
- Class edu.iu.dsc.tws.examples.arrow.ArrowTSetSourceExample extends java.lang.Object implements Serializable
Package edu.iu.dsc.tws.examples.batch.cdfw
- Class edu.iu.dsc.tws.examples.batch.cdfw.DataGeneratorSink extends BaseCompute implements Serializable
- Class edu.iu.dsc.tws.examples.batch.cdfw.DataGeneratorSource extends BaseSource implements Serializable
  - Serialized Fields
    - edge
```
java.lang.String edge
```
    - dim
```
int dim
```
    - dataDirectory
```
java.lang.String dataDirectory
```
    - centroidDirectory
```
java.lang.String centroidDirectory
```
    - dsize
```
int dsize
```
    - csize
```
int csize
```
    - byteType
```
java.lang.String byteType
```
- Class edu.iu.dsc.tws.examples.batch.cdfw.HelloExample.Aggregator extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  -254264120110286748L
- Class edu.iu.dsc.tws.examples.batch.cdfw.KMeansConnectedDataflowExample.CentroidAggregator extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  -254264120110286748L
- Class edu.iu.dsc.tws.examples.batch.cdfw.KMeansConnectedDataflowExample.KMeansAllReduceTask extends BaseCompute implements Serializable
  
  serialVersionUID:
  
  -5190777711234234L
  - Serialized Fields
    - centroids
```
double[][] centroids
```
    - newCentroids
```
double[][] newCentroids
```
- Class edu.iu.dsc.tws.examples.batch.cdfw.KMeansConnectedDataflowExample.KMeansSourceTask extends BaseSource implements Serializable
  
  serialVersionUID:
  
  -254264120110286748L
  - Serialized Fields
    - dataPartition
```
DataPartition<T> dataPartition
```
    - centroidPartition
```
DataPartition<T> centroidPartition
```
    - dimension
```
int dimension
```
- Class edu.iu.dsc.tws.examples.batch.cdfw.KMeansDataObjectCompute extends BaseCompute implements Serializable
  
  serialVersionUID:
  
  -254264120110286748L
  - Serialized Fields
    - edgeName
```
java.lang.String edgeName
```
      Edge name to write the partitoned datapoints
    - parallel
```
int parallel
```
      Task parallelism
    - datasize
```
int datasize
```
      Data size
    - dimension
```
int dimension
```
      Dimension of the datapoints
    - dataPointsLocal
```
double[][] dataPointsLocal
```
      Datapoints array
- Class edu.iu.dsc.tws.examples.batch.cdfw.KMeansDataObjectDirectSink extends BaseCompute implements Serializable
  
  serialVersionUID:
  
  -1L
  - Serialized Fields
    - dataPointsLocal
```
double[][] dataPointsLocal
```
    - inputKey
```
java.lang.String inputKey
```
- Class edu.iu.dsc.tws.examples.batch.cdfw.ParallelDataFlowsExample.Aggregator extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  -254264120110286748L
- Class edu.iu.dsc.tws.examples.batch.cdfw.TwoDataFlowsExample.Aggregator extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  -254264120110286748L
Package edu.iu.dsc.tws.examples.batch.csv
- Class edu.iu.dsc.tws.examples.batch.csv.CSVTSetSourceExample extends java.lang.Object implements Serializable
Package edu.iu.dsc.tws.examples.batch.kmeans
- Class edu.iu.dsc.tws.examples.batch.kmeans.CSVInputFormatTest.TestSink extends BaseCompute implements Serializable
  
  serialVersionUID:
  
  -254264903510284748L
  - Serialized Fields
    - inputKey
```
java.lang.String inputKey
```
- Class edu.iu.dsc.tws.examples.batch.kmeans.CSVInputFormatTest.TestSource extends BaseSource implements Serializable
  
  serialVersionUID:
  
  -254264903510284748L
  - Serialized Fields
    - inputKey
```
java.lang.String inputKey
```
- Class edu.iu.dsc.tws.examples.batch.kmeans.KMeansComputeJob.CentroidAggregator extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  -254264120110286748L
- Class edu.iu.dsc.tws.examples.batch.kmeans.KMeansComputeJob.KMeansAllReduceTask extends BaseCompute implements Serializable
  
  serialVersionUID:
  
  -5190777711234234L
  - Serialized Fields
    - newCentroids
```
double[][] newCentroids
```
- Class edu.iu.dsc.tws.examples.batch.kmeans.KMeansComputeJob.KMeansSourceTask extends BaseSource implements Serializable
  
  serialVersionUID:
  
  -254264120110286748L
  - Serialized Fields
    - dataPartition
```
DataPartition<T> dataPartition
```
    - centroidPartition
```
DataPartition<T> centroidPartition
```
- Class edu.iu.dsc.tws.examples.batch.kmeans.KMeansTsetJob extends java.lang.Object implements Serializable
- Class edu.iu.dsc.tws.examples.batch.kmeans.KMeansTsetJob.CenterSource extends BaseSourceFunc<double[][]> implements Serializable
  - Serialized Fields
    - source
```
DataSource<T,O extends InputSplit<T>> source
```
    - read
```
boolean read
```
    - dimension
```
int dimension
```
    - centers
```
double[][] centers
```
    - fileType
```
java.lang.String fileType
```
- Class edu.iu.dsc.tws.examples.batch.kmeans.PointDataSource extends BaseSource implements Serializable
  
  serialVersionUID:
  
  -1L
  - Serialized Fields
    - source
```
DataSource<T,O extends InputSplit<T>> source
```
    - edgeName
```
java.lang.String edgeName
```
    - dataDirectory
```
java.lang.String dataDirectory
```
    - inputKey
```
java.lang.String inputKey
```
    - fileType
```
java.lang.String fileType
```
    - dimension
```
int dimension
```
    - datasize
```
int datasize
```
    - dataPointsLocal
```
double[][] dataPointsLocal
```
- Class edu.iu.dsc.tws.examples.batch.kmeans.TaskGraphBuildTest.Aggregator extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  -254264120110286748L
- Class edu.iu.dsc.tws.examples.batch.kmeans.TaskGraphBuildTest.TestSink1 extends BaseCompute implements Serializable
  
  serialVersionUID:
  
  -254264903510284748L
- Class edu.iu.dsc.tws.examples.batch.kmeans.TaskGraphBuildTest.TestSink2 extends BaseCompute implements Serializable
  
  serialVersionUID:
  
  -254264903510284748L
- Class edu.iu.dsc.tws.examples.batch.kmeans.TaskGraphBuildTest.TestSource extends BaseSource implements Serializable
  
  serialVersionUID:
  
  -254264903510284748L
Package edu.iu.dsc.tws.examples.batch.terasort
- Class edu.iu.dsc.tws.examples.batch.terasort.TaskPartitionerForRandom extends java.lang.Object implements Serializable
  - Serialized Fields
    - keysToOneTask
```
int keysToOneTask
```
    - destinationsList
```
int[] destinationsList
```
- Class edu.iu.dsc.tws.examples.batch.terasort.TaskPartitionerForSampledData extends TaskPartitionerForRandom implements Serializable
  - Serialized Fields
    - minMax
```
byte[] minMax
```
    - keySize
```
int keySize
```
    - ratio
```
double ratio
```
    - minIndexForSample
```
int minIndexForSample
```
    - maxIndexMaxIndexForSample
```
int maxIndexMaxIndexForSample
```
    - lowestTaskIndex
```
int lowestTaskIndex
```
- Class edu.iu.dsc.tws.examples.batch.terasort.TeraSort.FileDataSource extends BaseSource implements Serializable
  - Serialized Fields
    - fileChannel
```
java.nio.channels.FileChannel fileChannel
```
    - tupleBuffers
```
java.nio.ByteBuffer[] tupleBuffers
```
    - sent
```
long sent
```
    - timingCondition
```
boolean timingCondition
```
    - keySize
```
int keySize
```
    - valueSize
```
int valueSize
```
- Class edu.iu.dsc.tws.examples.batch.terasort.TeraSort.RandomDataSource extends BaseSource implements Serializable
  - Serialized Fields
    - toSend
```
long toSend
```
    - sent
```
long sent
```
    - value
```
byte[] value
```
    - random
```
java.util.Random random
```
    - keySize
```
int keySize
```
    - timingCondition
```
boolean timingCondition
```
- Class edu.iu.dsc.tws.examples.batch.terasort.TeraSort.Receiver extends BKeyedGatherUnGroupedCompute<byte[],byte[]> implements Serializable
  - Serialized Fields
    - timingCondition
```
boolean timingCondition
```
    - resultsWriter
```
java.io.BufferedOutputStream resultsWriter
```
- Class edu.iu.dsc.tws.examples.batch.terasort.TeraSort.Sampler extends BaseSource implements Serializable
  - Serialized Fields
    - fileChannel
```
java.nio.channels.FileChannel fileChannel
```
    - keySize
```
int keySize
```
    - valueSize
```
int valueSize
```
    - sampleSize
```
int sampleSize
```
    - tupleBuffers
```
java.nio.ByteBuffer[] tupleBuffers
```
- Class edu.iu.dsc.tws.examples.batch.terasort.TeraSort.SamplerReduce extends AllReduceCompute<byte[]> implements Serializable
  - Serialized Fields
    - minMax
```
DataPartition<T> minMax
```
Package edu.iu.dsc.tws.examples.batch.wordcount.tset
- Class edu.iu.dsc.tws.examples.batch.wordcount.tset.FileBasedWordCount extends java.lang.Object implements Serializable
- Class edu.iu.dsc.tws.examples.batch.wordcount.tset.WordCount extends java.lang.Object implements Serializable
Package edu.iu.dsc.tws.examples.checkpointing
- Class edu.iu.dsc.tws.examples.checkpointing.CheckpointingTaskExample.ComputeTask extends BaseCompute<java.lang.Integer> implements Serializable
  - Serialized Fields
    - count
```
int count
```
- Class edu.iu.dsc.tws.examples.checkpointing.CheckpointingTaskExample.SinkTask extends BaseCompute<java.lang.Integer> implements Serializable
  - Serialized Fields
    - count
```
int count
```
- Class edu.iu.dsc.tws.examples.checkpointing.CheckpointingTaskExample.SourceTask extends BaseSource implements Serializable
  - Serialized Fields
    - count
```
int count
```
Package edu.iu.dsc.tws.examples.compatibility.storm
- Class edu.iu.dsc.tws.examples.compatibility.storm.MultiSpoutTopology.ExclamationBolt extends BaseRichBolt implements Serializable
  
  serialVersionUID:
  
  6945654705222426596L
- Class edu.iu.dsc.tws.examples.compatibility.storm.MultiSpoutTopology.TestWordSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    - randomString
```
RandomString randomString
```
    - spoutOutputCollector
```
SpoutOutputCollector spoutOutputCollector
```
    - topologyContext
```
TopologyContext topologyContext
```
- Class edu.iu.dsc.tws.examples.compatibility.storm.SentenceWordCountTopology.FastRandomSentenceSpout extends BaseRichSpout implements Serializable
  
  serialVersionUID:
  
  8068075156393183973L
  - Serialized Fields
    - sentences
```
java.lang.String[] sentences
```
    - rnd
```
java.util.Random rnd
```
    - collector
```
SpoutOutputCollector collector
```
- Class edu.iu.dsc.tws.examples.compatibility.storm.SentenceWordCountTopology.SplitSentence extends BaseBasicBolt implements Serializable
  
  serialVersionUID:
  
  1249629174039601217L
- Class edu.iu.dsc.tws.examples.compatibility.storm.SentenceWordCountTopology.WordCount extends BaseBasicBolt implements Serializable
  
  serialVersionUID:
  
  -8492566595062774310L
  - Serialized Fields
    - counts
```
java.util.Map<K,V> counts
```
- Class edu.iu.dsc.tws.examples.compatibility.storm.WordCountTopology.ConsumerBolt extends BaseRichBolt implements Serializable
  
  serialVersionUID:
  
  -5470591933906954522L
  - Serialized Fields
    - countMap
```
java.util.Map<K,V> countMap
```
- Class edu.iu.dsc.tws.examples.compatibility.storm.WordCountTopology.WordSpout extends BaseRichSpout implements Serializable
  
  serialVersionUID:
  
  4322775001819135036L
  - Serialized Fields
    - words
```
java.lang.String[] words
```
    - rnd
```
java.util.Random rnd
```
    - collector
```
SpoutOutputCollector collector
```
Package edu.iu.dsc.tws.examples.compatibility.storm.bench
- Class edu.iu.dsc.tws.examples.compatibility.storm.bench.StormBenchmark.DataSink extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  -254264903510284798L
  - Serialized Fields
    - timeStamps
```
java.util.List<E> timeStamps
```
    - messageCount
```
int messageCount
```
    - done
```
boolean done
```
    - dataSize
```
int dataSize
```
    - operation
```
java.lang.String operation
```
    - parallelSources
```
int parallelSources
```
- Class edu.iu.dsc.tws.examples.compatibility.storm.bench.StormBenchmark.Generator extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  -254264903510284798L
  - Serialized Fields
    - taskContext
```
TaskContext taskContext
```
    - data
```
double[] data
```
Package edu.iu.dsc.tws.examples.compatibility.storm.windowing
- Class edu.iu.dsc.tws.examples.compatibility.storm.windowing.IntervalWindowTopology.IntervalWindowBolt extends BaseWindowedBolt implements Serializable
  
  serialVersionUID:
  
  6945654705222426596L
- Class edu.iu.dsc.tws.examples.compatibility.storm.windowing.IntervalWindowTopology.TestWordSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    - spoutOutputCollector
```
SpoutOutputCollector spoutOutputCollector
```
    - counter
```
int counter
```
- Class edu.iu.dsc.tws.examples.compatibility.storm.windowing.SlidingWindowTopology.SlidingWindowBolt extends BaseWindowedBolt implements Serializable
  
  serialVersionUID:
  
  6945654705222426596L
- Class edu.iu.dsc.tws.examples.compatibility.storm.windowing.SlidingWindowTopology.TestWordSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    - spoutOutputCollector
```
SpoutOutputCollector spoutOutputCollector
```
    - counter
```
int counter
```
- Class edu.iu.dsc.tws.examples.compatibility.storm.windowing.TumblingWindowTopology.TestWordSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    - spoutOutputCollector
```
SpoutOutputCollector spoutOutputCollector
```
    - counter
```
int counter
```
- Class edu.iu.dsc.tws.examples.compatibility.storm.windowing.TumblingWindowTopology.TumblingWindowBolt extends BaseWindowedBolt implements Serializable
  
  serialVersionUID:
  
  6945654705222426596L
Package edu.iu.dsc.tws.examples.connectors
- Class edu.iu.dsc.tws.examples.connectors.KafkaExample.KSink extends java.lang.Object implements Serializable
  - Serialized Fields
    - sum
```
java.lang.Long sum
```
    - context
```
TaskContext context
```
- Class edu.iu.dsc.tws.examples.connectors.KafkaExample.KSource extends KafkaSource implements Serializable
Package edu.iu.dsc.tws.examples.internal.dataflowexperiment
- Class edu.iu.dsc.tws.examples.internal.dataflowexperiment.DataflowAddNodeExperiment.Aggregator extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  -254264120110286748L
- Class edu.iu.dsc.tws.examples.internal.dataflowexperiment.DataflowAddNodeExperiment.Aggregator1 extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  -254264120110286748L
- Class edu.iu.dsc.tws.examples.internal.dataflowexperiment.DataflowNodeExperiment.Aggregator extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  -254264120110286748L
- Class edu.iu.dsc.tws.examples.internal.dataflowexperiment.DataflowNodeExperiment.Aggregator1 extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  -254264120110286748L
Package edu.iu.dsc.tws.examples.internal.taskgraph
- Class edu.iu.dsc.tws.examples.internal.taskgraph.MultiComputeTasksGraphExample.Aggregator extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  -254264120110286748L
Package edu.iu.dsc.tws.examples.ml.svm.aggregate
- Class edu.iu.dsc.tws.examples.ml.svm.aggregate.IterativeAccuracyReduceFunction extends java.lang.Object implements Serializable
- Class edu.iu.dsc.tws.examples.ml.svm.aggregate.IterativeSVMAccuracyReduce extends BaseCompute<java.lang.Double> implements Serializable
  
  serialVersionUID:
  
  4268361215513644139L
  - Serialized Fields
    - newAccuracy
```
double newAccuracy
```
    - debug
```
boolean debug
```
    - status
```
boolean status
```
    - operationMode
```
OperationMode operationMode
```
- Class edu.iu.dsc.tws.examples.ml.svm.aggregate.IterativeSVMDataPointReduce extends BaseCompute<double[][]> implements Serializable
  
  serialVersionUID:
  
  5737384175970887837L
  - Serialized Fields
    - newDataPoint
```
double[][] newDataPoint
```
    - debug
```
boolean debug
```
    - status
```
boolean status
```
    - operationMode
```
OperationMode operationMode
```
- Class edu.iu.dsc.tws.examples.ml.svm.aggregate.IterativeSVMReduce extends BaseCompute implements Serializable
  
  serialVersionUID:
  
  -254264120110286748L
  - Serialized Fields
    - newWeightVector
```
double[][] newWeightVector
```
    - debug
```
boolean debug
```
    - status
```
boolean status
```
    - operationMode
```
OperationMode operationMode
```
- Class edu.iu.dsc.tws.examples.ml.svm.aggregate.IterativeSVMWeightVectorReduce extends BaseCompute<double[]> implements Serializable
  
  serialVersionUID:
  
  -2284525532560239802L
  - Serialized Fields
    - newWeightVector
```
double[] newWeightVector
```
    - debug
```
boolean debug
```
    - operationMode
```
OperationMode operationMode
```
- Class edu.iu.dsc.tws.examples.ml.svm.aggregate.IterativeTestingReduce extends java.lang.Object implements Serializable
- Class edu.iu.dsc.tws.examples.ml.svm.aggregate.IterativeTrainingReduce extends java.lang.Object implements Serializable
- Class edu.iu.dsc.tws.examples.ml.svm.aggregate.IterativeWeightVectorReduceFunction extends java.lang.Object implements Serializable
- Class edu.iu.dsc.tws.examples.ml.svm.aggregate.ReduceAggregator extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  -254264120110286748L
  - Serialized Fields
    - aggregatorResult
```
double[] aggregatorResult
```
- Class edu.iu.dsc.tws.examples.ml.svm.aggregate.SVMReduce extends BaseCompute implements Serializable
  
  serialVersionUID:
  
  -254264120110286748L
  - Serialized Fields
    - object
```
double[] object
```
    - debug
```
boolean debug
```
    - status
```
boolean status
```
    - operationMode
```
OperationMode operationMode
```
Package edu.iu.dsc.tws.examples.ml.svm.compute
- Class edu.iu.dsc.tws.examples.ml.svm.compute.IterativeStreamingCompute extends BaseCompute<double[]> implements Serializable
  
  serialVersionUID:
  
  332173590941256461L
  - Serialized Fields
    - aggregatedModels
```
java.util.List<E> aggregatedModels
```
    - newWeightVector
```
double[] newWeightVector
```
    - debug
```
boolean debug
```
    - operationMode
```
OperationMode operationMode
```
    - reduceFn
```
IFunction<T> reduceFn
```
    - evaluationInterval
```
int evaluationInterval
```
    - dataPointsObject
```
DataObject<T> dataPointsObject
```
    - datapoints
```
double[][] datapoints
```
    - svmJobParameters
```
SVMJobParameters svmJobParameters
```
    - trainedModel
```
TrainedModel trainedModel
```
- Class edu.iu.dsc.tws.examples.ml.svm.compute.IterativeSVMCompute extends BaseCompute implements Serializable
  
  serialVersionUID:
  
  -254264120110286748L
  - Serialized Fields
    - debug
```
boolean debug
```
    - streamDataPoint
```
double[] streamDataPoint
```
    - batchDataPoints
```
double[][] batchDataPoints
```
    - binaryBatchModel
```
BinaryBatchModel binaryBatchModel
```
    - wInit
```
double[] wInit
```
    - w
```
double[] w
```
    - x
```
double[] x
```
    - y
```
double y
```
    - operationMode
```
OperationMode operationMode
```
    - pegasosSgdSvm
```
PegasosSgdSvm pegasosSgdSvm
```
    - batchDataCount
```
int batchDataCount
```
- Class edu.iu.dsc.tws.examples.ml.svm.compute.SVMCompute extends BaseCompute implements Serializable
  
  serialVersionUID:
  
  -254264120110286748L
  - Serialized Fields
    - debug
```
boolean debug
```
    - streamDataPoint
```
double[] streamDataPoint
```
    - batchDataPoints
```
double[][] batchDataPoints
```
    - binaryBatchModel
```
BinaryBatchModel binaryBatchModel
```
    - wInit
```
double[] wInit
```
    - w
```
double[] w
```
    - x
```
double[] x
```
    - y
```
double y
```
    - operationMode
```
OperationMode operationMode
```
    - pegasosSgdSvm
```
PegasosSgdSvm pegasosSgdSvm
```
    - batchDataCount
```
int batchDataCount
```
Package edu.iu.dsc.tws.examples.ml.svm.compute.window
- Class edu.iu.dsc.tws.examples.ml.svm.compute.window.IterativeStreamingSinkEvaluator extends BaseCompute<java.lang.Double> implements Serializable
  
  serialVersionUID:
  
  1576464625318900125L
  - Serialized Fields
    - count
```
int count
```
- Class edu.iu.dsc.tws.examples.ml.svm.compute.window.IterativeStreamingWindowedCompute extends ProcessWindow<double[]> implements Serializable
  
  serialVersionUID:
  
  -2951513581887018830L
  - Serialized Fields
    - operationMode
```
OperationMode operationMode
```
    - svmJobParameters
```
SVMJobParameters svmJobParameters
```
    - binaryBatchModel
```
BinaryBatchModel binaryBatchModel
```
    - modelName
```
java.lang.String modelName
```
    - trainedModel
```
TrainedModel trainedModel
```
    - debug
```
boolean debug
```
Package edu.iu.dsc.tws.examples.ml.svm.data
- Class edu.iu.dsc.tws.examples.ml.svm.data.IterativeSVMDataObjectCompute extends AbstractIterableDataCompute<java.lang.String> implements Serializable
  
  serialVersionUID:
  
  2616064651374815799L
  - Serialized Fields
    - delemiter
```
java.lang.String delemiter
```
    - edgeName
```
java.lang.String edgeName
```
      Edge name to write the partitoned datapoints
    - parallelism
```
int parallelism
```
      Task parallelism
    - datasize
```
int datasize
```
      Data size
    - features
```
int features
```
      Dimension of the datapoints
    - dataPointsLocal
```
double[][] dataPointsLocal
```
      Datapoints array
- Class edu.iu.dsc.tws.examples.ml.svm.data.IterativeSVMDataObjectDirectSink extends AbstractIterableDataCompute<double[][]> implements Serializable
  
  serialVersionUID:
  
  556286022242885874L
  - Serialized Fields
    - dataPointsLocal
```
double[][] dataPointsLocal
```
- Class edu.iu.dsc.tws.examples.ml.svm.data.IterativeSVMPrimaryDataObjectDirectSink extends BaseCompute implements Serializable
  
  serialVersionUID:
  
  -1L
  - Serialized Fields
    - dataPointsLocal
```
double[][] dataPointsLocal
```
- Class edu.iu.dsc.tws.examples.ml.svm.data.IterativeSVMPrimaryWeightVectorObjectCompute extends BaseCompute implements Serializable
  
  serialVersionUID:
  
  -254264120110286748L
  - Serialized Fields
    - edgeName
```
java.lang.String edgeName
```
      Edge name to write the partitoned datapoints
    - parallelism
```
int parallelism
```
      Task parallelism
    - datasize
```
int datasize
```
      Data size
    - features
```
int features
```
      Dimension of the datapoints
    - dataPointsLocal
```
double[][] dataPointsLocal
```
      Datapoints array
- Class edu.iu.dsc.tws.examples.ml.svm.data.IterativeSVMWeightVectorObjectCompute extends AbstractIterableDataCompute<java.lang.String> implements Serializable
  
  serialVersionUID:
  
  -254264120110286748L
  - Serialized Fields
    - edgeName
```
java.lang.String edgeName
```
      Edge name to write the partitoned datapoints
    - parallelism
```
int parallelism
```
      Task parallelism
    - datasize
```
int datasize
```
      Data size
    - features
```
int features
```
      Dimension of the datapoints
    - dataPointsLocal
```
double[] dataPointsLocal
```
      Datapoints array
- Class edu.iu.dsc.tws.examples.ml.svm.data.IterativeSVMWeightVectorObjectDirectSink extends AbstractIterableDataCompute<double[]> implements Serializable
  
  serialVersionUID:
  
  -1L
  - Serialized Fields
    - dataPointsLocal
```
double[] dataPointsLocal
```
- Class edu.iu.dsc.tws.examples.ml.svm.data.SourceTaskDataLoader.SimpleDataAggregator extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  4948225063068433511L
  - Serialized Fields
    - object
```
java.lang.Object object
```
- Class edu.iu.dsc.tws.examples.ml.svm.data.SVMDataObjectSource extends BaseSource implements Serializable
  
  serialVersionUID:
  
  -3569318984520808783L
  - Serialized Fields
    - source
```
DataSource<T,O extends InputSplit<T>> source
```
    - edgeName
```
java.lang.String edgeName
```
      Edge name to write the partitoned datapoints
    - dataDirectory
```
java.lang.String dataDirectory
```
    - datasize
```
int datasize
```
Package edu.iu.dsc.tws.examples.ml.svm.exceptions
- Class edu.iu.dsc.tws.examples.ml.svm.exceptions.InputDataFormatException extends java.lang.Exception implements Serializable
- Class edu.iu.dsc.tws.examples.ml.svm.exceptions.InvalidArguments extends java.lang.Exception implements Serializable
- Class edu.iu.dsc.tws.examples.ml.svm.exceptions.MatrixMultiplicationException extends java.lang.Exception implements Serializable
- Class edu.iu.dsc.tws.examples.ml.svm.exceptions.NullDataSetException extends java.lang.Exception implements Serializable
Package edu.iu.dsc.tws.examples.ml.svm.integration.test
- Class edu.iu.dsc.tws.examples.ml.svm.integration.test.LocalTextInputPartitioner1 extends FileInputPartitioner<T> implements Serializable
  
  serialVersionUID:
  
  4957141554227629138L
  - Serialized Fields
    - nTasks
```
int nTasks
```
    - assigner
```
OrderedInputSplitAssigner<T> assigner
```
Package edu.iu.dsc.tws.examples.ml.svm.job
- Class edu.iu.dsc.tws.examples.ml.svm.job.SvmSgdOnlineRunner.ProcessWindowFunctionImpl extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  8517840191276879034L
- Class edu.iu.dsc.tws.examples.ml.svm.job.SvmSgdTsetRunner extends java.lang.Object implements Serializable
  - Serialized Fields
    - reduceParallelism
```
int reduceParallelism
```
    - dataStreamerParallelism
```
int dataStreamerParallelism
```
    - svmComputeParallelism
```
int svmComputeParallelism
```
    - features
```
int features
```
    - operationMode
```
OperationMode operationMode
```
    - svmJobParameters
```
SVMJobParameters svmJobParameters
```
    - binaryBatchModel
```
BinaryBatchModel binaryBatchModel
```
    - trainedWeightVector
```
CachedTSet<T> trainedWeightVector
```
    - trainingData
```
CachedTSet<T> trainingData
```
    - testingData
```
CachedTSet<T> testingData
```
    - dataLoadingTime
```
long dataLoadingTime
```
    - initializingTime
```
long initializingTime
```
    - initializingDTime
```
double initializingDTime
```
    - trainingTime
```
long trainingTime
```
    - testingTime
```
long testingTime
```
    - dataLoadingDTime
```
double dataLoadingDTime
```
    - trainingDTime
```
double trainingDTime
```
    - testingDTime
```
double testingDTime
```
    - totalTime
```
double totalTime
```
    - accuracy
```
double accuracy
```
    - debug
```
boolean debug
```
    - experimentName
```
java.lang.String experimentName
```
    - testStatus
```
boolean testStatus
```
Package edu.iu.dsc.tws.examples.ml.svm.math
- Class edu.iu.dsc.tws.examples.ml.svm.math.Matrix extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  -5712263538644901408L
Package edu.iu.dsc.tws.examples.ml.svm.sgd
- Class edu.iu.dsc.tws.examples.ml.svm.sgd.SgdSvm extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  7674550472679161913L
  - Serialized Fields
    - x
```
double[] x
```
    - y
```
double y
```
    - xBatch
```
double[][] xBatch
```
    - yBatch
```
double[] yBatch
```
    - alpha
```
double alpha
```
    - features
```
int features
```
    - samples
```
int samples
```
    - isInvalid
```
boolean isInvalid
```
    - w
```
double[] w
```
    - iterations
```
int iterations
```
    - trainingTime
```
long trainingTime
```
    - testingTime
```
long testingTime
```
    - dataLoadingTime
```
long dataLoadingTime
```
Package edu.iu.dsc.tws.examples.ml.svm.sgd.pegasos
- Class edu.iu.dsc.tws.examples.ml.svm.sgd.pegasos.PegasosSgdSvm extends SgdSvm implements Serializable
  
  serialVersionUID:
  
  -8279454451787246995L
  - Serialized Fields
    - wa
```
double[] wa
```
    - features
```
int features
```
    - xyia
```
double[] xyia
```
Package edu.iu.dsc.tws.examples.ml.svm.streamer
- Class edu.iu.dsc.tws.examples.ml.svm.streamer.DataStreamer extends BaseSource implements Serializable
  - Serialized Fields
    - labels
```
double[] labels
```
      Deprecated.
    - features
```
int features
```
      Deprecated.
    - operationMode
```
OperationMode operationMode
```
      Deprecated.
    - isDummy
```
boolean isDummy
```
      Deprecated.
    - binaryBatchModel
```
BinaryBatchModel binaryBatchModel
```
      Deprecated.
- Class edu.iu.dsc.tws.examples.ml.svm.streamer.InputDataStreamer extends BaseSource implements Serializable
  - Serialized Fields
    - labels
```
double[] labels
```
    - features
```
int features
```
    - operationMode
```
OperationMode operationMode
```
    - isDummy
```
boolean isDummy
```
    - binaryBatchModel
```
BinaryBatchModel binaryBatchModel
```
    - dataPointsObject
```
DataObject<T> dataPointsObject
```
    - weightVectorObject
```
DataObject<T> weightVectorObject
```
    - datapoints
```
java.lang.Object datapoints
```
    - weightVector
```
java.lang.Object weightVector
```
    - datapointArray
```
double[][] datapointArray
```
    - weightVectorArray
```
double[][] weightVectorArray
```
    - debug
```
boolean debug
```
- Class edu.iu.dsc.tws.examples.ml.svm.streamer.IterativeDataStream extends BaseSource implements Serializable
  
  serialVersionUID:
  
  6672551932831677547L
  - Serialized Fields
    - labels
```
double[] labels
```
    - features
```
int features
```
    - operationMode
```
OperationMode operationMode
```
    - isDummy
```
boolean isDummy
```
    - binaryBatchModel
```
BinaryBatchModel binaryBatchModel
```
    - dataPointsObject
```
DataObject<T> dataPointsObject
```
    - weightVectorObject
```
DataObject<T> weightVectorObject
```
    - datapoints
```
double[][] datapoints
```
    - weightVector
```
double[] weightVector
```
    - computedWeightVector
```
double[] computedWeightVector
```
    - pegasosSgdSvm
```
PegasosSgdSvm pegasosSgdSvm
```
    - debug
```
boolean debug
```
- Class edu.iu.dsc.tws.examples.ml.svm.streamer.IterativePredictionDataStreamer extends BaseSource implements Serializable
  
  serialVersionUID:
  
  -5619263102396811849L
  - Serialized Fields
    - labels
```
double[] labels
```
    - features
```
int features
```
    - operationMode
```
OperationMode operationMode
```
    - isDummy
```
boolean isDummy
```
    - binaryBatchModel
```
BinaryBatchModel binaryBatchModel
```
    - dataPointsObject
```
DataObject<T> dataPointsObject
```
    - weightVectorObject
```
DataObject<T> weightVectorObject
```
    - datapoints
```
double[][] datapoints
```
    - weightVector
```
double[] weightVector
```
    - pegasosSgdSvm
```
PegasosSgdSvm pegasosSgdSvm
```
    - debug
```
boolean debug
```
    - finalAccuracy
```
double finalAccuracy
```
- Class edu.iu.dsc.tws.examples.ml.svm.streamer.IterativeStreamingDataStreamer extends BaseSource implements Serializable
  
  serialVersionUID:
  
  -5845248990437663713L
  - Serialized Fields
    - labels
```
double[] labels
```
    - features
```
int features
```
    - operationMode
```
OperationMode operationMode
```
    - isDummy
```
boolean isDummy
```
    - binaryBatchModel
```
BinaryBatchModel binaryBatchModel
```
    - dataPointsObject
```
DataObject<T> dataPointsObject
```
    - weightVectorObject
```
DataObject<T> weightVectorObject
```
    - datapoints
```
double[][] datapoints
```
    - weightVector
```
double[] weightVector
```
    - debug
```
boolean debug
```
    - count
```
int count
```
    - isDataLoaded
```
boolean isDataLoaded
```
Package edu.iu.dsc.tws.examples.ml.svm.test
- Class edu.iu.dsc.tws.examples.ml.svm.test.PredictionAggregator extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  -254264120110286748L
  - Serialized Fields
    - aggregatorResult
```
java.lang.Object aggregatorResult
```
- Class edu.iu.dsc.tws.examples.ml.svm.test.PredictionReduceTask extends BaseCompute implements Serializable
  
  serialVersionUID:
  
  -254264120110286748L
  - Serialized Fields
    - object
```
double[] object
```
    - doubleObject
```
double doubleObject
```
    - debug
```
boolean debug
```
    - status
```
boolean status
```
    - operationMode
```
OperationMode operationMode
```
- Class edu.iu.dsc.tws.examples.ml.svm.test.PredictionSourceTask extends BaseSource implements Serializable
  - Serialized Fields
    - isDummy
```
boolean isDummy
```
    - binaryBatchModel
```
BinaryBatchModel binaryBatchModel
```
    - testDataPointsObject
```
DataObject<T> testDataPointsObject
```
    - testDataPoints
```
java.lang.Object testDataPoints
```
    - testDatapointArray
```
double[][] testDatapointArray
```
    - weightVectorObject
```
DataObject<T> weightVectorObject
```
    - weighVector
```
java.lang.Object weighVector
```
    - weightVectorArray
```
double[] weightVectorArray
```
    - operationMode
```
OperationMode operationMode
```
    - accuracy
```
double accuracy
```
    - debug
```
boolean debug
```
Package edu.iu.dsc.tws.examples.ml.svm.tset
- Class edu.iu.dsc.tws.examples.ml.svm.tset.AccuracyAverager extends java.lang.Object implements Serializable
  - Serialized Fields
    - parallelism
```
int parallelism
```
- Class edu.iu.dsc.tws.examples.ml.svm.tset.DataLoadingTask extends BaseSourceFunc<double[][]> implements Serializable
  - Serialized Fields
    - binaryBatchModel
```
BinaryBatchModel binaryBatchModel
```
    - svmJobParameters
```
SVMJobParameters svmJobParameters
```
    - read
```
boolean read
```
    - dataSize
```
int dataSize
```
    - dimension
```
int dimension
```
    - parallelism
```
int parallelism
```
    - config
```
Config config
```
    - localPoints
```
double[][] localPoints
```
    - source
```
DataSource<T,O extends InputSplit<T>> source
```
    - dataType
```
java.lang.String dataType
```
    - debug
```
boolean debug
```
- Class edu.iu.dsc.tws.examples.ml.svm.tset.ModelAverager extends java.lang.Object implements Serializable
  - Serialized Fields
    - parallelism
```
int parallelism
```
- Class edu.iu.dsc.tws.examples.ml.svm.tset.SvmTestMap extends java.lang.Object implements Serializable
  - Serialized Fields
    - binaryBatchModel
```
BinaryBatchModel binaryBatchModel
```
    - svmJobParameters
```
SVMJobParameters svmJobParameters
```
    - predict
```
Predict predict
```
    - localAccuracy
```
double localAccuracy
```
    - debug
```
boolean debug
```
    - context
```
TSetContext context
```
- Class edu.iu.dsc.tws.examples.ml.svm.tset.SvmTrainMap extends BaseTFunction<double[],double[][]> implements Serializable
  - Serialized Fields
    - w
```
double[] w
```
    - binaryBatchModel
```
BinaryBatchModel binaryBatchModel
```
    - svmJobParameters
```
SVMJobParameters svmJobParameters
```
    - pegasosSgdSvm
```
PegasosSgdSvm pegasosSgdSvm
```
    - debug
```
boolean debug
```
- Class edu.iu.dsc.tws.examples.ml.svm.tset.WeightVectorAverager extends java.lang.Object implements Serializable
  - Serialized Fields
    - parallelism
```
int parallelism
```
- Class edu.iu.dsc.tws.examples.ml.svm.tset.WeightVectorLoad extends BaseSourceFunc<double[]> implements Serializable
  
  serialVersionUID:
  
  -8333645489977825619L
  - Serialized Fields
    - binaryBatchModel
```
BinaryBatchModel binaryBatchModel
```
    - svmJobParameters
```
SVMJobParameters svmJobParameters
```
    - read
```
boolean read
```
    - dataSize
```
int dataSize
```
    - dimension
```
int dimension
```
    - parallelism
```
int parallelism
```
    - config
```
Config config
```
    - localPoints
```
double[] localPoints
```
    - source
```
DataSource<T,O extends InputSplit<T>> source
```
    - dataType
```
java.lang.String dataType
```
    - debug
```
boolean debug
```
Package edu.iu.dsc.tws.examples.ml.svm.util
- Class edu.iu.dsc.tws.examples.ml.svm.util.BinaryBatchModel extends Model implements Serializable
  
  serialVersionUID:
  
  4109749989421999985L
  - Serialized Fields
    - x
```
double[][] x
```
      All data points involved in the batch mode execution Memory bound exceptions has to be handled X keeps all the data points per this worker in it's memory
    - y
```
double[] y
```
      All the labels of datapoints kept in memory
    - xy
```
double[][] xy
```
      Temporary filed to hold the incoming {y_i,x_i} combined message
    - iterations
```
int iterations
```
      Number of iterations for the batch mode iterative algorithm
    - features
```
int features
```
      Number of elements in a given data point (dimensionality)
    - samples
```
int samples
```
      Number of data samples in the batch mode
    - alpha
```
double alpha
```
      Learning rate
    - w
```
double[] w
```
      Weight vector and takes the shape of a single data point.
- Class edu.iu.dsc.tws.examples.ml.svm.util.Model extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  -3452275060295386696L
  - Serialized Fields
    - samples
```
int samples
```
      Number of data points
    - features
```
int features
```
      Number of features in a data point (dimensions)
    - labels
```
double[] labels
```
      Class labels in the classification {+1,-1} is the default for Binary Classification
    - w
```
double[] w
```
      Weight Vector
    - alpha
```
double alpha
```
      Learning rate
- Class edu.iu.dsc.tws.examples.ml.svm.util.SVMJobParameters extends java.lang.Object implements Serializable
  - Serialized Fields
    - features
```
int features
```
      Number of features in a data point
    - samples
```
int samples
```
      Number of data points
    - testingSamples
```
int testingSamples
```
      Number of testing data points
    - isStreaming
```
boolean isStreaming
```
    - trainingDataDir
```
java.lang.String trainingDataDir
```
      Training data directory {csv format data is expected {label, features}}
    - testingDataDir
```
java.lang.String testingDataDir
```
      Testing data directory {csv format data is expected {label, features}}
    - crossValidationDataDir
```
java.lang.String crossValidationDataDir
```
      Cross-Validation data directory {csv format data is expected {label, features}}
    - weightVectorDataDir
```
java.lang.String weightVectorDataDir
```
    - modelSaveDir
```
java.lang.String modelSaveDir
```
      Saving trained model
    - iterations
```
int iterations
```
      Iterations in training model Stream mode , iterations = 1
    - alpha
```
double alpha
```
      Learning rate
    - c
```
double c
```
      Hyper Parameter ; default is 1.0
    - isSplit
```
boolean isSplit
```
      Is data split from a single source [training, cross-validation, testing]
    - isDummy
```
boolean isDummy
```
    - parallelism
```
int parallelism
```
    - experimentName
```
java.lang.String experimentName
```
      Experiment name == Job Name
    - windowArguments
```
WindowArguments windowArguments
```
      WindowParameter object holds the window type, window length, slide size
- Class edu.iu.dsc.tws.examples.ml.svm.util.TrainedModel extends Model implements Serializable
  
  serialVersionUID:
  
  -6049759570540858599L
  - Serialized Fields
    - accuracy
```
double accuracy
```
    - trainingTime
```
double trainingTime
```
    - modelName
```
java.lang.String modelName
```
    - parallelism
```
int parallelism
```
- Class edu.iu.dsc.tws.examples.ml.svm.util.WindowArguments extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  7215545889817090308L
  - Serialized Fields
    - windowType
```
WindowType windowType
```
    - windowLength
```
long windowLength
```
    - slidingLength
```
long slidingLength
```
    - isDuration
```
boolean isDuration
```
Package edu.iu.dsc.tws.examples.streaming.wordcount.tset
- Class edu.iu.dsc.tws.examples.streaming.wordcount.tset.WordCount extends java.lang.Object implements Serializable
Package edu.iu.dsc.tws.examples.task
- Class edu.iu.dsc.tws.examples.task.BenchTaskWorker.SourceTask extends BaseSource implements Serializable
  
  serialVersionUID:
  
  -254264903510284748L
  - Serialized Fields
    - count
```
int count
```
    - edge
```
java.lang.String edge
```
    - iterations
```
int iterations
```
    - timingCondition
```
boolean timingCondition
```
    - keyed
```
boolean keyed
```
    - endNotified
```
boolean endNotified
```
    - markTimingOnlyForLowestTarget
```
boolean markTimingOnlyForLowestTarget
```
    - noOfTargets
```
int noOfTargets
```
- Class edu.iu.dsc.tws.examples.task.BenchTaskWorker.SourceWindowTask extends BaseWindowSource implements Serializable
  
  serialVersionUID:
  
  -254264903510284748L
  - Serialized Fields
    - count
```
int count
```
    - edge
```
java.lang.String edge
```
    - iterations
```
int iterations
```
    - timingCondition
```
boolean timingCondition
```
    - keyed
```
boolean keyed
```
    - endNotified
```
boolean endNotified
```
    - markTimingOnlyForLowestTarget
```
boolean markTimingOnlyForLowestTarget
```
    - noOfTargets
```
int noOfTargets
```
- Class edu.iu.dsc.tws.examples.task.BenchTaskWorker.SourceWindowTimeStampTask extends BaseWindowSource implements Serializable
  
  serialVersionUID:
  
  -254264903510284748L
  - Serialized Fields
    - count
```
int count
```
    - edge
```
java.lang.String edge
```
    - iterations
```
int iterations
```
    - timingCondition
```
boolean timingCondition
```
    - keyed
```
boolean keyed
```
    - prevTime
```
long prevTime
```
    - endNotified
```
boolean endNotified
```
    - markTimingOnlyForLowestTarget
```
boolean markTimingOnlyForLowestTarget
```
    - noOfTargets
```
int noOfTargets
```
- Class edu.iu.dsc.tws.examples.task.BenchWindowTaskWorker.SourceWindowTask extends BaseWindowSource implements Serializable
  
  serialVersionUID:
  
  -6402650835073995738L
  - Serialized Fields
    - count
```
int count
```
    - edge
```
java.lang.String edge
```
    - iterations
```
int iterations
```
    - endNotified
```
boolean endNotified
```
Package edu.iu.dsc.tws.examples.task.batch
- Class edu.iu.dsc.tws.examples.task.batch.BTAllGatherExample.AllGatherSinkTask extends AllGatherCompute<int[]> implements Serializable
  
  serialVersionUID:
  
  -254264903510284798L
  - Serialized Fields
    - resultsVerifier
```
ResultsVerifier<I,O> resultsVerifier
```
    - verified
```
boolean verified
```
    - timingCondition
```
boolean timingCondition
```
- Class edu.iu.dsc.tws.examples.task.batch.BTAllReduceExample.AllReduceSinkTask extends AllReduceCompute<int[]> implements Serializable
  
  serialVersionUID:
  
  -254264903510284798L
  - Serialized Fields
    - timingCondition
```
boolean timingCondition
```
    - resultsVerifier
```
ResultsVerifier<I,O> resultsVerifier
```
    - verified
```
boolean verified
```
- Class edu.iu.dsc.tws.examples.task.batch.BTBroadCastExample.BroadcastSinkTask extends BBroadCastCompute<int[]> implements Serializable
  
  serialVersionUID:
  
  -254264903510284798L
  - Serialized Fields
    - resultsVerifier
```
ResultsVerifier<I,O> resultsVerifier
```
    - verified
```
boolean verified
```
    - timingCondition
```
boolean timingCondition
```
- Class edu.iu.dsc.tws.examples.task.batch.BTDirectExample.PartitionSinkTask extends BPartitionCompute<int[]> implements Serializable
  
  serialVersionUID:
  
  -254264903510284798L
  - Serialized Fields
    - resultsVerifier
```
ResultsVerifier<I,O> resultsVerifier
```
    - verified
```
boolean verified
```
    - timingCondition
```
boolean timingCondition
```
- Class edu.iu.dsc.tws.examples.task.batch.BTGatherExample.GatherSinkTask extends GatherCompute<int[]> implements Serializable
  
  serialVersionUID:
  
  -254264903510284798L
  - Serialized Fields
    - resultsVerifier
```
ResultsVerifier<I,O> resultsVerifier
```
    - verified
```
boolean verified
```
    - timingCondition
```
boolean timingCondition
```
- Class edu.iu.dsc.tws.examples.task.batch.BTJoinExample.JoinSinkTask extends BJoinCompute<java.lang.Integer,int[],int[]> implements Serializable
  
  serialVersionUID:
  
  -254264903510284798L
  - Serialized Fields
    - resultsVerifier
```
ResultsVerifier<I,O> resultsVerifier
```
    - verified
```
boolean verified
```
    - timingCondition
```
boolean timingCondition
```
- Class edu.iu.dsc.tws.examples.task.batch.BTJoinExample.JoinSource extends BaseSource implements Serializable
  - Serialized Fields
    - count
```
int count
```
    - iterations
```
int iterations
```
    - timingCondition
```
boolean timingCondition
```
    - endNotified
```
boolean endNotified
```
    - joinRelation
```
JoinRelation joinRelation
```
- Class edu.iu.dsc.tws.examples.task.batch.BTKeyedGatherExample.KeyedGatherGroupedSinkTask extends BKeyedGatherGroupedCompute<java.lang.Integer,int[]> implements Serializable
  
  serialVersionUID:
  
  -254264903510284798L
  - Serialized Fields
    - resultsVerifier
```
ResultsVerifier<I,O> resultsVerifier
```
    - verified
```
boolean verified
```
    - timingCondition
```
boolean timingCondition
```
- Class edu.iu.dsc.tws.examples.task.batch.BTKeyedReduceExample.KeyedReduceSinkTask extends BKeyedReduceCompute<java.lang.Integer,int[]> implements Serializable
  
  serialVersionUID:
  
  -254264903510284798L
  - Serialized Fields
    - resultsVerifier
```
ResultsVerifier<I,O> resultsVerifier
```
    - verified
```
boolean verified
```
    - timingCondition
```
boolean timingCondition
```
- Class edu.iu.dsc.tws.examples.task.batch.BTPartitionExample.PartitionSinkTask extends BPartitionCompute<int[]> implements Serializable
  
  serialVersionUID:
  
  -254264903510284798L
  - Serialized Fields
    - resultsVerifier
```
ResultsVerifier<I,O> resultsVerifier
```
    - verified
```
boolean verified
```
    - timingCondition
```
boolean timingCondition
```
- Class edu.iu.dsc.tws.examples.task.batch.BTPartitionKeyedExample.BKeyedPartitionSinkTask extends BKeyedPartitionCompute<java.lang.Integer,int[]> implements Serializable
  
  serialVersionUID:
  
  -254264903510284798L
  - Serialized Fields
    - resultsVerifier
```
ResultsVerifier<I,O> resultsVerifier
```
    - verified
```
boolean verified
```
    - timingCondition
```
boolean timingCondition
```
- Class edu.iu.dsc.tws.examples.task.batch.BTReduceExample.ReduceSinkTask extends ReduceCompute<int[]> implements Serializable
  
  serialVersionUID:
  
  -254264903510284798L
  - Serialized Fields
    - timingCondition
```
boolean timingCondition
```
    - resultsVerifier
```
ResultsVerifier<I,O> resultsVerifier
```
    - verified
```
boolean verified
```
Package edu.iu.dsc.tws.examples.task.dataparallel
- Class edu.iu.dsc.tws.examples.task.dataparallel.DataParallelTask extends BaseSource implements Serializable
  
  serialVersionUID:
  
  -1L
  - Serialized Fields
    - source
```
DataSource<T,O extends InputSplit<T>> source
```
    - sink
```
DataSink<T> sink
```
Package edu.iu.dsc.tws.examples.task.streaming
- Class edu.iu.dsc.tws.examples.task.streaming.STAllGatherExample.AllGatherSinkTask extends AllGatherCompute<int[]> implements Serializable
  
  serialVersionUID:
  
  -254264903510284798L
  - Serialized Fields
    - resultsVerifier
```
ResultsVerifier<I,O> resultsVerifier
```
    - verified
```
boolean verified
```
    - timingCondition
```
boolean timingCondition
```
    - count
```
int count
```
- Class edu.iu.dsc.tws.examples.task.streaming.STAllReduceExample.AllReduceSinkTask extends AllReduceCompute<int[]> implements Serializable
  
  serialVersionUID:
  
  -254264903510284798L
  - Serialized Fields
    - resultsVerifier
```
ResultsVerifier<I,O> resultsVerifier
```
    - verified
```
boolean verified
```
    - timingCondition
```
boolean timingCondition
```
    - count
```
int count
```
- Class edu.iu.dsc.tws.examples.task.streaming.STBroadCastExample.BroadCastSinkTask extends SBroadCastCompute<int[]> implements Serializable
  
  serialVersionUID:
  
  -254264903510284798L
  - Serialized Fields
    - resultsVerifier
```
ResultsVerifier<I,O> resultsVerifier
```
    - verified
```
boolean verified
```
    - timingCondition
```
boolean timingCondition
```
    - count
```
int count
```
- Class edu.iu.dsc.tws.examples.task.streaming.STGatherExample.GatherSinkTask extends GatherCompute<int[]> implements Serializable
  
  serialVersionUID:
  
  -254264903510284798L
  - Serialized Fields
    - resultsVerifier
```
ResultsVerifier<I,O> resultsVerifier
```
    - verified
```
boolean verified
```
    - timingCondition
```
boolean timingCondition
```
    - count
```
int count
```
- Class edu.iu.dsc.tws.examples.task.streaming.STKeyedGatherExample.KeyedGatherSinkTask extends KeyedGatherCompute<java.lang.Integer,int[]> implements Serializable
  
  serialVersionUID:
  
  -254264903510284798L
  - Serialized Fields
    - resultsVerifier
```
ResultsVerifier<I,O> resultsVerifier
```
    - verified
```
boolean verified
```
    - timingCondition
```
boolean timingCondition
```
    - count
```
int count
```
- Class edu.iu.dsc.tws.examples.task.streaming.STKeyedReduceExample.KeyedReduceSinkTask extends SKeyedReduceCompute<java.lang.Integer,int[]> implements Serializable
  
  serialVersionUID:
  
  -254264903510284798L
- Class edu.iu.dsc.tws.examples.task.streaming.STPartitionExample.PartitionSinkTask extends SPartitionCompute<int[]> implements Serializable
  
  serialVersionUID:
  
  -254264903510284798L
  - Serialized Fields
    - resultsVerifier
```
ResultsVerifier<I,O> resultsVerifier
```
    - verified
```
boolean verified
```
    - timingCondition
```
boolean timingCondition
```
    - count
```
int count
```
    - countTotal
```
int countTotal
```
    - expectedWarmups
```
int expectedWarmups
```
    - expectedTotal
```
int expectedTotal
```
    - expectedTotalFromAll
```
int expectedTotalFromAll
```
- Class edu.iu.dsc.tws.examples.task.streaming.STPartitionKeyedExample.SKeyedPartitionSinkTask extends SKeyedPartitionCompute<java.lang.Integer,int[]> implements Serializable
  
  serialVersionUID:
  
  -254264903510284798L
  - Serialized Fields
    - resultsVerifier
```
ResultsVerifier<I,O> resultsVerifier
```
    - verified
```
boolean verified
```
    - timingCondition
```
boolean timingCondition
```
    - count
```
int count
```
    - lowestSource
```
int lowestSource
```
- Class edu.iu.dsc.tws.examples.task.streaming.STReduceExample.ReduceSinkTask extends ReduceCompute<int[]> implements Serializable
  
  serialVersionUID:
  
  -254264903510284798L
  - Serialized Fields
    - resultsVerifier
```
ResultsVerifier<I,O> resultsVerifier
```
    - verified
```
boolean verified
```
    - timingCondition
```
boolean timingCondition
```
    - count
```
int count
```
Package edu.iu.dsc.tws.examples.task.streaming.windowing
- Class edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowCustomExample.DirectCustomWindowReceiver extends BaseWindowedSink<int[]> implements Serializable
- Class edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowEventTimeExample.AggregateFunctionImpl extends java.lang.Object implements Serializable
  - Serialized Fields
    - weight1
```
int weight1
```
    - weight2
```
int weight2
```
- Class edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowEventTimeExample.DirectAggregateWindowedTask extends AggregateWindow<int[]> implements Serializable
- Class edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowEventTimeExample.DirectFoldWindowedTask extends FoldWindow<int[],java.lang.String> implements Serializable
- Class edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowEventTimeExample.DirectProcessWindowedIntTask extends ProcessWindow<EventTimeData> implements Serializable
- Class edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowEventTimeExample.DirectProcessWindowedTask extends ProcessWindow<IntData> implements Serializable
- Class edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowEventTimeExample.DirectReceiveTask extends DirectCompute<int[]> implements Serializable
  
  serialVersionUID:
  
  -254264903510284798L
  - Serialized Fields
    - count
```
int count
```
- Class edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowEventTimeExample.DirectReduceWindowedTask extends ReduceWindow<int[]> implements Serializable
- Class edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowEventTimeExample.DirectWindowedReceivingTask extends BaseWindowedSink<int[]> implements Serializable
- Class edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowEventTimeExample.FoldFunctionImpl extends java.lang.Object implements Serializable
  - Serialized Fields
    - ans
```
int[] ans
```
- Class edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowEventTimeExample.ProcessFunctionImpl extends java.lang.Object implements Serializable
- Class edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowEventTimeExample.ProcessFunctionIntImpl extends java.lang.Object implements Serializable
- Class edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowEventTimeExample.ReduceFunctionImpl extends java.lang.Object implements Serializable
- Class edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowExample.AggregateFunctionImpl extends java.lang.Object implements Serializable
  - Serialized Fields
    - weight1
```
int weight1
```
    - weight2
```
int weight2
```
- Class edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowExample.DirectAggregateWindowedTask extends AggregateWindow<int[]> implements Serializable
- Class edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowExample.DirectFoldWindowedTask extends FoldWindow<int[],java.lang.String> implements Serializable
- Class edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowExample.DirectProcessWindowedTask extends ProcessWindow<int[]> implements Serializable
- Class edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowExample.DirectReceiveTask extends DirectCompute<int[]> implements Serializable
  
  serialVersionUID:
  
  -254264903510284798L
  - Serialized Fields
    - count
```
int count
```
- Class edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowExample.DirectReduceWindowedTask extends ReduceWindow<int[]> implements Serializable
- Class edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowExample.DirectWindowedReceivingTask extends BaseWindowedSink<int[]> implements Serializable
- Class edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowExample.FoldFunctionImpl extends java.lang.Object implements Serializable
  - Serialized Fields
    - ans
```
int[] ans
```
- Class edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowExample.ProcessFunctionImpl extends java.lang.Object implements Serializable
- Class edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowExample.ReduceFunctionImpl extends java.lang.Object implements Serializable
- Class edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowMPI.DirectWindowedReceivingTask extends BaseWindowedSink<int[]> implements Serializable
Package edu.iu.dsc.tws.examples.task.streaming.windowing.data
- Class edu.iu.dsc.tws.examples.task.streaming.windowing.data.EventTimeData extends java.lang.Object implements Serializable
  - Serialized Fields
    - data
```
int[] data
```
    - id
```
int id
```
    - eventTime
```
long eventTime
```
Package edu.iu.dsc.tws.examples.task.streaming.windowing.extract
- Class edu.iu.dsc.tws.examples.task.streaming.windowing.extract.EventTimeExtractor extends TimestampExtractor<EventTimeData> implements Serializable
Package edu.iu.dsc.tws.examples.tset
- Class edu.iu.dsc.tws.examples.tset.BaseTSetBatchWorker extends java.lang.Object implements Serializable
- Class edu.iu.dsc.tws.examples.tset.BaseTSetBatchWorker.TestBaseSource extends java.lang.Object implements Serializable
  - Serialized Fields
    - count
```
int count
```
    - values
```
int[] values
```
- Class edu.iu.dsc.tws.examples.tset.HadoopTSet extends java.lang.Object implements Serializable
- Class edu.iu.dsc.tws.examples.tset.HelloTSet extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  -2L
Package edu.iu.dsc.tws.examples.tset.batch
- Class edu.iu.dsc.tws.examples.tset.batch.AddInputsExample extends BatchTsetExample implements Serializable
  
  serialVersionUID:
  
  -2753072757838198105L
- Class edu.iu.dsc.tws.examples.tset.batch.AllGatherExample extends BatchTsetExample implements Serializable
  
  serialVersionUID:
  
  -2753072757838198105L
- Class edu.iu.dsc.tws.examples.tset.batch.AllReduceExample extends BatchTsetExample implements Serializable
  
  serialVersionUID:
  
  -2753072757838198105L
- Class edu.iu.dsc.tws.examples.tset.batch.BatchTsetExample extends java.lang.Object implements Serializable
- Class edu.iu.dsc.tws.examples.tset.batch.BranchingExample extends BatchTsetExample implements Serializable
- Class edu.iu.dsc.tws.examples.tset.batch.BroadcastExample extends BatchTsetExample implements Serializable
  
  serialVersionUID:
  
  -2753072757838198105L
- Class edu.iu.dsc.tws.examples.tset.batch.CacheExample extends BatchTsetExample implements Serializable
  
  serialVersionUID:
  
  -2753072757838198105L
- Class edu.iu.dsc.tws.examples.tset.batch.ComputeCollectExample extends BatchTsetExample implements Serializable
  
  serialVersionUID:
  
  -2753072757838198105L
- Class edu.iu.dsc.tws.examples.tset.batch.ComputeExample extends BatchTsetExample implements Serializable
  
  serialVersionUID:
  
  -2753072757838198105L
- Class edu.iu.dsc.tws.examples.tset.batch.DirectExample extends BatchTsetExample implements Serializable
  
  serialVersionUID:
  
  -2753072757838198105L
- Class edu.iu.dsc.tws.examples.tset.batch.DirectIterExample extends BatchTsetExample implements Serializable
  
  serialVersionUID:
  
  -2753072757838198105L
- Class edu.iu.dsc.tws.examples.tset.batch.EvaluateExample extends BatchTsetExample implements Serializable
  
  serialVersionUID:
  
  -2753072757838198105L
- Class edu.iu.dsc.tws.examples.tset.batch.FullGraphRunExample extends BatchTsetExample implements Serializable
  
  serialVersionUID:
  
  -2753072757838198105L
- Class edu.iu.dsc.tws.examples.tset.batch.GatherExample extends BatchTsetExample implements Serializable
  
  serialVersionUID:
  
  -2753072757838198105L
- Class edu.iu.dsc.tws.examples.tset.batch.JoinExample extends BatchTsetExample implements Serializable
- Class edu.iu.dsc.tws.examples.tset.batch.KeyedAddInputsExample extends BatchTsetExample implements Serializable
  
  serialVersionUID:
  
  -2753072757838198105L
- Class edu.iu.dsc.tws.examples.tset.batch.KeyedOperationsExample extends BatchTsetExample implements Serializable
- Class edu.iu.dsc.tws.examples.tset.batch.KGatherExample extends BatchTsetExample implements Serializable
  
  serialVersionUID:
  
  -2753072757838198105L
- Class edu.iu.dsc.tws.examples.tset.batch.KGatherUngroupedExample extends BatchTsetExample implements Serializable
  
  serialVersionUID:
  
  -2753072757838198105L
- Class edu.iu.dsc.tws.examples.tset.batch.KPartitionExample extends BatchTsetExample implements Serializable
  
  serialVersionUID:
  
  -2753072757838198105L
- Class edu.iu.dsc.tws.examples.tset.batch.KReduceExample extends BatchTsetExample implements Serializable
  
  serialVersionUID:
  
  -2753072757838198105L
- Class edu.iu.dsc.tws.examples.tset.batch.PartitionExample extends BatchTsetExample implements Serializable
  
  serialVersionUID:
  
  -2753072757838198105L
- Class edu.iu.dsc.tws.examples.tset.batch.PartitionMtoNExample extends BatchTsetExample implements Serializable
  
  serialVersionUID:
  
  -2753072757838198105L
- Class edu.iu.dsc.tws.examples.tset.batch.PersistExample extends BatchTsetExample implements Serializable
  
  serialVersionUID:
  
  -2753072757838198105L
- Class edu.iu.dsc.tws.examples.tset.batch.PipeExample extends BatchTsetExample implements Serializable
  
  serialVersionUID:
  
  -2753072757838198105L
- Class edu.iu.dsc.tws.examples.tset.batch.ReduceExample extends BatchTsetExample implements Serializable
  
  serialVersionUID:
  
  -2753072757838198105L
- Class edu.iu.dsc.tws.examples.tset.batch.SetSchemaExample extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  -2753072757838198105L
- Class edu.iu.dsc.tws.examples.tset.batch.TSetExecDemo extends java.lang.Object implements Serializable
- Class edu.iu.dsc.tws.examples.tset.batch.UnionExample extends BatchTsetExample implements Serializable
  
  serialVersionUID:
  
  -2753072757838198105L
- Class edu.iu.dsc.tws.examples.tset.batch.UnionExample2 extends BatchTsetExample implements Serializable
  
  serialVersionUID:
  
  -2753072757838198105L
Package edu.iu.dsc.tws.examples.tset.batch.row
- Class edu.iu.dsc.tws.examples.tset.batch.row.PartitionExample extends BatchTsetExample implements Serializable
  
  serialVersionUID:
  
  -2753072757838198105L
Package edu.iu.dsc.tws.examples.tset.checkpointing
- Class edu.iu.dsc.tws.examples.tset.checkpointing.CheckpointingExample extends java.lang.Object implements Serializable
- Class edu.iu.dsc.tws.examples.tset.checkpointing.KeyedCheckpointingExample extends java.lang.Object implements Serializable
- Class edu.iu.dsc.tws.examples.tset.checkpointing.TSetFTExample extends java.lang.Object implements Serializable
- Class edu.iu.dsc.tws.examples.tset.checkpointing.WordCount extends java.lang.Object implements Serializable
Package edu.iu.dsc.tws.examples.tset.streaming
- Class edu.iu.dsc.tws.examples.tset.streaming.SDirectExample extends StreamingTsetExample implements Serializable
  
  serialVersionUID:
  
  -2753072757838198105L
- Class edu.iu.dsc.tws.examples.tset.streaming.SReduceExample extends StreamingTsetExample implements Serializable
  
  serialVersionUID:
  
  -275307275783819805L
- Class edu.iu.dsc.tws.examples.tset.streaming.SReduceWindowExample extends StreamingTsetExample implements Serializable
  
  serialVersionUID:
  
  -2753072757838198105L
- Class edu.iu.dsc.tws.examples.tset.streaming.StreamingTsetExample extends java.lang.Object implements Serializable
- Class edu.iu.dsc.tws.examples.tset.streaming.SUnionExample extends StreamingTsetExample implements Serializable
  
  serialVersionUID:
  
  -2753072757838198105L
Package edu.iu.dsc.tws.examples.tset.tutorial.intermediate.caching
- Class edu.iu.dsc.tws.examples.tset.tutorial.intermediate.caching.TSetCachingExample extends java.lang.Object implements Serializable
Package edu.iu.dsc.tws.examples.tset.tutorial.intermediate.checkpoint
- Class edu.iu.dsc.tws.examples.tset.tutorial.intermediate.checkpoint.TSetCheckptExample extends java.lang.Object implements Serializable
Package edu.iu.dsc.tws.examples.tset.tutorial.intermediate.comm
- Class edu.iu.dsc.tws.examples.tset.tutorial.intermediate.comm.TSetCommunicationExample extends java.lang.Object implements Serializable
Package edu.iu.dsc.tws.examples.tset.tutorial.intermediate.compute
- Class edu.iu.dsc.tws.examples.tset.tutorial.intermediate.compute.TSetComputeExample extends java.lang.Object implements Serializable
Package edu.iu.dsc.tws.examples.tset.tutorial.simple.source
- Class edu.iu.dsc.tws.examples.tset.tutorial.simple.source.TSetSourceExample extends java.lang.Object implements Serializable
Package edu.iu.dsc.tws.examples.tset.tutorial.terasort
- Class edu.iu.dsc.tws.examples.tset.tutorial.terasort.TSetTeraSort extends BaseTSetBatchWorker implements Serializable
Package edu.iu.dsc.tws.examples.tset.verified
- Class edu.iu.dsc.tws.examples.tset.verified.TSetAllGatherExample extends BaseTSetBatchWorker implements Serializable
- Class edu.iu.dsc.tws.examples.tset.verified.TSetAllReduceExample extends BaseTSetBatchWorker implements Serializable
- Class edu.iu.dsc.tws.examples.tset.verified.TSetFileAccessExample extends BaseTSetBatchWorker implements Serializable
- Class edu.iu.dsc.tws.examples.tset.verified.TSetGatherExample extends BaseTSetBatchWorker implements Serializable
- Class edu.iu.dsc.tws.examples.tset.verified.TSetKeyedGatherExample extends BaseTSetBatchWorker implements Serializable
- Class edu.iu.dsc.tws.examples.tset.verified.TSetKeyedReduceExample extends BaseTSetBatchWorker implements Serializable
- Class edu.iu.dsc.tws.examples.tset.verified.TSetPartitionExample extends BaseTSetBatchWorker implements Serializable
- Class edu.iu.dsc.tws.examples.tset.verified.TSetReduceExample extends BaseTSetBatchWorker implements Serializable
- Class edu.iu.dsc.tws.examples.tset.verified.TSetReplicateExample extends BaseTSetBatchWorker implements Serializable
Package edu.iu.dsc.tws.examples.utils.partitioners
- Class edu.iu.dsc.tws.examples.utils.partitioners.DeterministicTaskPartitioner extends java.lang.Object implements Serializable
  - Serialized Fields
    - dst
```
java.util.List<E> dst
```
Package edu.iu.dsc.tws.examples.verification
- Class edu.iu.dsc.tws.examples.verification.VerificationException extends java.lang.Exception implements Serializable
  
  serialVersionUID:
  
  8518462128140814091L
Package edu.iu.dsc.tws.graphapi.api
- Class edu.iu.dsc.tws.graphapi.api.BasicComputation.ComputeTask extends BaseCompute implements Serializable
- Class edu.iu.dsc.tws.graphapi.api.BasicComputation.GraphInitialization extends ConstructDataStr implements Serializable
- Class edu.iu.dsc.tws.graphapi.api.BasicComputation.GraphPartiton extends ConstructDataStr implements Serializable
- Class edu.iu.dsc.tws.graphapi.api.BasicComputation.ReductionFunction extends java.lang.Object implements Serializable
- Class edu.iu.dsc.tws.graphapi.api.BasicComputation.SourceTask extends BaseSource implements Serializable
  - Serialized Fields
    - graphObject
```
DataObject<T> graphObject
```
    - graphObjectvalues
```
DataObject<T> graphObjectvalues
```
    - count
```
int count
```
- Class edu.iu.dsc.tws.graphapi.api.ConstructDataStr extends BaseCompute implements Serializable
  - Serialized Fields
    - edgeName
```
java.lang.String edgeName
```
      Edge name to write the partitoned datapoints
    - parallel
```
int parallel
```
      Task parallelism
    - datasize
```
int datasize
```
      Data size
- Class edu.iu.dsc.tws.graphapi.api.DataInitializationSinkTask extends BaseCompute implements Serializable
  
  serialVersionUID:
  
  -1L
  - Serialized Fields
    - dataPointsLocal
```
java.util.HashMap<K,V> dataPointsLocal
```
    - inputKey
```
java.lang.String inputKey
```
- Class edu.iu.dsc.tws.graphapi.api.DataSinkTask extends BaseCompute implements Serializable
  
  serialVersionUID:
  
  -1L
  - Serialized Fields
    - dataPointsLocal
```
java.util.HashMap<K,V> dataPointsLocal
```
    - inputKey
```
java.lang.String inputKey
```

Package edu.iu.dsc.tws.graphapi.impl

Class edu.iu.dsc.tws.graphapi.impl.TestForSSSP extends BasicComputation implements Serializable

Serialized Fields

graphPartiton

BasicComputation.GraphPartiton graphPartiton

graphInitialization

BasicComputation.GraphInitialization graphInitialization

sourceTask
```
BasicComputation.SourceTask sourceTask
```

computeTask

BasicComputation.ComputeTask computeTask

reductionFunction

BasicComputation.ReductionFunction reductionFunction

Package edu.iu.dsc.tws.graphapi.pagerank
- Class edu.iu.dsc.tws.graphapi.pagerank.DataObjectCompute extends BaseCompute implements Serializable
  
  serialVersionUID:
  
  -254264120110286748L
  - Serialized Fields
    - edgeName
```
java.lang.String edgeName
```
      Edge name to write the partitoned datapoints
    - parallel
```
int parallel
```
      Task parallelism
    - datasize
```
int datasize
```
      Data size
- Class edu.iu.dsc.tws.graphapi.pagerank.DataObjectSink extends BaseCompute implements Serializable
  
  serialVersionUID:
  
  -1L
  - Serialized Fields
    - dataPointsLocal
```
java.util.HashMap<K,V> dataPointsLocal
```
    - inputKey
```
java.lang.String inputKey
```
- Class edu.iu.dsc.tws.graphapi.pagerank.PageRankValueHolderCompute extends BaseCompute implements Serializable
  
  serialVersionUID:
  
  -254264120110286748L
  - Serialized Fields
    - edgeName
```
java.lang.String edgeName
```
      Edge name to write the partitoned datapoints
    - parallel
```
int parallel
```
      Task parallelism
    - datasize
```
int datasize
```
      Data size
- Class edu.iu.dsc.tws.graphapi.pagerank.PageRankValueHolderSink extends BaseCompute implements Serializable
  
  serialVersionUID:
  
  -1L
  - Serialized Fields
    - dataPointsLocal
```
java.util.HashMap<K,V> dataPointsLocal
```
    - inputKey
```
java.lang.String inputKey
```
Package edu.iu.dsc.tws.graphapi.partition
- Class edu.iu.dsc.tws.graphapi.partition.GraphDataSource extends BaseSource implements Serializable
  
  serialVersionUID:
  
  -1L
  - Serialized Fields
    - source
```
DataSource<T,O extends InputSplit<T>> source
```
      DataSource to partition the datapoints
    - edgeName
```
java.lang.String edgeName
```
      Edge name to write the partitoned datapoints
    - dataDirectory
```
java.lang.String dataDirectory
```
    - dsize
```
int dsize
```
Package edu.iu.dsc.tws.graphapi.sssp
- Class edu.iu.dsc.tws.graphapi.sssp.GraphDataCompute extends BaseCompute implements Serializable
  - Serialized Fields
    - edgeName
```
java.lang.String edgeName
```
      Edge name to write the partitoned datapoints
    - parallel
```
int parallel
```
      Task parallelism
    - datasize
```
int datasize
```
      Data size
    - sourceVertex
```
java.lang.String sourceVertex
```
- Class edu.iu.dsc.tws.graphapi.sssp.GraphDataSink extends BaseCompute implements Serializable
  
  serialVersionUID:
  
  -1L
  - Serialized Fields
    - dataPointsLocal
```
java.util.HashMap<K,V> dataPointsLocal
```
    - inputKey
```
java.lang.String inputKey
```
- Class edu.iu.dsc.tws.graphapi.sssp.SsspInitialCompute extends BaseCompute implements Serializable
  - Serialized Fields
    - edgeName
```
java.lang.String edgeName
```
      Edge name to write the partitoned datapoints
    - parallel
```
int parallel
```
      Task parallelism
    - datasize
```
int datasize
```
      Data size
    - sourceVertex
```
java.lang.String sourceVertex
```
- Class edu.iu.dsc.tws.graphapi.sssp.SsspInitialSink extends BaseCompute implements Serializable
  
  serialVersionUID:
  
  -1L
  - Serialized Fields
    - dataPointsLocal
```
java.util.HashMap<K,V> dataPointsLocal
```
    - inputKey
```
java.lang.String inputKey
```
Package edu.iu.dsc.tws.python.numpy
- Class edu.iu.dsc.tws.python.numpy.NumpyHolder extends java.lang.Object implements Serializable
  - Serialized Fields
    - numpyFlatArray
```
java.lang.Object numpyFlatArray
```
    - type
```
java.lang.Object type
```
    - shape
```
java.lang.Object shape
```
- Class edu.iu.dsc.tws.python.numpy.NumpyHolderBuilder extends java.lang.Object implements Serializable
Package edu.iu.dsc.tws.python.processors
- Class edu.iu.dsc.tws.python.processors.AbstractPythonProcessor extends java.lang.ThreadLocal<Jep> implements Serializable
  - Serialized Fields
    - objectId
```
java.lang.String objectId
```
    - bytes
```
byte[] bytes
```
- Class edu.iu.dsc.tws.python.processors.PythonClassProcessor extends AbstractPythonProcessor implements Serializable
- Class edu.iu.dsc.tws.python.processors.PythonLambdaProcessor extends AbstractPythonProcessor implements Serializable
Package edu.iu.dsc.tws.python.tset
- Class edu.iu.dsc.tws.python.tset.PyTSetKeyedSource extends java.lang.Object implements Serializable
  - Serialized Fields
    - processor
```
PythonClassProcessor processor
```
- Class edu.iu.dsc.tws.python.tset.PyTSetSource extends java.lang.Object implements Serializable
  - Serialized Fields
    - processor
```
PythonClassProcessor processor
```
Package edu.iu.dsc.tws.python.tset.fn
- Class edu.iu.dsc.tws.python.tset.fn.ApplyFunctions.ApplyFuncImpl extends java.lang.Object implements Serializable
  - Serialized Fields
    - pythonLambdaProcessor
```
PythonLambdaProcessor pythonLambdaProcessor
```
- Class edu.iu.dsc.tws.python.tset.fn.ComputeFunctions.ComputeFuncImpl extends java.lang.Object implements Serializable
  - Serialized Fields
    - lambdaProcessor
```
PythonLambdaProcessor lambdaProcessor
```
    - ctx
```
TSetContext ctx
```
- Class edu.iu.dsc.tws.python.tset.fn.ComputeWithCollectorFunctions.ComputeFuncImpl extends java.lang.Object implements Serializable
  - Serialized Fields
    - lambdaProcessor
```
PythonLambdaProcessor lambdaProcessor
```
    - ctx
```
TSetContext ctx
```
- Class edu.iu.dsc.tws.python.tset.fn.FlatMapFunctions.FlatMapFuncImpl extends java.lang.Object implements Serializable
  - Serialized Fields
    - pythonLambdaProcessor
```
PythonLambdaProcessor pythonLambdaProcessor
```
- Class edu.iu.dsc.tws.python.tset.fn.ReduceFunctions.ReduceFuncImpl extends java.lang.Object implements Serializable
  - Serialized Fields
    - pythonLambdaProcessor
```
PythonLambdaProcessor pythonLambdaProcessor
```
Package edu.iu.dsc.tws.task.cdfw
- Class edu.iu.dsc.tws.task.cdfw.DataFlowJobConfig extends java.util.HashMap<java.lang.String,java.lang.Object> implements Serializable
  
  serialVersionUID:
  
  271141341213046590L
Package edu.iu.dsc.tws.task.cdfw.task
- Class edu.iu.dsc.tws.task.cdfw.task.ConnectedSink extends BaseCompute implements Serializable
  - Serialized Fields
    - inputKey
```
java.lang.String inputKey
```
      The name of the data set
    - partition
```
CollectionPartition<T> partition
```
      The partition to use
- Class edu.iu.dsc.tws.task.cdfw.task.ConnectedSource extends BaseSource implements Serializable
  - Serialized Fields
    - edge
```
java.lang.String edge
```
    - dataPartition
```
DataPartition<T> dataPartition
```
    - dataObject
```
java.lang.Object dataObject
```
    - inputKey
```
java.lang.String inputKey
```
Package edu.iu.dsc.tws.task.dataobjects
- Class edu.iu.dsc.tws.task.dataobjects.DataFileReplicatedReadSource extends BaseSource implements Serializable
  
  serialVersionUID:
  
  -1L
  - Serialized Fields
    - source
```
DataSource<T,O extends InputSplit<T>> source
```
      DataSource to partition the datapoints
    - edgeName
```
java.lang.String edgeName
```
      Edge name to write the partitoned datapoints
    - dataDirectory
```
java.lang.String dataDirectory
```
    - dataSize
```
int dataSize
```
- Class edu.iu.dsc.tws.task.dataobjects.DataFileSink extends BaseCompute<T> implements Serializable
  
  serialVersionUID:
  
  -1L
  - Serialized Fields
    - datasink
```
DataSink<T> datasink
```
- Class edu.iu.dsc.tws.task.dataobjects.DataFileSplittedReadSource extends BaseSource implements Serializable
  
  serialVersionUID:
  
  -1L
  - Serialized Fields
    - source
```
DataSource<T,O extends InputSplit<T>> source
```
      DataSource to partition the datapoints
    - edgeName
```
java.lang.String edgeName
```
      Edge name to write the partitoned datapoints
    - dataDirectory
```
java.lang.String dataDirectory
```
- Class edu.iu.dsc.tws.task.dataobjects.DataObjectCSVSource extends BaseSource implements Serializable
  
  serialVersionUID:
  
  -1L
  - Serialized Fields
    - source
```
DataSource<T,O extends InputSplit<T>> source
```
    - edgeName
```
java.lang.String edgeName
```
    - dataDirectory
```
java.lang.String dataDirectory
```
- Class edu.iu.dsc.tws.task.dataobjects.DataObjectSink extends BaseCompute implements Serializable
  
  serialVersionUID:
  
  -1L
  - Serialized Fields
    - datapoints
```
DataObject<T> datapoints
```
- Class edu.iu.dsc.tws.task.dataobjects.DataObjectSource extends BaseSource implements Serializable
  
  serialVersionUID:
  
  -1L
  - Serialized Fields
    - source
```
DataSource<T,O extends InputSplit<T>> source
```
      DataSource to partition the datapoints
    - edgeName
```
java.lang.String edgeName
```
      Edge name to write the partitoned datapoints
    - dataDirectory
```
java.lang.String dataDirectory
```
Package edu.iu.dsc.tws.task.impl.function
- Class edu.iu.dsc.tws.task.impl.function.ReduceFn extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  -123142353453456L
  - Serialized Fields
    - reduceFunction
```
ReduceFunction reduceFunction
```
      The actual reduce function
Package edu.iu.dsc.tws.task.impl.ops
- Class edu.iu.dsc.tws.task.impl.ops.OpConfigValidationFailedException extends java.lang.RuntimeException implements Serializable
Package edu.iu.dsc.tws.task.typed
- Class edu.iu.dsc.tws.task.typed.AbstractIterableDataCompute extends BaseCompute<java.util.Iterator<T>> implements Serializable
- Class edu.iu.dsc.tws.task.typed.AbstractSingleDataCompute extends BaseCompute<T> implements Serializable
- Class edu.iu.dsc.tws.task.typed.AllGatherCompute extends AbstractIterableDataCompute<Tuple<java.lang.Integer,T>> implements Serializable
- Class edu.iu.dsc.tws.task.typed.AllReduceCompute extends AbstractSingleDataCompute<T> implements Serializable
- Class edu.iu.dsc.tws.task.typed.DirectCompute extends AbstractSingleDataCompute<T> implements Serializable
- Class edu.iu.dsc.tws.task.typed.GatherCompute extends AbstractIterableDataCompute<Tuple<java.lang.Integer,T>> implements Serializable
- Class edu.iu.dsc.tws.task.typed.KeyedGatherCompute extends AbstractIterableDataCompute<Tuple<K,T>> implements Serializable
- Class edu.iu.dsc.tws.task.typed.ReduceCompute extends AbstractSingleDataCompute<T> implements Serializable
Package edu.iu.dsc.tws.task.typed.batch
- Class edu.iu.dsc.tws.task.typed.batch.BBroadCastCompute extends AbstractIterableDataCompute<T> implements Serializable
- Class edu.iu.dsc.tws.task.typed.batch.BJoinCompute extends AbstractIterableDataCompute<JoinedTuple<K,L,R>> implements Serializable
- Class edu.iu.dsc.tws.task.typed.batch.BKeyedGatherGroupedCompute extends KeyedGatherCompute<K,java.util.Iterator<T>> implements Serializable
- Class edu.iu.dsc.tws.task.typed.batch.BKeyedGatherUnGroupedCompute extends KeyedGatherCompute<K,T> implements Serializable
- Class edu.iu.dsc.tws.task.typed.batch.BKeyedPartitionCompute extends AbstractIterableDataCompute<Tuple<K,T>> implements Serializable
- Class edu.iu.dsc.tws.task.typed.batch.BKeyedReduceCompute extends AbstractIterableDataCompute<Tuple<K,T>> implements Serializable
- Class edu.iu.dsc.tws.task.typed.batch.BPartitionCompute extends AbstractIterableDataCompute<T> implements Serializable
Package edu.iu.dsc.tws.task.typed.streaming
- Class edu.iu.dsc.tws.task.typed.streaming.SBroadCastCompute extends AbstractSingleDataCompute<T> implements Serializable
- Class edu.iu.dsc.tws.task.typed.streaming.SKeyedPartitionCompute extends AbstractSingleDataCompute<Tuple<K,T>> implements Serializable
- Class edu.iu.dsc.tws.task.typed.streaming.SKeyedReduceCompute extends AbstractSingleDataCompute<Tuple<K,T>> implements Serializable
- Class edu.iu.dsc.tws.task.typed.streaming.SPartitionCompute extends AbstractSingleDataCompute<T> implements Serializable
Package edu.iu.dsc.tws.task.window
- Class edu.iu.dsc.tws.task.window.BaseWindowCompute extends BaseNode implements Serializable
- Class edu.iu.dsc.tws.task.window.BaseWindowSource extends BaseNode implements Serializable
Package edu.iu.dsc.tws.task.window.api
- Class edu.iu.dsc.tws.task.window.api.BaseWindow extends java.lang.Object implements Serializable
  - Serialized Fields
    - windowLength
```
long windowLength
```
    - slideLength
```
long slideLength
```
- Class edu.iu.dsc.tws.task.window.api.BaseWindowSink extends BaseNode implements Serializable
- Class edu.iu.dsc.tws.task.window.api.TimestampExtractor extends java.lang.Object implements Serializable
Package edu.iu.dsc.tws.task.window.collectives
- Class edu.iu.dsc.tws.task.window.collectives.AggregateWindow extends BaseWindowedSink<T> implements Serializable
  - Serialized Fields
    - aggregateWindowedFunction
```
AggregateWindowedFunction<T> aggregateWindowedFunction
```
- Class edu.iu.dsc.tws.task.window.collectives.FoldWindow extends BaseWindowedSink<T> implements Serializable
  - Serialized Fields
    - foldWindowedFunction
```
FoldWindowedFunction<T,K> foldWindowedFunction
```
- Class edu.iu.dsc.tws.task.window.collectives.ProcessWindow extends BaseWindowedSink<T> implements Serializable
  - Serialized Fields
    - processWindowedFunction
```
ProcessWindowedFunction<T> processWindowedFunction
```
- Class edu.iu.dsc.tws.task.window.collectives.ReduceWindow extends BaseWindowedSink<T> implements Serializable
  - Serialized Fields
    - reduceWindowedFunction
```
ReduceWindowedFunction<T> reduceWindowedFunction
```
Package edu.iu.dsc.tws.task.window.config
- Class edu.iu.dsc.tws.task.window.config.SlidingCountWindow extends BaseWindow implements Serializable
- Class edu.iu.dsc.tws.task.window.config.SlidingDurationWindow extends BaseWindow implements Serializable
- Class edu.iu.dsc.tws.task.window.config.TumblingCountWindow extends BaseWindow implements Serializable
- Class edu.iu.dsc.tws.task.window.config.TumblingDurationWindow extends BaseWindow implements Serializable
- Class edu.iu.dsc.tws.task.window.config.WindowConfig extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  5892396934750193462L
- Class edu.iu.dsc.tws.task.window.config.WindowConfig.Count extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  8272120867802383759L
  - Serialized Fields
    - value
```
long value
```
- Class edu.iu.dsc.tws.task.window.config.WindowConfig.Duration extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  -8082429717934376825L
  - Serialized Fields
    - value
```
long value
```
Package edu.iu.dsc.tws.task.window.core
- Class edu.iu.dsc.tws.task.window.core.AbstractListDataCompute extends BaseCompute<java.util.List<T>> implements Serializable
- Class edu.iu.dsc.tws.task.window.core.AbstractSingleWindowDataCompute extends BaseWindowCompute<T> implements Serializable
- Class edu.iu.dsc.tws.task.window.core.AbstractSingleWindowDataSink extends BaseWindowSink<T> implements Serializable
- Class edu.iu.dsc.tws.task.window.core.BaseWindowedSink extends AbstractSingleWindowDataSink<T> implements Serializable
  - Serialized Fields
    - maxLagMs
```
long maxLagMs
```
    - watermarkInterval
```
WindowConfig.Duration watermarkInterval
```
    - allowedLateness
```
WindowConfig.Duration allowedLateness
```
    - windowManager
```
WindowManager<T> windowManager
```
    - windowingPolicy
```
IWindowingPolicy<T> windowingPolicy
```
    - windowParameter
```
WindowParameter windowParameter
```
    - windowLifeCycleListener
```
WindowLifeCycleListener<T> windowLifeCycleListener
```
    - evictionPolicy
```
IEvictionPolicy<T> evictionPolicy
```
    - iWindow
```
IWindow iWindow
```
    - collectiveOutput
```
java.lang.Object collectiveOutput
```
    - collectiveEvents
```
IWindowMessage<T> collectiveEvents
```
    - iTimestampExtractor
```
ITimestampExtractor<T> iTimestampExtractor
```
    - watermarkEventGenerator
```
WatermarkEventGenerator<T> watermarkEventGenerator
```
- Class edu.iu.dsc.tws.task.window.core.WindowedCompute extends AbstractSingleWindowDataCompute<T> implements Serializable
Package edu.iu.dsc.tws.task.window.exceptions
- Class edu.iu.dsc.tws.task.window.exceptions.FailedException extends java.lang.RuntimeException implements Serializable
- Class edu.iu.dsc.tws.task.window.exceptions.FailureException extends java.lang.Exception implements Serializable
- Class edu.iu.dsc.tws.task.window.exceptions.InvalidWindow extends java.lang.Exception implements Serializable
- Class edu.iu.dsc.tws.task.window.exceptions.InValidWindowingPolicy extends java.lang.Exception implements Serializable
Package edu.iu.dsc.tws.task.window.function

Package edu.iu.dsc.tws.task.window.manage

Class edu.iu.dsc.tws.task.window.manage.WindowManager extends java.lang.Object implements Serializable

serialVersionUID:: -15452808832480739L

Serialized Fields

windowingPolicy
```
IWindowingPolicy<T> windowingPolicy
```
evictionPolicy
```
IEvictionPolicy<T> evictionPolicy
```

windowLifeCycleListener

WindowLifeCycleListener<T> windowLifeCycleListener

expiredEvents
```
java.util.List<E> expiredEvents
```

lock

java.util.concurrent.locks.ReentrantLock lock

queue

java.util.concurrent.ConcurrentLinkedQueue<E> queue

previousWindowEvents
```
java.util.Set<E> previousWindowEvents
```

eventsSinceLastExpiration

java.util.concurrent.atomic.AtomicInteger eventsSinceLastExpiration

debug
```
boolean debug
```

Package edu.iu.dsc.tws.task.window.policy.trigger
- Class edu.iu.dsc.tws.task.window.policy.trigger.WindowingGlobalPolicy extends WindowingPolicy implements Serializable
- Class edu.iu.dsc.tws.task.window.policy.trigger.WindowingPolicy extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  -2786001848413534229L
  - Serialized Fields
    - windowType
```
WindowType windowType
```
    - count
```
WindowConfig.Count count
```
    - duration
```
WindowConfig.Duration duration
```
- Class edu.iu.dsc.tws.task.window.policy.trigger.WindowingSessionPolicy extends WindowingPolicy implements Serializable
- Class edu.iu.dsc.tws.task.window.policy.trigger.WindowingSlidingPolicy extends WindowingPolicy implements Serializable
- Class edu.iu.dsc.tws.task.window.policy.trigger.WindowingTumblingPolicy extends WindowingPolicy implements Serializable
  - Serialized Fields
    - windowType
```
WindowType windowType
```
    - count
```
WindowConfig.Count count
```
    - duration
```
WindowConfig.Duration duration
```
Package edu.iu.dsc.tws.task.window.policy.trigger.count
- Class edu.iu.dsc.tws.task.window.policy.trigger.count.CountWindowPolicy extends java.lang.Object implements Serializable
  - Serialized Fields
    - count
```
long count
```
    - currentCount
```
java.util.concurrent.atomic.AtomicInteger currentCount
```
    - manager
```
IManager<T> manager
```
    - evictionPolicy
```
IEvictionPolicy<T> evictionPolicy
```
    - started
```
boolean started
```
- Class edu.iu.dsc.tws.task.window.policy.trigger.count.WatermarkCountWindowPolicy extends CountWindowPolicy<T> implements Serializable
  - Serialized Fields
    - count
```
long count
```
    - currentCount
```
java.util.concurrent.atomic.AtomicInteger currentCount
```
    - manager
```
IManager<T> manager
```
    - windowManager
```
WindowManager<T> windowManager
```
    - evictionPolicy
```
IEvictionPolicy<T> evictionPolicy
```
    - started
```
boolean started
```
    - lastProcessedTimestamp
```
long lastProcessedTimestamp
```
Package edu.iu.dsc.tws.task.window.policy.trigger.duration
- Class edu.iu.dsc.tws.task.window.policy.trigger.duration.DurationWindowPolicy extends java.lang.Object implements Serializable
  - Serialized Fields
    - duration
```
long duration
```
    - executor
```
java.util.concurrent.ScheduledExecutorService executor
```
    - executorFuture
```
java.util.concurrent.ScheduledFuture<V> executorFuture
```
    - manager
```
IManager<T> manager
```
    - evictionPolicy
```
IEvictionPolicy<T> evictionPolicy
```
- Class edu.iu.dsc.tws.task.window.policy.trigger.duration.WatermarkDurationWindowPolicy extends DurationWindowPolicy<T> implements Serializable
  - Serialized Fields
    - slidingInterval
```
long slidingInterval
```
    - manager
```
IManager<T> manager
```
    - windowManager
```
WindowManager<T> windowManager
```
    - evictionPolicy
```
IEvictionPolicy<T> evictionPolicy
```
    - started
```
boolean started
```
    - nextWindowEndTime
```
long nextWindowEndTime
```
Package edu.iu.dsc.tws.task.window.util
- Class edu.iu.dsc.tws.task.window.util.WindowParameter extends java.lang.Object implements Serializable
  - Serialized Fields
    - windowCountSize
```
WindowConfig.Count windowCountSize
```
      Window Type Description Window Length == Sliding Length => Tumbling Window Window Length > Sliding Length => Sliding Window Window Length < Sliding Length => Invalid Window
    - slidingCountSize
```
WindowConfig.Count slidingCountSize
```
    - windowDurationSize
```
WindowConfig.Duration windowDurationSize
```
    - sldingDurationSize
```
WindowConfig.Duration sldingDurationSize
```
Package edu.iu.dsc.tws.tsched.utils
- Class edu.iu.dsc.tws.tsched.utils.TaskSchedulerClassTest.Aggregator extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  -254264120110286748L
- Class edu.iu.dsc.tws.tsched.utils.TaskSchedulerClassTest.TestCompute extends BaseCompute implements Serializable
  
  serialVersionUID:
  
  -254264903510284748L
- Class edu.iu.dsc.tws.tsched.utils.TaskSchedulerClassTest.TestComputeChild extends BaseCompute implements Serializable
  
  serialVersionUID:
  
  -254264903510284748L
- Class edu.iu.dsc.tws.tsched.utils.TaskSchedulerClassTest.TestSink extends BaseCompute implements Serializable
  
  serialVersionUID:
  
  -254264903510284748L
  - Serialized Fields
    - inputKey
```
java.lang.String inputKey
```
- Class edu.iu.dsc.tws.tsched.utils.TaskSchedulerClassTest.TestSource extends BaseSource implements Serializable
  
  serialVersionUID:
  
  -254264903510284748L
  - Serialized Fields
    - inputSet
```
java.util.Set<E> inputSet
```
    - inputKey
```
java.lang.String inputKey
```
Package edu.iu.dsc.tws.tset
- Class edu.iu.dsc.tws.tset.TBaseGraph extends java.lang.Object implements Serializable
  - Serialized Fields
    - graph
```
MutableGraph<T> graph
```
    - opMode
```
OperationMode opMode
```
    - sources
```
java.util.Set<E> sources
```
Package edu.iu.dsc.tws.tset.fn
- Class edu.iu.dsc.tws.tset.fn.FlatMapCompute extends java.lang.Object implements Serializable
  - Serialized Fields
    - mapFn
```
FlatMapFunc<O,I> mapFn
```
- Class edu.iu.dsc.tws.tset.fn.FlatMapIterCompute extends java.lang.Object implements Serializable
  - Serialized Fields
    - mapFn
```
FlatMapFunc<O,I> mapFn
```
- Class edu.iu.dsc.tws.tset.fn.ForEachCompute extends java.lang.Object implements Serializable
  - Serialized Fields
    - applyFn
```
ApplyFunc<T> applyFn
```
- Class edu.iu.dsc.tws.tset.fn.ForEachIterCompute extends java.lang.Object implements Serializable
  - Serialized Fields
    - applyFn
```
ApplyFunc<T> applyFn
```
- Class edu.iu.dsc.tws.tset.fn.GatherFlatMapCompute extends java.lang.Object implements Serializable
  - Serialized Fields
    - mapFn
```
FlatMapFunc<O,I> mapFn
```
- Class edu.iu.dsc.tws.tset.fn.GatherForEachCompute extends java.lang.Object implements Serializable
  - Serialized Fields
    - applyFn
```
ApplyFunc<T> applyFn
```
- Class edu.iu.dsc.tws.tset.fn.GatherMapCompute extends java.lang.Object implements Serializable
  - Serialized Fields
    - mapFn
```
MapFunc<O,I> mapFn
```
- Class edu.iu.dsc.tws.tset.fn.HashingPartitioner extends java.lang.Object implements Serializable
  - Serialized Fields
    - destinations
```
java.util.List<E> destinations
```
- Class edu.iu.dsc.tws.tset.fn.IdentitySelector extends java.lang.Object implements Serializable
- Class edu.iu.dsc.tws.tset.fn.LoadBalancePartitioner extends java.lang.Object implements Serializable
  - Serialized Fields
    - destination
```
java.util.Map<K,V> destination
```
    - destinationIndexes
```
java.util.Map<K,V> destinationIndexes
```
    - invertedIndexes
```
java.util.Map<K,V> invertedIndexes
```
- Class edu.iu.dsc.tws.tset.fn.MapCompute extends java.lang.Object implements Serializable
  - Serialized Fields
    - mapFn
```
MapFunc<O,I> mapFn
```
- Class edu.iu.dsc.tws.tset.fn.MapIterCompute extends java.lang.Object implements Serializable
  - Serialized Fields
    - mapFn
```
MapFunc<O,I> mapFn
```
- Class edu.iu.dsc.tws.tset.fn.OneToOnePartitioner extends java.lang.Object implements Serializable
  - Serialized Fields
    - destinations
```
java.util.List<E> destinations
```
- Class edu.iu.dsc.tws.tset.fn.ProcessWindowCompute extends java.lang.Object implements Serializable
  - Serialized Fields
    - processFn
```
MapFunc<O,I> processFn
```
Package edu.iu.dsc.tws.tset.fn.impl
- Class edu.iu.dsc.tws.tset.fn.impl.ArrowBasedSinkFunction extends BaseSinkFunc<java.util.Iterator<T>> implements Serializable
  - Serialized Fields
    - filePath
```
java.lang.String filePath
```
    - fileName
```
java.lang.String fileName
```
    - arrowSchema
```
java.lang.String arrowSchema
```
- Class edu.iu.dsc.tws.tset.fn.impl.ArrowBasedSourceFunction extends BaseSourceFunc<java.lang.Object> implements Serializable
  - Serialized Fields
    - arrowInputDirectory
```
java.lang.String arrowInputDirectory
```
    - arrowInputFile
```
java.lang.String arrowInputFile
```
    - arrowSchema
```
java.lang.String arrowSchema
```
    - parallel
```
int parallel
```
    - currentCell
```
int currentCell
```
    - intVector
```
IntVector intVector
```
- Class edu.iu.dsc.tws.tset.fn.impl.CSVBasedSourceFunction extends BaseSourceFunc<java.lang.String[]> implements Serializable
  - Serialized Fields
    - textSource
```
TextBasedSourceFunction textSource
```
    - pattern
```
java.util.regex.Pattern pattern
```
- Class edu.iu.dsc.tws.tset.fn.impl.ListBasedSourceFunction extends java.lang.Object implements Serializable
  - Serialized Fields
    - listName
```
java.lang.String listName
```
    - dataList
```
java.util.List<E> dataList
```
    - index
```
int index
```
    - endIndex
```
int endIndex
```
- Class edu.iu.dsc.tws.tset.fn.impl.MapBasedSourceFunction extends java.lang.Object implements Serializable
  - Serialized Fields
    - listName
```
java.lang.String listName
```
    - mapName
```
java.lang.String mapName
```
    - dataMap
```
java.util.Map<K,V> dataMap
```
    - keysList
```
java.util.List<E> keysList
```
    - index
```
int index
```
    - endIndex
```
int endIndex
```
- Class edu.iu.dsc.tws.tset.fn.impl.TextBasedSourceFunction extends BaseSourceFunc<java.lang.String> implements Serializable
  - Serialized Fields
    - dataSource
```
DataSource<T,O extends InputSplit<T>> dataSource
```
    - dataSplit
```
InputSplit<OT> dataSplit
```
    - ctx
```
TSetContext ctx
```
    - datainputDirectory
```
java.lang.String datainputDirectory
```
    - dataSize
```
int dataSize
```
    - parallel
```
int parallel
```
    - count
```
int count
```
    - partitionerType
```
java.lang.String partitionerType
```
Package edu.iu.dsc.tws.tset.fn.row
- Class edu.iu.dsc.tws.tset.fn.row.RowFlatMapCompute extends java.lang.Object implements Serializable
  - Serialized Fields
    - mapFn
```
FlatMapFunc<O,I> mapFn
```
- Class edu.iu.dsc.tws.tset.fn.row.RowForEachCompute extends java.lang.Object implements Serializable
  - Serialized Fields
    - applyFn
```
ApplyFunc<T> applyFn
```
    - ctx
```
TSetContext ctx
```
- Class edu.iu.dsc.tws.tset.fn.row.RowMapCompute extends java.lang.Object implements Serializable
  - Serialized Fields
    - mapFn
```
MapFunc<O,I> mapFn
```
Package edu.iu.dsc.tws.tset.graph
- Class edu.iu.dsc.tws.tset.graph.DAGMutableGraph extends java.lang.Object implements Serializable
  - Serialized Fields
    - directed
```
boolean directed
```
    - index
```
java.util.Map<K,V> index
```
    - childList
```
java.util.Map<K,V> childList
```
    - parentList
```
java.util.Map<K,V> parentList
```
    - allowsSelfLoop
```
boolean allowsSelfLoop
```
Package edu.iu.dsc.tws.tset.links
- Class edu.iu.dsc.tws.tset.links.BaseTLink extends java.lang.Object implements Serializable
  - Serialized Fields
    - tSetEnv
```
TSetEnvironment tSetEnv
```
      The TSet Env used for runtime operations
    - name
```
java.lang.String name
```
      Name of the data set
    - thisID
```
java.lang.String thisID
```
      ID of the tlink
    - sourceParallelism
```
int sourceParallelism
```
    - targetParallelism
```
int targetParallelism
```
- Class edu.iu.dsc.tws.tset.links.BaseTLinkWithSchema extends BaseTLink<T1,T0> implements Serializable
  - Serialized Fields
    - linkSchema
```
Schema linkSchema
```
Package edu.iu.dsc.tws.tset.links.batch
- Class edu.iu.dsc.tws.tset.links.batch.AllGatherTLink extends BatchGatherLink<T> implements Serializable
  - Serialized Fields
    - useDisk
```
boolean useDisk
```
- Class edu.iu.dsc.tws.tset.links.batch.AllReduceTLink extends BatchSingleLink<T> implements Serializable
  - Serialized Fields
    - reduceFn
```
ReduceFunc<T> reduceFn
```
- Class edu.iu.dsc.tws.tset.links.batch.BatchGatherLink extends BatchTLinkImpl<java.util.Iterator<Tuple<java.lang.Integer,T>>,T> implements Serializable
- Class edu.iu.dsc.tws.tset.links.batch.BatchIteratorLink extends BatchTLinkImpl<java.util.Iterator<T>,T> implements Serializable
- Class edu.iu.dsc.tws.tset.links.batch.BatchIteratorLinkWrapper extends BatchIteratorLink<T> implements Serializable
- Class edu.iu.dsc.tws.tset.links.batch.BatchSingleLink extends BatchTLinkImpl<T,T> implements Serializable
- Class edu.iu.dsc.tws.tset.links.batch.BatchTLinkImpl extends BaseTLinkWithSchema<T1,T0> implements Serializable
- Class edu.iu.dsc.tws.tset.links.batch.DirectTLink extends BatchIteratorLinkWrapper<T> implements Serializable
  - Serialized Fields
    - useDisk
```
boolean useDisk
```
- Class edu.iu.dsc.tws.tset.links.batch.GatherTLink extends BatchGatherLink<T> implements Serializable
  - Serialized Fields
    - useDisk
```
boolean useDisk
```
- Class edu.iu.dsc.tws.tset.links.batch.JoinTLink extends BatchIteratorLinkWrapper<JoinedTuple<K,VL,VR>> implements Serializable
  - Serialized Fields
    - joinType
```
CommunicationContext.JoinType joinType
```
    - partitioner
```
TaskPartitioner<T> partitioner
```
    - keyComparator
```
java.util.Comparator<T> keyComparator
```
    - algorithm
```
CommunicationContext.JoinAlgorithm algorithm
```
    - leftTSet
```
TupleTSet<K,V> leftTSet
```
    - rightTSet
```
TupleTSet<K,V> rightTSet
```
    - useDisk
```
boolean useDisk
```
- Class edu.iu.dsc.tws.tset.links.batch.KeyedBatchIteratorLinkWrapper extends BatchIteratorLink<Tuple<K,V>> implements Serializable
- Class edu.iu.dsc.tws.tset.links.batch.KeyedDirectTLink extends KeyedBatchIteratorLinkWrapper<K,V> implements Serializable
  - Serialized Fields
    - useDisk
```
boolean useDisk
```
- Class edu.iu.dsc.tws.tset.links.batch.KeyedGatherTLink extends KeyedGatherUngroupedTLink<K,java.util.Iterator<V>> implements Serializable
- Class edu.iu.dsc.tws.tset.links.batch.KeyedGatherUngroupedTLink extends KeyedBatchIteratorLinkWrapper<K,V> implements Serializable
  - Serialized Fields
    - partitionFunction
```
PartitionFunc<T> partitionFunction
```
    - keyCompartor
```
java.util.Comparator<T> keyCompartor
```
    - groupByKey
```
boolean groupByKey
```
    - useDisk
```
boolean useDisk
```
- Class edu.iu.dsc.tws.tset.links.batch.KeyedPartitionTLink extends KeyedBatchIteratorLinkWrapper<K,V> implements Serializable
  - Serialized Fields
    - partitionFunction
```
PartitionFunc<T> partitionFunction
```
    - useDisk
```
boolean useDisk
```
- Class edu.iu.dsc.tws.tset.links.batch.KeyedPipeTLink extends BatchSingleLink<Tuple<K,V>> implements Serializable
- Class edu.iu.dsc.tws.tset.links.batch.KeyedReduceTLink extends KeyedBatchIteratorLinkWrapper<K,V> implements Serializable
  - Serialized Fields
    - reduceFn
```
ReduceFunc<T> reduceFn
```
- Class edu.iu.dsc.tws.tset.links.batch.PartitionTLink extends BatchIteratorLinkWrapper<T> implements Serializable
  - Serialized Fields
    - useDisk
```
boolean useDisk
```
    - partitionFunction
```
PartitionFunc<T> partitionFunction
```
- Class edu.iu.dsc.tws.tset.links.batch.PipeTLink extends BatchTLinkImpl<T,T> implements Serializable
- Class edu.iu.dsc.tws.tset.links.batch.ReduceTLink extends BatchSingleLink<T> implements Serializable
  - Serialized Fields
    - reduceFn
```
ReduceFunc<T> reduceFn
```
- Class edu.iu.dsc.tws.tset.links.batch.ReplicateTLink extends BatchIteratorLinkWrapper<T> implements Serializable
  - Serialized Fields
    - useDisk
```
boolean useDisk
```
Package edu.iu.dsc.tws.tset.links.batch.row
- Class edu.iu.dsc.tws.tset.links.batch.row.RowBatchTLinkImpl extends BaseTLinkWithSchema<Row,Row> implements Serializable
- Class edu.iu.dsc.tws.tset.links.batch.row.RowDirectLink extends RowBatchTLinkImpl implements Serializable
  - Serialized Fields
    - useDisk
```
boolean useDisk
```
- Class edu.iu.dsc.tws.tset.links.batch.row.RowPartitionTLink extends RowBatchTLinkImpl implements Serializable
  - Serialized Fields
    - useDisk
```
boolean useDisk
```
    - partitionFunction
```
PartitionFunc<T> partitionFunction
```
- Class edu.iu.dsc.tws.tset.links.batch.row.RowPipeTLink extends RowBatchTLinkImpl implements Serializable
  - Serialized Fields
    - useDisk
```
boolean useDisk
```
Package edu.iu.dsc.tws.tset.links.streaming
- Class edu.iu.dsc.tws.tset.links.streaming.SAllGatherTLink extends StreamingGatherLink<T> implements Serializable
- Class edu.iu.dsc.tws.tset.links.streaming.SAllReduceTLink extends StreamingSingleLink<T> implements Serializable
  - Serialized Fields
    - reduceFn
```
ReduceFunc<T> reduceFn
```
- Class edu.iu.dsc.tws.tset.links.streaming.SDirectTLink extends StreamingSingleLink<T> implements Serializable
- Class edu.iu.dsc.tws.tset.links.streaming.SGatherTLink extends StreamingGatherLink<T> implements Serializable
- Class edu.iu.dsc.tws.tset.links.streaming.SKeyedDirectTLink extends StreamingSingleLink<Tuple<K,V>> implements Serializable
- Class edu.iu.dsc.tws.tset.links.streaming.SKeyedPartitionTLink extends StreamingSingleLink<Tuple<K,V>> implements Serializable
  - Serialized Fields
    - partitionFunction
```
PartitionFunc<T> partitionFunction
```
- Class edu.iu.dsc.tws.tset.links.streaming.SPartitionTLink extends StreamingSingleLink<T> implements Serializable
  - Serialized Fields
    - partitionFunction
```
PartitionFunc<T> partitionFunction
```
- Class edu.iu.dsc.tws.tset.links.streaming.SReduceTLink extends StreamingSingleLink<T> implements Serializable
  - Serialized Fields
    - reduceFn
```
ReduceFunc<T> reduceFn
```
- Class edu.iu.dsc.tws.tset.links.streaming.SReplicateTLink extends StreamingSingleLink<T> implements Serializable
- Class edu.iu.dsc.tws.tset.links.streaming.StreamingGatherLink extends StreamingTLinkImpl<java.util.Iterator<Tuple<java.lang.Integer,T>>,T> implements Serializable
- Class edu.iu.dsc.tws.tset.links.streaming.StreamingIteratorLink extends StreamingTLinkImpl<java.util.Iterator<T>,T> implements Serializable
- Class edu.iu.dsc.tws.tset.links.streaming.StreamingSingleLink extends StreamingTLinkImpl<T,T> implements Serializable
- Class edu.iu.dsc.tws.tset.links.streaming.StreamingTLinkImpl extends BaseTLinkWithSchema<T1,T0> implements Serializable
  - Serialized Fields
    - windowParameter
```
WindowParameter windowParameter
```
Package edu.iu.dsc.tws.tset.ops
- Class edu.iu.dsc.tws.tset.ops.BaseComputeOp extends BaseOp implements Serializable
  - Serialized Fields
    - multiEdgeOpAdapter
```
MultiEdgeOpAdapter multiEdgeOpAdapter
```
- Class edu.iu.dsc.tws.tset.ops.BaseOp extends java.lang.Object implements Serializable
  - Serialized Fields
    - tSetContext
```
TSetContext tSetContext
```
    - receivables
```
IONames receivables
```
    - rcvTSets
```
java.util.Map<K,V> rcvTSets
```
- Class edu.iu.dsc.tws.tset.ops.CheckpointedSourceOp extends SourceOp<T> implements Serializable
  - Serialized Fields
    - sourceWrapper
```
DiskPartitionBackedSourceWrapper<T> sourceWrapper
```
    - collectible
```
IONames collectible
```
- Class edu.iu.dsc.tws.tset.ops.ComputeCollectorOp extends BaseComputeOp<I> implements Serializable
  - Serialized Fields
    - computeFunction
```
ComputeCollectorFunc<O,I> computeFunction
```
    - output
```
RecordCollector<T> output
```
- Class edu.iu.dsc.tws.tset.ops.ComputeCollectorToTupleOp extends BaseComputeOp<I> implements Serializable
  - Serialized Fields
    - compFunction
```
ComputeCollectorFunc<O,I> compFunction
```
    - collector
```
RecordCollector<T> collector
```
- Class edu.iu.dsc.tws.tset.ops.ComputeOp extends BaseComputeOp<I> implements Serializable
  - Serialized Fields
    - computeFunction
```
ComputeFunc<O,I> computeFunction
```
- Class edu.iu.dsc.tws.tset.ops.ComputeToTupleOp extends BaseComputeOp<I> implements Serializable
  - Serialized Fields
    - computeFunc
```
ComputeFunc<O,I> computeFunc
```
- Class edu.iu.dsc.tws.tset.ops.KeyedSourceOp extends SourceOp<Tuple<K,V>> implements Serializable
- Class edu.iu.dsc.tws.tset.ops.SinkOp extends BaseOp implements Serializable
  
  serialVersionUID:
  
  -9398832570L
  - Serialized Fields
    - sink
```
SinkFunc<T> sink
```
    - collectible
```
IONames collectible
```
- Class edu.iu.dsc.tws.tset.ops.SourceOp extends BaseOp implements Serializable
  - Serialized Fields
    - multiEdgeOpAdapter
```
MultiEdgeOpAdapter multiEdgeOpAdapter
```
    - source
```
SourceFunc<T> source
```
- Class edu.iu.dsc.tws.tset.ops.WindowComputeOp extends BaseWindowedSink<I> implements Serializable
  - Serialized Fields
    - tSetContext
```
TSetContext tSetContext
```
    - receivables
```
IONames receivables
```
    - rcvTSets
```
java.util.Map<K,V> rcvTSets
```
    - multiEdgeOpAdapter
```
MultiEdgeOpAdapter multiEdgeOpAdapter
```
    - computeFunction
```
ComputeFunc<O,I> computeFunction
```
Package edu.iu.dsc.tws.tset.ops.row
- Class edu.iu.dsc.tws.tset.ops.row.RowComupteCollectorOp extends BaseComputeOp<Table> implements Serializable
  - Serialized Fields
    - computeFunction
```
ComputeCollectorFunc<O,I> computeFunction
```
    - builder
```
TableBuilder builder
```
    - tableMaxSize
```
long tableMaxSize
```
      Table max size set to 64MB
    - runtime
```
TableRuntime runtime
```
      Table runtime to use, it contains
    - schema
```
RowSchema schema
```
      The output schema
    - collectorImp
```
edu.iu.dsc.tws.tset.ops.row.RowComupteCollectorOp.CollectorImp collectorImp
```
- Class edu.iu.dsc.tws.tset.ops.row.RowItrComputeCollectorOp extends BaseComputeOp<java.util.Iterator<Table>> implements Serializable
  - Serialized Fields
    - computeFunction
```
ComputeCollectorFunc<O,I> computeFunction
```
    - builder
```
TableBuilder builder
```
    - tableMaxSize
```
long tableMaxSize
```
      Table max size set to 64MB
    - runtime
```
TableRuntime runtime
```
      Table runtime to use, it contains
    - schema
```
RowSchema schema
```
      The output schema
    - collectorImp
```
edu.iu.dsc.tws.tset.ops.row.RowItrComputeCollectorOp.CollectorImp collectorImp
```
- Class edu.iu.dsc.tws.tset.ops.row.RowSinkOp extends BaseOp implements Serializable
  
  serialVersionUID:
  
  -9398832570L
  - Serialized Fields
    - sink
```
SinkFunc<T> sink
```
    - collectible
```
IONames collectible
```
- Class edu.iu.dsc.tws.tset.ops.row.RowSourceOp extends SourceOp<Row> implements Serializable
  - Serialized Fields
    - builder
```
TableBuilder builder
```
    - tableMaxSize
```
long tableMaxSize
```
      Table max size set to 64MB
    - runtime
```
TableRuntime runtime
```
      Table runtime to use, it contains
    - schema
```
RowSchema schema
```
      The output schema
Package edu.iu.dsc.tws.tset.sets
- Class edu.iu.dsc.tws.tset.sets.BaseTSet extends java.lang.Object implements Serializable
  - Serialized Fields
    - name
```
java.lang.String name
```
      Name of the data set
    - id
```
java.lang.String id
```
      ID of the tset
    - parallelism
```
int parallelism
```
      The parallelism of the set
    - isMutable
```
boolean isMutable
```
      Defines if the TSet is Mutable or not
    - stateType
```
BaseTSet.StateType stateType
```
      The type of the TSet
- Class edu.iu.dsc.tws.tset.sets.BaseTSetWithSchema extends BaseTSet<T> implements Serializable
  - Serialized Fields
    - outSchema
```
Schema outSchema
```
    - inSchema
```
Schema inSchema
```
Package edu.iu.dsc.tws.tset.sets.batch
- Class edu.iu.dsc.tws.tset.sets.batch.BatchTSetImpl extends BaseTSetWithSchema<T> implements Serializable
- Class edu.iu.dsc.tws.tset.sets.batch.BatchTupleTSetImpl extends BaseTSetWithSchema<V> implements Serializable
- Class edu.iu.dsc.tws.tset.sets.batch.CachedTSet extends StoredTSet<T> implements Serializable
- Class edu.iu.dsc.tws.tset.sets.batch.CheckpointedTSet extends PersistedTSet<T> implements Serializable
  - Serialized Fields
    - sourceFunc
```
DiskPartitionBackedSource<T> sourceFunc
```
- Class edu.iu.dsc.tws.tset.sets.batch.ComputeTSet extends BatchTSetImpl<O> implements Serializable
  - Serialized Fields
    - computeFunc
```
TFunction<O,I> computeFunc
```
- Class edu.iu.dsc.tws.tset.sets.batch.KeyedCachedTSet extends KeyedStoredTSet<K,V> implements Serializable
- Class edu.iu.dsc.tws.tset.sets.batch.KeyedCheckpointedTSet extends KeyedPersistedTSet<K,V> implements Serializable
  - Serialized Fields
    - sourceFunc
```
DiskPartitionBackedSource<T> sourceFunc
```
- Class edu.iu.dsc.tws.tset.sets.batch.KeyedPersistedTSet extends KeyedStoredTSet<K,V> implements Serializable
- Class edu.iu.dsc.tws.tset.sets.batch.KeyedSourceTSet extends BatchTupleTSetImpl<K,V> implements Serializable
  - Serialized Fields
    - source
```
SourceFunc<T> source
```
- Class edu.iu.dsc.tws.tset.sets.batch.KeyedStoredTSet extends BatchTupleTSetImpl<K,V> implements Serializable
  - Serialized Fields
    - storedSourcePrefix
```
java.lang.String storedSourcePrefix
```
    - storingSinkFunc
```
SinkFunc<T> storingSinkFunc
```
    - storedSource
```
KeyedSourceTSet<K,V> storedSource
```
- Class edu.iu.dsc.tws.tset.sets.batch.KeyedTSet extends BatchTupleTSetImpl<K,V> implements Serializable
  - Serialized Fields
    - mapToTupleFunc
```
TFunction<O,I> mapToTupleFunc
```
- Class edu.iu.dsc.tws.tset.sets.batch.PersistedTSet extends StoredTSet<T> implements Serializable
- Class edu.iu.dsc.tws.tset.sets.batch.SinkTSet extends BaseTSetWithSchema<T> implements Serializable
  - Serialized Fields
    - sinkFunc
```
SinkFunc<T> sinkFunc
```
- Class edu.iu.dsc.tws.tset.sets.batch.SourceTSet extends BatchTSetImpl<T> implements Serializable
  - Serialized Fields
    - source
```
SourceFunc<T> source
```
- Class edu.iu.dsc.tws.tset.sets.batch.StoredTSet extends BatchTSetImpl<T> implements Serializable
  - Serialized Fields
    - storingSinkFunc
```
SinkFunc<T> storingSinkFunc
```
    - storedSourcePrefix
```
java.lang.String storedSourcePrefix
```
    - storedSource
```
SourceTSet<T> storedSource
```
Package edu.iu.dsc.tws.tset.sets.batch.functions
- Class edu.iu.dsc.tws.tset.sets.batch.functions.IdentityFunction extends java.lang.Object implements Serializable
Package edu.iu.dsc.tws.tset.sets.batch.row
- Class edu.iu.dsc.tws.tset.sets.batch.row.BatchRowTSetImpl extends BaseTSetWithSchema<Row> implements Serializable
- Class edu.iu.dsc.tws.tset.sets.batch.row.RowCachedTSet extends RowStoredTSet implements Serializable
- Class edu.iu.dsc.tws.tset.sets.batch.row.RowCheckpointedTSet extends RowPersistedTSet implements Serializable
  - Serialized Fields
    - sourceFunc
```
DiskPartitionBackedSource<T> sourceFunc
```
- Class edu.iu.dsc.tws.tset.sets.batch.row.RowComputeTSet extends BatchRowTSetImpl implements Serializable
  - Serialized Fields
    - computeFunc
```
TFunction<O,I> computeFunc
```
    - iterative
```
boolean iterative
```
- Class edu.iu.dsc.tws.tset.sets.batch.row.RowPersistedTSet extends RowStoredTSet implements Serializable
- Class edu.iu.dsc.tws.tset.sets.batch.row.RowSinkTSet extends BaseTSetWithSchema<Row> implements Serializable
  - Serialized Fields
    - sinkFunc
```
SinkFunc<T> sinkFunc
```
- Class edu.iu.dsc.tws.tset.sets.batch.row.RowSourceTSet extends BatchRowTSetImpl implements Serializable
  - Serialized Fields
    - source
```
SourceFunc<T> source
```
- Class edu.iu.dsc.tws.tset.sets.batch.row.RowStoredTSet extends BatchRowTSetImpl implements Serializable
  - Serialized Fields
    - storedSourcePrefix
```
java.lang.String storedSourcePrefix
```
    - storingSinkFunc
```
SinkFunc<T> storingSinkFunc
```
    - storedSource
```
RowSourceTSet storedSource
```
Package edu.iu.dsc.tws.tset.sets.streaming
- Class edu.iu.dsc.tws.tset.sets.streaming.SComputeTSet extends StreamingTSetImpl<O> implements Serializable
  - Serialized Fields
    - computeFunc
```
TFunction<O,I> computeFunc
```
- Class edu.iu.dsc.tws.tset.sets.streaming.SKeyedSourceTSet extends StreamingTupleTSetImpl<K,V> implements Serializable
  - Serialized Fields
    - source
```
SourceFunc<T> source
```
- Class edu.iu.dsc.tws.tset.sets.streaming.SKeyedTSet extends StreamingTupleTSetImpl<K,V> implements Serializable
  - Serialized Fields
    - mapToTupleFunc
```
TFunction<O,I> mapToTupleFunc
```
- Class edu.iu.dsc.tws.tset.sets.streaming.SSinkTSet extends StreamingTSetImpl<T> implements Serializable
  - Serialized Fields
    - sink
```
SinkFunc<T> sink
```
- Class edu.iu.dsc.tws.tset.sets.streaming.SSourceTSet extends StreamingTSetImpl<T> implements Serializable
  - Serialized Fields
    - source
```
SourceFunc<T> source
```
- Class edu.iu.dsc.tws.tset.sets.streaming.StreamingTSetImpl extends BaseTSetWithSchema<T> implements Serializable
- Class edu.iu.dsc.tws.tset.sets.streaming.StreamingTupleTSetImpl extends BaseTSetWithSchema<V> implements Serializable
- Class edu.iu.dsc.tws.tset.sets.streaming.WindowComputeTSet extends StreamingTSetImpl<O> implements Serializable
  - Serialized Fields
    - computeFunc
```
TFunction<O,I> computeFunc
```
    - windowParameter
```
WindowParameter windowParameter
```
Package edu.iu.dsc.tws.tset.sinks
- Class edu.iu.dsc.tws.tset.sinks.BaseDiskPersistIterSink extends StoreIterSink<T,T1> implements Serializable
  - Serialized Fields
    - partition
```
DiskBackedCollectionPartition<T> partition
```
    - referencePrefix
```
java.lang.String referencePrefix
```
- Class edu.iu.dsc.tws.tset.sinks.CacheGatherSink extends StoreIterSink<Tuple<java.lang.Integer,T>,T> implements Serializable
  - Serialized Fields
    - partition
```
CollectionPartition<T> partition
```
- Class edu.iu.dsc.tws.tset.sinks.CacheIterSink extends StoreIterSink<T,T> implements Serializable
  - Serialized Fields
    - partition
```
CollectionPartition<T> partition
```
- Class edu.iu.dsc.tws.tset.sinks.CacheSingleSink extends BaseSinkFunc<T> implements Serializable
  - Serialized Fields
    - partition
```
EntityPartition<T> partition
```
- Class edu.iu.dsc.tws.tset.sinks.DiskPersistGatherIterSink extends BaseDiskPersistIterSink<Tuple<java.lang.Integer,T>,T> implements Serializable
- Class edu.iu.dsc.tws.tset.sinks.DiskPersistIterIterSink extends BaseDiskPersistIterSink<T,T> implements Serializable
- Class edu.iu.dsc.tws.tset.sinks.DiskPersistSingleSink extends BaseSinkFunc<T> implements Serializable
  - Serialized Fields
    - partition
```
DiskBackedCollectionPartition<T> partition
```
    - referencePrefix
```
java.lang.String referencePrefix
```
- Class edu.iu.dsc.tws.tset.sinks.FileIterSink extends java.lang.Object implements Serializable
  - Serialized Fields
    - output
```
FileOutputWriter<T> output
```
    - partition
```
int partition
```
- Class edu.iu.dsc.tws.tset.sinks.FileSink extends java.lang.Object implements Serializable
  - Serialized Fields
    - output
```
FileOutputWriter<T> output
```
    - partition
```
int partition
```
- Class edu.iu.dsc.tws.tset.sinks.StoreIterSink extends BaseSinkFunc<java.util.Iterator<T>> implements Serializable
- Class edu.iu.dsc.tws.tset.sinks.StreamingCacheSink extends BaseSinkFunc<T> implements Serializable
  - Serialized Fields
    - partition
```
CollectionPartition<T> partition
```
- Class edu.iu.dsc.tws.tset.sinks.StreamingDiskPersistSink extends BaseSinkFunc<T> implements Serializable
  - Serialized Fields
    - partition
```
DiskBackedCollectionPartition<T> partition
```
    - referencePrefix
```
java.lang.String referencePrefix
```
Package edu.iu.dsc.tws.tset.sources
- Class edu.iu.dsc.tws.tset.sources.CollectionSource extends java.lang.Object implements Serializable
  - Serialized Fields
    - collection
```
java.util.Collection<E> collection
```
      Collection to be divided
    - startIndex
```
int startIndex
```
      The start of the collection for this instance
    - endIndex
```
int endIndex
```
      End of the collection
    - itr
```
java.util.Iterator<E> itr
```
      The current index
    - currentIndex
```
int currentIndex
```
      The current index
- Class edu.iu.dsc.tws.tset.sources.DataPartitionSourceFunc extends BaseSourceFunc<T> implements Serializable
  - Serialized Fields
    - storedKey
```
java.lang.String storedKey
```
- Class edu.iu.dsc.tws.tset.sources.DiskPartitionBackedSource extends BaseSourceFunc<T> implements Serializable
  - Serialized Fields
    - consumer
```
DataPartitionConsumer<T> consumer
```
    - referencePrefix
```
java.lang.String referencePrefix
```
    - diskPartition
```
DiskBackedCollectionPartition<T> diskPartition
```
- Class edu.iu.dsc.tws.tset.sources.DiskPartitionBackedSourceWrapper extends BaseSourceFunc<T> implements Serializable
  - Serialized Fields
    - sourceFunc
```
DiskPartitionBackedSource<T> sourceFunc
```
- Class edu.iu.dsc.tws.tset.sources.FileSource extends java.lang.Object implements Serializable
  - Serialized Fields
    - inputPartitioner
```
FileInputPartitioner<OT> inputPartitioner
```
      The input partitioner
    - splits
```
FileInputSplit<OT>[] splits
```
      Splits created
    - currentSplit
```
InputSplit<OT> currentSplit
```
      The current split we are using
    - tSetContext
```
TSetContext tSetContext
```
      The context
- Class edu.iu.dsc.tws.tset.sources.HadoopConfSerializeWrapper extends java.lang.Object implements Serializable
  - Serialized Fields
    - value
```
byte[] value
```
      Holds the serialize value
- Class edu.iu.dsc.tws.tset.sources.HadoopSource extends java.lang.Object implements Serializable
  - Serialized Fields
    - inputClazz
```
java.lang.Class<T> inputClazz
```
      InputFormat class
    - wrappedConfiguration
```
HadoopConfSerializeWrapper wrappedConfiguration
```
      The wrapped configurations for serialization
    - assignedSplits
```
java.util.List<E> assignedSplits
```
      Assigned splits for this task
    - consumingSplit
```
int consumingSplit
```
      The current consuming split
    - currentReader
```
<any> currentReader
```
      The current record reader
    - format
```
<any> format
```
      The initialized InputFormat
    - jconf
```
JobConf jconf
```
      Job configuration
    - context
```
TSetContext context
```
      TSet context
- Class edu.iu.dsc.tws.tset.sources.HadoopSourceWithMap extends java.lang.Object implements Serializable
  - Serialized Fields
    - inputClazz
```
java.lang.Class<T> inputClazz
```
      InputFormat class
    - wrappedConfiguration
```
HadoopConfSerializeWrapper wrappedConfiguration
```
      The wrapped configurations for serialization
    - assignedSplits
```
java.util.List<E> assignedSplits
```
      Assigned splits for this task
    - consumingSplit
```
int consumingSplit
```
      The current consuming split
    - currentReader
```
<any> currentReader
```
      The current record reader
    - format
```
<any> format
```
      The initialized InputFormat
    - jconf
```
JobConf jconf
```
      Job configuration
    - context
```
TSetContext context
```
      TSet context
    - mapFunc
```
MapFunc<O,I> mapFunc
```
      Map function
Package org.apache.beam.runners.twister2
- Class org.apache.beam.runners.twister2.BeamBatchWorker extends java.lang.Object implements Serializable
Package org.apache.beam.runners.twister2.examples
- Class org.apache.beam.runners.twister2.examples.MinimalWordCount extends java.lang.Object implements Serializable
- Class org.apache.beam.runners.twister2.examples.ReadSourceTest extends java.lang.Object implements Serializable
- Class org.apache.beam.runners.twister2.examples.WordCount extends java.lang.Object implements Serializable
Package org.apache.beam.runners.twister2.translation.wrappers
- Class org.apache.beam.runners.twister2.translation.wrappers.Twister2BoundedSource extends BaseSourceFunc<<any>> implements Serializable
  - Serialized Fields
    - source
```
<any> source
```
    - numPartitions
```
int numPartitions
```
    - splitSize
```
long splitSize
```
    - partitionedSources
```
java.util.List<E> partitionedSources
```
    - localPartition
```
<any> localPartition
```
Package org.apache.beam.runners.twister2.translators.functions
- Class org.apache.beam.runners.twister2.translators.functions.AssignWindowsFunction extends java.lang.Object implements Serializable
  - Serialized Fields
    - windowFn
```
<any> windowFn
```
- Class org.apache.beam.runners.twister2.translators.functions.ByteToWindowFunction extends java.lang.Object implements Serializable
  - Serialized Fields
    - keyCoder
```
<any> keyCoder
```
    - wvCoder
```
<any> wvCoder
```
- Class org.apache.beam.runners.twister2.translators.functions.DoFnFunction extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  -5701440128544343353L
  - Serialized Fields
    - doFn
```
<any> doFn
```
    - inputCoder
```
<any> inputCoder
```
    - outputCoders
```
java.util.Map<K,V> outputCoders
```
    - windowingStrategy
```
<any> windowingStrategy
```
    - sideInputs
```
java.util.Map<K,V> sideInputs
```
    - mainOutput
```
<any> mainOutput
```
    - outputManager
```
org.apache.beam.runners.twister2.translators.functions.DoFnFunction.DoFnOutputManager outputManager
```
    - sideOutputs
```
java.util.List<E> sideOutputs
```
    - stepcontext
```
StepContext stepcontext
```
    - doFnSchemaInformation
```
DoFnSchemaInformation doFnSchemaInformation
```
    - outputMap
```
java.util.Map<K,V> outputMap
```
- Class org.apache.beam.runners.twister2.translators.functions.GroupByWindowFunction extends java.lang.Object implements Serializable
  - Serialized Fields
    - windowingStrategy
```
<any> windowingStrategy
```
    - reduceFn
```
<any> reduceFn
```
    - options
```
SerializablePipelineOptions options
```
- Class org.apache.beam.runners.twister2.translators.functions.MapToTupleFunction extends java.lang.Object implements Serializable
  - Serialized Fields
    - keyCoder
```
<any> keyCoder
```
    - wvCoder
```
<any> wvCoder
```
- Class org.apache.beam.runners.twister2.translators.functions.OutputTagFilter extends java.lang.Object implements Serializable
  - Serialized Fields
    - tag
```
int tag
```
- Class org.apache.beam.runners.twister2.translators.functions.SideInputSinkFunction extends java.lang.Object implements Serializable
  - Serialized Fields
    - view
```
<any> view
```
- Class org.apache.beam.runners.twister2.translators.functions.Twister2SinkFunction extends java.lang.Object implements Serializable
Package org.apache.beam.runners.twister2.utils
- Class org.apache.beam.runners.twister2.utils.NoOpStepContext extends java.lang.Object implements Serializable
Package org.apache.storm
- Class org.apache.storm.Config extends java.util.HashMap<java.lang.String,java.lang.Object> implements Serializable
  
  serialVersionUID:
  
  4781760255471579334L
Package org.apache.storm.grouping
Package org.apache.storm.spout
- Class org.apache.storm.spout.CheckpointSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    - context
```
TopologyContext context
```
    - collector
```
SpoutOutputCollector collector
```
    - lastCheckpointTs
```
long lastCheckpointTs
```
    - checkpointInterval
```
int checkpointInterval
```
    - sleepInterval
```
int sleepInterval
```
    - recoveryStepInProgress
```
boolean recoveryStepInProgress
```
    - checkpointStepInProgress
```
boolean checkpointStepInProgress
```
    - recovering
```
boolean recovering
```
    - checkpointState
```
KeyValueState<K,V> checkpointState
```
    - curTxState
```
CheckPointState curTxState
```
Package org.apache.storm.streams
- Class org.apache.storm.streams.Pair extends java.lang.Object implements Serializable
  - Serialized Fields
    - val1
```
java.lang.Object val1
```
      The first value
    - val2
```
java.lang.Object val2
```
      The second value
Package org.apache.storm.task
Package org.apache.storm.topology
- Class org.apache.storm.topology.FailedException extends java.lang.RuntimeException implements Serializable
- Class org.apache.storm.topology.TopologyBuilder extends java.lang.Object implements Serializable
  - Serialized Fields
    - nodes
```
java.util.HashMap<K,V> nodes
```
    - sinkNodes
```
java.util.Set<E> sinkNodes
```
    - sourceNodes
```
java.util.Set<E> sourceNodes
```
    - computeNodes
```
java.util.Set<E> computeNodes
```
- Class org.apache.storm.topology.TupleFieldTimestampExtractor extends java.lang.Object implements Serializable
  - Serialized Fields
    - fieldName
```
java.lang.String fieldName
```
- Class org.apache.storm.topology.WindowedBoltExecutor extends java.lang.Object implements Serializable
  - Serialized Fields
    - bolt
```
IWindowedBolt bolt
```
    - timestampExtractor
```
TimestampExtractor timestampExtractor
```
Package org.apache.storm.topology.base
- Class org.apache.storm.topology.base.BaseBasicBolt extends BaseComponent implements Serializable
  
  serialVersionUID:
  
  1464223135325402830L
- Class org.apache.storm.topology.base.BaseComponent extends java.lang.Object implements Serializable
  
  serialVersionUID:
  
  -892888971805729161L
- Class org.apache.storm.topology.base.BaseRichBolt extends BaseComponent implements Serializable
  
  serialVersionUID:
  
  5749013017107995933L
- Class org.apache.storm.topology.base.BaseRichSpout extends BaseComponent implements Serializable
  
  serialVersionUID:
  
  7053278702425063125L
- Class org.apache.storm.topology.base.BaseStatefulWindowedBolt extends BaseWindowedBolt implements Serializable
  - Serialized Fields
    - persistent
```
boolean persistent
```
    - maxEventsInMemory
```
long maxEventsInMemory
```
- Class org.apache.storm.topology.base.BaseWindowedBolt extends java.lang.Object implements Serializable
  - Serialized Fields
    - windowConfiguration
```
java.util.Map<K,V> windowConfiguration
```
    - timestampExtractor
```
TimestampExtractor timestampExtractor
```
- Class org.apache.storm.topology.base.BaseWindowedBolt.Count extends java.lang.Object implements Serializable
  - Serialized Fields
    - value
```
int value
```
- Class org.apache.storm.topology.base.BaseWindowedBolt.Duration extends java.lang.Object implements Serializable
  - Serialized Fields
    - value
```
int value
```
Package org.apache.storm.topology.twister2
- Class org.apache.storm.topology.twister2.EdgeFieldMap extends java.util.HashMap<java.lang.String,Fields> implements Serializable
  - Serialized Fields
    - defaultEdge
```
java.lang.String defaultEdge
```
- Class org.apache.storm.topology.twister2.Twister2Bolt extends java.lang.Object implements Serializable
  - Serialized Fields
    - stormBolt
```
IRichBolt stormBolt
```
    - stormBasicBolt
```
IBasicBolt stormBasicBolt
```
    - stormWindowedBolt
```
BaseWindowedBolt stormWindowedBolt
```
    - stormWindowedBoltExecutor
```
WindowedBoltExecutor stormWindowedBoltExecutor
```
    - boltDeclarer
```
Twister2BoltDeclarer boltDeclarer
```
    - parallelism
```
java.lang.Integer parallelism
```
    - id
```
java.lang.String id
```
    - outputCollector
```
OutputCollector outputCollector
```
    - basicOutputCollector
```
BasicOutputCollector basicOutputCollector
```
    - inboundEdgeToFieldsMap
```
java.util.HashMap<K,V> inboundEdgeToFieldsMap
```
    - outFieldsForEdge
```
EdgeFieldMap outFieldsForEdge
```
    - keyedOutEdges
```
EdgeFieldMap keyedOutEdges
```
- Class org.apache.storm.topology.twister2.Twister2BoltDeclarer extends java.lang.Object implements Serializable
  - Serialized Fields
    - configuration
```
java.util.HashMap<K,V> configuration
```
    - debugOn
```
boolean debugOn
```
    - maxTParallelism
```
java.lang.Number maxTParallelism
```
    - maxSpPending
```
java.lang.Number maxSpPending
```
    - nTasks
```
java.lang.Number nTasks
```
    - groupings
```
java.util.List<E> groupings
```
- Class org.apache.storm.topology.twister2.Twister2BoltGrouping extends java.lang.Object implements Serializable
  - Serialized Fields
    - groupingTechnique
```
GroupingTechnique groupingTechnique
```
    - componentId
```
java.lang.String componentId
```
    - streamId
```
java.lang.String streamId
```
    - groupingKey
```
Fields groupingKey
```
- Class org.apache.storm.topology.twister2.Twister2Spout extends java.lang.Object implements Serializable
  - Serialized Fields
    - stormSpout
```
IRichSpout stormSpout
```
    - spoutDeclarer
```
Twister2SpoutDeclarer spoutDeclarer
```
    - parallelism
```
java.lang.Integer parallelism
```
    - id
```
java.lang.String id
```
    - outFieldsForEdge
```
EdgeFieldMap outFieldsForEdge
```
    - keyedOutEdges
```
EdgeFieldMap keyedOutEdges
```
- Class org.apache.storm.topology.twister2.Twister2SpoutDeclarer extends java.lang.Object implements Serializable
  - Serialized Fields
    - maxTParallelism
```
java.lang.Number maxTParallelism
```
    - maxSpPending
```
java.lang.Number maxSpPending
```
    - nTasks
```
java.lang.Number nTasks
```
    - debugOn
```
boolean debugOn
```
    - configuration
```
java.util.HashMap<K,V> configuration
```
Package org.apache.storm.tuple
- Class org.apache.storm.tuple.Fields extends java.lang.Object implements Serializable
  - Serialized Fields
    - fields
```
java.util.List<E> fields
```
    - index
```
java.util.Map<K,V> index
```
- Class org.apache.storm.tuple.Values extends java.util.ArrayList<java.lang.Object> implements Serializable
Package org.apache.storm.windowing

Serialized Form

Package edu.iu.dsc.tws.api

Class edu.iu.dsc.tws.api.JobConfig extends java.util.HashMap<java.lang.String,java.lang.Object> implements Serializable

Package edu.iu.dsc.tws.api.comms.packing

Class edu.iu.dsc.tws.api.comms.packing.PackerStore extends java.util.HashMap<java.lang.String,java.lang.Object> implements Serializable

Package edu.iu.dsc.tws.api.compute

Package edu.iu.dsc.tws.api.compute.exceptions

Class edu.iu.dsc.tws.api.compute.exceptions.TaskSchedulerException extends Twister2RuntimeException implements Serializable

Package edu.iu.dsc.tws.api.compute.modifiers

Class edu.iu.dsc.tws.api.compute.modifiers.IONames extends java.util.HashSet<java.lang.String> implements Serializable

Package edu.iu.dsc.tws.api.compute.nodes

Class edu.iu.dsc.tws.api.compute.nodes.BaseCompute extends BaseNode implements Serializable

Class edu.iu.dsc.tws.api.compute.nodes.BaseNode extends java.lang.Object implements Serializable

Serialized Fields

context

config

Class edu.iu.dsc.tws.api.compute.nodes.BaseSource extends BaseNode implements Serializable

Package edu.iu.dsc.tws.api.data

Class edu.iu.dsc.tws.api.data.FileSystem extends java.lang.Object implements Serializable

Class edu.iu.dsc.tws.api.data.Path extends java.lang.Object implements Serializable

Serialized Fields

uri

Package edu.iu.dsc.tws.api.dataset

Class edu.iu.dsc.tws.api.dataset.EmptyDataObject extends java.lang.Object implements Serializable

Class edu.iu.dsc.tws.api.dataset.EmptyDataPartition extends java.lang.Object implements Serializable

Package edu.iu.dsc.tws.api.exceptions

Class edu.iu.dsc.tws.api.exceptions.JobFaultyException extends Twister2RuntimeException implements Serializable

Class edu.iu.dsc.tws.api.exceptions.TimeoutException extends Twister2Exception implements Serializable

Class edu.iu.dsc.tws.api.exceptions.Twister2Exception extends java.lang.Exception implements Serializable

Class edu.iu.dsc.tws.api.exceptions.Twister2RuntimeException extends java.lang.RuntimeException implements Serializable

Package edu.iu.dsc.tws.api.exceptions.net

Class edu.iu.dsc.tws.api.exceptions.net.BlockingSendException extends Twister2Exception implements Serializable

Serialized Fields

failureReason

Package edu.iu.dsc.tws.api.scheduler

Class edu.iu.dsc.tws.api.scheduler.LauncherException extends Twister2RuntimeException implements Serializable

Class edu.iu.dsc.tws.api.scheduler.UploaderException extends Twister2RuntimeException implements Serializable

Package edu.iu.dsc.tws.api.tset

Class edu.iu.dsc.tws.api.tset.TSetContext extends java.lang.Object implements Serializable

Serialized Fields

tSetIndex

tSetId

tSetName

parallelism

configs

inputMap

workerId

config

Package edu.iu.dsc.tws.api.tset.fn

Class edu.iu.dsc.tws.api.tset.fn.BaseApplyFunc extends BaseTFunction<T,T> implements Serializable

Class edu.iu.dsc.tws.api.tset.fn.BaseComputeCollectorFunc extends BaseTFunction<O,I> implements Serializable

Class edu.iu.dsc.tws.api.tset.fn.BaseComputeFunc extends BaseTFunction<O,I> implements Serializable

Class edu.iu.dsc.tws.api.tset.fn.BaseMapFunc extends BaseTFunction<O,I> implements Serializable

Class edu.iu.dsc.tws.api.tset.fn.BaseSinkFunc extends BaseTFunction<T,T> implements Serializable

Class edu.iu.dsc.tws.api.tset.fn.BaseSourceFunc extends BaseTFunction<T,T> implements Serializable

Class edu.iu.dsc.tws.api.tset.fn.BaseTFunction extends java.lang.Object implements Serializable

Serialized Fields

context

Package edu.iu.dsc.tws.api.tset.link

Package edu.iu.dsc.tws.api.tset.link.batch

Package edu.iu.dsc.tws.api.tset.link.streaming

Package edu.iu.dsc.tws.api.tset.sets

Package edu.iu.dsc.tws.api.tset.sets.batch

Package edu.iu.dsc.tws.api.tset.sets.streaming

Package edu.iu.dsc.tws.checkpointing.task

Class edu.iu.dsc.tws.checkpointing.task.CheckpointingSGatherSink extends java.lang.Object implements Serializable

Serialized Fields

taskContext

parentTaskName

parentTaskId

Package edu.iu.dsc.tws.common.logging

Class edu.iu.dsc.tws.common.logging.LoggingHelper.StdOutErrLevel extends java.util.logging.Level implements Serializable

Serialization Methods

readResolve

Package edu.iu.dsc.tws.common.pojo

Class edu.iu.dsc.tws.common.pojo.Time extends java.lang.Object implements Serializable

Serialized Fields

size

unit

Package edu.iu.dsc.tws.comms.dfw.io