草庐IT

python - 使用 sum(if...) 或条件语句操作两个数据集,这些语句与 Hive Hadoop Python 没有共同的标识符

coder 2024-01-07 原文

我正在尝试对地理 ip 定位的准确性进行分析,并且有两个非常大的数据集可以根据 ip 地址到 ip 整数或 ip_number(s) 的转换来处理。

转换过程如下

ip_number = 16777216*w + 65536*x + 256*y + z   (1)

在哪里

IP Address = w.x.y.z

我使用 Hive 在 Hadoop 中构建了我的两个表:表 1 是 2.9MM 行,并组织到由 ip_number(s) 范围标识的地理位置。字段读出:

start_ip, end_ip, zipcode, city 

start_ip 是给定邮政编码的最小 ip_numberend_ip 是最大 ip_number

此表是 ip_num 桶或范围的索引以及我需要从具有唯一 ip_number(s) 的另一个表分析其使用情况的相应位置。

我的第二个表或数据集包括来 self 们服务器的每个单独 IP 的交互和使用数据。因此,我有 25MM 唯一 ip_number(s),其中包含我需要在第一个表中按存储桶汇总和分组的使用数据。字段读出:

ip_number, ip_address, usage

在 hive 中标准连接的两个数据集之间没有公共(public)字段,所以我被卡住了。

我尝试过使用完全外部联接,但认为生成的数据集太大,我们的 Hadoop 集群无法处理。脚本在 map/reduce 期间超时。

Hive 有没有一种方法可以从我的第一个表中选择行,并从我的第二个表中为来自 ip_numbers 的事件对第一个表中每个桶或范围内的事件求和?如果没有,是否可以使用 Python 或 R 来操纵 Hadoop 表来完成此操作?

我想要组织生成的数据集:

table_1.ip_start, table_1.ip_end, table_1.zipcode, sum(table_2.usage)

非常感谢任何帮助!

最佳答案

我可以看到两种方法。

  1. 创建一个 UDF,它将使用 Distributed Cache 加载 geo-ip 数据并用它来丰富使用表
  2. 创建一个 UDF,将 geo-ip 扩展为完整的 32 位 ip 地址,以便您可以进行标准连接

这些都不是那么好。选项 1 的执行速度会快得多,因为它将能够通过使用表上的单个 map 传递来输出结果。这样做的缺点是加载 2.9MM 行的 geo-ip 数据需要内存。

关于python - 使用 sum(if...) 或条件语句操作两个数据集,这些语句与 Hive Hadoop Python 没有共同的标识符,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/8694783/

