@Override
  protected void handleClose() {
    this.sinkFn.close();
  }
An operator that sends incoming messages to an arbitrary output system using the provided {@link SinkFunction}.
samza-core/src/main/java/org/apache/samza/operators/impl/SinkOperatorImpl.java