如何在 presto 中将 varchar 转换为 MAP(VARCHAR,VARCHAR)

2023-11-21

我在 presto 中有一个表,名为(“映射”)的一列将键值对作为字符串

从 hello 中选择映射;

例如:{“foo”:“baar”,“foo1”:“bar1”}

我想将“映射”列转换为 MAP

就像从 hello 中选择 CAST("mappings" as MAP) 一样;

这会在 presto 中引发错误。我们如何将其翻译成地图?


没有规范的字符串表示形式MAP在 Presto/Trino 中,所以无法将其直接投射到MAP(VARCHAR, VARCHAR)。但是,如果您的字符串包含 JSON 映射,则可以使用json_parse函数将字符串转换为值JSON输入并将其转换为 SQLMAP via a cast.

Example:

WITH
data(c) AS (
    VALUES '{"foo": "baar", "foo1": "bar1"}'
),
parsed AS (
    SELECT cast(json_parse(c) as map(varchar, varchar)) AS m
    FROM data
)
SELECT m['foo'], m['foo1']
FROM parsed

产生:

 _col0 | _col1
-------+-------
 baar  | bar1
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

如何在 presto 中将 varchar 转换为 MAP(VARCHAR,VARCHAR) 的相关文章

  • 库存管理系统的 SQL 与 NoSQL

    我正在开发一个基于 JAVA 的网络应用程序 主要目的是拥有在多个称为渠道的网站上销售的产品的库存 我们将担任所有这些渠道的管理者 我们需要的是 用于管理每个渠道的库存更新的队列 库存表 其中包含每个通道上分配的正确快照 将会话 ID 和其
  • 有没有好的方法来检查 Datastax Session.executeAsync() 是否引发异常?

    我试图通过调用来加速我们的代码session executeAsync 代替session execute 用于数据库写入 我们有数据库连接可能会关闭的用例 目前是之前的execute 当连接丢失 集群中没有可访问的主机 时抛出异常 我们可
  • 如何在Cassandra中搜索不相等的二级索引?

    我需要能够仅使用 对二级索引执行搜索 据我所知 Cassandra 至少需要一个等式索引子句 因为它会迭代该等式索引的所有结果 是否有任何技巧可以仅使用 执行操作 至少在概念上 这是一个坏主意吗 另外 有人知道 Cassandra 是否有计
  • 使用 DataStax Java 驱动程序 1.0.4 通过 CQL 连接到 Cassandra 时出现异常

    我的笔记本电脑上运行的是 Cassandra 1 2 11 我可以使用连接到它nodetool and cqlsh但是当我尝试使用 DataStax 1 0 4 Java API 来使用 CQL 3 0 进行连接时 出现以下错误 com d
  • 通过sparklyr将cassandra表导入spark - 可以仅选择某些列吗?

    我一直在与sparklyr要将大型 cassandra 表带入 Spark 请使用 R 注册它们并执行dplyr对他们进行操作 我已经成功导入 cassandra 表 代码如下 import cassandra table into spa
  • AWS Athena 扁平化来自嵌套 JSON 源的数据

    我想从 Athena 中的嵌套 JSON 创建一个表 描述的解决方案here http docs aws amazon com athena latest ug json html使用 hive Openx JsonSerDe 等工具尝试在
  • TaskSchedulerImpl:初始作业尚未接受任何资源;

    这就是我正在尝试做的事情 我创建了DataStax企业集群的两个节点 在其上创建了一个java程序来获取一张表 Cassandra数据库表 的计数 该程序是在 eclipse 中构建的 实际上是来自 windows 盒子 从 Windows
  • Cassandra CQL 查询检查多个值

    如何使用 Cassandra CQL 查询检查非主键字段的值是 A 还是 B 我使用的是Cassandra 2 0 1 这是表定义 CREATE TABLE my table my field text my field2 text PRI
  • 如何使用 javascript 从 UUID v1 (TimeUUID) 中提取时间戳?

    我使用 Cassandra DB 和 Nodejs 的 Helenus 模块来操作它 我有一些包含 TimeUUID 列的行 如何在javascript中从TimeUUID获取时间戳 这个库 UUID 至今 https github com
  • Cassandra data stax 查询生成器更新

    我正在尝试编写一个简单的更新查询 更新表 set col1 val1 col2 val2 where col3 val3 您能否提供一个使用查询生成器 API 在 Cassandra 中编写简单 UPDATE 的示例 试试这个 v1 x Q
  • Cassandra CQL v3.0 和复合类型

    我正在浏览以下文档CQLv3 0 http www datastax com docs 1 1 references cql index 我们是否应该在更新中指定复合键并选择 a b 1 以防万一comparator or key vali
  • InvalidRequestException(为什么:empid 如果包含 Equal,则不能被多个关系限制)

    这是关于我从 Apache Spark 查询 Cassandra 时遇到的问题 Spark 的正常查询工作正常 没有任何问题 但是当我使用关键条件进行查询时 出现以下错误 最初 我尝试查询复合键列族 它也给出了与下面相同的问题 由以下原因引
  • 错误:无法连接到 cassandra 服务器。未配置的表

    我正在尝试使用这个简单的代码通过 python 的 cassandra driver 连接到在本地桌面上运行的 cassandra from cassandra cluster import Cluster cluster Cluster
  • Cassandra - 选择而不复制

    假设我创建了一个键空间和表 CREATE KEYSPACE IF NOT EXISTS keyspace rep 0 WITH replication class SimpleStrategy replication factor 0 CR
  • Cassandra cqlsh - 如何显示时间戳列的微秒/毫秒?

    我正在插入带有时间戳列的 Cassandra 表 我的数据具有微秒精度 因此时间数据字符串如下所示 2015 02 16T18 00 03 234 00 00 但是 在 cqlsh 中 当我运行选择查询时 微秒数据不会显示 我只能看到精确到
  • Presto 数组包含一个喜欢某种模式的元素

    例如 我的表中的一列是一个数组 我想检查该列是否包含包含子字符串 denied 的元素 因此 在中午 12 00 拒绝 被管理员拒绝 等元素都将计数 我相信我将不得不使用 like 来识别模式 这个sql该怎么写呢 使用急板数组函数 htt
  • 将 Datastax Enterprise Cassandra 迁移到 Apache Cassandra

    我们目前使用的是 DSE 4 8 和 5 12 我们想迁移到 apache cassandra 因为我们不使用 Spark 或搜索 所以想节省一些钱迁移到 apache 这可以在不停机的情况下实现吗 我看到 sstableloader 以其
  • 关于 Cassandra 与 MySQL 的一些建议

    几天前我在这里问了一个问题 得到了一些非常好的答案 我正在考虑做一个带有个人资料 个人简介等的facebook风格的网站 并询问我是否应该使用mysql 答案是使用Cassandra 因为好多了 我只是问这是每个人都会建议的 只是我对mys
  • 允许在cql中进行过滤、数据建模

    我目前正在使用和研究 cassandra 中的数据建模实践 到目前为止 我知道您需要基于执行的查询进行数据建模 然而 多个select需求使得数据建模变得更加困难或不可能在一张表上处理它 所以 当你无法在1个表上处理这些要求时 你需要插入2
  • Cassandra 与 ZooKeeper 的事务 - 这有效吗?

    我正在尝试在 ZooKeeper 的帮助下为 Cassandra 实现一个事务系统 由于我认为我在数据库实现方面没有足够的经验 所以我想知道我的想法原则上是否可行 或者是否有任何重大缺陷 以下是步骤的高级描述 识别所有要编辑的行 键 和列

