Uses of Class
org.apache.wayang.profiler.spark.SparkUnaryOperatorProfiler

Packages that use SparkUnaryOperatorProfiler

Package	Description
org.apache.wayang.profiler.spark

Uses of SparkUnaryOperatorProfiler in org.apache.wayang.profiler.spark

Methods in org.apache.wayang.profiler.spark that return SparkUnaryOperatorProfiler

Modifier and Type	Method	Description
static SparkUnaryOperatorProfiler	OperatorProfilers.createSparkCountProfiler()	Creates a default SparkCountOperator profiler.
static <In> SparkUnaryOperatorProfiler	OperatorProfilers.createSparkCountProfiler(Supplier<In> dataGenerator, Class<In> inClass, Configuration configuration)	Creates a custom SparkCountOperator profiler.
static SparkUnaryOperatorProfiler	OperatorProfilers.createSparkDistinctProfiler()	Creates a default SparkDistinctOperator profiler.
static <Type> SparkUnaryOperatorProfiler	OperatorProfilers.createSparkDistinctProfiler(Supplier<Type> dataGenerator, Class<Type> inOutClass, Configuration configuration)	Creates a custom SparkGlobalReduceOperator profiler.
static SparkUnaryOperatorProfiler	OperatorProfilers.createSparkFilterProfiler()	Creates a default SparkFilterOperator profiler.
static <Type> SparkUnaryOperatorProfiler	OperatorProfilers.createSparkFilterProfiler(Supplier<Type> dataGenerator, FunctionDescriptor.SerializablePredicate<Type> udf, Class<Type> inOutClass, Configuration configuration)	Creates a custom SparkMapOperator profiler.
static SparkUnaryOperatorProfiler	OperatorProfilers.createSparkFlatMapProfiler()	Creates a default SparkFlatMapOperator profiler.
static <In, Out> SparkUnaryOperatorProfiler	OperatorProfilers.createSparkFlatMapProfiler(Supplier<In> dataGenerator, FunctionDescriptor.SerializableFunction<In,Iterable<Out>> udf, Class<In> inClass, Class<Out> outClass, Configuration configuration)	Creates a custom SparkFlatMapOperator profiler.
static SparkUnaryOperatorProfiler	OperatorProfilers.createSparkGlobalReduceProfiler()	Creates a default SparkGlobalReduceOperator profiler.
static <Type> SparkUnaryOperatorProfiler	OperatorProfilers.createSparkGlobalReduceProfiler(Supplier<Type> dataGenerator, FunctionDescriptor.SerializableBinaryOperator<Type> udf, Class<Type> inOutClass, Configuration configuration)	Creates a custom SparkGlobalReduceOperator profiler.
static SparkUnaryOperatorProfiler	OperatorProfilers.createSparkMapProfiler()	Creates a default SparkMapOperator profiler.
static <In, Out> SparkUnaryOperatorProfiler	OperatorProfilers.createSparkMapProfiler(Supplier<In> dataGenerator, FunctionDescriptor.SerializableFunction<In,Out> udf, Class<In> inClass, Class<Out> outClass, Configuration configuration)	Creates a custom SparkMapOperator profiler.
static SparkUnaryOperatorProfiler	OperatorProfilers.createSparkMaterializedGroupByProfiler()	Creates a default SparkMaterializedGroupByOperator profiler.
static <In, Key> SparkUnaryOperatorProfiler	OperatorProfilers.createSparkMaterializedGroupByProfiler(Supplier<In> dataGenerator, FunctionDescriptor.SerializableFunction<In,Key> keyUdf, Class<In> inClass, Class<Key> keyClass, Configuration configuration)	Creates a custom SparkMaterializedGroupByOperator profiler.
static SparkUnaryOperatorProfiler	OperatorProfilers.createSparkReduceByProfiler()	Creates a default SparkReduceByOperator profiler.
static <In, Key> SparkUnaryOperatorProfiler	OperatorProfilers.createSparkReduceByProfiler(Supplier<In> dataGenerator, FunctionDescriptor.SerializableFunction<In,Key> keyUdf, FunctionDescriptor.SerializableBinaryOperator<In> udf, Class<In> inOutClass, Class<Key> keyClass, Configuration configuration)	Creates a custom SparkReduceByOperator profiler.
static SparkUnaryOperatorProfiler	OperatorProfilers.createSparkSortProfiler()	Creates a default SparkSortOperator profiler.
static <Type> SparkUnaryOperatorProfiler	OperatorProfilers.createSparkSortProfiler(Supplier<Type> dataGenerator, Class<Type> inOutClass, Configuration configuration)	Creates a custom SparkSortOperator profiler.