| | |
| | | // 定义 Zarr 数组的维度 |
| | | int[] shape = {numRows, numColumns}; |
| | | // 定义分块大小 |
| | | int[] chunks = {1440}; |
| | | int check=stationRainVos.size(); |
| | | int[] chunks = {check}; |
| | | int[] offset = {0}; |
| | | // 创建 Zarr 数组 |
| | | ArrayParams params = new ArrayParams(); |
| | | params.shape(chunks); |
| | |
| | | params.dataType(DataType.f4); |
| | | ZarrArray zarrArray = zarrGroup.createArray("rainfall", params); |
| | | int rowIndex = 0; |
| | | double[] values=new double[stationRainVos.size()]; |
| | | for (StationRainVo record : stationRainVos) { |
| | | double value = record.getRainfall(); |
| | | zarrArray.write(value); |
| | | // double value = record.getRainfall(); |
| | | // zarrArray.write(value); |
| | | values[rowIndex]=record.getRainfall(); |
| | | rowIndex++; |
| | | } |
| | | zarrArray.write(values,chunks,offset); |
| | | // 关闭 Zarr 组 |
| | | //zarrGroup.close(); |
| | | } catch (Exception e) { |
| | |
| | | // 定义 Zarr 数组的维度 |
| | | int[] shape = {numRows, numColumns}; |
| | | // 定义分块大小 |
| | | int[] chunks = {1440}; |
| | | int check=stationRainVos.size(); |
| | | int[] chunks = {check}; |
| | | int[] offset = {0}; |
| | | // 创建 Zarr 数组 |
| | | ArrayParams params = new ArrayParams(); |
| | | params.shape(chunks); |
| | |
| | | ZarrArray zarrArray = zarrGroup.createArray("time", params); |
| | | int rowIndex = 0; |
| | | SimpleDateFormat sdf = new SimpleDateFormat("yyyy/MM/dd HH:mm"); |
| | | long[] values=new long[stationRainVos.size()]; |
| | | for (StationRainVo record : stationRainVos) { |
| | | long value = sdf.parse(record.getDatetime()).getTime()/1000; |
| | | zarrArray.write(value); |
| | | values[rowIndex]=sdf.parse(record.getDatetime()).getTime()/1000; |
| | | // long value = sdf.parse(record.getDatetime()).getTime()/1000; |
| | | // zarrArray.write(value); |
| | | rowIndex++; |
| | | } |
| | | zarrArray.write(values,chunks,offset); |
| | | // 关闭 Zarr 组 |
| | | //zarrGroup.close(); |
| | | } catch (Exception e) { |