wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/ObjectFileSinkMapping.java [47:57]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    private SubplanPattern createSubplanPattern() {
        final OperatorPattern operatorPattern = new OperatorPattern<>(
                "sink",
                new ObjectFileSink<>(
                    null,
                    DataSetType.none().getDataUnitType().getTypeClass()
                ),
                false
        );
        return SubplanPattern.createSingleton(operatorPattern);
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/ObjectFileSinkMapping.java [49:59]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    private SubplanPattern createSubplanPattern() {
        final OperatorPattern operatorPattern = new OperatorPattern<>(
            "sink",
            new ObjectFileSink<>(
                null,
                DataSetType.none().getDataUnitType().getTypeClass()
            ),
            false
        );
        return SubplanPattern.createSingleton(operatorPattern);
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -