WALFile.java 文件源码

java
阅读 19 收藏 0 点赞 0 评论 0

项目:kafka-connect-hdfs 作者:
/**
 * Read the next key/value pair in the file into <code>key</code> and <code>val</code>.  Returns
 * true if such a pair exists and false when at end of file
 */
public synchronized boolean next(Writable key, Writable val)
    throws IOException {
  if (val.getClass() != WALEntry.class) {
    throw new IOException("wrong value class: " + val + " is not " + WALEntry.class);
  }

  boolean more = next(key);

  if (more) {
    getCurrentValue(val);
  }

  return more;
}
评论列表
文章目录


问题


面经


文章

微信
公众号

扫码关注公众号