/**
* 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;
}
WALFile.java 文件源码
java
阅读 19
收藏 0
点赞 0
评论 0
项目:kafka-connect-hdfs
作者:
评论列表
文章目录