請參見下面的示例代碼： User datum = new User("a123456", "[email protected]");
Schema schema = ReflectData.get().getSchema(datum.getClass());
DatumWriter<Object> writer = new ReflectDatumWriter<>(sch
我試過以下Avro IDL中引用邏輯類型timestamp-millis的代碼，它不起作用。 是否需要在Avro IDL中使用邏輯類型的導入？或者邏輯類型是不可用的，我需要使用原始類型（在這種情況下是long）呢？ protocol test {
record test {
timestamp-millis time;
}
}
結果： Exception in
我有一個指定模式的avro文件。 當我加載Avro文件時，他們總是以GenericData出現，即使我指定了Schema。 val schema = Article.Schema$
val job = new Job()
AvroJob.setInputKeySchema(job, schema)
val rootDir = "path-to-avro-files"
val article