AVRO - API อ้างอิง
ในบทที่แล้วเราได้อธิบายประเภทอินพุตของ Avro ได้แก่ Avro schemas ในบทนี้เราจะอธิบายคลาสและวิธีการที่ใช้ในการทำให้เป็นอนุกรมและการดีซีเรียลไลเซชันของสคีมาของ Avro
คลาส SpecificDatumWriter
คลาสนี้เป็นของแพ็คเกจ org.apache.avro.specific. มันใช้DatumWriter อินเทอร์เฟซที่แปลงวัตถุ Java เป็นรูปแบบอนุกรมในหน่วยความจำ
ตัวสร้าง
ส. | คำอธิบาย |
---|---|
1 | SpecificDatumWriter(Schema schema) |
วิธี
ส. | คำอธิบาย |
---|---|
1 | SpecificData getSpecificData() ส่งกลับการใช้งาน SpecificData ที่ใช้โดยผู้เขียนนี้ |
คลาส SpecificDatumReader
คลาสนี้เป็นของแพ็คเกจ org.apache.avro.specific. มันใช้DatumReader อินเทอร์เฟซที่อ่านข้อมูลของสคีมาและกำหนดการแสดงข้อมูลในหน่วยความจำ SpecificDatumReader เป็นคลาสที่รองรับคลาส java ที่สร้างขึ้น
ตัวสร้าง
ส. | คำอธิบาย |
---|---|
1 | SpecificDatumReader(Schema schema) สร้างที่แผนผังของผู้เขียนและผู้อ่านเหมือนกัน |
วิธีการ
ส. | คำอธิบาย |
---|---|
1 | SpecificData getSpecificData() ส่งคืนข้อมูลเฉพาะที่มีอยู่ |
2 | void setSchema(Schema actual) วิธีนี้ใช้เพื่อตั้งค่าสคีมาของผู้เขียน |
DataFileWriter
อินสแตนซ์ DataFileWrite สำหรับ empชั้นเรียน คลาสนี้เขียนเร็กคอร์ดที่ทำให้เป็นอนุกรมตามลำดับของข้อมูลที่สอดคล้องกับสคีมาพร้อมกับสคีมาในไฟล์
ตัวสร้าง
ส. | คำอธิบาย |
---|---|
1 | DataFileWriter(DatumWriter<D> dout) |
วิธีการ
ส. เลขที่ | คำอธิบาย |
---|---|
1 | void append(D datum) ผนวกข้อมูลเข้ากับไฟล์ |
2 | DataFileWriter<D> appendTo(File file) วิธีนี้ใช้เพื่อเปิดตัวเขียนที่ต่อท้ายไฟล์ที่มีอยู่ |
Data FileReader
คลาสนี้ให้การเข้าถึงโดยสุ่มไปยังไฟล์ที่เขียนด้วย DataFileWriter. มันสืบทอดคลาสDataFileStream.
ตัวสร้าง
ส. | คำอธิบาย |
---|---|
1 | DataFileReader(File file, DatumReader<D> reader)) |
วิธีการ
ส. | คำอธิบาย |
---|---|
1 | next() อ่านข้อมูลถัดไปในไฟล์ |
2 | Boolean hasNext() ส่งคืนจริงหากยังมีรายการอยู่ในไฟล์นี้มากขึ้น |
คลาส Schema.parser
คลาสนี้เป็นตัวแยกวิเคราะห์สำหรับสกีมารูปแบบ JSON มีวิธีการแยกวิเคราะห์สคีมา มันเป็นของorg.apache.avro แพ็คเกจ
ตัวสร้าง
ส. | คำอธิบาย |
---|---|
1 | Schema.Parser() |
วิธีการ
ส. | คำอธิบาย |
---|---|
1 | parse (File file) แยกวิเคราะห์สคีมาที่ระบุในที่ระบุ file. |
2 | parse (InputStream in) แยกวิเคราะห์สคีมาที่ระบุในที่ระบุ InputStream. |
3 | parse (String s) แยกวิเคราะห์สคีมาที่ระบุในที่ระบุ String. |
อินเทอร์เฟซ GenricRecord
อินเทอร์เฟซนี้จัดเตรียมวิธีการเข้าถึงฟิลด์ตามชื่อและดัชนี
วิธีการ
ส. | คำอธิบาย |
---|---|
1 | Object get(String key) ส่งคืนค่าของเขตข้อมูลที่กำหนด |
2 | void put(String key, Object v) ตั้งค่าของเขตข้อมูลตามชื่อ |
คลาส GenericData บันทึก
ตัวสร้าง
ส. | คำอธิบาย |
---|---|
1 | GenericData.Record(Schema schema) |
วิธีการ
ส. | คำอธิบาย |
---|---|
1 | Object get(String key) ส่งคืนค่าของเขตข้อมูลของชื่อที่กำหนด |
2 | Schema getSchema() ส่งคืนสคีมาของอินสแตนซ์นี้ |
3 | void put(int i, Object v) ตั้งค่าของฟิลด์ที่กำหนดตำแหน่งในสคีมา |
4 | void put(String key, Object value) ตั้งค่าของเขตข้อมูลตามชื่อ |