edu.iu.dsc.tws.python

Class Twister2Environment

java.lang.Object

edu.iu.dsc.tws.python.EntryPoint

edu.iu.dsc.tws.python.Twister2Environment

All Implemented Interfaces:

Closable

public class Twister2Environment
extends EntryPoint

Method Summary

Modifier and Type	Method and Description
KeyedSourceTSet	createKeyedSource(byte[] lambda, int parallelism)
SourceTSet	createSource(byte[] lambda, int parallelism)
TSetFunctions	functions()
Config	getConfig()
NumpyHolderBuilder	getNumpyBuilder()
java.util.Map<java.lang.Integer,java.lang.String>	getPeerNetworkInfo()
int	getWorkerId()
SourceTSet	parallelize(java.util.List data, int parallelism)
KeyedSourceTSet	parallelize(java.util.Map map, java.util.Comparator comparator, int parallelism)
KeyedSourceTSet	parallelize(java.util.Map map, int parallelism)

Methods inherited from class edu.iu.dsc.tws.python.EntryPoint

close, waitForCompletion

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface edu.iu.dsc.tws.api.compute.modifiers.Closable

reset

Method Detail

getPeerNetworkInfo

public java.util.Map<java.lang.Integer,java.lang.String> getPeerNetworkInfo()

getWorkerId

public int getWorkerId()

getConfig

public Config getConfig()

createSource

public SourceTSet createSource(byte[] lambda,
                               int parallelism)

parallelize

public SourceTSet parallelize(java.util.List data,
                              int parallelism)

parallelize

public KeyedSourceTSet parallelize(java.util.Map map,
                                   int parallelism)

parallelize

public KeyedSourceTSet parallelize(java.util.Map map,
                                   java.util.Comparator comparator,
                                   int parallelism)

createKeyedSource

public KeyedSourceTSet createKeyedSource(byte[] lambda,
                                         int parallelism)

functions

public TSetFunctions functions()

getNumpyBuilder

public NumpyHolderBuilder getNumpyBuilder()