本文整理汇总了Java中org.springframework.data.mongodb.core.mapreduce.MapReduceResults类的典型用法代码示例。如果您正苦于以下问题:Java MapReduceResults类的具体用法?Java MapReduceResults怎么用?Java MapReduceResults使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
MapReduceResults类属于org.springframework.data.mongodb.core.mapreduce包,在下文中一共展示了MapReduceResults类的11个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: sumCommentsGroupByCreatedDate
import org.springframework.data.mongodb.core.mapreduce.MapReduceResults; //导入依赖的package包/类
@Override
public LineChartStatisticsResult sumCommentsGroupByCreatedDate(TimeRangedStatisticsRequest request) {
// Emit UTC millis (only year, month, week and day are taken into account) of createdDate as key
// Value is set to 1 to sum up later (reduce)
String map = "function () { " +
" var day = Date.UTC(this.createdDate.getFullYear(), this.createdDate.getMonth(), this.createdDate.getDate()); " +
" emit(day.toString(), 1); " +
"}";
// Reduce all the values for one "key" (for details about key, see above) by summing up each value.
final String reduce = "function(key,values){ return values.length;}";
Query filter = Query.query(Criteria.where("createdDate").gte(request.getStartDate()).lte(request.getEndDate()));
MapReduceResults<KeyValuePair> sumResults = mongoTemplate.mapReduce(
filter,
COLLECTION_NAME,
map,
reduce,
KeyValuePair.class
);
return toLineChartStatisticsResult(sumResults, request);
}
开发者ID:as-ideas,项目名称:crowdsource,代码行数:24,代码来源:CommentRepositoryImpl.java
示例2: toLineChartStatisticsResult
import org.springframework.data.mongodb.core.mapreduce.MapReduceResults; //导入依赖的package包/类
private LineChartStatisticsResult toLineChartStatisticsResult(MapReduceResults<KeyValuePair> sumResults, TimeRangedStatisticsRequest request) {
Map<String, Long> results = new LinkedHashMap<>();
for (KeyValuePair vo : sumResults) {
DateTime dateFromDbId;
try {
dateFromDbId = new DateTime(Long.parseLong(vo.getId()), DateTimeZone.UTC);
} catch (NumberFormatException nfe) {
throw new IllegalStateException("MapReduce emitted wrong format for id / key field. Expected UTC millis.", nfe);
}
results.put(StatisticsActionUtil.formatDate(dateFromDbId), vo.getValue());
}
return new LineChartStatisticsResult(
CHART_NAME_SUM_COMMENTS,
StatisticsActionUtil.fillMap(StatisticsActionUtil.getDefaultMap(request), results)
);
}
开发者ID:as-ideas,项目名称:crowdsource,代码行数:20,代码来源:CommentRepositoryImpl.java
示例3: analyseIngredientsByPopularity
import org.springframework.data.mongodb.core.mapreduce.MapReduceResults; //导入依赖的package包/类
@Override
public Map<String, Integer> analyseIngredientsByPopularity()
{
/*
* This class references two JavaScript functions, the mapper and the
* reducer, respectively.
*/
MapReduceResults<IngredientAnalysis> results = mongoTemplate.mapReduce("menu",
"classpath:ingredientsmap.js",
"classpath:ingredientsreduce.js",
IngredientAnalysis.class);
Map<String, Integer> analysis = new HashMap<String, Integer>();
for (IngredientAnalysis ingredientAnalysis : results)
{
analysis.put(ingredientAnalysis.getId(), ingredientAnalysis.getValue());
}
return analysis;
}
开发者ID:huangye177,项目名称:spring4probe,代码行数:22,代码来源:MenuItemRepositoryImpl.java
示例4: aggregateDailyStatistics
import org.springframework.data.mongodb.core.mapreduce.MapReduceResults; //导入依赖的package包/类
@Override
public DailyStatistic aggregateDailyStatistics(String day) {
// Build a query to pre-select the statistics that will be aggregated.
Query query = new Query(Criteria.where("day").is(day));
// Execute a MapReduce command.
MapReduceResults<WrappedDailyStatistic> results = template.mapReduce(query, "dailyStatistic",
"classpath:mapDailyStatisticForADay.js",
"classpath:reduceDailyStatisticForADay.js",
WrappedDailyStatistic.class);
// Output some debug messages.
if (log.isDebugEnabled()){
log.debug("aggregateDailyStatistics mapReduce for day " + day);
log.debug("aggregateDailyStatistics mapReduce result counts: " + results.getCounts());
for (WrappedDailyStatistic wdt : results){
log.debug("aggregateDailyStatistics mapReduce result value: " + wdt.getValue());
}
}
// We've got a result if we've got an output.
if (results.getCounts().getOutputCount() > 0){
return results.iterator().next().getValue();
}
// Build and return an empty object otherwise?
DailyStatistic statistic = new DailyStatistic();
statistic.setDay(day);
statistic.setDailyCount(0);
return statistic;
}
开发者ID:microcks,项目名称:microcks,代码行数:33,代码来源:DailyStatisticRepositoryImpl.java
示例5: countCommentsGroupByProject
import org.springframework.data.mongodb.core.mapreduce.MapReduceResults; //导入依赖的package包/类
@Override
public List<BarChartStatisticsResult> countCommentsGroupByProject(int projectCount) {
final String map = "function(){ emit(this.project.$id , 1 ); } ";
final String reduce = "function(key,values){ return values.length;}";
MapReduceResults<KeyValuePair> results = mongoTemplate.mapReduce(COLLECTION_NAME, map, reduce, KeyValuePair.class);
final List<KeyValuePair> sortedList = new ArrayList<>();
for (KeyValuePair result : results) {
sortedList.add(result);
}
Collections.sort(sortedList);
List<BarChartStatisticsResult> res = new ArrayList<>(projectCount);
for (KeyValuePair kv : sortedList) {
ProjectEntity project = mongoTemplate.findOne(new Query(Criteria.where("id").is(kv.getId())), ProjectEntity.class);
if (project != null) {
res.add(new BarChartStatisticsResult(kv.getId(), project.getTitle(), kv.getValue()));
}
if (res.size() >= projectCount) {
break;
}
}
return res;
}
开发者ID:as-ideas,项目名称:crowdsource,代码行数:30,代码来源:CommentRepositoryImpl.java
示例6: mapReduce
import org.springframework.data.mongodb.core.mapreduce.MapReduceResults; //导入依赖的package包/类
@Override
public <E> MapReduceResults<E> mapReduce(String mapFunction, String reduceFunction, Class<E> entityClass) {
return mongoTemplate.mapReduce(collection, mapFunction, reduceFunction, entityClass);
}
开发者ID:apache,项目名称:rave,代码行数:5,代码来源:MongoModelTemplate.java
示例7: main
import org.springframework.data.mongodb.core.mapreduce.MapReduceResults; //导入依赖的package包/类
public static void main(String[] args) {
ApplicationContext ctx = new AnnotationConfigApplicationContext(
AppConfig.class);
MongoOperations mongoOperation = (MongoOperations) ctx
.getBean("mongoTemplate");
MapReduceResults<CameraCount> mrResults = mongoOperation.mapReduce("photographers", "classpath:mapByCameraMakeModel.js", "classpath:reduce.js", CameraCount.class);
for (CameraCount cameraCount : mrResults) {
System.out.println("make is " + cameraCount.getId().getMake());
System.out.println("model is " + cameraCount.getId().getModel());
System.out.println("count is " + cameraCount.getValue().getCount());
}
((ConfigurableApplicationContext)ctx).close();
}
开发者ID:larrysthomas,项目名称:mongodb-springdata,代码行数:20,代码来源:MapReduceCountsByCameraMakeAndModel.java
示例8: main
import org.springframework.data.mongodb.core.mapreduce.MapReduceResults; //导入依赖的package包/类
public static void main(String[] args) {
ApplicationContext ctx = new AnnotationConfigApplicationContext(
AppConfig.class);
MongoOperations mongoOperation = (MongoOperations) ctx
.getBean("mongoTemplate");
MapReduceResults<ValueObject> mrResults = mongoOperation.mapReduce("metadata", "classpath:mapByCameraModelFStop.js", "classpath:reduce.js", ValueObject.class);
for (ValueObject valueObject : mrResults) {
System.out.println(valueObject);
}
((ConfigurableApplicationContext)ctx).close();
}
开发者ID:larrysthomas,项目名称:mongodb-springdata,代码行数:17,代码来源:MapReduceCountsByCameraModelAndFstop.java
示例9: executeUsersMapReduce
import org.springframework.data.mongodb.core.mapreduce.MapReduceResults; //导入依赖的package包/类
private MapReduceResults<WidgetUsersMapReduceResult> executeUsersMapReduce() {
return mongoOperations.mapReduce(PAGE_COLLECTION, USERS_MAP, USERS_REDUCE, getOptions(WIDGET_USERS), WidgetUsersMapReduceResult.class);
}
开发者ID:apache,项目名称:rave,代码行数:4,代码来源:MongoDbMapReduceStatisticsAggregator.java
示例10: executeRatingsMapReduce
import org.springframework.data.mongodb.core.mapreduce.MapReduceResults; //导入依赖的package包/类
private MapReduceResults<WidgetRatingsMapReduceResult> executeRatingsMapReduce() {
return mongoOperations.mapReduce(WIDGET_COLLECTION, RATINGS_MAP, RATINGS_REDUCE, getOptions(WIDGET_RATINGS), WidgetRatingsMapReduceResult.class);
}
开发者ID:apache,项目名称:rave,代码行数:4,代码来源:MongoDbMapReduceStatisticsAggregator.java
示例11: mapReduce
import org.springframework.data.mongodb.core.mapreduce.MapReduceResults; //导入依赖的package包/类
<E> MapReduceResults<E> mapReduce(String mapFunction, String reduceFunction, Class<E> entityClass);
开发者ID:apache,项目名称:rave,代码行数:2,代码来源:MongoModelOperations.java
注:本文中的org.springframework.data.mongodb.core.mapreduce.MapReduceResults类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论