public class ProtoMessageReader<T extends com.google.protobuf.MessageLite> extends Object implements Closeable
Modifier and Type | Method and Description |
---|---|
void |
close() |
org.apache.hadoop.fs.Path |
getFilePath() |
long |
getOffset() |
T |
readEvent() |
void |
setOffset(long offset) |
public org.apache.hadoop.fs.Path getFilePath()
public void setOffset(long offset) throws IOException
IOException
public long getOffset() throws IOException
IOException
public T readEvent() throws IOException
IOException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
Copyright © 2022 The Apache Software Foundation. All rights reserved.