Package org.apache.wayang.profiler.java

Class JavaTextFileSourceProfiler

java.lang.Object

org.apache.wayang.profiler.java.OperatorProfiler

org.apache.wayang.profiler.java.SourceProfiler

org.apache.wayang.profiler.java.JavaTextFileSourceProfiler

public class JavaTextFileSourceProfiler
extends SourceProfiler

OperatorProfiler for sources.

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
JavaTextFileSourceProfiler(java.util.function.Supplier<java.lang.String> dataQuantumGenerator, java.lang.String fileUrl)

Method Summary

Modifier and Type	Method	Description
protected long	provideDiskBytes()

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, provideNetworkBytes, run

Methods inherited from class java.lang.Object

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

Constructor Detail

JavaTextFileSourceProfiler

public JavaTextFileSourceProfiler(java.util.function.Supplier<java.lang.String> dataQuantumGenerator,
                                  java.lang.String fileUrl)

Method Detail

provideDiskBytes

protected long provideDiskBytes()

Overrides:

provideDiskBytes in class OperatorProfiler