@Test public void writeMatchedCitations() { String path = "/matched/citations/path"; when(matchedCitations.keys()).thenReturn(matchedCitationsKeys); citationOutputWriter.writeMatchedCitations(matchedCitations, path); verify(matchedCitationsKeys).cache(); verify(avroSaver).saveJavaRDD(matchedCitationsKeys, Citation.SCHEMA$, path); verify(citationMatchingReporter).report(matchedCitationsKeys); }
@Override public void writeMatchedCitations(JavaPairRDD<Citation, NullWritable> matchedCitations, String path) { JavaRDD<Citation> matchedCitationsKeys = matchedCitations.keys(); matchedCitationsKeys.cache(); avroSaver.saveJavaRDD(matchedCitationsKeys, Citation.SCHEMA$, path); citationMatchingReporter.report(matchedCitationsKeys); }
CitationOutputWriter implements OutputWriter<Citation, NullWritable>, Serializable { @Override public void writeMatchedCitations(JavaPairRDD<Citation, NullWritable> matchedCitations, String path) { JavaRDD<Citation> matchedCitationsKeys = matchedCitations.keys(); matchedCitationsKeys.cache(); avroSaver.saveJavaRDD(matchedCitationsKeys, Citation.SCHEMA$, path); citationMatchingReporter.report(matchedCitationsKeys); } }
CitationOutputWriter implements OutputWriter<Citation, NullWritable>, Serializable { @Override public void writeMatchedCitations(JavaPairRDD<Citation, NullWritable> matchedCitations, String path) { JavaRDD<Citation> matchedCitationsKeys = matchedCitations.keys(); matchedCitationsKeys.cache(); avroSaver.saveJavaRDD(matchedCitationsKeys, Citation.SCHEMA$, path); citationMatchingReporter.report(matchedCitationsKeys); }  }
CitationOutputWriter implements OutputWriter<Citation, NullWritable>, Serializable { @Override public void writeMatchedCitations(JavaPairRDD<Citation, NullWritable> matchedCitations, String path) { JavaRDD<Citation> matchedCitationsKeys = matchedCitations.keys(); matchedCitationsKeys.cache(); avroSaver.saveJavaRDD(matchedCitationsKeys, Citation.SCHEMA$, path); citationMatchingReporter.report(matchedCitationsKeys); }  @Override void writeMatchedCitations(JavaPairRDD<Citation, NullWritable> matchedCitations, String path); void setCitationMatchingReporter(CitationMatchingCounterReporter citationMatchingReporter); }
CitationOutputWriter implements OutputWriter<Citation, NullWritable>, Serializable { @Override public void writeMatchedCitations(JavaPairRDD<Citation, NullWritable> matchedCitations, String path) { JavaRDD<Citation> matchedCitationsKeys = matchedCitations.keys(); matchedCitationsKeys.cache(); avroSaver.saveJavaRDD(matchedCitationsKeys, Citation.SCHEMA$, path); citationMatchingReporter.report(matchedCitationsKeys); }  @Override void writeMatchedCitations(JavaPairRDD<Citation, NullWritable> matchedCitations, String path); void setCitationMatchingReporter(CitationMatchingCounterReporter citationMatchingReporter);  }