class HDFSFileSink extends Sink<T> {

  public static <T, K, V, W extends FileOutputFormat<K, V>> HDFSFileSink<T, K, V>
  to(String path,
     Class<W> formatClass,
     Class<K> keyClass,
     Class<V> valueClass,
     SerializableFunction<T, KV<K, V>> outputConverter) {
    return HDFSFileSink.<T, K, V>builder()
        .setPath(path)
        .setFormatClass(formatClass)
        .setKeyClass(keyClass)
        .setValueClass(valueClass)
        .setOutputConverter(outputConverter)
        .setConfiguration(null)
        .setUsername(null)
        .setValidate(true)
        .build();
  }

}