我可以创建一个可以公开客户端可以调用的自定义端点的 pyarrow 飞行服务器吗？ 我只看到do_get方法返回pyarrow表的代码。 客户端可以传递可用于在服务器端过滤数据并返回过滤后的箭头表的参...

我想通过使用 Dremio 的 Spring Java 应用程序查询包含 parquet 文件的 S3 存储。这些是具有用户给定参数的动态查询。 我使用 Apache Arrow SQl 驱动程序，只...

我有一个脚本，它生成了几个中间数据文件，这些文件将大大超过（2^31-1）中的最大行数。我的系统足够大，可以存储数据（例如，我可以存储这种大小的矩阵，但不能将它们转换为长格式），但我不知道哪种文件格式...

我正在使用 PyArrow Flight 在 Exasol 上阅读和编写表格。我注意到一个问题，即空字符串在飞行过程中被转换为 NULL。当我写一个pa。包含 “” 列的表到 Exasol，生成的表包...

我有这段代码，我用来在 Dremio 中使用 pyarrow flight 执行查询： class DremioConnector: env: str auth_token: str def...

箭头飞行数据是列式数据，我想以这样一种方式实现 DoGet 函数，即它首先将 arrow.record 拆分为特定大小的数据（比如 4 MB），然后使用流将其发送到客户端。我该怎么做？...

我正在用 Go 包装 DuckDB 构建一个 Arrow Flight SQL 服务器来查询大量 parquet 文件（每个文件都有不同的架构）。我希望这些 parquet 文件按需加载到 DuckD...

在 pandas 中，我可以通过以下方式使用 pyarrow dtype 创建一个系列： >>> import pandas as pd >>> s = pd.Series([1,2,3]).as...

我正在尝试读取一个镶木地板文件并将其存储在自定义 C 结构中，以便在我的 C 代码中进一步使用 case arrow::Type::DECIMAL: { const arrow::Decimal1...

我正在使用 Apache Http 客户端从服务器发送和接收数据。对于大型请求，我手动对数据进行了分块，并逐个发送。有没有办法并行发送这些数据块。就在那时，我读到了关于阿帕奇飞行的文章。对我的情况有帮...