Pig 条件运算符

2023-11-26

考虑下面的关系

test = LOAD 'input' USING PigStorage(',') as (a:chararray, b:chararray);

有没有办法达到以下效果

if (b == 1) {
    a = 'abc';
else if (b == 2) {
    a = 'xyz';
else 
    // retain whatever is there in the column 'a'

你可以做一个FOREACH并按如下方式使用三元运算符。

test2 = FOREACH test GENERATE (b=='1' ? 'abc' : (b=='2' ? 'xyz' : a)) AS a, b;
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

Pig 条件运算符 的相关文章

  • 在 Pig 中将一个元组拆分为多个元组

    我喜欢从单个元组生成多个元组 我的意思是 我有包含以下数据的文件 gt gt cat data ID ColumnName1 Value1 ColumnName2 Value2 所以我通过以下命令加载它 grunt gt gt A load
  • Pig 条件运算符

    考虑下面的关系 test LOAD input USING PigStorage as a chararray b chararray 有没有办法达到以下效果 if b 1 a abc else if b 2 a xyz else reta
  • Pig 脚本:加入多个文件

    我正在读取一个大文件 超过十亿条记录 并将其与其他三个文件连接 我想知道是否可以使该过程更有效 以避免在大表上进行多次读取 小表可能不适合记忆 A join smalltable1 by f1 f2 RIGHT OUTER massive
  • Pig默认JsonLoader架构问题

    我有以下需要使用 Pig 解析的数据 Data Name BBQ Chicken Sizes Size Large Price 14 99 Size Medium Price 12 99 Toppings Barbecue Sauce Ch
  • 如何从 PIG 中生成的包(其大小可能会有所不同)中提取第一个元组?

    我正在生成一个信息 包 其大小 包内元组的数量 可能会有所不同 由此 我想动态提取第一个元素 我该怎么做呢 使用DataFu UDF FirstTupleFromBag http datafu incubator apache org do
  • 在生成语句中格式化日期

    在 Pig 中 我有一个语句 基本上将日期附加到我生成的值中 Data FOREACH Input GENERATE CurrentTime FLATTEN group COUNT guid oas Cnt 输出给了我日期2013 05 2
  • 是否可以将参数值传递给 UDF 构造函数?

    我编写了一个带有构造函数参数的 UDF 我已经成功初始化并使用它grunt as grunt gt register mylib jar grunt gt define Function com company pig udf MyFunc
  • 根据 Pig 中的数据将关系拆分为不同的输出文件

    目前 我的数据如下所示 1 A a 1 A b 2 B b 2 B c 3 A a 3 B b 3 C c 我想根据第一列中的数据将它们存储在不同的文件中 所以 我希望我的输出与此类似 1 out包含 A a A b 2 out包含 B b
  • 从udf访问hdfs文件

    我想通过 udf 调用访问文件 这是我的脚本 files LOAD docs in USING PigStorage AS id stopwords id2 file buzz FOREACH files GENERATE pigbuzz
  • 如何使用 Pig 从列中解析 JSON 字符串

    我有 tsv 日志文件 其中一列由 json 字符串填充 我想用以下内容解析该列JsonLoader in a Pig脚本 我看到很多例子JsonLoader用于每行只有一个 json 字符串的情况 我还有其他专栏想要跳过 但我不知道该怎么
  • 在 Pig 中解析复杂的 JSON 字符串

    我想在 Pig 中解析一串复杂的 JSON 具体来说 我希望 Pig 将我的 JSON 数组理解为一个包 而不是单个字符数组 使用 JsonLoader 时 我可以通过指定架构轻松完成此操作 如下所示这个问题 https stackover
  • Pig 和 Hive 之间的区别?为什么两者都有? [关闭]

    Closed 这个问题是基于意见的 help closed questions 目前不接受答案 我的背景 进入 Hadoop 世界已经 4 周了 使用 Cloudera 的 Hadoop VM 涉足 Hive Pig 和 Hadoop 读过
  • 如何在有或没有 Pig 的情况下使用 Cassandra 的 Map Reduce?

    有人可以解释 MapReduce 如何与 Cassandra 6 配合使用吗 我已经阅读了字数统计示例 但我不太明白 Cassandra 端与 客户端 端发生的情况 https svn apache org repos asf cassan
  • strsplit 问题 - Pig

    我有以下元组 H1 我想将其 0 拆分为元组 但是我总是收到错误消息 DUMP H1 item32 item31 1 m FOREACH H1 GENERATE STRSPLIT 0 50 ERROR 1000 解析期间出错 第 1 行第
  • JAVA 中的 PIG UDF 错误 1070

    我创造了UDF UPPER jar文件输入 home GED385 pigScripts GED385 snshadoope1 pigScripts jar tf home GED385 pigScripts UDF UPPER jar g
  • Hive 和 PIG/Grunt shell 挂在 cygwin 上

    我在 Windows 7 机器 32 位 上以本地模式运行 Hadoop 我已将 HIVE PIG Hadoop Java6 全部安装在 C 驱动器上 我使用的 Cygwin 版本 2 819 我已将 C 安装在 cygwin 上 我可以从
  • Pig:如何将数据连接到嵌套包中的键上

    我只是想合并来自的值data2 to data1 on the value1 value2 两者中都可见的键data1 and data2 注意嵌套结构 容易吧 在面向对象的代码中 它是一个嵌套的 for 循环 但在 Pig 中 感觉就像解
  • Pig Batch 模式:如何设置日志记录级别以隐藏 INFO 日志消息?

    使用阿帕奇猪版本0 10 1 21 重新出口 当我执行 Pig 脚本时 有很多 INFO 日志记录行 如下所示 2013 05 18 14 30 12 810 Thread 28 INFO org apache hadoop mapred
  • 逃离 Pig 中的美元符号?

    这在 0 9 2 中不是问题 但在 0 10 中 当我尝试访问地图中带有美元符号的键时 我会遇到没有定义变量的错误 具体来说 blah FOREACH meh GENERATE source json post id id AS post
  • Pig 10.0 - 将元组分组并在 foreach 中合并包

    我在用着Pig 10 0 我想在 foreach 中合并包 假设我有以下内容visitors alias a b 1 2 3 4 a d 1 3 6 a e 7 z b 1 2 3 我想对第一个字段上的元组进行分组 并将包与一组语义合并以获

随机推荐

  • 如果构造函数的参数非法,则阻止类的实例化?

    我有一个公共构造函数 它接受一个参数 int Age 来创建一个对象 我想检查传递的参数是否合法 例如年龄不能为负数 如果非法 则不要创建对象 实例 如果合法的话没问题 我只能想到一种方法来做到这一点 将构造函数设为私有 创建一个带有参数
  • 什么是未定义的引用/未解析的外部符号错误以及如何修复它?

    什么是未定义的引用 未解析的外部符号错误 常见原因有哪些 如何修复和预防这些错误 假设您有以下代码 a cpp int get return 0 b cpp int get usually one doesn t write this di
  • JQuery 检测标签是否自关闭

    有没有办法像图像标签一样使用 JQuery 检测标签是否自动关闭 动态的东西不仅仅是图像标签 if selector 0 tagName toLowerCase img do something jQuery 在内部使用这个列表 area
  • Flutter - 未处理的异常:FormatException:意外的字符(在字符 1 处)|响应实例

    当我获取 api 时 控制台显示如下错误 E flutter 10838 错误 flutter lib ui ui dart state cc 157 未处理的异常 FormatException 意外的字符 在字符 1 处 E flutt
  • Git 错误:[远程拒绝] master -> master(缺少必要的对象)

    我对 git 有一个相当令人担忧的问题 几天前 当服务器 git 出现蓝屏时 我正在提交一些更改 我们认为这实际上是由 git 引起的 从那时起 我无法向存储库提交任何更改 而其他人可以 我无法再对服务器崩溃时提交的文件提交更改 但是我可以
  • 如何不硬编码密码?

    在我的最后一个问题 用于存储秘密的便携式数据库 中迄今为止最好的答案告诉使用 sqlite crypt 阅读 sqlite crypt 文档 打开数据库的新参数是密码 当然 我不想对密码进行硬编码 所以我在想存储密码的最佳 简单且快速的方法
  • 让 CMake 声明一个虚假目标

    我想生成一些compile时间常数 这第一个答案另一个问题让我非常接近 来自我的 CMakeLists txt add library PROJECT NAME STATIC CXX SRCS compile time hpp add cu
  • 在 java/swing 中关闭窗口时采取的正确操作是什么?

    我刚刚在我的 CustomUIPanel 类中编写了这个测试代码 public static void main String args final JDialog dialog CustomUIPanel createDialog nul
  • 查找源代码从 git 分支的位置

    我有一个 git 存储库 或多或少涵盖了项目历史 和单独的源代码 只是一个只有几个文件的 tarball 它们在不久前 实际上是在 2004 年或 2005 年的某个地方 分叉了 tarball 的源代码已经发生了相当多的变化 我想从中合并
  • 闭包范围未捕获? — 咖啡脚本

    好吧 我不知道如何表达这个问题的标题 openDir path gt socket emit get metadata path data gt columnBox div div class columnbox for item in d
  • 如何在浏览器中更改“文件上传”对话框的标题?

    是否可以在任何常见浏览器 例如 IE 或 FireFox 中更改 文件上传 对话框的标题 检查文档页面我找不到这样的东西 我想这是不可能的 In the 控制类型来自Forms我们找到的部分the input type file 描述为 文
  • Objective-C 中的受保护方法

    Objective C 中受保护的方法相当于什么 我想定义只有派生类可以调用 实现的方法 You can simulate通过执行以下操作对方法进行受保护和私有访问 在类扩展中声明您的私有方法 即在类的 m 文件顶部附近声明的未命名类别 在
  • Django 模板中带有空格的字典键

    我试图在 HTML 模板中显示 view py 中的字典 例如 test works True this fails False 并在模板中 这工作没有问题 test works 但是 字典键在单词之间有空格 例如 这失败了 时不起作用 t
  • PersistenceConstructor 参数变量名称与实例变量名称不匹配

    我试图坚持以下对象spring data mongodb版本1 1 1 RELEASE Document public static class TestObject private final int m property Persist
  • ini_set('memory_limit', ...) 不起作用并返回 false;不明白为什么

    ini set memory limit 128M Returns false memory limit unchanged 我无法找到可能导致此问题的原因列表 到目前为止我检查过 安全模式 禁用 禁用功能 空 php admin valu
  • 创建没有 Cron 作业的计划任务

    需要创建计划任务 但无法使用 Cron 作业 托管提供商发出警告 在 45 分钟内多次运行 cron 作业违反了他们的规则 可能会导致关闭帐户 php 脚本 将 txt 中的数据插入到 mysql 数据库 应该每分钟执行一次 即应该调用此链
  • 使用 unicode 字符填写 pdf 表单

    我正在尝试使用 c 将一些 unicode 字符 阿拉伯语 插入 PDF 表单 我使用了 iTextSharp 库 但是当我插入字符并将字符保存在 PDF 文件中时 unicode 字符不会显示 直到我双击字符的位置应该会出现 string
  • Python:exec() 代码块和 eval() 最后一行

    我有一个字符串文字 其中包含一行或多行 可信 Python 代码 我想exec 块 同时捕获最后一行的结果 更具体地说 我想要一个函数exec then eval返回以下内容 code x 4 y 5 x y assert exec the
  • webpack-dev-server 保存文件时不更新包

    我正在从头开始自学 webpack 并且我正在尝试使用webpack dev server当我更改应用程序文件中的 js 并显示更改时 实时更新浏览器 假设我有以下内容package json name webpack babel vers
  • Pig 条件运算符

    考虑下面的关系 test LOAD input USING PigStorage as a chararray b chararray 有没有办法达到以下效果 if b 1 a abc else if b 2 a xyz else reta