Package org.apache.wayang.profiler.spark

Class OperatorProfilers

java.lang.Object

org.apache.wayang.profiler.spark.OperatorProfilers

public class OperatorProfilers
extends Object

Utilities to create SparkOperatorProfiler instances.

Constructor Summary

Constructors

Constructor	Description
OperatorProfilers()

Method Summary

Modifier and Type	Method	Description
static BinaryOperatorProfiler	createSparkCartesianProfiler()	Creates a default SparkCartesianOperator profiler.
static <In0, In1> BinaryOperatorProfiler	createSparkCartesianProfiler(Supplier<In0> dataGenerator0, Supplier<In1> dataGenerator1, Class<In0> inClass0, Class<In1> inClass1, Configuration configuration)	Creates a custom SparkCartesianOperator profiler.
static SparkTextFileSourceProfiler	createSparkCollectionSourceProfiler()	Create a default SparkCollectionSource profiler.
static SparkTextFileSourceProfiler	createSparkCollectionSourceProfiler(Supplier<String> dataGenerator, Configuration configuration)	Create a custom SparkTextFileSource profiler.
static SparkUnaryOperatorProfiler	createSparkCountProfiler()	Creates a default SparkCountOperator profiler.
static <In> SparkUnaryOperatorProfiler	createSparkCountProfiler(Supplier<In> dataGenerator, Class<In> inClass, Configuration configuration)	Creates a custom SparkCountOperator profiler.
static SparkUnaryOperatorProfiler	createSparkDistinctProfiler()	Creates a default SparkDistinctOperator profiler.
static <Type> SparkUnaryOperatorProfiler	createSparkDistinctProfiler(Supplier<Type> dataGenerator, Class<Type> inOutClass, Configuration configuration)	Creates a custom SparkGlobalReduceOperator profiler.
static SparkUnaryOperatorProfiler	createSparkFilterProfiler()	Creates a default SparkFilterOperator profiler.
static <Type> SparkUnaryOperatorProfiler	createSparkFilterProfiler(Supplier<Type> dataGenerator, FunctionDescriptor.SerializablePredicate<Type> udf, Class<Type> inOutClass, Configuration configuration)	Creates a custom SparkMapOperator profiler.
static SparkUnaryOperatorProfiler	createSparkFlatMapProfiler()	Creates a default SparkFlatMapOperator profiler.
static <In, Out> SparkUnaryOperatorProfiler	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	createSparkGlobalReduceProfiler()	Creates a default SparkGlobalReduceOperator profiler.
static <Type> SparkUnaryOperatorProfiler	createSparkGlobalReduceProfiler(Supplier<Type> dataGenerator, FunctionDescriptor.SerializableBinaryOperator<Type> udf, Class<Type> inOutClass, Configuration configuration)	Creates a custom SparkGlobalReduceOperator profiler.
static BinaryOperatorProfiler	createSparkJoinProfiler()	Creates a default SparkJoinOperator profiler.
static <In0, In1, Key> BinaryOperatorProfiler	createSparkJoinProfiler(Supplier<In0> dataGenerator0, Class<In0> inClass0, FunctionDescriptor.SerializableFunction<In0,Key> keyUdf0, Supplier<In1> dataGenerator1, Class<In1> inClass1, FunctionDescriptor.SerializableFunction<In1,Key> keyUdf1, Class<Key> keyClass, Configuration configuration)	Creates a custom SparkJoinOperator profiler.
static SinkProfiler	createSparkLocalCallbackSinkProfiler()	Creates a default SparkLocalCallbackSink profiler.
static <Type> SinkProfiler	createSparkLocalCallbackSinkProfiler(Supplier<Type> dataGenerator, Class<Type> typeClass, Configuration configuration)	Creates a custom SparkLocalCallbackSink profiler.
static SparkUnaryOperatorProfiler	createSparkMapProfiler()	Creates a default SparkMapOperator profiler.
static <In, Out> SparkUnaryOperatorProfiler	createSparkMapProfiler(Supplier<In> dataGenerator, FunctionDescriptor.SerializableFunction<In,Out> udf, Class<In> inClass, Class<Out> outClass, Configuration configuration)	Creates a custom SparkMapOperator profiler.
static SparkUnaryOperatorProfiler	createSparkMaterializedGroupByProfiler()	Creates a default SparkMaterializedGroupByOperator profiler.
static <In, Key> SparkUnaryOperatorProfiler	createSparkMaterializedGroupByProfiler(Supplier<In> dataGenerator, FunctionDescriptor.SerializableFunction<In,Key> keyUdf, Class<In> inClass, Class<Key> keyClass, Configuration configuration)	Creates a custom SparkMaterializedGroupByOperator profiler.
static SparkUnaryOperatorProfiler	createSparkReduceByProfiler()	Creates a default SparkReduceByOperator profiler.
static <In, Key> SparkUnaryOperatorProfiler	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	createSparkSortProfiler()	Creates a default SparkSortOperator profiler.
static <Type> SparkUnaryOperatorProfiler	createSparkSortProfiler(Supplier<Type> dataGenerator, Class<Type> inOutClass, Configuration configuration)	Creates a custom SparkSortOperator profiler.
static SparkTextFileSourceProfiler	createSparkTextFileSourceProfiler()	Create a default SparkTextFileSource profiler.
static SparkTextFileSourceProfiler	createSparkTextFileSourceProfiler(Supplier<String> dataGenerator, Configuration configuration)	Create a custom SparkTextFileSource profiler.
static BinaryOperatorProfiler	createSparkUnionProfiler()	Creates a default SparkUnionAllOperator profiler.
static <Type> BinaryOperatorProfiler	createSparkUnionProfiler(Supplier<Type> dataGenerator0, Supplier<Type> dataGenerator1, Class<Type> typeClass, Configuration configuration)	Creates a custom SparkUnionAllOperator profiler.

