public class TextPipelineTest extends BaseSparkTest
sc
Constructor and Description |
---|
TextPipelineTest() |
Modifier and Type | Method and Description |
---|---|
void |
before() |
org.apache.spark.api.java.JavaRDD<java.lang.String> |
getCorpusRDD(org.apache.spark.api.java.JavaSparkContext sc) |
void |
testBuildVocabCache() |
void |
testBuildVocabWordListRDD() |
void |
testCountCumSum() |
void |
testFilterMinWordAddVocab() |
void |
testFirstIteration() |
void |
testHuffman() |
void |
testSyn0AfterFirstIteration() |
void |
testTokenizer() |
void |
testWordFreqAccIdentifyingStopWords() |
void |
testWordFreqAccIdentifyStopWords() |
void |
testWordFreqAccNotIdentifyingStopWords() |
void |
testZipFunction1()
This test checked generations retrieved using stopWords
|
void |
testZipFunction2() |
after, getContext
public org.apache.spark.api.java.JavaRDD<java.lang.String> getCorpusRDD(org.apache.spark.api.java.JavaSparkContext sc)
public void before() throws java.lang.Exception
before
in class BaseSparkTest
java.lang.Exception
public void testTokenizer() throws java.lang.Exception
java.lang.Exception
public void testWordFreqAccIdentifyStopWords() throws java.lang.Exception
java.lang.Exception
public void testWordFreqAccNotIdentifyingStopWords() throws java.lang.Exception
java.lang.Exception
public void testWordFreqAccIdentifyingStopWords() throws java.lang.Exception
java.lang.Exception
public void testFilterMinWordAddVocab() throws java.lang.Exception
java.lang.Exception
public void testBuildVocabCache() throws java.lang.Exception
java.lang.Exception
public void testBuildVocabWordListRDD() throws java.lang.Exception
java.lang.Exception
public void testHuffman() throws java.lang.Exception
java.lang.Exception
public void testCountCumSum() throws java.lang.Exception
java.lang.Exception
public void testZipFunction1() throws java.lang.Exception
java.lang.Exception
public void testZipFunction2() throws java.lang.Exception
java.lang.Exception
public void testFirstIteration() throws java.lang.Exception
java.lang.Exception
public void testSyn0AfterFirstIteration() throws java.lang.Exception
java.lang.Exception