有效地重塑这个数组
Reshaping this array efficiently
给定这个数组 X:
[1 2 3 2 3 1 4 5 7 1]
和行长数组R:
[3 2 5]
表示变换后每一行的长度
我正在寻找一个计算效率高的函数来将 X 重塑为这个数组 Y:
[[ 1. 2. 3. nan nan]
[ 2. 3. nan nan nan]
[ 1. 4. 5. 7. 1.]]
这些只是我正在处理的实际数组的简化版本。我的实际数组更像这样:
R = np.random.randint(5, size = 21000)+1
X = np.random.randint(10, size = np.sum(R))
我已经下了一个函数来生成重塑的数组,但是这个函数运行得太慢了。我已经尝试了一些 Numba 功能来加速它,但它们会生成许多错误消息来处理。我的超慢功能:
def func1(given_array, row_length):
corresponding_indices = np.cumsum(row_length)
desired_result = np.full([len(row_length),np.amax(row_length)], np.nan)
desired_result[0,:row_length[0]] = given_array[:corresponding_indices[0]]
for i in range(1,len(row_length)):
desired_result[i,:row_length[i]] = given_array[corresponding_indices[i-1]:corresponding_indices[i]]
return desired_result
当 input_arrays 的大小还没有超过 100K 时,这个函数每个循环需要 34 毫秒的时间,这是令人生畏的。我正在寻找一个函数,它以相同的大小做同样的事情,但每个循环的时间不到 10 毫秒
提前致谢
这是一个矢量化的利用 broadcasting
-
def func2(given_array, row_length):
given_array = np.asarray(given_array)
row_length = np.asarray(row_length)
mask = row_length[:,None] > np.arange(row_length.max())
out = np.full(mask.shape, np.nan)
out[mask] = given_array
return out
样本运行-
In [305]: a = [1, 2, 3, 2, 3, 1, 4, 5, 7, 1]
...: b = [3, 2, 5]
In [306]: func2(a,b)
Out[306]:
array([[ 1., 2., 3., nan, nan],
[ 2., 3., nan, nan, nan],
[ 1., 4., 5., 7., 1.]])
大型数据集的计时和验证 -
In [323]: np.random.seed(0)
...: R = np.random.randint(5, size = 21000)+1
...: X = np.random.randint(10, size = np.sum(R))
In [324]: %timeit func1(X,R)
100 loops, best of 3: 17.5 ms per loop
In [325]: %timeit func2(X,R)
1000 loops, best of 3: 657 µs per loop
In [332]: o1 = func1(X,R)
In [333]: o2 = func2(X,R)
In [334]: np.allclose(np.where(np.isnan(o1),0,o1),np.where(np.isnan(o2),0,o2))
Out[334]: True
给定这个数组 X:
[1 2 3 2 3 1 4 5 7 1]
和行长数组R:
[3 2 5]
表示变换后每一行的长度
我正在寻找一个计算效率高的函数来将 X 重塑为这个数组 Y:
[[ 1. 2. 3. nan nan]
[ 2. 3. nan nan nan]
[ 1. 4. 5. 7. 1.]]
这些只是我正在处理的实际数组的简化版本。我的实际数组更像这样:
R = np.random.randint(5, size = 21000)+1
X = np.random.randint(10, size = np.sum(R))
我已经下了一个函数来生成重塑的数组,但是这个函数运行得太慢了。我已经尝试了一些 Numba 功能来加速它,但它们会生成许多错误消息来处理。我的超慢功能:
def func1(given_array, row_length):
corresponding_indices = np.cumsum(row_length)
desired_result = np.full([len(row_length),np.amax(row_length)], np.nan)
desired_result[0,:row_length[0]] = given_array[:corresponding_indices[0]]
for i in range(1,len(row_length)):
desired_result[i,:row_length[i]] = given_array[corresponding_indices[i-1]:corresponding_indices[i]]
return desired_result
当 input_arrays 的大小还没有超过 100K 时,这个函数每个循环需要 34 毫秒的时间,这是令人生畏的。我正在寻找一个函数,它以相同的大小做同样的事情,但每个循环的时间不到 10 毫秒
提前致谢
这是一个矢量化的利用 broadcasting
-
def func2(given_array, row_length):
given_array = np.asarray(given_array)
row_length = np.asarray(row_length)
mask = row_length[:,None] > np.arange(row_length.max())
out = np.full(mask.shape, np.nan)
out[mask] = given_array
return out
样本运行-
In [305]: a = [1, 2, 3, 2, 3, 1, 4, 5, 7, 1]
...: b = [3, 2, 5]
In [306]: func2(a,b)
Out[306]:
array([[ 1., 2., 3., nan, nan],
[ 2., 3., nan, nan, nan],
[ 1., 4., 5., 7., 1.]])
大型数据集的计时和验证 -
In [323]: np.random.seed(0)
...: R = np.random.randint(5, size = 21000)+1
...: X = np.random.randint(10, size = np.sum(R))
In [324]: %timeit func1(X,R)
100 loops, best of 3: 17.5 ms per loop
In [325]: %timeit func2(X,R)
1000 loops, best of 3: 657 µs per loop
In [332]: o1 = func1(X,R)
In [333]: o2 = func2(X,R)
In [334]: np.allclose(np.where(np.isnan(o1),0,o1),np.where(np.isnan(o2),0,o2))
Out[334]: True