You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@arrow.apache.org by bh...@apache.org on 2019/06/22 00:06:35 UTC
[arrow] branch master updated: ARROW-5438: [JS] EOS bytes for
sequential readers
This is an automated email from the ASF dual-hosted git repository.
bhulette pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/arrow.git
The following commit(s) were added to refs/heads/master by this push:
new 71deb04 ARROW-5438: [JS] EOS bytes for sequential readers
71deb04 is described below
commit 71deb04536b8fdc98a8f99433555af2ac1b81072
Author: John Muehlhausen <jm...@kershnertrading.com>
AuthorDate: Fri Jun 21 17:06:22 2019 -0700
ARROW-5438: [JS] EOS bytes for sequential readers
Author: John Muehlhausen <jm...@kershnertrading.com>
Closes #4466 from jgm-ktg/arrow_5438 and squashes the following commits:
d8a73e370 <John Muehlhausen> ARROW-5438: EOS bytes for sequential readers
---
js/src/ipc/writer.ts | 1 +
1 file changed, 1 insertion(+)
diff --git a/js/src/ipc/writer.ts b/js/src/ipc/writer.ts
index 363d588..14a8d0f 100644
--- a/js/src/ipc/writer.ts
+++ b/js/src/ipc/writer.ts
@@ -324,6 +324,7 @@ export class RecordBatchFileWriter<T extends { [key: string]: DataType } = any>
this._recordBatchBlocks, this._dictionaryBlocks
));
return this
+ ._writePadding(4) // EOS bytes for sequential readers
._write(buffer) // Write the flatbuffer
._write(Int32Array.of(buffer.byteLength)) // then the footer size suffix
._writeMagic(); // then the magic suffix