fybrik / airbyte-module

A FybrikModule based on Airbyte
Apache License 2.0
3 stars 6 forks source link

Flight record batches #29

Closed cdoron closed 2 years ago

cdoron commented 2 years ago

This PR is based on the docker python library's ability to stream out the output from a "docker run" line by line. We take 100 output lines each time, create an arrow table, and translate the table to record batches. The number 100 is currently hard-coded.