@Test public void testFilterCollection() throws Exception { List<EPGMVertex> result = getExecutionEnvironment().fromCollection(inputVertices) .filter(new LabelIsIn<>(Arrays.asList("a", "b", "a", null))).collect(); result.sort(comparator); assertArrayEquals(expected.toArray(), result.toArray()); }
@Override public boolean filter(EL element) throws Exception { return labels.contains(element.getLabel()); }
LabelIsIn implements CombinableFilter<EL> { @Override public boolean filter(EL element) throws Exception { return labels.contains(element.getLabel()); } }
LabelIsIn implements CombinableFilter<EL> { @Override public boolean filter(EL element) throws Exception { return labels.contains(element.getLabel()); } LabelIsIn(String... labels);  LabelIsIn(Collection<String> labels); }
LabelIsIn implements CombinableFilter<EL> { @Override public boolean filter(EL element) throws Exception { return labels.contains(element.getLabel()); } LabelIsIn(String... labels);  LabelIsIn(Collection<String> labels); @Override boolean filter(EL element); }
LabelIsIn implements CombinableFilter<EL> { @Override public boolean filter(EL element) throws Exception { return labels.contains(element.getLabel()); } LabelIsIn(String... labels);  LabelIsIn(Collection<String> labels); @Override boolean filter(EL element);  }