public class StagingFileUtils extends Object
Modifier and Type | Field and Description |
---|---|
static int |
CELL_BUFFER_SIZE |
Constructor and Description |
---|
StagingFileUtils() |
Modifier and Type | Method and Description |
---|---|
static void |
nextKeyMap(BufferedReader in,
HashMap<Integer,HashMap<Long,Long>> map,
int bi,
int blen) |
static int |
nextSizedKeyMap(BufferedReader in,
HashMap<Integer,HashMap<Long,Long>> map,
int blen,
int size) |
static BufferedReader |
openKeyMap(String name) |
static MatrixBlock |
readCellList2BlockFromLocal(String fname,
int blen) |
static MatrixBlock |
readCellList2BlockFromLocal(String fname,
int blen,
boolean sparse) |
static LinkedList<Cell> |
readCellListFromLocal(String fname) |
static void |
writeCellListToLocal(String fname,
LinkedList<Cell> buffer) |
static void |
writeKeyMappingToLocal(String fname,
long[][] keys) |
public static final int CELL_BUFFER_SIZE
public static void writeCellListToLocal(String fname, LinkedList<Cell> buffer) throws IOException
IOException
public static void writeKeyMappingToLocal(String fname, long[][] keys) throws IOException
IOException
public static BufferedReader openKeyMap(String name) throws FileNotFoundException
FileNotFoundException
public static void nextKeyMap(BufferedReader in, HashMap<Integer,HashMap<Long,Long>> map, int bi, int blen) throws NumberFormatException, IOException
NumberFormatException
IOException
public static int nextSizedKeyMap(BufferedReader in, HashMap<Integer,HashMap<Long,Long>> map, int blen, int size) throws NumberFormatException, IOException
NumberFormatException
IOException
public static LinkedList<Cell> readCellListFromLocal(String fname) throws IOException
IOException
public static MatrixBlock readCellList2BlockFromLocal(String fname, int blen) throws IOException, DMLRuntimeException
IOException
DMLRuntimeException
public static MatrixBlock readCellList2BlockFromLocal(String fname, int blen, boolean sparse) throws IOException, DMLRuntimeException
IOException
DMLRuntimeException
Copyright © 2022 The Apache Software Foundation. All rights reserved.