org.apache.hadoop.io.UTF8#writeString ( )源码实例Demo

下面列出了org.apache.hadoop.io.UTF8#writeString ( ) 实例代码，或者点击链接到github查看源代码，也可以在右侧发表评论。

源代码1 项目： HiveKa 文件： KafkaRequest.java

@Override
public void write(DataOutput out) throws IOException {
  UTF8.writeString(out, topic);
  UTF8.writeString(out, leaderId);
  if (uri != null)
    UTF8.writeString(out, uri.toString());
  else
    UTF8.writeString(out, "");
  out.writeInt(partition);
  out.writeLong(offset);
  out.writeLong(latestOffset);
}

源代码2 项目： HiveKa 文件： KafkaKey.java

@Override
public void write(DataOutput out) throws IOException {
  UTF8.writeString(out, this.leaderId);
  out.writeInt(this.partition);
  out.writeLong(this.beginOffset);
  out.writeLong(this.offset);
  out.writeLong(this.checksum);
  out.writeUTF(this.topic);
  out.writeLong(this.time);
  out.writeUTF(this.server); // left for legacy
  out.writeUTF(this.service); // left for legacy
  this.partitionMap.write(out);
}

源代码3 项目： RDFS 文件： NamespaceInfo.java

public void write(DataOutput out) throws IOException {
  UTF8.writeString(out, getBuildVersion());
  out.writeInt(getLayoutVersion());
  out.writeInt(getNamespaceID());
  out.writeLong(getCTime());
  out.writeInt(getDistributedUpgradeVersion());
}

源代码4 项目： hadoop-gpu 文件： NamespaceInfo.java

public void write(DataOutput out) throws IOException {
  UTF8.writeString(out, getBuildVersion());
  out.writeInt(getLayoutVersion());
  out.writeInt(getNamespaceID());
  out.writeLong(getCTime());
  out.writeInt(getDistributedUpgradeVersion());
}

源代码5 项目： RDFS 文件： FileSplit.java

public void write(DataOutput out) throws IOException {
  UTF8.writeString(out, file);
  out.writeLong(start);
  out.writeLong(length);
}

源代码6 项目： RDFS 文件： DatanodeID.java

/** {@inheritDoc} */
public void write(DataOutput out) throws IOException {
  UTF8.writeString(out, name);
  UTF8.writeString(out, storageID);
  out.writeShort(infoPort);
}

源代码7 项目： RDFS 文件： Tokenizer.java

@Override
@SuppressWarnings("deprecation")
public void toBinary(DataOutputStream out) throws IOException {
  UTF8.writeString(out, value);
}

源代码8 项目： hadoop-gpu 文件： FileSplit.java

public void write(DataOutput out) throws IOException {
  UTF8.writeString(out, file.toString());
  out.writeLong(start);
  out.writeLong(length);
}

源代码9 项目： hadoop-gpu 文件： DatanodeID.java

/** {@inheritDoc} */
public void write(DataOutput out) throws IOException {
  UTF8.writeString(out, name);
  UTF8.writeString(out, storageID);
  out.writeShort(infoPort);
}

方法所在类

org.apache.hadoop.io.UTF8