本文整理了Java中ch.lambdaj.Lambda.group()
方法的一些代码示例,展示了Lambda.group()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Lambda.group()
方法的具体详情如下:
包路径:ch.lambdaj.Lambda
类名称:Lambda
方法名:group
[英]Organizes the given list of items in (hierarchy of) groups based on the given grouping conditions
[中]根据给定的分组条件组织(层次结构)组中的给定项列表
代码示例来源:origin: mariofusco/lambdaj
/**
* Organizes the given list of items in (hierarchy of) groups based on the given grouping conditions
* @param conditions The conditions that define how the items have to be grouped
* @return The items grouped by the given conditions
*/
public LambdaGroup<T> group(GroupCondition<?>... conditions) {
return new LambdaGroup(Lambda.group(innerIterable, conditions));
}
代码示例来源:origin: CloudSlang/score
private List<Message> optimize(List<Message> messages){
long t = System.currentTimeMillis();
List<Message> result = new ArrayList<>();
Group<Message> groups = group(messages, by(on(Message.class).getId()));
for (Group<Message> group :groups.subgroups()){
result.addAll(group.first().shrink(group.findAll()));
}
if (logger.isDebugEnabled()) logger.debug("bulk optimization result: " + messages.size() + " -> " + result.size() + " in " + (System.currentTimeMillis()-t) + " ms");
return result;
}
代码示例来源:origin: io.openscore/score-worker-manager-impl
private List<Message> optimize(List<Message> messages){
long t = System.currentTimeMillis();
List<Message> result = new ArrayList<>();
Group<Message> groups = group(messages, by(on(Message.class).getId()));
for (Group<Message> group :groups.subgroups()){
result.addAll(group.first().shrink(group.findAll()));
}
if (logger.isDebugEnabled()) logger.debug("bulk optimization result: " + messages.size() + " -> " + result.size() + " in " + (System.currentTimeMillis()-t) + " ms");
return result;
}
代码示例来源:origin: CloudSlang/cloud-slang
public Map<String, List<StepData>> aggregate() {
Map<String, List<StepData>> branchesDataByPath = new HashMap<>();
Group<LanguageEventData> groups = group(getEvents(), by(on(LanguageEventData.class).getPath()));
for (Group<LanguageEventData> subGroup : groups.subgroups()) {
List<StepData> branchesData = buildBranchesData(subGroup.findAll());
branchesDataByPath.put(branchesData.get(0).getPath(), branchesData);
}
return branchesDataByPath;
}
代码示例来源:origin: CloudSlang/cloud-slang
public Map<String, StepData> aggregate() {
Map<String, StepData> joinDataByPath = new HashMap<>();
Group<LanguageEventData> groups = group(getEvents(), by(on(LanguageEventData.class).getPath()));
for (Group<LanguageEventData> subGroup : groups.subgroups()) {
StepData joinData = buildPublishAggregateData(subGroup.first());
joinDataByPath.put(joinData.getPath(), joinData);
}
return joinDataByPath;
}
代码示例来源:origin: CloudSlang/cloud-slang
public Map<String, StepData> aggregate() {
Map<String, StepData> stepsData = new HashMap<>();
Group<LanguageEventData> groups = group(getEvents(), by(on(LanguageEventData.class).getPath()));
for (Group<LanguageEventData> subGroup : groups.subgroups()) {
StepData stepData = buildStepData(subGroup.findAll());
stepsData.put(stepData.getPath(), stepData);
}
return stepsData;
}
内容来源于网络,如有侵权,请联系作者删除!