有关python - 使用 sum(if...) 或条件语句操作两个数据集,这些语句与 Hive Hadoop Python 没有共同的标识符的更多相关文章

  1. python - 如何使用 Ruby 或 Python 创建一系列高音调和低音调的蜂鸣声? - 2

    关闭。这个问题是opinion-based.它目前不接受答案。想要改进这个问题?更新问题,以便editingthispost可以用事实和引用来回答它.关闭4年前。Improvethisquestion我想在固定时间创建一系列低音和高音调的哔哔声。例如:在150毫秒时发出高音调的蜂鸣声在151毫秒时发出低音调的蜂鸣声200毫秒时发出低音调的蜂鸣声250毫秒的高音调蜂鸣声有没有办法在Ruby或Python中做到这一点?我真的不在乎输出编码是什么(.wav、.mp3、.ogg等等),但我确实想创建一个输出文件。

  2. ruby - 难道Lua没有和Ruby的method_missing相媲美的东西吗? - 2

    我好像记得Lua有类似Ruby的method_missing的东西。还是我记错了? 最佳答案 表的metatable的__index和__newindex可以用于与Ruby的method_missing相同的效果。 关于ruby-难道Lua没有和Ruby的method_missing相媲美的东西吗?,我们在StackOverflow上找到一个类似的问题: https://stackoverflow.com/questions/7732154/

  3. ruby-on-rails - rails 目前在重启后没有安装 - 2

    我有一个奇怪的问题:我在rvm上安装了ruby​​onrails。一切正常,我可以创建项目。但是在我输入“railsnew”时重新启动后,我有“程序'rails'当前未安装。”。SystemUbuntu12.04ruby-v"1.9.3p194"gemlistactionmailer(3.2.5)actionpack(3.2.5)activemodel(3.2.5)activerecord(3.2.5)activeresource(3.2.5)activesupport(3.2.5)arel(3.0.2)builder(3.0.0)bundler(1.1.4)coffee-rails(

  4. ruby - 在没有 sass 引擎的情况下使用 sass 颜色函数 - 2

    我想在一个没有Sass引擎的类中使用Sass颜色函数。我已经在项目中使用了sassgem,所以我认为搭载会像以下一样简单:classRectangleincludeSass::Script::FunctionsdefcolorSass::Script::Color.new([0x82,0x39,0x06])enddefrender#hamlengineexecutedwithcontextofself#sothatwithintemlateicouldcall#%stop{offset:'0%',stop:{color:lighten(color)}}endend更新:参见上面的#re

  5. 没有类的 Ruby 方法? - 2

    大家好!我想知道Ruby中未使用语法ClassName.method_name调用的方法是如何工作的。我头脑中的一些是puts、print、gets、chomp。可以在不使用点运算符的情况下调用这些方法。为什么是这样?他们来自哪里?我怎样才能看到这些方法的完整列表? 最佳答案 Kernel中的所有方法都可用于Object类的所有对象或从Object派生的任何类。您可以使用Kernel.instance_methods列出它们。 关于没有类的Ruby方法?,我们在StackOverflow

  6. ruby - 如何在 Ruby 中向现有方法定义添加语句 - 2

    我注意到类定义,如果我打开classMyClass,并在不覆盖的情况下添加一些东西我仍然得到了之前定义的原始方法。添加的新语句扩充了现有语句。但是对于方法定义,我仍然想要与类定义相同的行为,但是当我打开defmy_method时似乎,def中的现有语句和end被覆盖了,我需要重写一遍。那么有什么方法可以使方法定义的行为与定义相同,类似于super,但不一定是子类? 最佳答案 我想您正在寻找alias_method:classAalias_method:old_func,:funcdeffuncold_func#similartoca

  7. ruby-on-rails - Rails 3,嵌套资源,没有路由匹配 [PUT] - 2

    我真的为这个而疯狂。我一直在搜索答案并尝试我找到的所有内容,包括相关问题和stackoverflow上的答案,但仍然无法正常工作。我正在使用嵌套资源,但无法使表单正常工作。我总是遇到错误,例如没有路线匹配[PUT]"/galleries/1/photos"表格在这里:/galleries/1/photos/1/edit路线.rbresources:galleriesdoresources:photosendresources:galleriesresources:photos照片Controller.rbdefnew@gallery=Gallery.find(params[:galle

  8. Python 相当于 Perl/Ruby ||= - 2

    这个问题在这里已经有了答案:关闭10年前。PossibleDuplicate:Pythonconditionalassignmentoperator对于这样一个简单的问题表示歉意,但是谷歌搜索||=并不是很有帮助;)Python中是否有与Ruby和Perl中的||=语句等效的语句?例如:foo="hey"foo||="what"#assignfooifit'sundefined#fooisstill"hey"bar||="yeah"#baris"yeah"另外,类似这样的东西的通用术语是什么?条件分配是我的第一个猜测,但Wikipediapage跟我想的不太一样。

  9. ruby-on-rails - 有没有办法为 CarrierWave/Fog 设置上传进度指示器? - 2

    我在Rails应用程序中使用CarrierWave/Fog将视频上传到AmazonS3。有没有办法判断上传的进度,让我可以显示上传进度如何? 最佳答案 CarrierWave和Fog本身没有这种功能;你需要一个前端uploader来显示进度。当我不得不解决这个问题时,我使用了jQueryfileupload因为我的堆栈中已经有jQuery。甚至还有apostonCarrierWaveintegration因此您只需按照那里的说明操作即可获得适用于您的应用的进度条。 关于ruby-on-r

  10. ruby - 没有类方法获取 Ruby 类名 - 2

    如何在Ruby中获取BasicObject实例的类名?例如,假设我有这个:classMyObjectSystem我怎样才能使这段代码成功?编辑:我发现Object的实例方法class被定义为returnrb_class_real(CLASS_OF(obj));。有什么方法可以从Ruby中使用它? 最佳答案 我花了一些时间研究irb并想出了这个:classBasicObjectdefclassklass=class这将为任何从BasicObject继承的对象提供一个#class您可以调用的方法。编辑评论中要求的进一步解释:假设你有对象

随机推荐