- 如果您觉得本站非常有看点,那么赶紧使用Ctrl+D 收藏吧
我在确定加载“ Avro Tools”类及其run方法的方法时遇到了一些困难。问题出在Java和Scala接口与类加载方法之间。由于avro在Spark应用程序的其他位置使用了不同版本来加载数据文件,因此我需要能够将此特定方法视为对另一版本avro-tools的孤立调用。
以下是我的代码:
package samples
import java.io.{B……继续阅读 »
我正在使用https://github.com/allegro/json-avro-converter将json消息转换为avro文件。调用convertToAvro方法后,我得到一个字节数组:byte [] byteArrayJson。然后,我使用来自Apache的commons库:
FileUtils.writeByteArrayToFile(myFil……继续阅读 »