Package org.apache.wayang.profiler.java

Class JavaCollectionSourceProfiler

java.lang.Object

org.apache.wayang.profiler.java.OperatorProfiler

org.apache.wayang.profiler.java.SourceProfiler

org.apache.wayang.profiler.java.JavaCollectionSourceProfiler

public class JavaCollectionSourceProfiler
extends SourceProfiler

OperatorProfiler for JavaCollectionSources.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.wayang.profiler.java.OperatorProfiler

OperatorProfiler.Result

Field Summary

Fields inherited from class org.apache.wayang.profiler.java.OperatorProfiler

cpuMhz, dataQuantumGenerators, executor, logger, operator, operatorGenerator

Constructor Summary

Constructors

Constructor	Description
JavaCollectionSourceProfiler(java.util.function.Supplier<?> dataQuantumGenerator)

Method Summary

Methods inherited from class org.apache.wayang.profiler.java.SourceProfiler

executeOperator, prepare

Methods inherited from class org.apache.wayang.profiler.java.OperatorProfiler

createChannelInstance, createChannelInstance, evaluate, getOperator, provideDiskBytes, provideNetworkBytes, run

Methods inherited from class java.lang.Object

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

Constructor Detail

JavaCollectionSourceProfiler

public JavaCollectionSourceProfiler(java.util.function.Supplier<?> dataQuantumGenerator)