Skip to content

Instantly share code, notes, and snippets.

diff --git a/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/mapreduce/JobContextImpl.java b/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/mapreduce/JobContextImpl.java
index 12491ed..b4ca24c 100644
--- a/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/mapreduce/JobContextImpl.java
+++ b/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/mapreduce/JobContextImpl.java
@@ -475,5 +475,16 @@ public class JobContextImpl implements JobContext {
public Progressable getProgressible() {
return progress;
}
+
+ /**
package main
import (
"fmt"
"labix.org/v2/mgo"
"labix.org/v2/mgo/bson"
"time"
)
type Person struct {
@xiocode
xiocode / verify.go
Created August 23, 2013 06:54 — forked from jedy/verify.go
package main
import (
"crypto"
"crypto/rsa"
"crypto/sha1"
"crypto/x509"
"encoding/base64"
"fmt"
)
Assertions:
- I'm not stupid
- I don't want to be limited by some idiotic `people that write templates are stupid` rule.
- I don't want to learn yet another template language.
- I want to use golang expressions if, for..
- I want all the power of indexing, getting attributes and performing operations that golang offers.
- I want to type less stuff and do more.
- I want to include other templates in my template. (jinja?)
- I want to extend templates.
package main
import (
"unicode/utf8"
)
type Item string
type Stream chan Item
type Acc string
import gevent
from gevent.event import AsyncResult
import gevent.pool
import gevent.queue
class WorkerQueue(object):
def __init__(self):
self.group = gevent.pool.Group()
self.q = gevent.queue.Queue()
@xiocode
xiocode / dbbake.sh
Created July 18, 2012 02:56 — forked from syshack/dbbake.sh
mysql bak
#!/usr/bin/env bash
#dbbake.sh
#author:syshack
#date:2011.9.10
#数据库
DBName=mysql
#用户名
DBUser=root
#数据库密码
DBPasswd=
@xiocode
xiocode / gist:3090710
Created July 11, 2012 14:26 — forked from creotiv/gist:1217855
Multicore gevent wsgi server
import sys
from gevent import server
from gevent.baseserver import _tcp_listener
from gevent import pywsgi
from gevent.monkey import patch_all; patch_all()
from multiprocessing import Process, current_process, cpu_count
def hello_world(env, start_response):
if env['PATH_INFO'] == '/':
start_response('200 OK', [('Content-Type', 'text/html')])
@xiocode
xiocode / gist:3090669
Created July 11, 2012 14:20 — forked from tmc/gist:776364
simple multiprocessing gevent echo server
import sys
from gevent import server
from multiprocessing import Process, current_process, cpu_count
def note(format, *args):
sys.stderr.write('[%s]\t%s\n' % (current_process().name, format%args))
def echo(socket, address):
print 'New connection from %s:%s' % address
@xiocode
xiocode / pinhole.py
Created May 31, 2012 02:01 — forked from mayli/pinhole.py
A simple port multiplexer
#!/usr/bin/env python
# -*- coding: utf-8 -*-
#
# author: mayli <[email protected]>
#
# Modified from Pinhole, and the original code is found here:
# {{{ http://code.activestate.com/recipes/114642/ (r1)
#
"""
usage: pinhole