小编Jam*_*mes的帖子

使用Hadoop统计独特访客的最佳方式是什么?

嘿所有,刚刚开始使用hadoop并且很好奇如果你的日志文件看起来像这样,mapreduce的最佳方式是计算唯一访问者...

DATE       siteID  action   username
05-05-2010 siteA   pageview jim
05-05-2010 siteB   pageview tom
05-05-2010 siteA   pageview jim
05-05-2010 siteB   pageview bob
05-05-2010 siteA   pageview mike
Run Code Online (Sandbox Code Playgroud)

对于每个网站,您想要找出每个网站的唯一身份访问者?

我以为mapper会发出siteID\t用户名,reducer会为每个键保留一个唯一用户名的set(),然后发出该组的长度.然而,这可能会在内存中存储数百万个用户名,这似乎并不正确.谁有更好的方法?

我顺便使用python流

谢谢

python hadoop mapreduce

9
推荐指数
1
解决办法
5541
查看次数

http连接的最佳java lib?

大家好我正在编写一个简单的网页抓取脚本,需要连接到网页,自动跟踪302重定向,给我链接的最终网址,让我抓住HTML.

做这些事情的首选java lib是什么?

谢谢

java

8
推荐指数
1
解决办法
674
查看次数

无法获得线程转储?我的应用程序阻止的任何想法?

我有一个基本的Java服务器应用程序,它有100个工作线程,可以在URL上执行简单的HEAD请求.我正在使用HttpClient 4.x.

几分钟后,我的程序冻结了几分钟,我无法弄清楚原因.查看可视vm监视器报告的屏幕截图.你可以看到它扁平化.在这段时间里,我无法获得良好的线程转储,视觉vm只是冻结,直到它被解锁.有没有人有任何想法,我可以做什么来尝试开始调试这个人?

Visual VM:http://tinypic.com/view.php?pic = 2i915bs&s = 7

这是我在冻结时尝试获取jstack转储时的输出:

jstack -F 4325 
Attaching to process ID 4325, please wait...
Debugger attached successfully.
Server compiler detected.
JVM version is 16.3-b01
Deadlock Detection:

No deadlocks found.

Thread 4557: (state = BLOCKED)
Error occurred during stack walking:
sun.jvm.hotspot.debugger.DebuggerException: sun.jvm.hotspot.debugger.DebuggerException: get_thread_regs failed for a lwp
    at sun.jvm.hotspot.debugger.linux.LinuxDebuggerLocal$LinuxDebuggerLocalWorkerThread.execute(LinuxDebuggerLocal.java:152)
    at sun.jvm.hotspot.debugger.linux.LinuxDebuggerLocal.getThreadIntegerRegisterSet(LinuxDebuggerLocal.java:466)
    at sun.jvm.hotspot.debugger.linux.LinuxThread.getContext(LinuxThread.java:65)
    at sun.jvm.hotspot.runtime.linux_amd64.LinuxAMD64JavaThreadPDAccess.getCurrentFrameGuess(LinuxAMD64JavaThreadPDAccess.java:92)
    at sun.jvm.hotspot.runtime.JavaThread.getCurrentFrameGuess(JavaThread.java:256)
    at sun.jvm.hotspot.runtime.JavaThread.getLastJavaVFrameDbg(JavaThread.java:218)
    at sun.jvm.hotspot.tools.StackTrace.run(StackTrace.java:76)
    at sun.jvm.hotspot.tools.StackTrace.run(StackTrace.java:45)
    at sun.jvm.hotspot.tools.JStack.run(JStack.java:60)
    at sun.jvm.hotspot.tools.Tool.start(Tool.java:221)
    at sun.jvm.hotspot.tools.JStack.main(JStack.java:86)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) …
Run Code Online (Sandbox Code Playgroud)

java debugging stack multithreading

8
推荐指数
1
解决办法
9891
查看次数

什么是Java中的process_reaper线程?

