TextMultipleOutputFormat.java

package mobvista.dmp.format;

import org.apache.hadoop.io.Text;

public class TextMultipleOutputFormat extends MultipleOutputFormat<Text, Text> {
	protected String generateFileNameForKeyValue(Text key, Text value,
			String name) {
		String temp = key.toString();
		int pos = temp.indexOf(",");
		if (pos != -1) {
			temp = temp.substring(0, pos);
		}
		return temp + "/" + name;
	}

	protected Text generateActualKey(Text key, Text value) {
		String temp = key.toString();
		int pos = temp.indexOf(",");
		if (pos == -1)
			return key;
		String outKey = temp.substring(pos + 1).trim();
		if ("".equals(outKey)) {
			return null;
		}
		return new Text(temp.substring(pos + 1));
	}
}