patchset to stratosphere-0.2 to allow for latency optimizations in streaming applications
addendum to stratosphere-0.2 patchset
new nephele component for streaming
added streaming plugin configuration to stratosphere-dist
Changed version strings
changed Environment.registerMapper() to a generic method (using raw types produced a lot of warnings)
* fixed division by zero bug caused by inactive edges being ignored during buffer size logging
* fixed bug that cause output buffer latencies to not be reported (mistake during 0.2 merge)
profiling data aggregation on task managers (works locally, needs testing)
added plugin data attachment ExecutionVertex and TaskDeploymentDescriptor
nephele-server: execution vertices can be attached with arbitrary plugin data, that will be handed to the plugin on the task manager side
* added distributed profiling
** job manager sets up profiling master threads on task managers for job
** job manager instructs other task managers to send data to profiling masters
** profiling master does not yet analyze the received data (TODO)
fixed bug that caused ArrayIndexOutOfBoundsException
fixed some bugs and improved logging
fixed pom file to include streaming project
code style
parallel profiling master setup
* first sketch of using new ProfilingSequence for latency profiling
* implemented pruning algorithm to efficiently find active paths (low memory overhead, enumeration scheme)
config file changes
profiling master code with adjustment