umbrant

import socket
import time
import threading
import SocketServer

class ThreadedTCPRequestHandler(SocketServer.BaseRequestHandler):

    def handle(self):
        data = open("file", "r").readlines()
        for line in data:

umbrant

javascript:(function(){
// parseUri 1.2.2
// (c) Steven Levithan <stevenlevithan.com>
// MIT License

function parseUri (str) {
    var o   = parseUri.options,
        m   = o.parser[o.strictMode ? "strict" : "loose"].exec(str),
        uri = {},
        i   = 14;

umbrant

export HADOOP_COMMON_HOME=$(pwd)/$(ls -d hadoop-common-project/hadoop-common/target/hadoop-common-*-SNAPSHOT)
export HADOOP_HDFS_HOME=$(pwd)/$(ls -d hadoop-hdfs-project/hadoop-hdfs/target/hadoop-hdfs-*-SNAPSHOT)
export PATH=$HADOOP_COMMON_HOME/bin:$HADOOP_HDFS_HOME/bin:$PATH

umbrant

#!/usr/bin/env bash

function p {
    echo `date --rfc-3339=ns` "$@"
}

BASEDIR=`pwd`/hardtest

SOURCEDIR=$BASEDIR/dfs
SNAPDIR=$BASEDIR/dfs-snap