class XmlSink extends FileBasedSink<T, Void, T> {

  @Override
  public XmlWriteOperation<T> createWriteOperation() {
    return new XmlWriteOperation<>(this);
  }

    XmlSink(XmlIO.Write<T> spec);

}