给定a、b两个文件,各存放50亿个url,每个url各占64字节,内存限制是4G,让你找出a、b文件共同的url?

两种方法:

一、采用Bloom filter,假设布隆过滤器的错误率为0.01,则位数组大小m约为输入元素个数n的13倍,此时需要的哈希函数k约为8个。

元素个数:n = 5G

位数组大小:m = 5G * 13 = 65G = 650亿 即需要650亿个bit位才能达到错误率0.01

而我们拥有的内存可容纳bit位个数:4G * 8bit = 32G bit = 320亿,按此实现错误率大于0.01。

布隆过滤器:https://blog.csdn.net/qq_41946557/article/details/102593912

二、采用分治的思想

假如每个url大小为10bytes,那么可以估计每个文件的大小为50G×64=320G,远远大于内存限制的4G,所以不可能将其完全加载到内存中处理,可以采用分治的思想来解决。

  Step1:遍历文件a,对每个url求取hash(url)%1000,然后根据所取得的值将url分别存储到1000个小文件(记为a0,a1,...,a999,每个小文件约300M);

  Step2:遍历文件b,采取和a相同的方式将url分别存储到1000个小文件(记为b0,b1,...,b999);

  巧妙之处:这样处理后,所有可能相同的url都被保存在对应的小文件(a0vsb0,a1vsb1,...,a999vsb999)中,不对应的小文件不可能有相同的url。然后我们只要求出这个1000对小文件中相同的url即可。

  Step3:求每对小文件ai和bi中相同的url时,可以把ai的url存储到hash_set/hash_map中。然后遍历bi的每个url,看其是否在刚才构建的hash_set中,如果是,那么就是共同的url,存到文件里面就可以了。

【补充】

1、为什么使用hash?是把任意长度的输入(又叫做预映射pre-image)通过散列算法变换成固定长度的输出,该输出就是散列值。这种转换是一种压缩映射,也就是,散列值的空间通常远小于输入的空间,不同的输入可能会散列成相同的输出,所以不可能从散列值来确定唯一的输入值。简单的说就是一种将任意长度的消息压缩到某一固定长度的消息摘要的函数。

也就是说将url通过hash函数变成一个固定长度的值,(url有的挺长的!)然后假如有一部分数值%1000后,等于0,那么放入到a0中,等于1的放入到a1中,以此类推。。。

【注】:

  • 1、Hash取模是一种等价映射,不会存在同一个元素分散到不同小文件中的情况,即这里采用的是mod1000算法,那么相同的url在hash取模后,只可能落在同一个文件中,不可能被分散的。因为如果两个url相等,那么经过Hash(url)之后的哈希值是相同的,将此哈希值取模(如模1000),必定仍然相等。

  • 2、那到底什么是hash映射呢?简单来说,就是为了便于计算机在有限的内存中处理big数据,从而通过一种映射散列的方式让数据均匀分布在对应的内存位置(如大数据通过取余的方式映射成小树存放在内存中,或大文件映射成多个小文件),而这个映射散列方式便是我们通常所说的hash函数,设计的好的hash函数能让数据均匀分布而减少冲突。尽管数据映射到了另外一些不同的位置,但数据还是原来的数据,只是代替和表示这些原始数据的形式发生了变化而已。

mini版代码实现:https://blog.csdn.net/qq_41946557/article/details/102711573

根据https://blog.csdn.net/qq_41946557/article/details/102708186思想去写!!!

将文件中的信息当成我们文本中的每行文件,然后两个文件中分别是100条信息,然后进行读取  hash(url) %5

首先准备两个文件:xxoo.txt   ooxx.txt