我收到了数百个这样的process_reaper线程,这些线程会在我的应用程序中随着时间的推移而积累.任何人都知道这些可能是什么?他们似乎在使用我的Runtime.exec()但是我在finally语句中销毁了我的进程但它们仍然出现

屏幕截图:http: //www.dropmocks.com/mBxM5

Process proc = null;
        String line;
        try {
            logger.info("Trying to execute command " + Arrays.asList(command).toString().replace(",", ""));
            proc = Runtime.getRuntime().exec(command);

        } catch (IOException e) {
            logger.info("IOException while trying to execute " + command);
            return false;
        } finally {
            if(proc != null) {
                proc.destroy();
            }
    }
Run Code Online (Sandbox Code Playgroud)

java multithreading

8
推荐指数
1
解决办法
7647
查看次数

在AKKA中,在主管上调用关闭会阻止它监督的所有演员吗?

假设我有一个链接2个演员的主管.当我的应用程序关闭时,我想优雅地关闭这些演员.调用supervisor.shutdown()会停止所有演员还是我还需要手动停止我的演员?

格拉西亚斯

java scala actor akka akka-supervision

8
推荐指数
1
解决办法
1368
查看次数

使用maven编译Scala文件的最快方法是什么?

理想情况下使用FSC编译器

问题变成我应该使用的命令或pom文件设置?

我目前正在使用scala maven插件,但它似乎并没有实际使用fsc

谢谢

scala maven

8
推荐指数
1
解决办法
1390
查看次数

最有效的方法来查找一个字符串对一个单词数组的匹配计数?

假设我有一个字符串

String test = "This is a test string and I have some stopwords in here";
Run Code Online (Sandbox Code Playgroud)

我想看看下面数组中的单词与我的字符串匹配多少次

psudocode

array = a,and,the,them,they,I
Run Code Online (Sandbox Code Playgroud)

所以答案是"3"

只是好奇在java中最有效的方法是什么?

java

7
推荐指数
2
解决办法
2284
查看次数

尝试加载文件时出现JMagick错误 - UnsatisfiedLink

java.lang.UnsatisfiedLinkError:在java.lang.ClassLoader.loadLibrary(ClassLoader.java:1754)的java.library.path中没有JMagick,位于java.lang.System的java.lang.Runtime.loadLibrary0(Runtime.java:823) .loadLibrary(System.java:1045)

在尝试使用代码时

ImageInfo info;

    try {
      info = new ImageInfo();
      //image = new MagickImage(info);

    } catch (MagickException e) {
      logger.error(InsightsHelper.getStackTrace(e));
    }
Run Code Online (Sandbox Code Playgroud)

任何想法为什么会这样?我在OSX上使用eclipse

java imagemagick jmagick

7
推荐指数
1
解决办法
8747
查看次数

使用Akka Microkernel有哪些常见用例?

根据akki.io上的文档,我没有看到MicroKernel解决了哪些常见用例?有没有人有一些简单的现实世界用例?

谢谢

java scala akka

7
推荐指数
1
解决办法
1838
查看次数

使用MysqlDb时出现Python错误 - 不推荐使用sets模块

我每次运行使用MySQLdb的Python脚本时都会收到警告:

/var/lib/python-support/python2.6/MySQLdb/__init__.py:34:
DeprecationWarning: the sets module is deprecated
  from sets import ImmutableSet
Run Code Online (Sandbox Code Playgroud)

如果可能的话,我宁可不要乱用他们的lib.我在Ubuntu服务器上.任何人都知道一个简单的方法来修复该警告信息?

谢谢

更新:根据以下建议和此链接修复它:https://bugzilla.redhat.com/show_bug.cgi?id = 505611

import warnings
warnings.filterwarnings('ignore', '.*the sets module is deprecated.*',
                        DeprecationWarning, 'MySQLdb')
import MySQLdb
Run Code Online (Sandbox Code Playgroud)

python mysql

6
推荐指数
1
解决办法
2845
查看次数