public abstract static class ValueReaders.StructReader<S> extends java.lang.Object implements ValueReader<S>, SupportsRowPosition
Modifier | Constructor and Description |
---|---|
protected |
StructReader(java.util.List<ValueReader<?>> readers,
org.apache.avro.Schema schema) |
protected |
StructReader(java.util.List<ValueReader<?>> readers,
Types.StructType struct,
java.util.Map<java.lang.Integer,?> idToConstant) |
Modifier and Type | Method and Description |
---|---|
protected abstract java.lang.Object |
get(S struct,
int pos) |
S |
read(org.apache.avro.io.Decoder decoder,
java.lang.Object reuse) |
ValueReader<?> |
reader(int pos) |
protected abstract S |
reuseOrCreate(java.lang.Object reuse) |
protected abstract void |
set(S struct,
int pos,
java.lang.Object value) |
void |
setRowPositionSupplier(java.util.function.Supplier<java.lang.Long> posSupplier) |
protected StructReader(java.util.List<ValueReader<?>> readers, org.apache.avro.Schema schema)
protected StructReader(java.util.List<ValueReader<?>> readers, Types.StructType struct, java.util.Map<java.lang.Integer,?> idToConstant)
public void setRowPositionSupplier(java.util.function.Supplier<java.lang.Long> posSupplier)
setRowPositionSupplier
in interface SupportsRowPosition
protected abstract S reuseOrCreate(java.lang.Object reuse)
protected abstract java.lang.Object get(S struct, int pos)
protected abstract void set(S struct, int pos, java.lang.Object value)
public ValueReader<?> reader(int pos)
public S read(org.apache.avro.io.Decoder decoder, java.lang.Object reuse) throws java.io.IOException
read
in interface ValueReader<S>
java.io.IOException