跳到内容

向 Flight 服务器发送数据

用法

flight_put(client, data, path, overwrite = TRUE, max_chunksize = NULL)

参数

client

pyarrow.flight.FlightClient,由 flight_connect() 返回

data

要上传的 data.frameRecordBatchTable

path

用于存储数据的字符串标识符

overwrite

logical: 如果 path 已经存在于 client 上,我们是否应该用 data 的内容替换它? 默认为 TRUE; 如果 FALSE 并且 path 存在,该函数将报错。

max_chunksize

integer: 当发送 data.frame 时,RecordBatch 块的最大行数。根据各个列的块布局,单个块可能会更小。

client,不可见地。