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

Counter.write介绍

[英]Write the binary representation of the counter
[中]写入计数器的二进制表示形式

代码示例

代码示例来源：origin: NationalSecurityAgency/datawave

@Override
public void write(DataOutput out) throws IOException {
  delegate.write(out);
}

代码示例来源：origin: io.hops/hadoop-mapreduce-client-core

@Override
public void write(DataOutput out) throws IOException {
 realCounter.write(out);
}

代码示例来源：origin: ch.cern.hadoop/hadoop-mapreduce-client-core

@Override
public void write(DataOutput out) throws IOException {
 realCounter.write(out);
}

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

/**
 * Write to Hadoop output.
 *
 * @param out DataOutput to write to.
 * @throws IOException if something goes wrong.
 */
public void write(DataOutput out) throws IOException {
 counter.write(out);
}

代码示例来源：origin: io.prestosql.hadoop/hadoop-apache

@Override
public void write(DataOutput out) throws IOException {
 realCounter.write(out);
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-mapreduce-client-core

@Override
public void write(DataOutput out) throws IOException {
 realCounter.write(out);
}

代码示例来源：origin: ch.cern.hadoop/hadoop-mapreduce-client-core

/**
 * GenericGroup ::= displayName #counter counter*
 */
@Override
public synchronized void write(DataOutput out) throws IOException {
 Text.writeString(out, displayName);
 WritableUtils.writeVInt(out, counters.size());
 for(Counter counter: counters.values()) {
  counter.write(out);
 }
}

代码示例来源：origin: com.facebook.hadoop/hadoop-core

public synchronized void write(DataOutput out) throws IOException {
 Text.writeString(out, displayName);
 WritableUtils.writeVInt(out, counters.size());
 for(Counter counter: counters.values()) {
  counter.write(out);
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-mapred

public synchronized void write(DataOutput out) throws IOException {
 Text.writeString(out, displayName);
 WritableUtils.writeVInt(out, counters.size());
 for(Counter counter: counters.values()) {
  counter.write(out);
 }
}

代码示例来源：origin: io.hops/hadoop-mapreduce-client-core

/**
 * GenericGroup ::= displayName #counter counter*
 */
@Override
public synchronized void write(DataOutput out) throws IOException {
 Text.writeString(out, displayName);
 WritableUtils.writeVInt(out, counters.size());
 for(Counter counter: counters.values()) {
  counter.write(out);
 }
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-mapreduce-client-core

/**
 * GenericGroup ::= displayName #counter counter*
 */
@Override
public synchronized void write(DataOutput out) throws IOException {
 Text.writeString(out, displayName);
 WritableUtils.writeVInt(out, counters.size());
 for(Counter counter: counters.values()) {
  counter.write(out);
 }
}

代码示例来源：origin: io.prestosql.hadoop/hadoop-apache

/**
 * GenericGroup ::= displayName #counter counter*
 */
@Override
public synchronized void write(DataOutput out) throws IOException {
 Text.writeString(out, displayName);
 WritableUtils.writeVInt(out, counters.size());
 for(Counter counter: counters.values()) {
  counter.write(out);
 }
}

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

@Override
 public Object invoke(Object obj, Method m, Method m2, Object[] args) throws Throwable {
  String name = m.getName();
  if ("increment".equals(name)) {
   c.increment((Long) args[0]);
   return null;
  } else if ("getCounter".equals(name) || "getValue".equals(name)) {
   return c.getValue();
  } else if ("setValue".equals(name)) {
   c.setValue((Long) args[0]);
   return null;
  } else if ("getDisplayName".equals(name)) {
   return c.getDisplayName();
  } else if ("getName".equals(name)) {
   return c.getName();
  } else if ("getUnderlyingCounter".equals(name)) {
   return c;
  } else if ("readFields".equals(name)) {
   c.readFields((DataInput) args[0]);
   return null;
  } else if ("write".equals(name)) {
   c.write((DataOutput) args[0]);
   return null;
  }
  throw new IllegalStateException("Unhandled Counters.Counter method = " + name);
 }
}