replaced inner class by lambda

Change-Id: I12b44e92bd4aa15fceea67adafedce005a715950
This commit is contained in:
Axel Uhl committed 2019-02-08 13:29:14 +01:00
1 parent 9dfff677d7
commit 549bd4cc68
2 files changed
+2 -6

No files matched your search

@@ -42,4 +42,5 @@ public class MarkPassingImpl implements MarkPassing {
public MarkPassing getOriginal() {
return this;
}
}
@@ -50,12 +50,7 @@ public class ParallelGroupedDataCountDistinctAggregationProcessor
@Override
protected void handleElement(GroupedDataEntry<Object> element) {
GroupKey key = element.getKey();
Util.addToValueSet(countMap, key, element.getDataEntry(), new Util.ValueCollectionConstructor<Object, Set<Object>>() {
@Override
public Set<Object> createValueCollection() {
return ConcurrentHashMap.newKeySet();
}
});
Util.addToValueSet(countMap, key, element.getDataEntry(), ConcurrentHashMap::newKeySet);
}
@Override