common/src/main/java/org/apache/nemo/common/ir/vertex/transform/StreamTransform.java [41:58]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  @Override
  public void onData(final T element) {
    getOutputCollector().emit(element);
  }

  @Override
  public void onWatermark(final Watermark watermark) {
    getOutputCollector().emitWatermark(watermark);
  }

  @Override
  public void close() {
    // Do nothing.
  }

  @Override
  public String toString() {
    final StringBuilder sb = new StringBuilder();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/FlattenTransform.java [38:55]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  @Override
  public void onData(final T element) {
    getOutputCollector().emit(element);
  }

  @Override
  public void onWatermark(final Watermark watermark) {
    getOutputCollector().emitWatermark(watermark);
  }

  @Override
  public void close() {
    // Do nothing in a SparkTransform.
  }

  @Override
  public String toString() {
    final StringBuilder sb = new StringBuilder();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -