我的班级：private List<Object> field2;
List<Object>的Avro架构引发异常："type": {"items
浏览 20提问于2021-05-25得票数 0
-74.026675, ] ], }在这里，将坐标作为对象的数组发送coordinates", "type": "array",
"items": "object</e
浏览 2提问于2019-01-14得票数 2
回答已采纳
1回答
我试图包括火花-阿夫罗包，同时启动火花外壳，如这里提到的说明：。com.databricks:spark-avro_2.10:2.0.1封装的火花壳
我的目的是使用包中的SchemaConverter类将avro模式转换为schema类型。导入com.databricks.spark.avro._ . //colListDel是来自avsc的字段列表，由于某种功
浏览 3提问于2016-07-10得票数 3
回答已采纳
1回答
我想注册一个Avro模式，它引用模式注册中心上的另一个Avro模式。首先，我注册了以下基本Avro模式： "type":"record", "namespace":"com.test.client",
"doc":"Client Property sp
浏览 1提问于2020-11-27得票数 0
回答已采纳
这个问题与Avro版本1.8.1有关。我们的AVRO模式中有以下字段："type" : ["bytes", "null"], "precision": 18, 如您所见，该字段的
浏览 0提问于2017-03-28得票数 6
在处理这些记录并试图构建结果时，我调试并结束于PojoType验证阶段，而且由于类GenericType有一个声明为UNION的子字段，该字段为：private java.lang.Object data;线程“主”中的java.lang.IllegalStateException异常:期望类型为PojoTypeInfo
我的GenericTypejava类(生成的)
浏览 1提问于2022-04-01得票数 1
回答已采纳
正如Avro 中所述，在没有代码生成的情况下反序列化：“数据将使用包含在文件中的作者的模式，以及读者的模式提供给GenericDatumReader”。下面是如何在示例中创建GenericDatumReader但是，当
浏览 3提问于2022-05-27得票数 0
我有一个主要的avro模式和其他小的avro模式。所有这些文件都位于一个名为"com.example.common“的文件夹中。我编写了一个简单的python代码行来解析和打印Item.avsc的模式：
schema = avro.schema.parse(open(".not make an A
浏览 0提问于2021-08-23得票数 1
回答已采纳
我正在研究Avro作为序列化格式在Java应用程序中发布事件。
我想要做的是将一些Avro字节转换成一个特定Java类的实例，这个实例是我使用Avro插件生成的，反之亦然。我希望这样做，因为它允许使用我的代码的开发人员订阅特定事件，并接收表示该特定事件的特定生成类的实例(可能会将其从对象中转换为事件类，但不必触摸任何Avro特定代码)。我正在考虑一种解决方案，在这个解决方案中，我检
浏览 2提问于2016-12-08得票数 3
我有一个Avro模式，其中一些字段定义为decimal逻辑类型。根据该模式，我使用avro-maven-plugin (使用1.9.0版)生成类。我希望避免生成ByteBuffer类型，而使用BigDecimal。 我在较老的问题(如here)中发现使用版本1.8.2。我试过了，然后升级到1.9.0，仍然无法获得正确的数据类型。模式： {
"name":
浏览 68提问于2019-06-04得票数 1
我对Avro模式很陌生。我试图使用kafka发布/使用我的java对象。我有java类，它包含带有LocalDateTime和byte[]的字段。如何在avro模式原语类型中同时定义这两种类型？我可以为LocalDateTime使用的最佳基元类型是什么？private LocalDateTime timestamp; 我
浏览 2提问于2016-04-14得票数 6
回答已采纳
在我的数据库中，我有多个表，每个表都是不同的实体类型。我有一个在hadoop中使用的Avro模式，它是这些不同实体类型的所有字段的联合，另外还有一个实体类型字段。我想要做的是为每个实体类型设置一个DBWritable的DBInputFormat，它将实体<e
浏览 0提问于2011-12-02得票数 1
回答已采纳
我收到一个卡夫卡主题的二进制Avro文件，我必须反序列化它们。在Kafka收到的消息中，我可以在每条消息的开头看到一个模式。我知道不嵌入模式并将其与实际的Avro文件分离是一种更好的做法，但我无法控制生产者，也无法改变这一点。mDatumReader = new GenericDatumReader<GenericReco
浏览 3提问于2017-06-01得票数 3
我有一个3级嵌套的java类形式的数据。我成功地使用avro Tools ReflectData创建了Avro schema，并使用ReflectDatumWriter将数据写出avro文件。在Hive中，我能够创建一个表，并使用 ('avro.schema.url'='hdfs:///schema.avsc');
我可以看到有一些方法可以将相同的数
浏览 1提问于2014-10-15得票数 0
1回答
嘿，StackOverflow社区
我有一个关于嵌套Avro模式的问题，以及如何将它们与Kafka一起使用时存储在模式注册表中的最佳实践。TL;DR &问题：在Avro模式注册中心中存储复杂嵌套类型的最佳实践是什么？一个小上下文：我们的模式由一个主类型组成，它有几个复杂的子类型(其中一些子类型本身有子<
浏览 2提问于2021-11-18得票数 0
回答已采纳
我对Avro序列化完全陌生，我正试图了解如何定义复杂的类型。private com.example.Customertype customer_type; "type": "enu
浏览 7提问于2021-09-09得票数 0
1回答
我有一个XLS/CSV文件，我正在将其读取到pandas数据帧中。我想从这个数据帧中生成一个avro模式。我想从这个数据框中动态生成一个avro模式。请帮帮忙
浏览 14提问于2019-10-21得票数 1
回答已采纳
但这是非常糟糕的代码。因此，我正在寻找建议，如何更好地解决这一问题，如果这种方法存在。
准备一些工作。假设您有app，它将avro发送到n个主题并使用模式注册表。假设(一开始)您不想使用avro联合，因为它们带来了一些问题。N-1主题很简单，每个主题有1个模式。但是，您有数据，您需要按照的顺序发送，这意味着一个主题和指定的组键，但是这些数据没有相同的模式。但是该设置是每个模式注册表实例，因此您必须声明</em
浏览 5提问于2021-11-04得票数 0
我想加载一个avro文件到BQ而不指定模式，因为BQ会自动检测avro文件的模式。但是，它不会拾取logicaltype并将其转换为整数。我看到了一个合并在Airflow BQ钩子中的PR，但我不知道如何在我的工作中启用它。这是我需要在这里添加的参数吗？ task_id="gcs_to_bq",
浏览 0提问于2021-02-19得票数 0
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
