AVRO - Referenz-API

Im vorherigen Kapitel haben wir den Eingabetyp von Avro beschrieben, dh Avro-Schemata. In diesem Kapitel werden die Klassen und Methoden erläutert, die bei der Serialisierung und Deserialisierung von Avro-Schemata verwendet werden.

SpecificDatumWriter-Klasse

Diese Klasse gehört zum Paket org.apache.avro.specific. Es implementiert dieDatumWriter Schnittstelle, die Java-Objekte in ein speicherinternes serialisiertes Format konvertiert.

Konstrukteur

S.No. Beschreibung
1 SpecificDatumWriter(Schema schema)

Methode

S.No. Beschreibung
1

SpecificData getSpecificData()

Gibt die von diesem Writer verwendete SpecificData-Implementierung zurück.

SpecificDatumReader-Klasse

Diese Klasse gehört zum Paket org.apache.avro.specific. Es implementiert dieDatumReader Schnittstelle, die die Daten eines Schemas liest und die speicherinterne Datendarstellung bestimmt. SpecificDatumReader ist die Klasse, die generierte Java-Klassen unterstützt.

Konstrukteur

S.No. Beschreibung
1

SpecificDatumReader(Schema schema)

Konstruieren Sie, wo die Schemata von Schreiber und Leser gleich sind.

Methoden

S.No. Beschreibung
1

SpecificData getSpecificData()

Gibt die enthaltenen SpecificData zurück.

2

void setSchema(Schema actual)

Diese Methode wird verwendet, um das Schema des Schreibers festzulegen.

DataFileWriter

Instantiiert DataFileWrite zum empKlasse. Diese Klasse schreibt eine Sequenz serialisierter Datensätze von Daten, die einem Schema entsprechen, zusammen mit dem Schema in eine Datei.

Konstrukteur

S.No. Beschreibung
1 DataFileWriter(DatumWriter<D> dout)

Methoden

S.No. Beschreibung
1

void append(D datum)

Hängt ein Datum an eine Datei an.

2

DataFileWriter<D> appendTo(File file)

Diese Methode wird verwendet, um einen Writer zu öffnen, der an eine vorhandene Datei angehängt wird.

Data FileReader

Diese Klasse bietet zufälligen Zugriff auf Dateien, mit denen geschrieben wurde DataFileWriter. Es erbt die KlasseDataFileStream.

Konstrukteur

S.No. Beschreibung
1 DataFileReader(File file, DatumReader<D> reader))

Methoden

S.No. Beschreibung
1

next()

Liest das nächste Datum in der Datei.

2

Boolean hasNext()

Gibt true zurück, wenn weitere Einträge in dieser Datei verbleiben.

Klasse Schema.parser

Diese Klasse ist ein Parser für JSON-Formatschemas. Es enthält Methoden zum Parsen des Schemas. Es gehörtorg.apache.avro Paket.

Konstrukteur

S.No. Beschreibung
1 Schema.Parser()

Methoden

S.No. Beschreibung
1

parse (File file)

Analysiert das angegebene Schema file.

2

parse (InputStream in)

Analysiert das angegebene Schema InputStream.

3

parse (String s)

Analysiert das angegebene Schema String.

Schnittstelle GenricRecord

Diese Schnittstelle bietet Methoden für den Zugriff auf die Felder nach Name und Index.

Methoden

S.No. Beschreibung
1

Object get(String key)

Gibt den Wert eines angegebenen Feldes zurück.

2

void put(String key, Object v)

Legt den Wert eines Felds mit seinem Namen fest.

Klasse GenericData.Record

Konstrukteur

S.No. Beschreibung
1 GenericData.Record(Schema schema)

Methoden

S.No. Beschreibung
1

Object get(String key)

Gibt den Wert eines Feldes mit dem angegebenen Namen zurück.

2

Schema getSchema()

Gibt das Schema dieser Instanz zurück.

3

void put(int i, Object v)

Legt den Wert eines Felds anhand seiner Position im Schema fest.

4

void put(String key, Object value)

Legt den Wert eines Felds mit seinem Namen fest.