本文整理了Java中com.hazelcast.jet.pipeline.Sinks.files()方法的一些代码示例，展示了Sinks.files()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Sinks.files()方法的具体详情如下：
包路径：com.hazelcast.jet.pipeline.Sinks
类名称：Sinks
方法名：files

Sinks.files介绍

[英]Convenience for #filesBuilder with the UTF-8 charset and with overwriting of existing files.
[中]方便#FileBuilder使用UTF-8字符集并覆盖现有文件。

代码示例

代码示例来源：origin: hazelcast/hazelcast-jet-demos

.drainTo(Sinks.files(targetDirectory));
return pipeline;

代码示例来源：origin: hazelcast/hazelcast-jet-code-samples

private static Pipeline buildPipeline(String sourceDir, String targetDir) {
  Pipeline p = Pipeline.create();
  p.drawFrom(Sources.files(sourceDir))
   .map(LogLine::parse)
   .filter((LogLine log) -> log.getResponseCode() >= 200 && log.getResponseCode() < 400)
   .flatMap(AccessLogAnalyzer::explodeSubPaths)
   .groupingKey(wholeItem())
   .aggregate(counting())
   .drainTo(Sinks.files(targetDir));
  return p;
}