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