随机推荐

  • Android 将字节数组转换为位图的最佳方法?

    我知道为什么会发生 OutOfMemoryError 异常 但是有任何最好的方法可以将字节数组转换为位图 我使用了下面的代码 但是当大字节时它会强制关闭应用程序并给出 OutOfMemoryError 异常 我有 API 它只返回字节数组
  • 如何在 AWS Elastic Beanstalk 上使用 Ubuntu 14.04 来构建 Python Django 应用程序

    我想确保开发环境与生产环境一样工作 这是为了尽量减少 这对我有用 的指责 因此我的团队选择了 Ubuntu 14 04 作为操作系统 我们还想在AWS上部署 当我运行使用 Elastic Beanstalk 的 QwikLabs 示例时 我
  • 你能强制一个java对象在运行时实现一个接口吗?

    现在我的情况如下 1 java接口 2 一个具体的java类not实现上述接口 但是does包含与接口中定义的每个方法相匹配的方法签名 由于我无法更改第 2 项的实现 因此我想知道是否可以创建一种方法 该方法接受第 1 项的实例作为参数 接
  • ModuleNotFoundError:jupyter 中没有名为“pymysql”的模块

    在 jupyter 笔记本中导入 pymysql 后出现以下错误 请帮我找出错误 import pymysql print Welcome ModuleNotFoundError
  • Python:为什么我的列表在我实际上没有改变的情况下却发生了变化?

    新手有个问题请多多指教 list 1 2 3 4 5 list2 list def fxn list list2 for number in list print number print list list2 remove number
  • java(初学者)将科学计数法转换为十进制

    if double d 1 999e 4 我希望我的输出是 0 0001999 我该怎么做 NumberFormat formatter new DecimalFormat String f formatter format d 您可以探索
  • 原始双类型比较的 GCC 问题

    我有以下代码 但是当使用带有各种优化标志的 GCC 4 4 编译它时 我在运行时得到了一些意想不到的结果 include
  • React Uncaught ReferenceError:进程未定义

    我遇到了 iframe 问题 直到今天 一切都按预期进行 今天我添加了一个非常简单的 Modal 组件 不知何故 iframe 开始出现 当我编辑文件并完成热重载时会出现它 此外 对于此问题 它在控制台中显示错误为 Uncaught Ref
  • 使用内联 JavaScript 加密 mailto 电子邮件地址

    我有以下 JavaScript 代码
  • 如何将 Jenkins 凭证传递给 gradle?

    我正在使用 jib Gradle 插件创建一个 docker 映像并将其推送到 Azure 容器注册表 到目前为止 我已向 Jenkins 添加了用户名 密码凭据 并且需要将它们传递给 Gradle 访问凭据或将凭据传递给 Gradle 时
  • 内部错误 500 Apache,但日志中没有任何内容?

    当我尝试向应用程序中的特定地址发出 HTTP POST 时 出现 500 个内部服务器错误 我查看了虚拟主机文件中指定的自定义日志目录中的服务器日志 但错误没有显示在那里 因此调试这是一件很痛苦的事情 如何让 Apache 将内部 500
  • 如何使用 Node.js 正确设置 Coffeescript

    我尝试按以下方式使用 Coffeescript 定义一些节点路由 我的 app js 文件 Module dependencies require coffee script var express require express var
  • 圆形百分比进度条

    我想在我的网站上有一个百分比圆圈指示器 在本例中 它显示 75 这应该怎么做呢 我在图像文件中有黄色圆圈 但如果更容易 以某种方式 使用 CSS 来完成这一切 那对我来说没问题 考虑到进度条的形状 圆形结束 开始 我建议使用 SVG DEM
  • LWP::UserAgent HTTP 基本身份验证

    我尝试运行这个 perl5 程序 usr bin env perl use strict use warnings use LWP my ua LWP
  • EXECUTE 后的事务计数指示缺少 COMMIT 或 ROLLBACK TRANSACTION 语句 - SQL Server 2005

    我从 SQL Server 2005 的应用程序中收到如下错误 执行后的交易计数 表示 COMMIT 或 ROLLBACK 缺少 TRANSACTION 语句 先前计数 1 当前计数 0 如何找到出现此错误的阶段 如何找到丢失的事务或未提交
  • Strapi CMS:获取嵌套内容

    我正在使用 Strapi CMS 并努力获取嵌套 深层内容的数据 例如 假设我创建了以下内容类型并定义了关系 人物 姓名 年龄 地址 城市 国家 联系方式 代码 号码 一个人有一个地址 地址有很多联系人 现在的问题是 当我访问 person
  • 错误共享和原子变量

    当不同的变量位于同一个缓存行内时 您可以体验到虚假分享 这意味着即使两个不同的线程 在不同的内核上运行 正在访问两个不同的变量 如果这两个变量驻留在同一缓存行中 您也会受到性能影响 因为每次都会触发缓存一致性 现在说这些变量是原子变量 我所
  • 如何通过引用正确传递 Integer 类?

    我希望有人能为我澄清这里发生的事情 我在整数类中进行了一些研究 但是因为整数是压倒性的 the 操作员我无法弄清楚出了什么问题 我的问题是这一行 Integer i 0 i i 1 I think that this is somehow
  • 有黑莓浏览器模拟器吗?

    我正在开发一个需要在黑莓浏览器中运行的移动网站 这不是一个应用程序 只是一个带有自定义样式表的网站 是否有可用的 Blackberry 浏览器模拟器 或者我是否需要使用其中一个模拟器来为您提供整个 BB 系统 是的 你必须使用模拟器由 RI
  • 如何在 presto 中将 varchar 转换为 MAP(VARCHAR,VARCHAR)

    我在 presto 中有一个表 名为 映射 的一列将键值对作为字符串 从 hello 中选择映射 例如 foo baar foo1 bar1 我想将 映射 列转换为 MAP 就像从 hello 中选择 CAST mappings as MA