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

Writer.write介绍

[英]Write element to the output.
[中]将元素写入输出。

代码示例

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

@Override
public void write(NullWritable k, V v) throws IOException {
 writer.write(v);
}

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

@Override
public void writeRecord(BatchElement<?, T> record) throws IOException {
 writer.write(record.getElement());
}

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

@Override
public void write(E elem) throws IOException {
 impl.write(Pair.of(elem == null ? null : elem.toString(), NullWritable.get()));
}

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

@Override
public void invoke(StreamingElement<?, T> elem, Context context) throws Exception {
 writer.write(elem.getElement());
}

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

@Override
public void write(V elem) throws IOException {
 wrap.write(Pair.of(null, elem));
}

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

@Override
public void write(IN elem) throws IOException {
 final KEY key = selectFunction.apply(elem);
 final UnaryFunction<IN, ?> mapper = sinks.get(key).getMapper();
 writerMap.get(key).write(mapper.apply(elem));
}

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

@Override
public void write(IN elem) throws IOException {
 final KEY key = selectFunction.apply(elem);
 final UnaryFunction<IN, ?> mapper = sinks.get(key).getMapper();
 writerMap.get(key).write(mapper.apply(elem));
}

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

} else if (datum.isElement()) {
 writer.write(datum.getElement());

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

} else if (datum.isElement()) {
 writer.write(datum.getElement());

代码示例来源：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());
}

代码示例来源：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");
 }
}