AVRO - API de referencia
En el capítulo anterior, describimos el tipo de entrada de Avro, es decir, esquemas de Avro. En este capítulo, explicaremos las clases y métodos utilizados en la serialización y deserialización de esquemas Avro.
Clase SpecificDatumWriter
Esta clase pertenece al paquete org.apache.avro.specific. Implementa laDatumWriter interfaz que convierte objetos Java en un formato serializado en memoria.
Constructor
S.No. | Descripción |
---|---|
1 | SpecificDatumWriter(Schema schema) |
Método
S.No. | Descripción |
---|---|
1 | SpecificData getSpecificData() Devuelve la implementación de SpecificData utilizada por este escritor. |
Clase SpecificDatumReader
Esta clase pertenece al paquete org.apache.avro.specific. Implementa laDatumReader interfaz que lee los datos de un esquema y determina la representación de datos en memoria. SpecificDatumReader es la clase que admite clases java generadas.
Constructor
S.No. | Descripción |
---|---|
1 | SpecificDatumReader(Schema schema) Construya dónde los esquemas del escritor y del lector son iguales. |
Métodos
S.No. | Descripción |
---|---|
1 | SpecificData getSpecificData() Devuelve los datos específicos contenidos. |
2 | void setSchema(Schema actual) Este método se utiliza para establecer el esquema del escritor. |
DataFileWriter
Instancia DataFileWrite para empclase. Esta clase escribe una secuencia de registros serializados de datos que se ajustan a un esquema, junto con el esquema en un archivo.
Constructor
S.No. | Descripción |
---|---|
1 | DataFileWriter(DatumWriter<D> dout) |
Métodos
S. No | Descripción |
---|---|
1 | void append(D datum) Agrega un dato a un archivo. |
2 | DataFileWriter<D> appendTo(File file) Este método se utiliza para abrir un escritor que se agrega a un archivo existente. |
Lector de archivos de datos
Esta clase proporciona acceso aleatorio a archivos escritos con DataFileWriter. Hereda la claseDataFileStream.
Constructor
S.No. | Descripción |
---|---|
1 | DataFileReader(File file, DatumReader<D> reader)) |
Métodos
S.No. | Descripción |
---|---|
1 | next() Lee el siguiente dato del archivo. |
2 | Boolean hasNext() Devuelve verdadero si quedan más entradas en este archivo. |
Clase Schema.parser
Esta clase es un analizador de esquemas en formato JSON. Contiene métodos para analizar el esquema. Pertenece aorg.apache.avro paquete.
Constructor
S.No. | Descripción |
---|---|
1 | Schema.Parser() |
Métodos
S.No. | Descripción |
---|---|
1 | parse (File file) Analiza el esquema proporcionado en el file. |
2 | parse (InputStream in) Analiza el esquema proporcionado en el InputStream. |
3 | parse (String s) Analiza el esquema proporcionado en el String. |
Interfaz GenricRecord
Esta interfaz proporciona métodos para acceder a los campos por nombre e índice.
Métodos
S.No. | Descripción |
---|---|
1 | Object get(String key) Devuelve el valor de un campo dado. |
2 | void put(String key, Object v) Establece el valor de un campo dado su nombre. |
Clase GenericData.Record
Constructor
S.No. | Descripción |
---|---|
1 | GenericData.Record(Schema schema) |
Métodos
S.No. | Descripción |
---|---|
1 | Object get(String key) Devuelve el valor de un campo del nombre de pila. |
2 | Schema getSchema() Devuelve el esquema de esta instancia. |
3 | void put(int i, Object v) Establece el valor de un campo dada su posición en el esquema. |
4 | void put(String key, Object value) Establece el valor de un campo dado su nombre. |