Methods inherited from class java.lang.Object

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

Constructor Details

OperatorProfilers

public OperatorProfilers()

Method Details

createSparkTextFileSourceProfiler

public static SparkTextFileSourceProfiler createSparkTextFileSourceProfiler()

Create a default SparkTextFileSource profiler.

createSparkTextFileSourceProfiler

public static SparkTextFileSourceProfiler createSparkTextFileSourceProfiler(Supplier<String> dataGenerator,
 Configuration configuration)

Create a custom SparkTextFileSource profiler.

createSparkCollectionSourceProfiler

public static SparkTextFileSourceProfiler createSparkCollectionSourceProfiler()

Create a default SparkCollectionSource profiler.

createSparkCollectionSourceProfiler

public static SparkTextFileSourceProfiler createSparkCollectionSourceProfiler(Supplier<String> dataGenerator,
 Configuration configuration)

Create a custom SparkTextFileSource profiler.

createSparkFlatMapProfiler

public static SparkUnaryOperatorProfiler createSparkFlatMapProfiler()

Creates a default SparkFlatMapOperator profiler.

createSparkFlatMapProfiler

public static <In,
Out> SparkUnaryOperatorProfiler createSparkFlatMapProfiler(Supplier<In> dataGenerator,
 FunctionDescriptor.SerializableFunction<In,Iterable<Out>> udf,
 Class<In> inClass,
 Class<Out> outClass,
 Configuration configuration)

Creates a custom SparkFlatMapOperator profiler.

createSparkMapProfiler

public static SparkUnaryOperatorProfiler createSparkMapProfiler()

Creates a default SparkMapOperator profiler.

createSparkMapProfiler

public static <In,
Out> SparkUnaryOperatorProfiler createSparkMapProfiler(Supplier<In> dataGenerator,
 FunctionDescriptor.SerializableFunction<In,Out> udf,
 Class<In> inClass,
 Class<Out> outClass,
 Configuration configuration)

Creates a custom SparkMapOperator profiler.

createSparkFilterProfiler

public static SparkUnaryOperatorProfiler createSparkFilterProfiler()

Creates a default SparkFilterOperator profiler.

createSparkFilterProfiler

public static <Type> SparkUnaryOperatorProfiler createSparkFilterProfiler(Supplier<Type> dataGenerator,
 FunctionDescriptor.SerializablePredicate<Type> udf,
 Class<Type> inOutClass,
 Configuration configuration)

Creates a custom SparkMapOperator profiler.

createSparkReduceByProfiler

public static SparkUnaryOperatorProfiler createSparkReduceByProfiler()

Creates a default SparkReduceByOperator profiler.

createSparkReduceByProfiler

public static <In,
Key> SparkUnaryOperatorProfiler 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.

createSparkGlobalReduceProfiler

public static SparkUnaryOperatorProfiler createSparkGlobalReduceProfiler()

