我在确定加载“ Avro Tools”类及其run方法的方法时遇到了一些困难。问题出在Java和Scala接口与类加载方法之间。由于avro在Spark应用程序的其他位置使用了不同版本来加载数据文件,因此我需要能够将此特定方法视为对另一版本avro-tools的孤立调用。 以下是我的代码: package samples import java.io.{ByteArrayOutputStream, InputStream} import org.junit.runner.RunWith import org.spe…

2020年5月7日 0条评论 35点热度 阅读全文

我正在使用https://github.com/allegro/json-avro-converter将json消息转换为avro文件。调用convertToAvro方法后,我得到一个字节数组:byte [] byteArrayJson。然后,我使用来自Apache的commons库: FileUtils.writeByteArrayToFile(myFile.avro, byteArrayJson); 文件已创建。当我尝试将其转换为json时,请使用: java -jar avro-tools-1.8.1.jar…

2019年11月18日 0条评论 44点热度 阅读全文