回答情况：
提问时间：
问题标签：
我想使用Apache Iceberg执行读写操作。我使用的是Spark 3.0.0。2.12', version: '3.0.0'
compile group: 'org.apache.iceberg
浏览 228提问于2021-07-11得票数 1
我想将每种类型的消息写入一个独立的Iceberg表中。
为此，我使用了侧输出:当我将数据映射到RowData时，我使用ProcessFunction将每条消息写入特定的OutputTag。
浏览 18提问于2022-10-18得票数 0
回答已采纳
github中apache iceberg的问题1444显示了最新版本中的iceberg支持行级删除。为什么删除不成功？我使用的主要冰山版本是0.10.0。包org.apache.iceberg.iceberg-hive版本是0.9.1。请帮帮我！catalog,which is used in accessing table
sparkSQLConf.set("spark.sql.catalog.hadoop_prod", "org.apa
浏览 162修改于2020-12-07得票数 0
1回答
-- org.apache.iceberg BEGIN--> <groupId>org.apache.iceberg</groupId>>
<groupId>org.apache.iceberg</groupId>
<artifactId>
浏览 16修改于2020-11-18得票数 0
回答已采纳
(AvroIterable.java:101) at org.apache.iceberg.avro.AvroIterable.iterator(AvroIterable.java:77) at org.apache.iceberg.avro.AvroIterable.iterator:320) at org.apache.iceberg.relocated.com。:46) at org.apache.iceberg.BaseSnapshot.cac
浏览 7修改于2021-01-28得票数 0
如何将分区添加到现有的未分区的Iceberg表中？表已经装载了数据。创建了以下表：import org.apache.iceberg.catalog._import org.
浏览 6修改于2022-01-02得票数 3
--<logger name="org.apache.catalina.core" level="OFF" />--> </plugin> <groupId>com.github.Netflix.iceberg</groupId>
<artifactId>
浏览 65修改于2018-10-02得票数 0
回答已采纳
注意:我只在1.0.0版中使用的Javaimport org.apache.hadoop.conf.Configuration;import org.apache.iceberg.ca
浏览 18修改于2022-10-23得票数 1
我试图在Databricks环境中设置Apache，并在Spark中执行MERGE语句时遇到错误。这个代码：
MERGE INTO iceberg.db.table t USING (SELECT * F
浏览 6提问于2021-06-08得票数 2
for your platform... using builtin-java classes where applicable at org.apache.iceberg.parquet.TypeToMessageType.primitive(TypeToMessageType.java:145) ~[at org.apache.ic
浏览 10修改于2021-02-19得票数 0
火花环境：正如Iceberg的官方文档中所建议的，为了在shell中添加对Iceberg的支持，我们在启动shell时添加了Iceberg依赖项，如下所示，
spark-shell --packagesorg.apache.iceberg:iceberg</
浏览 11修改于2022-04-08得票数 1
回答已采纳
{Calendar, Properties}
import org.apache.flink.streaming.api.scala{GenericRowData, RowData, StringData}import org.apache.iceberg.catalog.Tabl
浏览 31提问于2021-01-12得票数 0
回答已采纳
我得到了这个错误-
org.apache.hadoop.hive.ql.metadata.HiveException:无法获取表temp_tag_thrshld_iceberg。"，“参数”：{ "iceberg.field.current"：“真”、"iceberg.field.id"："3“、"iceberg.field.optional"："true”}、{ "Name"："lev
浏览 9提问于2022-07-27得票数 0
回答已采纳
我们使用spark写到冰山，当重命名分区字段名时，我们得到了一个验证错误：
org.apache.iceberg.exceptions.ValidationException: Cannot find:找不到分区字段的源列: 1000: some_date: void(1) at org.apache.iceberg.exceptions.ValidationException.check(ValidationException.java:46) at org.apache.iceberg</em
浏览 33提问于2022-04-19得票数 0
我已经将Iceberg配置为使用Hive目录： import org.apache.hadoop.conf.Configuration;import org.apache.iceberg.hive.HiveCatalog;
public static void mainNamespace.of("my_metastor
浏览 40修改于2020-10-28得票数 0
1回答
因为冰山的原子性根据https://iceberg.apache.org/java-api-quickstart/工作，GCS应该支持原子重命名，但是从https://cloud.google.com/如果iceberg不支持GCS，那么处理原子性的解决方法是什么
浏览 22修改于2021-01-30得票数 0
我还有另一个用例，在那里我只想使用CLI下载jar，这是您可以使用其他外部maven repos轻松完成的事情，例如curl https://repo1.maven.org/maven2/org/apache/iceberg/iceberg-spark-runtime/0.7.0-incubating/iceberg-spark-runtime-0.7.0-incubating.jar --output temp.jar
浏览 30提问于2021-10-25得票数 2
问题来自:我用这样的冰山目录连接到spark： --conf spark.sql.extensions=org.apache.iceberg.spark.extensions.IcebergSparkSessionExtensions\ --conf spark.sql.catalog.ice_t
浏览 34修改于2022-05-16得票数 1
我正在尝试熟悉Apache，我在理解如何使用Spark将一些外部数据写入表时遇到了一些困难。I有一个文件，one.csv，位于一个目录中，/data我的Iceberg目录被配置为指向这个目录，/warehouse我想将这个one.csv写到Apache表(最好使用Spark )下面是一些我希望能有所帮助的代码
spark.conf.set("spark.sql.catalog.spark_catalog", "org.apache.
浏览 4修改于2020-12-09得票数 1
0回答
Flink写入iceberg时报错，json文件找不到？
javascript、node.js、大数据、flink、数据湖
用flink datastream API写入数据湖，写入一会儿就会报错flink用的1.13.6
iceberg
浏览 203提问于2022-10-08
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号