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. |