added uploading dataset and drag & drop support

modules/demo/ssr/graph/package.json

@@ -24,6 +24,7 @@
     "fastify-multipart": "5.0.2",
     "fastify-cors": "6.0.2",
     "fastify-arrow": "0.1.0",
+    "apache-arrow": "6.0.0",
     "nanoid": "3.1.25",
     "rxjs": "6.6.7",
     "shm-typed-array": "0.0.13",

modules/demo/ssr/graph/plugins/api/index.js

@@ -219,23 +219,22 @@ module.exports = function(fastify, opts, done) {
     } catch (err) { reply.code(500).send(err); }
   })
 
-  fastify.post('/dataframe/read', async (request, reply) => {
-    const pageIndex = request.body.pageIndex;
-    const pageSize  = request.body.pageSize;
-    const dataframe = request.body.dataframe;  //{'nodes', 'edges'}
+  fastify.get('/dataframe/read', async (request, reply) => {
+    const pageIndex = parseInt(request.query.pageIndex);
+    const pageSize  = parseInt(request.query.pageSize);
+    const dataframe = request.query.dataframe;  //{'nodes', 'edges'}
     const [res, numRows] =
       await getPaginatedRows(fastify[clients][request.query.id].data[dataframe].dataframe,
                              pageIndex,
                              pageSize,
                              fastify[clients][request.query.id].state.selectedInfo[dataframe]);
 
-    reply.send(JSON.stringify({page: res.toArray(), numRows: numRows}));
-    // try {
-    //   // RecordBatchStreamWriter.writeAll(res).pipe(reply.stream());
-    // } catch (err) {
-    //   request.log.error({err}, '/run_query error');
-    //   reply.code(500).send(err);
-    // }
+    try {
+      RecordBatchStreamWriter.writeAll(res).pipe(reply.stream());
+    } catch (err) {
+      request.log.error({err}, '/run_query error');
+      reply.code(500).send(err);
+    }
   });
 
   done();

modules/demo/viz-app/package.json

@@ -26,7 +26,7 @@
     "@fortawesome/free-solid-svg-icons": "5.15.3",
     "@fortawesome/react-fontawesome": "0.1.14",
     "@rapidsai/cudf": "0.0.1",
-    "apache-arrow": "^4.0.0",
+    "apache-arrow": "^6.0.0",
     "bootstrap": "4.6.0",
     "d3": "6.6.2",
     "echarts": "5.0.2",