我是Pig的新手，我想使用Pig从路径加载数据。该路径是动态的，并且存储在txt文件中。假设我们在pig脚本中有一个名为pigInputPath.txt的txt文件，我计划执行以下操作：InputPath = Load 'pigInputPath.txt' USINGPigStorage();Data = Load 'someprefix' + InputPath + '
浏览 8提问于2018-08-12得票数 2
1回答
我正在试着从小猪那里连接到Cassandra。但是Cassandra安装在不同的集群中，我需要连接才能从pig远程连接到Cassandra。我指的是下面的链接Failed to parse: Can not retrieve schema from loader org.apache.cassandra.hadoop.pig.CqlStorage@1216d9bf
at org.apache.pig
浏览 3提问于2017-05-25得票数 0
1回答
fraction":"3"},"destination":"/user/sree/OUT","source":"/user/sree/foo.txt"}USING PigJsonLoader();
但是如何在Apache Pig中</e
浏览 1提问于2014-07-24得票数 0
回答已采纳
1回答
我试图使用它的内置函数之一，将字符串转换为猪的大写。我用的是本地模式的猪。emps.csv2,Jack,30,F,201,3540000.00,09/10/84empdata = load: ERROR 1070: Could not resolve upper using imports: [, java.lang., org.apache.pig.builtin.
浏览 3提问于2014-07-29得票数 0
回答已采纳
但是，我未能转储字符串或( string，int)元组。只是想知道我在这里错过了什么？非常感谢!dataset = LOAD '/Users/me/input' USING PigStorage() AS (id:chararray,data:chararray);
dataset_GROUP
浏览 4提问于2015-03-12得票数 3
回答已采纳
在我的开发框中，我有MapR 3.0.2、Hive 0.11、HCatLog 0.4.1和Pig 0.12。我使用HCatlog从Pig (Pig Latin)读取和写入Hive表，使用标准查询，我的Hive表包含TIMTESTAMP数据类型(几列)，因此紧跟在GRUNT中的这条语句之后，
浏览 1提问于2014-05-27得票数 3
我在Apache中执行脚本时遇到了问题。我有3个文件，即movies.csv、ratings.csv、tags.csv。首先加载"movies.csv"，然后加载"ratings.csv“并连接两个表。但我在加载文件时遇到了一个错误。);当我发出"cat“命令时，我得到了一个错误，如ERROR 2997: Encountered IOException.(Grunt.java:69)
at org.apache.p
浏览 1提问于2017-10-13得票数 0
回答已采纳
我正在使用Dataproc上的Pig编写一个自定义load函数来从Bigtable加载数据。我使用从Dataproc获取的jar文件列表编译了我的java代码。当我运行下面的Pig脚本时，当它试图与Bigtable建立连接时，它会失败。Bigtable does not support managed connections.'hbase://events_sessions'
USING com.eduboom.pig.
浏览 5提问于2017-03-25得票数 1
回答已采纳
1回答
我尝试在apache pig中执行一个简单的连接。我使用的数据集来自profiles = LOAD '/user/hadoop/tests/userid-profile.tsv' AS (id,gender,age,country, dreg);
songs = LOAD '/user/hadoop/tests/userid-timestamp-ar
浏览 1提问于2013-04-20得票数 1
我想运行一个pig脚本，我不想将pig脚本嵌入到我的java程序中，我想通过任何传递必要的Pig脚本和参数(可能是参数文件)的pig执行方法来运行它。核心pig库或任何其他库是否提供了执行pig脚本的方法。我已经尝试过java运行时exec方法，我用空格分隔字符串来传递一些参数，所以我放弃了通过运行时exec方法调用pig命令，因为这不是执行pig命令的正确方式。
浏览 1提问于2012-06-22得票数 3
回答已采纳
我只是用水槽流一些twitter数据并将其集群到HDFS中，现在我尝试将其加载到analysis.As的JsonLoader中，默认的JsonLoader函数无法加载这些数据，所以我在google中搜索一些可以加载此类数据的库现在，当我尝试使用以下命令加载数据时
load_tweets = LOAD '/TwitterData/' USING com.twitter.elephantbird.pig.load.J
浏览 2提问于2016-02-22得票数 2
回答已采纳
1回答
我是hadoop的新手，我有一个用例，其中有3列--名称、值、时间stamp.The数据是分开的，逗号是分开的，并且是csv格式的--我需要检查副本并使用pig.How删除它们--我能做到这一点吗？
浏览 0提问于2015-11-28得票数 0
回答已采纳
我有两个文件，一个带有关键字/字符串列表：theorangefileThe blue fox jumpedthis file has nothing importantthis line does not match
我希望获取第一个文件中的字符串列表，并从第二个文件中找到与第一个文件中的任何字符串匹配的行所以我用Python编写了一个Pig脚本
浏览 0提问于2014-04-01得票数 0
回答已采纳
我正在使用parquet.pig.ParquetLoader。我做了以下转换：-
如何加载嵌套数据？在Pig中，可选值应该加载为null。
浏览 3提问于2016-03-28得票数 0
回答已采纳
使用Hadoop的头拉丁语从搜索引擎日志文件中查找唯一搜索字符串的出现次数。()请帮助我解决问题。提前谢谢。猪脚本(encryptcode:chararrayforeach GroupBySearchString Generate group as searchstring,count(searchstring);
浏览 3提问于2013-09-15得票数 1
回答已采纳
1回答
如何连接带有硬编码值的变量？A=加载'data‘as (f1:chararray，f2:chararray，f3:chararray)；预期产出：
(apache，open
浏览 3提问于2015-03-04得票数 1
回答已采纳
尝试使用http://pig.apache.org/docs/r0.8.1/api/org/apache/pig/piggybank/storage/HiveColumnarLoader.html读取Pig此外，它们被分区到多个目录(如/day=20140701)。rows = <em
浏览 2提问于2014-07-17得票数 0
2回答
目前，使用Hadoop学习Apache，并使用6200万个巨大的数据集。只是尝试做一个正常的计数函数，并不断地得到错误。、org.apache.pig.builtin.、org.apache.pig.impl.builtin解析计数。错误org.apache.pig.PigServer -解析过程中的异常:解析过程中的错误。无法使用导入、java.lang.、org.apache.pig</
浏览 3提问于2016-08-24得票数 0
回答已采纳
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
