public void testJobCompletes()

in src/testJobs/java/org/apache/sdap/ningester/testjobs/SmapJobTest.java [69:93]

• 17 lines of code
• 1 McCabe index (conditional complexity)

    public void testJobCompletes() throws Exception {

        JobParameters jobParameters = new JobParametersBuilder()
                .addString("granule", "classpath:granules/SMAP_L2B_SSS_04892_20160101T005507_R13080.h5")
                .toJobParameters();

        JobExecution jobExecution = jobLauncherTestUtils.launchJob(jobParameters);

        assertThat(jobExecution.getExitStatus().getExitCode(), is("COMPLETED"));
        StepExecution stepExecution = jobExecution.getStepExecutions().iterator().next();
        assertThat(stepExecution.getReadCount(), is(1624));
        assertThat(stepExecution.getWriteCount(), is(990));
        assertThat(stepExecution.getFilterCount(), is(634));

        TestUtils.assertEqualsEventually(990L,
                () -> solrTemplate.count(datasourceProperties.getSolrStore().getCollection(),
                        new SimpleQuery("dataset_s: " + applicationProperties.getAddDatasetName().getDatasetName())),
                2);

        long cassandraCount = cassandraTemplate.count(datasourceProperties.getCassandraStore().getTableName());

        assertThat(cassandraCount, is(990L));


    }