Skip to content

Commit

Permalink
Update hightable
Browse files Browse the repository at this point in the history
  • Loading branch information
platypii committed Oct 21, 2024
1 parent bedb991 commit e72b43e
Show file tree
Hide file tree
Showing 5 changed files with 7 additions and 7 deletions.
2 changes: 1 addition & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@
[![npm](https://img.shields.io/npm/v/hyperparam)](https://www.npmjs.com/package/hyperparam)
[![workflow status](https://github.com/hyparam/hyperparam-cli/actions/workflows/ci.yml/badge.svg)](https://github.com/hyparam/hyperparam-cli/actions)
[![mit license](https://img.shields.io/badge/License-MIT-blue.svg)](https://opensource.org/licenses/MIT)
![coverage](https://img.shields.io/badge/Coverage-38-darkred)
![coverage](https://img.shields.io/badge/Coverage-35-darkred)

This is the hyperparam cli tool.

Expand Down
2 changes: 1 addition & 1 deletion package.json
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
},
"dependencies": {
"highlight.js": "11.10.0",
"hightable": "0.5.5",
"hightable": "0.5.6",
"hyparquet": "1.5.0",
"hyparquet-compressors": "0.1.4"
},
Expand Down
2 changes: 1 addition & 1 deletion public/build/app.min.js

Large diffs are not rendered by default.

2 changes: 1 addition & 1 deletion public/build/app.min.js.map

Large diffs are not rendered by default.

6 changes: 3 additions & 3 deletions src/tableProvider.ts
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
import { DataFrame, resolvablePromise } from 'hightable'
import { DataFrame, resolvableRow } from 'hightable'
import { FileMetaData, parquetSchema } from 'hyparquet'
import { AsyncBufferFrom, parquetQueryWorker, parquetSortIndexWorker } from './workers/parquetWorkerClient.js'

Expand All @@ -20,7 +20,7 @@ export function parquetDataFrame(from: AsyncBufferFrom, metadata: FileMetaData):
const rowEnd = groupEnds[groupIndex]
// Initialize with resolvable promises
for (let i = rowStart; i < rowEnd; i++) {
data[i] = Object.fromEntries(header.map(key => [key, resolvablePromise()]))
data[i] = resolvableRow(header)
}
parquetQueryWorker({ from, metadata, rowStart, rowEnd }).then(groupData => {
for (let i = rowStart; i < rowEnd; i++) {
Expand Down Expand Up @@ -49,7 +49,7 @@ export function parquetDataFrame(from: AsyncBufferFrom, metadata: FileMetaData):
if (orderBy) {
const numRows = rowEnd - rowStart
const wrapped = new Array(numRows).fill(null)
.map(() => Object.fromEntries(header.map(key => [key, resolvablePromise()])))
.map(() => resolvableRow(header))

let sortIndex = getSortIndex(orderBy)
sortIndex.then(indices => {
Expand Down

0 comments on commit e72b43e

Please sign in to comment.