取模并且存储到5个小文件中。代码清晰易懂。适合初学。

  1. package com.henu;

  2. import java.io.*;

  3. /**

  4. * @author George

  5. * @description 大文件拆分小文件

  6. * 将文件中的信息当成我们文本中的每行文件,然后两个文件中分别是100条信息,然后进行读取 hash(url) %5

  7. **/

  8. public class HashClass {

  9. public static void main(String[] args) throws IOException {

  10. //读取第一个文件 ooxx

  11. BufferedReader obr = new BufferedReader(new FileReader("d://ooxx.txt"));

  12. BufferedWriter obw1 = new BufferedWriter(new FileWriter("d://ooxx1.txt",true));

  13. BufferedWriter obw2 = new BufferedWriter(new FileWriter("d://ooxx2.txt",true));

  14. BufferedWriter obw3 = new BufferedWriter(new FileWriter("d://ooxx3.txt",true));

  15. BufferedWriter obw4 = new BufferedWriter(new FileWriter("d://ooxx4.txt",true));

  16. BufferedWriter obw5 = new BufferedWriter(new FileWriter("d://ooxx5.txt",true));

  17. String oline = "";

  18. while((oline = obr.readLine()) != null){

  19. // System.out.println(toHash(line));

  20. // System.out.println(oline);

  21. int x = toHash(oline);

  22. System.out.println(x);

  23. if (x == 0){

  24. obw1.write(oline);

  25. obw1.write("\r\n");

  26. }else if(x == -1){

  27. obw2.write(oline);

  28. obw2.write("\r\n");

  29. }else if(x == -2){

  30. obw3.write(oline);

  31. obw3.write("\r\n");

  32. }else if(x == -3){

  33. obw4.write(oline);

  34. obw4.write("\r\n");

  35. }else{

  36. obw5.write(oline);

  37. obw5.write("\r\n");

  38. }

  39. }

  40. obw1.close();

  41. obw2.close();

  42. obw3.close();

  43. obw4.close();

  44. obw5.close();

  45. obr.close();

  46. //读取第二个文件 xxoo

  47. BufferedReader xbr = new BufferedReader(new FileReader("d://xxoo.txt"));

  48. BufferedWriter xbr1 = new BufferedWriter(new FileWriter("d://xxoo1.txt",true));

  49. BufferedWriter xbr2 = new BufferedWriter(new FileWriter("d://xxoo2.txt",true));

  50. BufferedWriter xbr3 = new BufferedWriter(new FileWriter("d://xxoo3.txt",true));

  51. BufferedWriter xbr4 = new BufferedWriter(new FileWriter("d://xxoo4.txt",true));

  52. BufferedWriter xbr5 = new BufferedWriter(new FileWriter("d://xxoo5.txt",true));

  53. String xline = "";

  54. while((xline = xbr.readLine()) != null){

  55. // System.out.println(toHash(xline));

  56. int x = toHash(xline);

  57. if (x == 0){

  58. xbr1.write(xline);

  59. xbr1.write("\r\n");

  60. }else if(x == -1){

  61. xbr2.write(xline);

  62. xbr2.write("\r\n");

  63. }else if(x == -2){

  64. xbr3.write(xline);

  65. xbr3.write("\r\n");

  66. }else if(x == -3){

  67. xbr4.write(xline);

  68. xbr4.write("\r\n");

  69. }else{

  70. xbr5.write(xline);

  71. xbr5.write("\r\n");

  72. }

  73. }

  74. xbr1.close();

  75. xbr2.close();

  76. xbr3.close();

  77. xbr4.close();

  78. xbr5.close();

  79. xbr.close();

  80. }

  81. // 将字符串转成hash值

  82. public static int toHash(String key) {

  83. int arraySize = 5; // 数组大小一般取质数

  84. int hashCode = 0;

  85. for (int i = 0; i < key.length(); i++) { // 从字符串的左边开始计算

  86. int letterValue = key.charAt(i) - 96;// 将获取到的字符串转换成数字,比如a的码值是97,则97-96=1

  87. // 就代表a的值,同理b=2;

  88. hashCode = ((hashCode << 5) + letterValue) % arraySize;// 防止编码溢出,对每步结果都进行取模运算

  89. }

  90. return hashCode;

  91. }

  92. }

* 进行比较,将ooxx1  - xxoo1
*            ooxx2 - xxoo2
*            ooxx3  - xxoo3
*  *         ooxx4 - xxoo4
*            ooxx5  - xxoo5

方法:将ooxx的对应文件放入set集合中。然后读取xxoo的文件,如果包含,则输出!!!!

  1. package com.henu;

  2. import java.io.BufferedReader;

  3. import java.io.FileReader;

  4. import java.io.IOException;

  5. import java.util.HashSet;

  6. /**

  7. * @author George

  8. * @description 进行比较

  9. **/

  10. public class HashClassEnd {

  11. public static void main(String[] args) throws IOException {

  12. BufferedReader br = null;

  13. HashSet<String> set = new HashSet<String>();

  14. String line = "";

  15. for (int j = 1; j < 6; j++) {

  16. String oPath = "d://ooxx" + j + ".txt";

  17. String xPath = "d://xxoo" + j + ".txt";

  18. br = new BufferedReader(new FileReader(oPath));

  19. while ((line = br.readLine()) != null){

  20. set.add(line);

  21. }

  22. br = new BufferedReader(new FileReader(xPath));

  23. while((line = br.readLine()) != null){

  24. if (set.contains(line)){

  25. System.out.println(line);

  26. }

  27. }

  28. }

  29. br.close();

  30. }

  31. }

输出结果:

"220764-7013"    "2014/9/22 13:25:00.000"    "0"    "0"    ""
"220764-7267"    "2014/9/22 10:45:00.000"    "0"    "0"    ""
"220764-7266"    "2014/9/22 11:45:00.000"    "2"    "0"    ""

