Package org.apache.wayang.profiler.java

Class OperatorProfilers

java.lang.Object

org.apache.wayang.profiler.java.OperatorProfilers

public class OperatorProfilers
extends java.lang.Object

Utilities to create OperatorProfiler instances.

Constructor Summary

Constructors

Constructor	Description
OperatorProfilers()

Method Summary

Modifier and Type	Method	Description
static <T> SinkProfiler	createCollectingJavaLocalCallbackSinkProfiler()
static BinaryOperatorProfiler	createJavaCartesianProfiler()	Creates a BinaryOperatorProfiler for the JavaCartesianOperator with Integer data quanta.
static JavaCollectionSourceProfiler	createJavaCollectionSourceProfiler()
static UnaryOperatorProfiler	createJavaCountProfiler()
static <T> UnaryOperatorProfiler	createJavaCountProfiler(java.util.function.Supplier<T> dataGenerator, java.lang.Class<T> inClass)
static UnaryOperatorProfiler	createJavaDistinctProfiler()
static <T> UnaryOperatorProfiler	createJavaDistinctProfiler(java.util.function.Supplier<T> dataGenerator, java.lang.Class<T> inClass)
static UnaryOperatorProfiler	createJavaFilterProfiler()
static UnaryOperatorProfiler	createJavaFlatMapProfiler()
static <In,Out> UnaryOperatorProfiler	createJavaFlatMapProfiler(java.util.function.Supplier<In> dataGenerator, FunctionDescriptor.SerializableFunction<In,java.lang.Iterable<Out>> udf, java.lang.Class<In> inClass, java.lang.Class<Out> outClass)
static UnaryOperatorProfiler	createJavaGlobalReduceProfiler()
static <In> UnaryOperatorProfiler	createJavaGlobalReduceProfiler(java.util.function.Supplier<In> dataGenerator, FunctionDescriptor.SerializableBinaryOperator<In> udf, java.lang.Class<In> inOutClass)
static BinaryOperatorProfiler	createJavaJoinProfiler()
static SinkProfiler	createJavaLocalCallbackSinkProfiler()
static UnaryOperatorProfiler	createJavaMapProfiler()
static <In,Out> UnaryOperatorProfiler	createJavaMapProfiler(java.util.function.Supplier<In> dataGenerator, FunctionDescriptor.SerializableFunction<In,Out> udf, java.lang.Class<In> inClass, java.lang.Class<Out> outClass)
static UnaryOperatorProfiler	createJavaMaterializedGroupByProfiler()
static <In,Key> UnaryOperatorProfiler	createJavaMaterializedGroupByProfiler(java.util.function.Supplier<In> dataGenerator, FunctionDescriptor.SerializableFunction<In,Key> keyUdf, java.lang.Class<In> inOutClass, java.lang.Class<Key> keyClass)
static UnaryOperatorProfiler	createJavaReduceByProfiler()
static <In,Key> UnaryOperatorProfiler	createJavaReduceByProfiler(java.util.function.Supplier<In> dataGenerator, FunctionDescriptor.SerializableFunction<In,Key> keyUdf, FunctionDescriptor.SerializableBinaryOperator<In> udf, java.lang.Class<In> inOutClass, java.lang.Class<Key> keyClass)
static UnaryOperatorProfiler	createJavaSortProfiler()
static <T> UnaryOperatorProfiler	createJavaSortProfiler(java.util.function.Supplier<T> dataGenerator, java.lang.Class<T> inClass)
static JavaTextFileSourceProfiler	createJavaTextFileSourceProfiler()
static BinaryOperatorProfiler	createJavaUnionProfiler()

Methods inherited from class java.lang.Object

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

Constructor Detail

OperatorProfilers

public OperatorProfilers()

Method Detail

createJavaTextFileSourceProfiler

public static JavaTextFileSourceProfiler createJavaTextFileSourceProfiler()

createJavaCollectionSourceProfiler

public static JavaCollectionSourceProfiler createJavaCollectionSourceProfiler()

createJavaMapProfiler

