Uses of Class
org.apache.wayang.profiler.spark.SinkProfiler
Packages that use SinkProfiler
-
Uses of SinkProfiler in org.apache.wayang.profiler.spark
Methods in org.apache.wayang.profiler.spark that return SinkProfilerModifier and TypeMethodDescriptionstatic SinkProfiler
OperatorProfilers.createSparkLocalCallbackSinkProfiler()
Creates a defaultSparkLocalCallbackSink
profiler.static <Type> SinkProfiler
OperatorProfilers.createSparkLocalCallbackSinkProfiler
(Supplier<Type> dataGenerator, Class<Type> typeClass, Configuration configuration) Creates a customSparkLocalCallbackSink
profiler.