下面列出了怎么用org.apache.hadoop.io.OutputBuffer的API类实例代码及写法,或者点击链接到github查看源代码。
public MRSortResultIterator(OutputBuffer keyValBuffer,
int []pointers, int []startOffsets,
int []keyLengths, int []valLengths) {
this.count = pointers.length;
this.pointers = pointers;
this.startOffsets = startOffsets;
this.keyLengths = keyLengths;
this.valLengths = valLengths;
this.keyValBuffer = keyValBuffer;
}
public MRSortResultIterator(OutputBuffer keyValBuffer,
int []pointers, int []startOffsets,
int []keyLengths, int []valLengths) {
this.count = pointers.length;
this.pointers = pointers;
this.startOffsets = startOffsets;
this.keyLengths = keyLengths;
this.valLengths = valLengths;
this.keyValBuffer = keyValBuffer;
}
public MRSortResultIterator(OutputBuffer keyValBuffer,
int []pointers, int []startOffsets,
int []keyLengths, int []valLengths) {
this.count = pointers.length;
this.pointers = pointers;
this.startOffsets = startOffsets;
this.keyLengths = keyLengths;
this.valLengths = valLengths;
this.keyValBuffer = keyValBuffer;
}
public MRSortResultIterator(OutputBuffer keyValBuffer,
int []pointers, int []startOffsets,
int []keyLengths, int []valLengths) {
this.count = pointers.length;
this.pointers = pointers;
this.startOffsets = startOffsets;
this.keyLengths = keyLengths;
this.valLengths = valLengths;
this.keyValBuffer = keyValBuffer;
}
public void setInputBuffer(OutputBuffer buffer) {
//store a reference to the keyValBuffer that we need to read during sort
this.keyValBuffer = buffer;
}
private void reset(OutputBuffer d, int start, int length)
throws IOException {
data = d.getData();
this.start = start;
dataSize = length;
}
public void setInputBuffer(OutputBuffer buffer) {
//store a reference to the keyValBuffer that we need to read during sort
this.keyValBuffer = buffer;
}
private void reset(OutputBuffer d, int start, int length)
throws IOException {
data = d.getData();
this.start = start;
dataSize = length;
}
public void setInputBuffer(OutputBuffer buffer) {
//store a reference to the keyValBuffer that we need to read during sort
this.keyValBuffer = buffer;
}
private void reset(OutputBuffer d, int start, int length)
throws IOException {
data = d.getData();
this.start = start;
dataSize = length;
}
public void setInputBuffer(OutputBuffer buffer) {
//store a reference to the keyValBuffer that we need to read during sort
this.keyValBuffer = buffer;
}
private void reset(OutputBuffer d, int start, int length)
throws IOException {
data = d.getData();
this.start = start;
dataSize = length;
}
/** The user class invokes this method to set the buffer that the specific
* sort algorithm should "indirectly" sort (generally, sort algorithm impl
* should access this buffer via comparators and sort offset-indices to the
* buffer).
* @param buffer the map output buffer
*/
public void setInputBuffer(OutputBuffer buffer);
/** The user class invokes this method to set the buffer that the specific
* sort algorithm should "indirectly" sort (generally, sort algorithm impl
* should access this buffer via comparators and sort offset-indices to the
* buffer).
* @param buffer the map output buffer
*/
public void setInputBuffer(OutputBuffer buffer);
/** The user class invokes this method to set the buffer that the specific
* sort algorithm should "indirectly" sort (generally, sort algorithm impl
* should access this buffer via comparators and sort offset-indices to the
* buffer).
* @param buffer the map output buffer
*/
public void setInputBuffer(OutputBuffer buffer);
/** The user class invokes this method to set the buffer that the specific
* sort algorithm should "indirectly" sort (generally, sort algorithm impl
* should access this buffer via comparators and sort offset-indices to the
* buffer).
* @param buffer the map output buffer
*/
public void setInputBuffer(OutputBuffer buffer);