Package org.apache.wayang.core.profiling

Class ExecutionLog

java.lang.Object

org.apache.wayang.core.profiling.ExecutionLog

All Implemented Interfaces:

java.lang.AutoCloseable

public class ExecutionLog
extends java.lang.Object
implements java.lang.AutoCloseable

Stores execution data have been collected by the CrossPlatformExecutor. The current version uses JSON as serialization format.

Method Summary

Modifier and Type	Method	Description
void	close()
static ExecutionLog	open(Configuration configuration)	Opens an instance according to the Configuration.
static ExecutionLog	open(Configuration configuration, java.lang.String repositoryPath)	Opens an instance.
void	store(PartialExecution partialExecution)	Stores the given PartialExecution in this instance.
void	storeAll(java.lang.Iterable<PartialExecution> partialExecutions)	Stores the given PartialExecutions in this instance.
java.util.stream.Stream<PartialExecution>	stream()	Streams the contents of this instance.

Methods inherited from class java.lang.Object

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

Method Detail

open

public static ExecutionLog open(Configuration configuration)

Opens an instance according to the Configuration.

Parameters:

configuration - describes the instance to be opened

Returns:

the new instance

open

public static ExecutionLog open(Configuration configuration,
                                java.lang.String repositoryPath)

Opens an instance.

Parameters:

configuration - describes the instance to be opened

repositoryPath - location of the instance

Returns:

the new instance

storeAll

public void storeAll(java.lang.Iterable<PartialExecution> partialExecutions)
              throws java.io.IOException

Stores the given PartialExecutions in this instance.

Parameters:

partialExecutions - that should be stored

Throws:

java.io.IOException

store

public void store(PartialExecution partialExecution)
           throws java.io.IOException

Stores the given PartialExecution in this instance.

Parameters:

partialExecution - that should be stored

Throws:

java.io.IOException

stream

public java.util.stream.Stream<PartialExecution> stream()
                                                 throws java.io.IOException

Streams the contents of this instance.

Returns:

a Stream of the contained PartialExecutions

Throws:

java.io.IOException

close

public void close()
           throws java.lang.Exception

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.lang.Exception