public class DataWriter<T> extends java.lang.Object implements MetricsAwareDatumWriter<T>
Modifier | Constructor and Description |
---|---|
protected |
DataWriter(org.apache.avro.Schema schema) |
Modifier and Type | Method and Description |
---|---|
static <D> DataWriter<D> |
create(org.apache.avro.Schema schema) |
protected ValueWriter<?> |
createStructWriter(java.util.List<ValueWriter<?>> fields) |
java.util.stream.Stream<FieldMetrics> |
metrics()
Returns a stream of
FieldMetrics that this MetricsAwareDatumWriter keeps track of. |
void |
setSchema(org.apache.avro.Schema schema) |
void |
write(T datum,
org.apache.avro.io.Encoder out) |
public static <D> DataWriter<D> create(org.apache.avro.Schema schema)
public void setSchema(org.apache.avro.Schema schema)
setSchema
in interface org.apache.avro.io.DatumWriter<T>
public void write(T datum, org.apache.avro.io.Encoder out) throws java.io.IOException
write
in interface org.apache.avro.io.DatumWriter<T>
java.io.IOException
protected ValueWriter<?> createStructWriter(java.util.List<ValueWriter<?>> fields)
public java.util.stream.Stream<FieldMetrics> metrics()
MetricsAwareDatumWriter
FieldMetrics
that this MetricsAwareDatumWriter keeps track of.metrics
in interface MetricsAwareDatumWriter<T>