public static UnaryOperatorProfiler createJavaMapProfiler()

createJavaMapProfiler

public static <In,Out> UnaryOperatorProfiler createJavaMapProfiler(java.util.function.Supplier<In> dataGenerator,
                                                                         FunctionDescriptor.SerializableFunction<In,Out> udf,
                                                                         java.lang.Class<In> inClass,
                                                                         java.lang.Class<Out> outClass)

createJavaFlatMapProfiler

public static UnaryOperatorProfiler createJavaFlatMapProfiler()

createJavaFlatMapProfiler

public static <In,Out> UnaryOperatorProfiler createJavaFlatMapProfiler(java.util.function.Supplier<In> dataGenerator,
                                                                             FunctionDescriptor.SerializableFunction<In,java.lang.Iterable<Out>> udf,
                                                                             java.lang.Class<In> inClass,
                                                                             java.lang.Class<Out> outClass)

createJavaFilterProfiler

public static UnaryOperatorProfiler createJavaFilterProfiler()

createJavaReduceByProfiler

public static UnaryOperatorProfiler createJavaReduceByProfiler()

createJavaReduceByProfiler

public static <In,Key> UnaryOperatorProfiler createJavaReduceByProfiler(java.util.function.Supplier<In> dataGenerator,
                                                                              FunctionDescriptor.SerializableFunction<In,Key> keyUdf,
                                                                              FunctionDescriptor.SerializableBinaryOperator<In> udf,
                                                                              java.lang.Class<In> inOutClass,
                                                                              java.lang.Class<Key> keyClass)

createJavaGlobalReduceProfiler

public static UnaryOperatorProfiler createJavaGlobalReduceProfiler()

createJavaGlobalReduceProfiler

public static <In> UnaryOperatorProfiler createJavaGlobalReduceProfiler(java.util.function.Supplier<In> dataGenerator,
                                                                        FunctionDescriptor.SerializableBinaryOperator<In> udf,
                                                                        java.lang.Class<In> inOutClass)

createJavaMaterializedGroupByProfiler

public static UnaryOperatorProfiler createJavaMaterializedGroupByProfiler()

createJavaMaterializedGroupByProfiler

public static <In,Key> UnaryOperatorProfiler createJavaMaterializedGroupByProfiler(java.util.function.Supplier<In> dataGenerator,
                                                                                         FunctionDescriptor.SerializableFunction<In,Key> keyUdf,
                                                                                         java.lang.Class<In> inOutClass,
                                                                                         java.lang.Class<Key> keyClass)

createJavaCountProfiler

public static UnaryOperatorProfiler createJavaCountProfiler()

createJavaCountProfiler

public static <T> UnaryOperatorProfiler createJavaCountProfiler(java.util.function.Supplier<T> dataGenerator,
                                                                java.lang.Class<T> inClass)

createJavaDistinctProfiler

public static UnaryOperatorProfiler createJavaDistinctProfiler()

createJavaDistinctProfiler

public static <T> UnaryOperatorProfiler createJavaDistinctProfiler(java.util.function.Supplier<T> dataGenerator,
                                                                   java.lang.Class<T> inClass)

createJavaSortProfiler

public static UnaryOperatorProfiler createJavaSortProfiler()

createJavaSortProfiler

public static <T> UnaryOperatorProfiler createJavaSortProfiler(java.util.function.Supplier<T> dataGenerator,
                                                               java.lang.Class<T> inClass)

createJavaJoinProfiler

public static BinaryOperatorProfiler createJavaJoinProfiler()

createJavaCartesianProfiler

public static BinaryOperatorProfiler createJavaCartesianProfiler()

Creates a BinaryOperatorProfiler for the JavaCartesianOperator with Integer data quanta.

createJavaUnionProfiler

public static BinaryOperatorProfiler createJavaUnionProfiler()

createJavaLocalCallbackSinkProfiler

public static SinkProfiler createJavaLocalCallbackSinkProfiler()

createCollectingJavaLocalCallbackSinkProfiler

public static <T> SinkProfiler createCollectingJavaLocalCallbackSinkProfiler()