parquetjs_lite_schema_write_read_with_async_cursor.ts

1import * as parquet from 'parquetjs-lite';
2
3async function example() {
4  // define parquet schema
5  const schema = new parquet.ParquetSchema({
6    name: { type: 'UTF8' },
7    quantity: { type: 'INT64' },
8    price: { type: 'DOUBLE' },
9    date: { type: 'TIMESTAMP_MILLIS' },
10    in_stock: { type: 'BOOLEAN' }
11  });
12
13  // create new ParquetWriter
14  const writer = await parquet.ParquetWriter.openFile(schema, 'fruits.parquet');
15
16  // append data
17  await writer.appendRow({name: 'apples', quantity: 10, price: 2.5, date: new Date(), in_stock: true});
18  await writer.appendRow({name: 'oranges', quantity: 20, price: 3.5, date: new Date(), in_stock: true});
19
20  // close the writer
21  await writer.close();
22
23  // read the file
24  let reader = await parquet.ParquetReader.openFile('fruits.parquet');
25  let cursor = reader.getCursor();
26
27  // read all records
28  let record = null;
29  while (record = await cursor.next()) {
30    console.log(record);
31  }
32
33  await reader.close();
34}
35
36example().catch(console.error);