public class TestAggregatorsHandling extends BspCase
READER_VERTICES_OPT
Constructor and Description |
---|
TestAggregatorsHandling() |
Modifier and Type | Method and Description |
---|---|
void |
testAggregatorsCheckpointing()
Test if aggregators are are handled properly when restarting from a
checkpoint
|
void |
testAggregatorsHandling()
Tests if aggregators are handled on a proper way during supersteps
|
getCallingMethodName, getNumResults, getNumWorkers, getSinglePartFileStatus, getTempPath, getZooKeeperList, prepareJob, prepareJob, process, removeAndSetOutput, runningInDistributedMode, setUp, setupConfiguration, tearDown
public void testAggregatorsHandling() throws IOException, ClassNotFoundException, InterruptedException
public void testAggregatorsCheckpointing() throws ClassNotFoundException, IOException, InterruptedException
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.