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, getContextpublic 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 BaseSparkTestjava.lang.Exceptionpublic void testTokenizer()
throws java.lang.Exception
java.lang.Exceptionpublic void testWordFreqAccIdentifyStopWords()
throws java.lang.Exception
java.lang.Exceptionpublic void testWordFreqAccNotIdentifyingStopWords()
throws java.lang.Exception
java.lang.Exceptionpublic void testWordFreqAccIdentifyingStopWords()
throws java.lang.Exception
java.lang.Exceptionpublic void testFilterMinWordAddVocab()
throws java.lang.Exception
java.lang.Exceptionpublic void testBuildVocabCache()
throws java.lang.Exception
java.lang.Exceptionpublic void testBuildVocabWordListRDD()
throws java.lang.Exception
java.lang.Exceptionpublic void testHuffman()
throws java.lang.Exception
java.lang.Exceptionpublic void testCountCumSum()
throws java.lang.Exception
java.lang.Exceptionpublic void testZipFunction1()
throws java.lang.Exception
java.lang.Exceptionpublic void testZipFunction2()
throws java.lang.Exception
java.lang.Exceptionpublic void testFirstIteration()
throws java.lang.Exception
java.lang.Exceptionpublic void testSyn0AfterFirstIteration()
throws java.lang.Exception
java.lang.Exception