I hereby claim:
- I am clizzin on github.
- I am clizzin (https://keybase.io/clizzin) on keybase.
- I have a public key ASB7ch-Q9IO4iJJVee84yMzG8SatrJveTbWKVDhecws03Qo
To claim this, I am signing this object:
{I hereby claim:
To claim this, I am signing this object:
{| ;; As predicate macro. Doesn't work because requires two-step aggregation (first step to get the mean, second step to get the moment). | |
| (def moment | |
| (<- [!val !k :> !moment] | |
| (c/avg !val :> !mean) | |
| (- !val !mean :> !dev) | |
| (expt !dev !k :> !pow-dev) | |
| (c/sum !pow-dev :> !pow-dev-sum) | |
| (c/count !count) | |
| (div !pow-dev-sum !count :> !moment))) |
| #!/usr/bin/env ruby | |
| # Put the contents of this gist into .git/hooks/pre-commit | |
| # Make sure to chmod a+x .git/hooks/pre-commit | |
| flag = false | |
| modified_files = `git diff-index --name-status --cached HEAD`. | |
| map {|line| line.split}. | |
| select {|(status, name)| status != 'D'}. # ignore deleted files |
| 2011-06-22 12:22:36,215 INFO com.cloudera.flume.core.connector.DirectDriver: Connector logicalNode xxx.ec2.internal-E2E-30 exited with error: Blocked append interrupted by rotation event | |
| java.lang.InterruptedException: Blocked append interrupted by rotation event | |
| at com.cloudera.flume.handlers.rolling.RollSink.append(RollSink.java:204) | |
| at com.cloudera.flume.agent.durability.NaiveFileWALDeco.append(NaiveFileWALDeco.java:132) | |
| at com.cloudera.flume.core.CompositeSink.append(CompositeSink.java:61) | |
| at com.cloudera.flume.agent.AgentFailChainSink.append(AgentFailChainSink.java:103) | |
| at com.cloudera.flume.core.connector.DirectDriver$PumperThread.run(DirectDriver.java:110) | |
| 2011-06-22 12:22:37,265 INFO com.cloudera.flume.handlers.thrift.ThriftEventSource: Closed server on port 35090... | |
| 2011-06-22 12:22:37,265 INFO com.cloudera.flume.handlers.thrift.ThriftEventSource: Queue still has 1 elements ... |
| Process Thread Dump: | |
| 137 active threads | |
| Thread 388 (pool-1-thread-182): | |
| State: RUNNABLE | |
| Blocked count: 0 | |
| Waited count: 0 | |
| Stack: | |
| java.net.SocketInputStream.socketRead0(Native Method) | |
| java.net.SocketInputStream.read(SocketInputStream.java:129) | |
| java.io.BufferedInputStream.fill(BufferedInputStream.java:218) |
| Process Thread Dump: | |
| 95 active threads | |
| Thread 20183 (SpawningLogicalNode foobar): | |
| State: BLOCKED | |
| Blocked count: 1 | |
| Waited count: 0 | |
| Blocked on com.cloudera.flume.agent.LogicalNode@5a3391c0 | |
| Blocked by 20028 (SpawningLogicalNode foobar) | |
| Stack: | |
| com.cloudera.flume.agent.LogicalNode.openLoadNode(LogicalNode.java:166) |
| # Change the cluster name here | |
| whirr.cluster-name=hadoop | |
| # Change the number of machines in the cluster here | |
| whirr.instance-templates=1 nn+jt,5 dn+tt | |
| # Uncomment out these lines to run CDH | |
| whirr.hadoop-install-runurl=cloudera/cdh/install | |
| whirr.hadoop-configure-runurl=cloudera/cdh/post-configure |
| > db.foo.insert({a: {john: true, george: true}}) | |
| > db.foo.insert({a: {paul: true, ringo: true}}) | |
| > db.foo.find() | |
| { "_id" : ObjectId("4d43912ceb913a1024b1410f"), "a" : { "john" : true, "george" : true } } | |
| { "_id" : ObjectId("4d43914beb913a1024b14110"), "a" : { "paul" : true, "ringo" : true } } | |
| > db.foo.find({'a.john': {$exists: true}}) | |
| { "_id" : ObjectId("4d43912ceb913a1024b1410f"), "a" : { "john" : true, "george" : true } } | |
| > db.foo.find({'a.paul': {$exists: true}}) |