AVRO - Reference API
W poprzednim rozdziale opisaliśmy typ wejścia Avro, czyli schematy Avro. W tym rozdziale wyjaśnimy klasy i metody używane w serializacji i deserializacji schematów Avro.
SpecificDatumWriter Klasa
Ta klasa należy do pakietu org.apache.avro.specific. ImplementujeDatumWriter interfejs, który konwertuje obiekty Java na format serializowany w pamięci.
Konstruktor
S.No. | Opis |
---|---|
1 | SpecificDatumWriter(Schema schema) |
metoda
S.No. | Opis |
---|---|
1 | SpecificData getSpecificData() Zwraca implementację SpecificData używaną przez ten moduł zapisujący. |
SpecificDatumReader Class
Ta klasa należy do pakietu org.apache.avro.specific. ImplementujeDatumReader interfejs, który odczytuje dane schematu i określa reprezentację danych w pamięci. SpecificDatumReader to klasa obsługująca wygenerowane klasy java.
Konstruktor
S.No. | Opis |
---|---|
1 | SpecificDatumReader(Schema schema) Skonstruuj, gdzie schematy pisarza i czytelnika są takie same. |
Metody
S.No. | Opis |
---|---|
1 | SpecificData getSpecificData() Zwraca zawarte dane SpecificData. |
2 | void setSchema(Schema actual) Ta metoda służy do ustawiania schematu modułu zapisującego. |
DataFileWriter
Instancje DataFileWrite dla empklasa. Ta klasa zapisuje sekwencję zserializowanych rekordów danych zgodnych ze schematem, wraz ze schematem w pliku.
Konstruktor
S.No. | Opis |
---|---|
1 | DataFileWriter(DatumWriter<D> dout) |
Metody
S.Nr | Opis |
---|---|
1 | void append(D datum) Dołącza odniesienie do pliku. |
2 | DataFileWriter<D> appendTo(File file) Ta metoda służy do otwierania modułu zapisującego dołączanego do istniejącego pliku. |
Data FileReader
Ta klasa zapewnia losowy dostęp do plików zapisanych w DataFileWriter. Dziedziczy klasęDataFileStream.
Konstruktor
S.No. | Opis |
---|---|
1 | DataFileReader(File file, DatumReader<D> reader)) |
Metody
S.No. | Opis |
---|---|
1 | next() Wczytuje następne odniesienie w pliku. |
2 | Boolean hasNext() Zwraca wartość true, jeśli w tym pliku pozostało więcej wpisów. |
Class Schema.parser
Ta klasa jest parserem dla schematów w formacie JSON. Zawiera metody do analizowania schematu. To należy doorg.apache.avro pakiet.
Konstruktor
S.No. | Opis |
---|---|
1 | Schema.Parser() |
Metody
S.No. | Opis |
---|---|
1 | parse (File file) Analizuje schemat podany w podanym file. |
2 | parse (InputStream in) Analizuje schemat podany w podanym InputStream. |
3 | parse (String s) Analizuje schemat podany w podanym String. |
Interfejs GenricRecord
Ten interfejs zapewnia metody dostępu do pól według nazwy oraz indeksu.
Metody
S.No. | Opis |
---|---|
1 | Object get(String key) Zwraca wartość podanego pola. |
2 | void put(String key, Object v) Ustawia wartość pola na podstawie jego nazwy. |
Klasa GenericData.Record
Konstruktor
S.No. | Opis |
---|---|
1 | GenericData.Record(Schema schema) |
Metody
S.No. | Opis |
---|---|
1 | Object get(String key) Zwraca wartość pola o podanej nazwie. |
2 | Schema getSchema() Zwraca schemat tego wystąpienia. |
3 | void put(int i, Object v) Ustawia wartość pola, biorąc pod uwagę jego pozycję w schemacie. |
4 | void put(String key, Object value) Ustawia wartość pola na podstawie jego nazwy. |