| | |
| | | if (sum == 0) { |
| | | kv.putAll(stateRatio); |
| | | } else { |
| | | stateRatio.forEach(k, v -> { |
| | | kv.put(k, NumberUtil.decimalFormat(MdcConstant.RATE_FORMAT, v.longValue() / (sum * 1.0d))); |
| | | }); |
| | | stateRatio.forEach((k, v) -> kv.put(k, NumberUtil.decimalFormat(MdcConstant.RATE_FORMAT, v.longValue() / (sum * 1.0d)))); |
| | | } |
| | | } |
| | | kv.put(OUTPUT_KEY, outputMap.getOrDefault(time2, 0L)); |
| | |
| | | if (sum == 0) { |
| | | kv.putAll(stateRatio); |
| | | } else { |
| | | stateRatio.forEach(k, v -> { |
| | | kv.put(k, NumberUtil.decimalFormat(MdcConstant.RATE_FORMAT, v.longValue() / (sum * 1.0d))); |
| | | }); |
| | | stateRatio.forEach((k, v) ->kv.put(k, NumberUtil.decimalFormat(MdcConstant.RATE_FORMAT, v.longValue() / (sum * 1.0d)))); |
| | | } |
| | | } |
| | | kv.put(OUTPUT_KEY, outputMap.getOrDefault(day, 0L)); |
| | |
| | | if (sum == 0) { |
| | | kv.putAll(stateRatio); |
| | | } else { |
| | | stateRatio.forEach(k, v -> { |
| | | kv.put(k, NumberUtil.decimalFormat(MdcConstant.RATE_FORMAT, v.longValue() / (sum * 1.0d))); |
| | | }); |
| | | stateRatio.forEach((k, v) ->kv.put(k, NumberUtil.decimalFormat(MdcConstant.RATE_FORMAT, v.longValue() / (sum * 1.0d)))); |
| | | } |
| | | } |
| | | kv.put(OUTPUT_KEY, outputMap.getOrDefault(wId, 0L)); |
| | |
| | | if (sum == 0) { |
| | | kv.putAll(stateRatio); |
| | | } else { |
| | | stateRatio.forEach(k, v -> { |
| | | kv.put(k, NumberUtil.decimalFormat(MdcConstant.RATE_FORMAT, v.longValue() / (sum * 1.0d))); |
| | | }); |
| | | stateRatio.forEach((k, v) ->kv.put(k, NumberUtil.decimalFormat(MdcConstant.RATE_FORMAT, v.longValue() / (sum * 1.0d)))); |
| | | } |
| | | } |
| | | kv.put(OUTPUT_KEY, outputMap.getOrDefault(eId, 0L)); |