Package org.apache.wayang.profiler.java

Class OperatorProfiler

java.lang.Object

org.apache.wayang.profiler.java.OperatorProfiler

Direct Known Subclasses:

BinaryOperatorProfiler, SinkProfiler, SourceProfiler, UnaryOperatorProfiler

public abstract class OperatorProfiler
extends Object

Allows to instrument an JavaExecutionOperator.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	OperatorProfiler.Result	The result of a single profiling run.

Field Summary

Fields

Modifier and Type	Field	Description
int	cpuMhz
protected final List<Supplier<?>>	dataQuantumGenerators
protected JavaExecutor	executor
protected final org.apache.logging.log4j.Logger	logger
protected JavaExecutionOperator	operator
protected Supplier<JavaExecutionOperator>	operatorGenerator

Constructor Summary

Constructors

Constructor	Description
OperatorProfiler(Supplier<JavaExecutionOperator> operatorGenerator, Supplier<?>... dataQuantumGenerators)

Method Summary

Modifier and Type	Method	Description
protected static CollectionChannel.Instance	createChannelInstance()
protected static CollectionChannel.Instance	createChannelInstance(Collection<?> collection)
protected void	evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs)	Utility method to invoke JavaExecutionOperator.evaluate(ChannelInstance[], ChannelInstance[], JavaExecutor, OptimizationContext.OperatorContext).
protected abstract long	executeOperator()	Executes the profiling task.
JavaExecutionOperator	getOperator()
void	prepare(long... inputCardinalities)
protected long	provideDiskBytes()
protected long	provideNetworkBytes()
OperatorProfiler.Result	run()	Executes and profiles the profiling task.

Methods inherited from class java.lang.Object

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

Field Details

logger

protected final org.apache.logging.log4j.Logger logger

cpuMhz

public int cpuMhz

operatorGenerator

protected Supplier<JavaExecutionOperator> operatorGenerator

operator

protected JavaExecutionOperator operator

executor

protected JavaExecutor executor

dataQuantumGenerators

protected final List<Supplier<?>> dataQuantumGenerators

Constructor Details

OperatorProfiler

public OperatorProfiler(Supplier<JavaExecutionOperator> operatorGenerator,
 Supplier<?>... dataQuantumGenerators)

Method Details

prepare

public void prepare(long... inputCardinalities)

run

public OperatorProfiler.Result run()

Executes and profiles the profiling task. Requires that this instance is prepared.

provideNetworkBytes

protected long provideNetworkBytes()

provideDiskBytes

protected long provideDiskBytes()

executeOperator

protected abstract long executeOperator()

Executes the profiling task. Requires that this instance is prepared.

createChannelInstance

protected static CollectionChannel.Instance createChannelInstance(Collection<?> collection)

createChannelInstance

protected static CollectionChannel.Instance createChannelInstance()

getOperator

public JavaExecutionOperator getOperator()

evaluate

protected void evaluate(ChannelInstance[] inputs,
 ChannelInstance[] outputs)

Utility method to invoke JavaExecutionOperator.evaluate(ChannelInstance[], ChannelInstance[], JavaExecutor, OptimizationContext.OperatorContext).