Skip to content

Commit 96f20f8

Browse files
committed
Update RecordBatchStreamReader
1 parent ea5304d commit 96f20f8

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

R/pkg/R/deserialize.R

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -242,7 +242,7 @@ readDeserializeInArrow <- function(inputCon) {
242242
# for now.
243243
dataLen <- readInt(inputCon)
244244
arrowData <- readBin(inputCon, raw(), as.integer(dataLen), endian = "big")
245-
batches <- arrow::RecordBatchStreamReader(arrowData)$batches()
245+
batches <- arrow::RecordBatchStreamReader$create(arrowData)$batches()
246246

247247
if (useAsTibble) {
248248
as_tibble <- get("as_tibble", envir = asNamespace("arrow"))

0 commit comments

Comments
 (0)