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

Writer.commit介绍

[英]Commit the write process.
[中]提交写过程。

代码示例

代码示例来源：origin: seznam/euphoria

@Override
 public void close() throws IOException {
  wrap.commit();
 }
}

代码示例来源：origin: seznam/euphoria

@Override
public void commitTask(TaskAttemptContext tac) throws IOException {
 if (innerWriter != null) {
  innerWriter.commit();
  closeWriter(tac, innerWriter);
 }
}

代码示例来源：origin: seznam/euphoria

@Override
public void commit() throws IOException {
 wrap.commit();
}

代码示例来源：origin: seznam/euphoria

@Override
public void commit() throws IOException {
 impl.commit();
}

代码示例来源：origin: seznam/euphoria

@Override
public void close() throws Exception {
 if (writer != null) {
  writer.flush();
  writer.commit();
  writer.close();
 }
}

代码示例来源：origin: seznam/euphoria

@Override
 public void close() throws IOException {
  if (writer != null) {
   writer.flush();
   writer.commit();
   writer.close();
  }
 }
}

代码示例来源：origin: seznam/euphoria

writer.commit();

代码示例来源：origin: seznam/euphoria

writer.commit();

代码示例来源：origin: seznam/euphoria

@Test
 public void testMultipleSinks() throws Exception {
  ListDataSink<String> sink1 = ListDataSink.get();
  ListDataSink<String> sink2 = ListDataSink.get();

  // write to first sink
  Writer<String> w = sink1.openWriter(0);
  w.write("first");
  w.commit();

  // write to seconds sink
  w = sink2.openWriter(0);
  w.write("second-0");
  w.commit();

  w = sink2.openWriter(1);
  w.write("second-1");
  w.commit();

  assertEquals("first", Iterables.getOnlyElement(sink1.getOutputs()));

  DatasetAssert.unorderedEquals(sink2.getOutputs(), "second-0", "second-1");
 }
}

代码示例来源：origin: seznam/euphoria

@Test
public void testMultiDataSinkWrites() throws IOException {
 ListDataSink<String> firstDataSink = ListDataSink.get();
 ListDataSink<String> secondDataSink = ListDataSink.get();
 ListDataSink<String> thirdDataSink = ListDataSink.get();
 DataSink<InputElement> output = createMultiDataSink(firstDataSink, secondDataSink,
   thirdDataSink);
 // write to first sink
 Writer<InputElement> wr = output.openWriter(0);
 wr.write(new InputElement(InputElement.Type.FIRST, "first-Data1"));
 wr.write(new InputElement(InputElement.Type.FIRST, "first-Data2"));
 wr.write(new InputElement(InputElement.Type.THIRD, "third-Data1"));
 wr.write(new InputElement(InputElement.Type.SECOND, "second-Data1"));
 wr.write(new InputElement(InputElement.Type.FIRST, "first-Data3"));
 wr.commit();
 output.commit();
 assertEquals(3, firstDataSink.getOutputs().size());
 assertEquals("first-Data1", firstDataSink.getOutputs().get(0));
 assertEquals("second-Data1", secondDataSink.getOutputs().get(0));
 assertEquals(1, secondDataSink.getOutputs().size());
 assertEquals(1, thirdDataSink.getOutputs().size());
}