Creates a default SparkGlobalReduceOperator profiler.

createSparkGlobalReduceProfiler

public static <Type> SparkUnaryOperatorProfiler createSparkGlobalReduceProfiler(Supplier<Type> dataGenerator,
 FunctionDescriptor.SerializableBinaryOperator<Type> udf,
 Class<Type> inOutClass,
 Configuration configuration)

Creates a custom SparkGlobalReduceOperator profiler.

createSparkDistinctProfiler

public static SparkUnaryOperatorProfiler createSparkDistinctProfiler()

Creates a default SparkDistinctOperator profiler.

createSparkDistinctProfiler

public static <Type> SparkUnaryOperatorProfiler createSparkDistinctProfiler(Supplier<Type> dataGenerator,
 Class<Type> inOutClass,
 Configuration configuration)

Creates a custom SparkGlobalReduceOperator profiler.

createSparkSortProfiler

public static SparkUnaryOperatorProfiler createSparkSortProfiler()

Creates a default SparkSortOperator profiler.

createSparkSortProfiler

public static <Type> SparkUnaryOperatorProfiler createSparkSortProfiler(Supplier<Type> dataGenerator,
 Class<Type> inOutClass,
 Configuration configuration)

Creates a custom SparkSortOperator profiler.

createSparkCountProfiler

public static SparkUnaryOperatorProfiler createSparkCountProfiler()

Creates a default SparkCountOperator profiler.

createSparkCountProfiler

public static <In> SparkUnaryOperatorProfiler createSparkCountProfiler(Supplier<In> dataGenerator,
 Class<In> inClass,
 Configuration configuration)

Creates a custom SparkCountOperator profiler.

createSparkMaterializedGroupByProfiler

public static SparkUnaryOperatorProfiler createSparkMaterializedGroupByProfiler()

Creates a default SparkMaterializedGroupByOperator profiler.

createSparkMaterializedGroupByProfiler

public static <In,
Key> SparkUnaryOperatorProfiler createSparkMaterializedGroupByProfiler(Supplier<In> dataGenerator,
 FunctionDescriptor.SerializableFunction<In,Key> keyUdf,
 Class<In> inClass,
 Class<Key> keyClass,
 Configuration configuration)

Creates a custom SparkMaterializedGroupByOperator profiler.

createSparkJoinProfiler

public static BinaryOperatorProfiler createSparkJoinProfiler()

Creates a default SparkJoinOperator profiler.

createSparkJoinProfiler

public static <In0,
In1,
Key> BinaryOperatorProfiler createSparkJoinProfiler(Supplier<In0> dataGenerator0,
 Class<In0> inClass0,
 FunctionDescriptor.SerializableFunction<In0,Key> keyUdf0,
 Supplier<In1> dataGenerator1,
 Class<In1> inClass1,
 FunctionDescriptor.SerializableFunction<In1,Key> keyUdf1,
 Class<Key> keyClass,
 Configuration configuration)

Creates a custom SparkJoinOperator profiler.

createSparkUnionProfiler

public static BinaryOperatorProfiler createSparkUnionProfiler()

Creates a default SparkUnionAllOperator profiler.

createSparkUnionProfiler

public static <Type> BinaryOperatorProfiler createSparkUnionProfiler(Supplier<Type> dataGenerator0,
 Supplier<Type> dataGenerator1,
 Class<Type> typeClass,
 Configuration configuration)

Creates a custom SparkUnionAllOperator profiler.

createSparkCartesianProfiler

public static BinaryOperatorProfiler createSparkCartesianProfiler()

Creates a default SparkCartesianOperator profiler.

createSparkCartesianProfiler

public static <In0,
In1> BinaryOperatorProfiler createSparkCartesianProfiler(Supplier<In0> dataGenerator0,
 Supplier<In1> dataGenerator1,
 Class<In0> inClass0,
 Class<In1> inClass1,
 Configuration configuration)

Creates a custom SparkCartesianOperator profiler.

createSparkLocalCallbackSinkProfiler

public static SinkProfiler createSparkLocalCallbackSinkProfiler()

Creates a default SparkLocalCallbackSink profiler.

createSparkLocalCallbackSinkProfiler

public static <Type> SinkProfiler createSparkLocalCallbackSinkProfiler(Supplier<Type> dataGenerator,
 Class<Type> typeClass,
 Configuration configuration)

Creates a custom SparkLocalCallbackSink profiler.