You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Copy file name to clipboardExpand all lines: docs/ref/dotq.md
+8-2Lines changed: 8 additions & 2 deletions
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -773,12 +773,18 @@ _[`.Q.fs`](#fs-file-streaming) for pipes_
773
773
.Q.fpn[x;y;z]
774
774
```
775
775
776
+
Where
777
+
778
+
-`x` is a unary function
779
+
-`y` is a filepath to a fifo (named pipe)
780
+
-`z` is an integer
781
+
776
782
(Since V3.4)
777
783
778
-
Reads `z`-sized lumps of complete `"\n"` delimited records from a pipe and applies a function to each record. This enables you to implement a streaming algorithm to convert a large CSV file into an on-disk kdb+ database without holding the data in memory all at once.
784
+
Reads `z`-sized lumps of complete `"\n"` delimited records from a pipe and applies a function to each record. This enables you to implement a streaming algorithm for various purposes such as converting a large compressed CSV file into an on-disk kdb+ database without holding the data in memory all at once or using disk space required for the uncompressed file.
779
785
780
786
:fontawesome-solid-graduation-cap:
781
-
[Named Pipes](../kb/named-pipes.md)
787
+
[Streaming data from named pipes](../kb/named-pipes.md#streaming)
782
788
783
789
!!! tip "`.Q.fps` is a projection of `.Q.fpn` with the chunk size set to 131000 bytes."
0 commit comments