@InterfaceAudience.LimitedPrivate(value={"Coprocesssor","Phoenix"}) public abstract class BaseDecoder extends Object implements Codec.Decoder
Modifier and Type | Class and Description |
---|---|
protected static class |
BaseDecoder.PBIS |
Modifier and Type | Field and Description |
---|---|
protected InputStream |
in |
protected static org.slf4j.Logger |
LOG |
Constructor and Description |
---|
BaseDecoder(InputStream in) |
Modifier and Type | Method and Description |
---|---|
boolean |
advance()
Advance the scanner 1 cell.
|
Cell |
current() |
protected InputStream |
getInputStream() |
protected abstract Cell |
parseCell()
Extract a Cell.
|
protected static final org.slf4j.Logger LOG
protected final InputStream in
public BaseDecoder(InputStream in)
public boolean advance() throws IOException
CellScanner
advance
in interface CellScanner
CellScanner.current()
will return a valid CellIOException
protected InputStream getInputStream()
@NonNull protected abstract Cell parseCell() throws IOException
IOException
public Cell current()
current
in interface CellScanner
Copyright © 2007–2019 Cloudera. All rights reserved.