如何在Java中从avro文件中提取模式 [英] How to extract schema from an avro file in Java
本文介绍了如何在Java中从avro文件中提取模式的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!
问题描述
我见过如何从AVSC文件而不是avro文件获取模式的示例。我应该朝哪个方向看?
Schema schema = new Schema.Parser().parse(
new File("/home/Hadoop/Avro/schema/emp.avsc")
);
推荐答案
如果您想知道avro文件的架构,而不必生成相应的类或关心该文件属于哪个类,则可以使用GenericDatumReader
:
DatumReader<GenericRecord> datumReader = new GenericDatumReader<>();
DataFileReader<GenericRecord> dataFileReader = new DataFileReader<>(new File("file.avro"), datumReader);
Schema schema = dataFileReader.getSchema();
System.out.println(schema);
然后您可以读取文件中的数据:
GenericRecord record = null;
while (dataFileReader.hasNext()) {
record = dataFileReader.next(record);
System.out.println(record);
}
这篇关于如何在Java中从avro文件中提取模式的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!
查看全文