|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object edu.stolaf.cs.wmrserver.streaming.StreamKeyValUtil
public class StreamKeyValUtil
Constructor Summary | |
---|---|
StreamKeyValUtil()
|
Method Summary | |
---|---|
static int |
findTab(byte[] utf)
Find the first occured tab in a UTF-8 encoded string |
static int |
findTab(byte[] utf,
int start,
int length)
Find the first occured tab in a UTF-8 encoded string |
static int |
readLine(org.apache.hadoop.util.LineReader lineReader,
org.apache.hadoop.io.Text out)
Read a utf8 encoded line from a data input stream. |
static void |
splitKeyVal(byte[] utf,
int start,
int length,
org.apache.hadoop.io.Text key,
org.apache.hadoop.io.Text val,
int splitPos)
split a UTF-8 byte array into key and value assuming that the delimilator is at splitpos. |
static void |
splitKeyVal(byte[] utf,
int start,
int length,
org.apache.hadoop.io.Text key,
org.apache.hadoop.io.Text val,
int splitPos,
int separatorLength)
split a UTF-8 byte array into key and value assuming that the delimilator is at splitpos. |
static void |
splitKeyVal(byte[] utf,
org.apache.hadoop.io.Text key,
org.apache.hadoop.io.Text val,
int splitPos)
split a UTF-8 byte array into key and value assuming that the delimilator is at splitpos. |
static void |
splitKeyVal(byte[] utf,
org.apache.hadoop.io.Text key,
org.apache.hadoop.io.Text val,
int splitPos,
int separatorLength)
split a UTF-8 byte array into key and value assuming that the delimilator is at splitpos. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public StreamKeyValUtil()
Method Detail |
---|
public static int findTab(byte[] utf, int start, int length)
utf
- a byte array containing a UTF-8 encoded stringstart
- starting offsetlength
- no. of bytes
public static int findTab(byte[] utf)
utf
- a byte array containing a UTF-8 encoded string
public static void splitKeyVal(byte[] utf, int start, int length, org.apache.hadoop.io.Text key, org.apache.hadoop.io.Text val, int splitPos, int separatorLength) throws java.io.IOException
utf
- utf-8 encoded stringstart
- starting offsetlength
- no. of byteskey
- contains key upon the method is returnedval
- contains value upon the method is returnedsplitPos
- the split posseparatorLength
- the length of the separator between key and value
java.io.IOException
public static void splitKeyVal(byte[] utf, int start, int length, org.apache.hadoop.io.Text key, org.apache.hadoop.io.Text val, int splitPos) throws java.io.IOException
utf
- utf-8 encoded stringstart
- starting offsetlength
- no. of byteskey
- contains key upon the method is returnedval
- contains value upon the method is returnedsplitPos
- the split pos
java.io.IOException
public static void splitKeyVal(byte[] utf, org.apache.hadoop.io.Text key, org.apache.hadoop.io.Text val, int splitPos, int separatorLength) throws java.io.IOException
utf
- utf-8 encoded stringkey
- contains key upon the method is returnedval
- contains value upon the method is returnedsplitPos
- the split posseparatorLength
- the length of the separator between key and value
java.io.IOException
public static void splitKeyVal(byte[] utf, org.apache.hadoop.io.Text key, org.apache.hadoop.io.Text val, int splitPos) throws java.io.IOException
utf
- utf-8 encoded stringkey
- contains key upon the method is returnedval
- contains value upon the method is returnedsplitPos
- the split pos
java.io.IOException
public static int readLine(org.apache.hadoop.util.LineReader lineReader, org.apache.hadoop.io.Text out) throws java.io.IOException
lineReader
- LineReader to read the line from.out
- Text to read into
java.io.IOException
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |