Package org.apache.iceberg.avro
Class ValueReaders
- java.lang.Object
-
- org.apache.iceberg.avro.ValueReaders
-
public class ValueReaders extends java.lang.Object
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
ValueReaders.StructReader<S>
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static <T> ValueReader<java.util.Collection<T>>
array(ValueReader<T> elementReader)
static <K,V>
ValueReader<java.util.Map<K,V>>arrayMap(ValueReader<K> keyReader, ValueReader<V> valueReader)
static ValueReader<java.lang.Boolean>
booleans()
static ValueReader<java.nio.ByteBuffer>
byteBuffers()
static ValueReader<byte[]>
bytes()
static ValueReader<java.math.BigDecimal>
decimal(ValueReader<byte[]> unscaledReader, int scale)
static ValueReader<byte[]>
decimalBytesReader(org.apache.avro.Schema schema)
static ValueReader<java.lang.Double>
doubles()
static ValueReader<java.lang.String>
enums(java.util.List<java.lang.String> symbols)
static ValueReader<byte[]>
fixed(int length)
static ValueReader<org.apache.avro.generic.GenericData.Fixed>
fixed(org.apache.avro.Schema schema)
static ValueReader<java.lang.Float>
floats()
static ValueReader<java.lang.Integer>
ints()
static ValueReader<java.lang.Long>
longs()
static <K,V>
ValueReader<java.util.Map<K,V>>map(ValueReader<K> keyReader, ValueReader<V> valueReader)
static ValueReader<java.lang.Object>
nulls()
static <R extends org.apache.avro.generic.IndexedRecord>
ValueReader<R>record(java.util.List<ValueReader<?>> readers, java.lang.Class<R> recordClass, org.apache.avro.Schema recordSchema)
static ValueReader<org.apache.avro.generic.GenericData.Record>
record(java.util.List<ValueReader<?>> readers, org.apache.avro.Schema recordSchema)
static ValueReader<java.lang.String>
strings()
static ValueReader<java.lang.Object>
union(java.util.List<ValueReader<?>> readers)
static ValueReader<org.apache.avro.util.Utf8>
utf8s()
static ValueReader<java.util.UUID>
uuids()
-
-
-
Method Detail
-
nulls
public static ValueReader<java.lang.Object> nulls()
-
booleans
public static ValueReader<java.lang.Boolean> booleans()
-
ints
public static ValueReader<java.lang.Integer> ints()
-
longs
public static ValueReader<java.lang.Long> longs()
-
floats
public static ValueReader<java.lang.Float> floats()
-
doubles
public static ValueReader<java.lang.Double> doubles()
-
strings
public static ValueReader<java.lang.String> strings()
-
utf8s
public static ValueReader<org.apache.avro.util.Utf8> utf8s()
-
enums
public static ValueReader<java.lang.String> enums(java.util.List<java.lang.String> symbols)
-
uuids
public static ValueReader<java.util.UUID> uuids()
-
fixed
public static ValueReader<byte[]> fixed(int length)
-
fixed
public static ValueReader<org.apache.avro.generic.GenericData.Fixed> fixed(org.apache.avro.Schema schema)
-
bytes
public static ValueReader<byte[]> bytes()
-
byteBuffers
public static ValueReader<java.nio.ByteBuffer> byteBuffers()
-
decimal
public static ValueReader<java.math.BigDecimal> decimal(ValueReader<byte[]> unscaledReader, int scale)
-
decimalBytesReader
public static ValueReader<byte[]> decimalBytesReader(org.apache.avro.Schema schema)
-
union
public static ValueReader<java.lang.Object> union(java.util.List<ValueReader<?>> readers)
-
array
public static <T> ValueReader<java.util.Collection<T>> array(ValueReader<T> elementReader)
-
arrayMap
public static <K,V> ValueReader<java.util.Map<K,V>> arrayMap(ValueReader<K> keyReader, ValueReader<V> valueReader)
-
map
public static <K,V> ValueReader<java.util.Map<K,V>> map(ValueReader<K> keyReader, ValueReader<V> valueReader)
-
record
public static ValueReader<org.apache.avro.generic.GenericData.Record> record(java.util.List<ValueReader<?>> readers, org.apache.avro.Schema recordSchema)
-
record
public static <R extends org.apache.avro.generic.IndexedRecord> ValueReader<R> record(java.util.List<ValueReader<?>> readers, java.lang.Class<R> recordClass, org.apache.avro.Schema recordSchema)
-
-