arnobroekhof

#!/bin/sh

#this looks up the nodes from the ring and rebalances them automatically

hosts = `/usr/bin/nodetool ring |grep Normal |awk '{print $1}' |xargs echo`

RING_SIZE=$(echo "2^127" | bc)

HOST_NUM=$(echo $hosts | wc -w)
INDEX=0

arnobroekhof

package com.srini.tikacustom;

import java.io.IOException;

import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.InputSplit;
import org.apache.hadoop.mapreduce.RecordReader;
import org.apache.hadoop.mapreduce.TaskAttemptContext;
import org.apache.hadoop.mapreduce.lib.input.FileInputFormat;