static class IntegrationTestBigLinkedListWithVisibility.VisibilityLoop extends IntegrationTestBigLinkedList.Loop
| Modifier and Type | Field and Description |
|---|---|
(package private) IntegrationTestBigLinkedListWithVisibility |
it |
private static org.slf4j.Logger |
LOG |
private static int |
SLEEP_IN_MS |
| Constructor and Description |
|---|
VisibilityLoop() |
| Modifier and Type | Method and Description |
|---|---|
int |
run(String[] args) |
protected void |
runCopier(String outputDir) |
protected void |
runDelete(int numMappers,
long numNodes,
String outputDir,
Integer width,
Integer wrapMultiplier,
int tableIndex) |
protected void |
runGenerator(int numMappers,
long numNodes,
String outputDir,
Integer width,
Integer wrapMultiplier,
Integer numWalkers) |
protected void |
runVerify(String outputDir,
int numReducers,
long expectedNumNodes,
boolean allTables) |
private void |
runVerify(String outputDir,
int numReducers,
long expectedNodes,
int tableIndex) |
protected void |
runVerifyCommonTable(String outputDir,
int numReducers,
long expectedNumNodes,
int index) |
private void |
sleep(long ms) |
private void |
verify(int numReducers,
long expectedNumNodes,
org.apache.hadoop.fs.Path iterationOutput,
IntegrationTestBigLinkedList.Verify verify) |
runVerifyprivate static final int SLEEP_IN_MS
private static final org.slf4j.Logger LOG
VisibilityLoop()
protected void runGenerator(int numMappers, long numNodes, String outputDir, Integer width, Integer wrapMultiplier, Integer numWalkers) throws Exception
runGenerator in class IntegrationTestBigLinkedList.LoopExceptionprotected void runDelete(int numMappers, long numNodes, String outputDir, Integer width, Integer wrapMultiplier, int tableIndex) throws Exception
Exceptionprotected void runVerify(String outputDir, int numReducers, long expectedNumNodes, boolean allTables) throws Exception
Exceptionprivate void runVerify(String outputDir, int numReducers, long expectedNodes, int tableIndex) throws Exception
Exceptionprivate void sleep(long ms) throws InterruptedException
InterruptedExceptionprotected void runVerifyCommonTable(String outputDir, int numReducers, long expectedNumNodes, int index) throws Exception
Exceptionprivate void verify(int numReducers, long expectedNumNodes, org.apache.hadoop.fs.Path iterationOutput, IntegrationTestBigLinkedList.Verify verify) throws Exception
ExceptionCopyright © 2007–2020 The Apache Software Foundation. All rights reserved.