static class IntegrationTestBigLinkedListWithVisibility.VisibilityLoop extends IntegrationTestBigLinkedList.Loop
Modifier and Type | Field and Description |
---|---|
private static org.slf4j.Logger |
LOG |
private static int |
SLEEP_IN_MS |
it
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) |
runVerify
private 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.Loop
Exception
protected void runDelete(int numMappers, long numNodes, String outputDir, Integer width, Integer wrapMultiplier, int tableIndex) throws Exception
Exception
protected void runVerify(String outputDir, int numReducers, long expectedNumNodes, boolean allTables) throws Exception
Exception
private void runVerify(String outputDir, int numReducers, long expectedNodes, int tableIndex) throws Exception
Exception
private void sleep(long ms) throws InterruptedException
InterruptedException
protected void runVerifyCommonTable(String outputDir, int numReducers, long expectedNumNodes, int index) throws Exception
Exception
private void verify(int numReducers, long expectedNumNodes, org.apache.hadoop.fs.Path iterationOutput, IntegrationTestBigLinkedList.Verify verify) throws Exception
Exception
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.