public class RepartitionTemporal extends Repartition
Repartition.RepartitionMap<T extends Shape>, Repartition.RepartitionMapNoReplication<T extends Shape>, Repartition.RepartitionOutputCommitter, Repartition.RepartitionReduce<T extends Shape>
Constructor and Description |
---|
RepartitionTemporal() |
Modifier and Type | Method and Description |
---|---|
static void |
main(java.lang.String[] args) |
protected static void |
printUsage() |
static void |
repartitionMapReduce(Path[] inputPaths,
Path outputPath,
OperationsParams params) |
static void |
repartitionMapReduce(Path[] inputPaths,
Path outputPath,
Shape stockShape,
long blockSize,
CellInfo[] cellInfos,
java.lang.String sindex,
boolean overwrite) |
calculateNumberOfPartitions, packInRectangles, packInRectangles, packInRectangles, repartition, repartitionLocal, repartitionLocal, repartitionLocal, repartitionLocal, repartitionMapReduce, repartitionMapReduce, repartitionMapReduce
public static void repartitionMapReduce(Path[] inputPaths, Path outputPath, OperationsParams params) throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
public static void repartitionMapReduce(Path[] inputPaths, Path outputPath, Shape stockShape, long blockSize, CellInfo[] cellInfos, java.lang.String sindex, boolean overwrite) throws java.io.IOException
java.io.IOException
protected static void printUsage()
public static void main(java.lang.String[] args) throws java.io.IOException, java.text.ParseException, java.lang.InterruptedException
java.io.IOException
java.text.ParseException
java.lang.InterruptedException