2013-03-04 56 views
4

我有大量的数据可能如下:获得连续两天的总和值

Date  rain code 
2009-04-01 0.0 0 
2009-04-02 0.0 0 
2009-04-03 0.0 0 
2009-04-04 0.7 1 
2009-04-05 54.2 1 
2009-04-06 0.0 0 
2009-04-07 0.0 0 
2009-04-08 0.0 0 
2009-04-09 0.0 0 
2009-04-10 0.0 0 
2009-04-11 0.0 0 
2009-04-12 5.3 1 
2009-04-13 10.1 1 
2009-04-14 6.0 1 
2009-04-15 8.7 1 
2009-04-16 0.0 0 
2009-04-17 0.0 0 
2009-04-18 0.0 0 
2009-04-19 0.0 0 
2009-04-20 0.0 0 
2009-04-21 0.0 0 
2009-04-22 0.0 0 
2009-04-23 0.0 0 
2009-04-24 0.0 0 
2009-04-25 4.3 1 
2009-04-26 42.2 1 
2009-04-27 45.6 1 
2009-04-28 12.6 1 
2009-04-29 6.2 1 
2009-04-30 1.0 1 

我试图计算的连续阴雨值的总和,当代码为“1”,我需要分别有他们的总和。例如,我想从2009-04-122009-04-15获得雨量值的总和。所以我试图找到方法来定义代码何时等于1,并且有连续的雨值我可以得到它们的总和。

对上述问题的任何帮助将不胜感激。

回答

4

一个简单的解决方案是使用rle。但我怀疑那里可能会有更多“优雅”的解决方案。

# assuming dd is your data.frame 
dd.rle <- rle(dd$code) 
# get start pos of each consecutive 1's 
start <- (cumsum(dd.rle$lengths) - dd.rle$lengths + 1)[dd.rle$values == 1] 
# how long do each 1's extend? 
ival <- dd.rle$lengths[dd.rle$values == 1] 
# using these two, compute the sum 
apply(as.matrix(seq_along(start)), 1, function(idx) { 
    sum(dd$rain[start[idx]:(start[idx]+ival[idx]-1)]) 
}) 

# [1] 54.9 30.1 111.9 

编辑:一个与rletapply更简单的方法。

dd.rle <- rle(dd$code) 
# get the length of each consecutive 1's 
ival <- dd.rle$lengths[dd.rle$values == 1] 
# using lengths, construct a `factor` with levels = length(ival) 
levl <- factor(rep(seq_along(ival), ival)) 
# use these levels to extract `rain[code == 1]` and compute sum 
tapply(dd$rain[dd$code == 1], levl, sum) 

# 1  2  3 
# 54.9 30.1 111.9 
+0

+1表示将使用的'rle' – 2013-03-04 09:21:58

+1

有谁知道如何可以改变上面的解决方案为一体的功能,这样可以同时适用于许多数据吗? – user1954153 2013-05-09 10:24:38

2

以下是获得所需结果的矢量化方法。

df <- read.table(textConnection("Date  rain code\n2009-04-01 0.0 0\n2009-04-02 0.0 0\n2009-04-03 0.0 0\n2009-04-04 0.7 1\n2009-04-05 54.2 1\n2009-04-06 0.0 0\n2009-04-07 0.0 0\n2009-04-08 0.0 0\n2009-04-09 0.0 0\n2009-04-10 0.0 0\n2009-04-11 0.0 0\n2009-04-12 5.3 1\n2009-04-13 10.1 1\n2009-04-14 6.0 1\n2009-04-15 8.7 1\n2009-04-16 0.0 0\n2009-04-17 0.0 0\n2009-04-18 0.0 0\n2009-04-19 0.0 0\n2009-04-20 0.0 0\n2009-04-21 0.0 0\n2009-04-22 0.0 0\n2009-04-23 0.0 0\n2009-04-24 0.0 0\n2009-04-25 4.3 1\n2009-04-26 42.2 1\n2009-04-27 45.6 1\n2009-04-28 12.6 1\n2009-04-29 6.2 1\n2009-04-30 1.0 1"), 
    header = TRUE) 

df$cumsum <- cumsum(df$rain) 
df$diff <- c(diff(df$code), 0) 
df$result <- rep(NA, nrow(df)) 

if (nrow(df[df$diff == -1, ]) == nrow(df[df$diff == 1, ])) { 
    result <- df[df$diff == -1, "cumsum"] - df[df$diff == 1, "cumsum"] 
    df[df$diff == -1, "result"] <- result 
} else { 
    result <- c(df[df$diff == -1, "cumsum"], df[nrow(df), "cumsum"]) - df[df$diff == 1, "cumsum"] 
    df[df$diff == -1, "result"] <- result[1:length(result) - 1] 
    df[nrow(df), "result"] <- result[length(result)] 
} 

df 
##   Date rain code cumsum diff result 
## 1 2009-04-01 0.0 0 0.0 0  NA 
## 2 2009-04-02 0.0 0 0.0 0  NA 
## 3 2009-04-03 0.0 0 0.0 1  NA 
## 4 2009-04-04 0.7 1 0.7 0  NA 
## 5 2009-04-05 54.2 1 54.9 -1 54.9 
## 6 2009-04-06 0.0 0 54.9 0  NA 
## 7 2009-04-07 0.0 0 54.9 0  NA 
## 8 2009-04-08 0.0 0 54.9 0  NA 
## 9 2009-04-09 0.0 0 54.9 0  NA 
## 10 2009-04-10 0.0 0 54.9 0  NA 
## 11 2009-04-11 0.0 0 54.9 1  NA 
## 12 2009-04-12 5.3 1 60.2 0  NA 
## 13 2009-04-13 10.1 1 70.3 0  NA 
## 14 2009-04-14 6.0 1 76.3 0  NA 
## 15 2009-04-15 8.7 1 85.0 -1 30.1 
## 16 2009-04-16 0.0 0 85.0 0  NA 
## 17 2009-04-17 0.0 0 85.0 0  NA 
## 18 2009-04-18 0.0 0 85.0 0  NA 
## 19 2009-04-19 0.0 0 85.0 0  NA 
## 20 2009-04-20 0.0 0 85.0 0  NA 
## 21 2009-04-21 0.0 0 85.0 0  NA 
## 22 2009-04-22 0.0 0 85.0 0  NA 
## 23 2009-04-23 0.0 0 85.0 0  NA 
## 24 2009-04-24 0.0 0 85.0 1  NA 
## 25 2009-04-25 4.3 1 89.3 0  NA 
## 26 2009-04-26 42.2 1 131.5 0  NA 
## 27 2009-04-27 45.6 1 177.1 0  NA 
## 28 2009-04-28 12.6 1 189.7 0  NA 
## 29 2009-04-29 6.2 1 195.9 0  NA 
## 30 2009-04-30 1.0 1 196.9 0 111.9 
+0

您可以展开此解决方案来总结数据框中的多个列吗?甚至不同的功能? (最小,最大等)? – RegressForward 2016-08-05 03:10:15

+0

此延伸到其他的功能下列命令是有用: groups_of_runs <-rep(cumsum(R $长度)中,r $长度)) 由于现在每个组具有自己独特的运行。 – RegressForward 2016-08-05 17:31:31