wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/function/MapPartitionsDescriptor.java [85:95]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public MapPartitionsDescriptor(SerializableFunction<Iterable<Input>, Iterable<Output>> javaImplementation,
                                   BasicDataUnitType<Input> inputType,
                                   BasicDataUnitType<Output> outputType,
                                   ProbabilisticDoubleInterval selectivity,
                                   LoadProfileEstimator loadProfileEstimator) {
        super(loadProfileEstimator);
        this.javaImplementation = javaImplementation;
        this.inputType = inputType;
        this.outputType = outputType;
        this.selectivity = selectivity;
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/function/FlatMapDescriptor.java [82:92]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public FlatMapDescriptor(SerializableFunction<Input, Iterable<Output>> javaImplementation,
                             BasicDataUnitType<Input> inputType,
                             BasicDataUnitType<Output> outputType,
                             ProbabilisticDoubleInterval selectivity,
                             LoadProfileEstimator loadProfileEstimator) {
        super(loadProfileEstimator);
        this.javaImplementation = javaImplementation;
        this.inputType = inputType;
        this.outputType = outputType;
        this.selectivity = selectivity;
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -