diff --git a/src/lib/tableProvider.ts b/src/lib/tableProvider.ts index 122b1fe6..596c8a7a 100644 --- a/src/lib/tableProvider.ts +++ b/src/lib/tableProvider.ts @@ -188,6 +188,19 @@ export function parquetDataFrame(from: AsyncBufferFrom, metadata: FileMetaData): } }, sortable: true, - // TODO(SL): implement getColumn({column, start, end}): any[] + getColumn({ column, start, end }) { + if (!header.includes(column)) { + return Promise.reject(new Error(`Column "${column}" not found in header`)) + } + + return parquetQueryWorker({ + from, + metadata, + rowStart: start, + rowEnd: end, + }).then(rows => { + return rows.map(row => row[column]) + }) + }, } }