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

OutputFormat.writeRecord介绍

[英]Adds a record to the output.

When this method is called, the output format it guaranteed to be opened.
[中]将记录添加到输出中。
当调用此方法时，它保证打开的输出格式。

代码示例

代码示例来源：origin: apache/flink

@Override
public void invoke(IN record) throws Exception {
  try {
    format.writeRecord(record);
  } catch (Exception ex) {
    cleanup();
    throw ex;
  }
}

代码示例来源：origin: apache/flink

format.writeRecord(element);

代码示例来源：origin: org.apache.flink/flink-streaming-java_2.11

@Override
public void invoke(IN record) throws Exception {
  try {
    format.writeRecord(record);
  } catch (Exception ex) {
    cleanup();
    throw ex;
  }
}

代码示例来源：origin: org.apache.flink/flink-streaming-java

@Override
public void invoke(IN record) throws Exception {
  try {
    format.writeRecord(record);
  } catch (Exception ex) {
    cleanup();
    throw ex;
  }
}

代码示例来源：origin: org.apache.flink/flink-streaming-java_2.10

@Override
public void invoke(IN record) throws Exception {
  try {
    format.writeRecord(record);
  } catch (Exception ex) {
    cleanup();
    throw ex;
  }
}

代码示例来源：origin: dbs-leipzig/gradoop

@Override
public void writeRecord(IT record) throws IOException {
 String subDirectory = getDirectoryForRecord(record);
 OutputFormat<IT> format;
 if (formatsPerSubdirectory.containsKey(subDirectory)) {
  format = formatsPerSubdirectory.get(subDirectory);
 } else {
  format = createFormatForDirectory(new Path(rootOutputPath, subDirectory));
  format.open(taskNumber, numTasks);
  formatsPerSubdirectory.put(subDirectory, format);
 }
 format.writeRecord(record);
}

代码示例来源：origin: org.gradoop/gradoop-flink

@Override
public void writeRecord(IT record) throws IOException {
 String subDirectory = getDirectoryForRecord(record);
 OutputFormat<IT> format;
 if (formatsPerSubdirectory.containsKey(subDirectory)) {
  format = formatsPerSubdirectory.get(subDirectory);
 } else {
  format = createFormatForDirectory(new Path(rootOutputPath, subDirectory));
  format.open(taskNumber, numTasks);
  formatsPerSubdirectory.put(subDirectory, format);
 }
 format.writeRecord(record);
}

代码示例来源：origin: org.apache.flink/flink-runtime_2.10

format.writeRecord(record);
format.writeRecord(record);

代码示例来源：origin: com.alibaba.blink/flink-core

format.writeRecord(element);

代码示例来源：origin: org.apache.flink/flink-runtime_2.11

format.writeRecord(record);
format.writeRecord(record);

代码示例来源：origin: org.apache.flink/flink-runtime

format.writeRecord(record);
format.writeRecord(record);

代码示例来源：origin: org.apache.flink/flink-core

format.writeRecord(element);

代码示例来源：origin: com.alibaba.blink/flink-runtime

format.writeRecord(record);
format.writeRecord(record);