给定a、b两个文件,各存放50亿个url,每个url各占64字节相关推荐

  1. 给定a、b两个文件,各存放50亿个url,每个url各占64字节,内存限制是4G,让你找出a、b文件共同的url?

    给定a.b两个文件,各存放50亿个url,每个url各占64字节,内存限制是4G,让你找出a.b文件共同的url? 两种方法: 一.采用Bloom filter,假设布隆过滤器的错误率为0.01,则位 ...

  2. 代码实现【mini版】——给定a、b两个文件,各存放50亿个url,每个url各占64字节,内存限制是4G,让你找出a、b文件共同的url?

    根据https://blog.csdn.net/qq_41946557/article/details/102708186思想去写!!! 将文件中的信息当成我们文本中的每行文件,然后两个文件中分别是1 ...

  3. 给定a、b两个文件,各存放50亿个url,每个url各占用64字节,内存限制是4G,如何找出a、b文件共同的url?

    思路:可以估计每个文件的大小为5G*64=300G,远大于4G.所以不可能将其完全加载到内存中处理.考虑采取分而治之的方法. 遍历文件a,对每个url求取hash(url)%1000,然后根据所得值将 ...

  4. 给定a、b两个文件,各存放50亿个url,每个url各占用64字节,内存限制是4G,如何找出a、b文件共同的url?...

    可以估计每个文件的大小为5G*64=300G,远大于4G.所以不可能将其完全加载到内存中处理.考虑采取分而治之的方法.  遍历文件a,对每个url求取hash(url)%1000,然后根据所得值将ur ...

  5. 面试- 阿里-. 大数据题目- 给定a、b两个文件,各存放50亿个url,每个url各占64字节,内存限制是4G,让你找出a、b文件共同的url?...

    假如每个url大小为10bytes,那么可以估计每个文件的大小为50G×64=320G,远远大于内存限制的4G,所以不可能将其完全加载到内存中处理,可以采用分治的思想来解决. Step1:遍历文件a, ...

  6. 海量数据实战(0)从两个文件50亿数据中找出相同的URL

    **问题:**给定a.b两个文件,各存放50亿个url,每个url各占64字节,内存限制是4G,让你找出a.b文件共同的url? 目录: 文章目录 Step 1 产生50亿 URL Step 2 将5 ...

  7. python现有两个磁盘文件a和b_有两个磁盘文件A和B,各存放一行字母,要求把这两个文件中的信息合并(按字母顺序排列), 输出到一个新文件C中Python实例...

    有两个磁盘文件A和B,各存放一行字母,要求把这两个文件中的信息合并(按字母顺序排列), 输出到一个新文件C中Python实例 题目:有两个磁盘文件A和B,各存放一行字母,要求把这两个文件中的信息合并( ...

  8. python现有两个磁盘文件a和b_有两个磁盘文件a和b,各存放一行字母,今要求把这两个文件中的信息合并...

    有两个磁盘文件"A"和"B",各存放一行字母,今要求把这两个文件中的信息合并(按字母顺序排列),输出到一个新文件"C"中去. [c源程序] ...

  9. diff命令两个服务器文件,LINUX命令diff-文件管理-比较给定的两个文件的不同

    diff命令 在最简单的情况下,比较给定的两个文件的不同.如果使用"-"代替"文件"参数,则要比较的内容将来自标准输入.diff命令是以逐行的方式,比较文本文件 ...

最新文章

  1. CentOS7安装Nginx及其相关
  2. 一日千里 云计算普及势不可挡
  3. delayqueue_在DelayQueue中更改延迟,从而更改顺序
  4. java获取api接口新浪数据,新浪短网址API接口的获取以及API接口的调用文档分享...
  5. kpi绩效考核流程图_KPI绩效考核法
  6. Metasploit Framework(6)客户端渗透(上)
  7. [收藏]判断文本框中的内容必须全为数字
  8. java 发送邮件多个人,java 发送邮件(支持多附件,抄送人等功能)
  9. Session使用方法详解
  10. centossocket5服务器搭建
  11. java审批工作流,值得一读!
  12. 自然辩证法概论国科大开卷考试
  13. 餐巾计划问题 费用流
  14. 邮件客户端开源_5个最佳开源环境电子邮件客户端
  15. 大白菜无法打开计算机硬盘,大白菜u盘启动盘出现问题及解决办法(上)
  16. Deep Learning模型之:CNN卷积神经网络(一)深度解析CNN
  17. 双向可控硅的触发电路设计
  18. 网络安全·Wireshark抓取流量
  19. 人工智能之配置环境教程二:在Anaconda中创建虚拟环境并在VsCode中使用
  20. 计算机考研专用邮件模板!复试/调剂联系导师邮件怎么写?

热门文章

  1. Navicat For Mysql快捷键
  2. 驱动WDK7600在VC6.0下的编译开发配置环境
  3. java设计模式---观察者模式
  4. Java 中的反射机制
  5. TCP/IP详解--学习笔记(6)-UDP协议
  6. 深入Linux内核网络堆栈
  7. swiper 定义放多少张图片,小程序swiper轮播图,自定义样式,两种方法:原生方法和bindchange方法;将点点改为数字(当前第几张 /总共几张);点击点点跳转当前图片...
  8. ip.php是什么意思,IP是什么意思
  9. ubuntu 终端批量复制文件_《卡死你3000》批量文件复制命令详解
  10. 机架搭建_铝型材设备机架定制流程