public class FlinkAvroWriter extends java.lang.Object implements MetricsAwareDatumWriter<org.apache.flink.table.data.RowData>
Constructor and Description |
---|
FlinkAvroWriter(org.apache.flink.table.types.logical.RowType rowType) |
Modifier and Type | Method and Description |
---|---|
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(org.apache.flink.table.data.RowData datum,
org.apache.avro.io.Encoder out) |
public FlinkAvroWriter(org.apache.flink.table.types.logical.RowType rowType)
public void setSchema(org.apache.avro.Schema schema)
setSchema
in interface org.apache.avro.io.DatumWriter<org.apache.flink.table.data.RowData>
public void write(org.apache.flink.table.data.RowData datum, org.apache.avro.io.Encoder out) throws java.io.IOException
write
in interface org.apache.avro.io.DatumWriter<org.apache.flink.table.data.RowData>
java.io.IOException
public java.util.stream.Stream<FieldMetrics> metrics()
MetricsAwareDatumWriter
FieldMetrics
that this MetricsAwareDatumWriter keeps track of.metrics
in interface MetricsAwareDatumWriter<org.apache.flink.table.data.RowData>