assertEquals(Lists.newArrayList(STR0,STR1,STR2,STR3,STR4,STR5,STR6),format); | assertEquals(actual.stream().collect(Collectors.toSet()),expected.stream().collect(Collectors.toSet())); | format | format.stream().collect(Collectors.toSet()) | beam | 6c1d1151e2fa564fb5890701bbf4fa282bb5eacb | org.apache.beam.runners.spark.translation.SparkKeyedCombineFnTest | | | | | | Uses | True |