File tree 1 file changed +13
-14
lines changed
1 file changed +13
-14
lines changed Original file line number Diff line number Diff line change @@ -818,6 +818,19 @@ Dependent block frames are not supported!!")
818
818
(write-message-header writer (MessageSerializer/serializeMetadata ^Schema schema)))
819
819
820
820
821
+ (defn- LE-wrap-data
822
+ ^java.nio.ByteBuffer [buffer]
823
+ (let [^java.nio.ByteBuffer bbuf (nio-buffer/->nio-buffer buffer)]
824
+ (.order bbuf java.nio.ByteOrder/LITTLE_ENDIAN)))
825
+
826
+ (defn- read-long
827
+ ^long [buffer]
828
+ (if (instance? NativeBuffer buffer)
829
+ (native-buffer/read-long buffer)
830
+ (-> (LE-wrap-data buffer)
831
+ (.getLong ))))
832
+
833
+
821
834
(defn- decompress-buffers
822
835
[^BodyCompression compression buffers]
823
836
(if-not compression
@@ -919,11 +932,6 @@ Dependent block frames are not supported!!")
919
932
(dtype/set-constant! c -1 )
920
933
c))
921
934
922
- (defn- LE-wrap-data
923
- ^java.nio.ByteBuffer [buffer]
924
- (let [^java.nio.ByteBuffer bbuf (nio-buffer/->nio-buffer buffer)]
925
- (.order bbuf java.nio.ByteOrder/LITTLE_ENDIAN)))
926
-
927
935
(defn- as-shorts
928
936
^shorts [abuf]
929
937
(let [bbuf (LE-wrap-data abuf)
@@ -964,15 +972,6 @@ Dependent block frames are not supported!!")
964
972
(.get rv))
965
973
rv))
966
974
967
- (defn read-long
968
- ^long [buffer]
969
- (if (instance? NativeBuffer buffer)
970
- (native-buffer/read-long buffer)
971
- (-> (LE-wrap-data buffer)
972
- (.getLong ))))
973
-
974
-
975
-
976
975
977
976
(defn- set-buffer-datatype
978
977
[buffer dtype]
You can’t perform that action at this time.
0 commit comments