public class Merge
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
Merge.RemoveNAsTask |
Modifier and Type | Field and Description |
---|---|
static int |
ASCENDING |
static int |
DESCENDING |
static int |
MEM_MULTIPLIER |
static int |
OPTIMAL_BATCHSIZE |
Constructor and Description |
---|
Merge() |
Modifier and Type | Method and Description |
---|---|
static long |
allocateChunk(java.util.List<water.rapids.SortCombine> bmList,
long[] chunkSizes,
int[] chunkLeftMSB,
int[] chunkRightMSB,
int[] chunkBatch) |
static Frame |
allocatePopulateChunk(java.util.List<water.rapids.SortCombine> bmList,
Frame leftFrame,
long ansN,
long[] chunkSizes,
int[] chunkLeftMSB,
int[] chunkRightMSB,
int[] chunkBatch,
long mergeId) |
static java.util.List<water.rapids.SortCombine> |
gatherSameMSBRows(Frame leftFrame,
long mergeId) |
static Frame |
merge(Frame leftFrame,
Frame riteFrame,
int[] leftCols,
int[] riteCols,
boolean allLeft,
int[][] id_maps) |
static Frame |
merge(Frame leftFrame,
Frame riteFrame,
int[] leftCols,
int[] riteCols,
boolean allLeft,
int[][] id_maps,
int[] ascendingL,
int[] ascendingR) |
static Frame |
sort(Frame fr,
int col) |
static Frame |
sort(Frame fr,
int[] cols) |
static Frame |
sort(Frame fr,
int[] cols,
int[] ascending) |
static Frame |
sortOnly(Frame leftFrame,
int[] leftCols,
int[][] id_maps,
int[] ascendingL) |
public static int ASCENDING
public static int DESCENDING
public static final int MEM_MULTIPLIER
public static final int OPTIMAL_BATCHSIZE
public static Frame merge(Frame leftFrame, Frame riteFrame, int[] leftCols, int[] riteCols, boolean allLeft, int[][] id_maps)
public static Frame merge(Frame leftFrame, Frame riteFrame, int[] leftCols, int[] riteCols, boolean allLeft, int[][] id_maps, int[] ascendingL, int[] ascendingR)
public static java.util.List<water.rapids.SortCombine> gatherSameMSBRows(Frame leftFrame, long mergeId)
public static long allocateChunk(java.util.List<water.rapids.SortCombine> bmList, long[] chunkSizes, int[] chunkLeftMSB, int[] chunkRightMSB, int[] chunkBatch)
public static Frame allocatePopulateChunk(java.util.List<water.rapids.SortCombine> bmList, Frame leftFrame, long ansN, long[] chunkSizes, int[] chunkLeftMSB, int[] chunkRightMSB, int[] chunkBatch, long mergeId)