File tree Expand file tree Collapse file tree 1 file changed +13
-14
lines changed
Expand file tree Collapse file tree 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!!")
818818 (write-message-header writer (MessageSerializer/serializeMetadata ^Schema schema)))
819819
820820
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+
821834(defn- decompress-buffers
822835 [^BodyCompression compression buffers]
823836 (if-not compression
@@ -919,11 +932,6 @@ Dependent block frames are not supported!!")
919932 (dtype/set-constant! c -1 )
920933 c))
921934
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-
927935(defn- as-shorts
928936 ^shorts [abuf]
929937 (let [bbuf (LE-wrap-data abuf)
@@ -964,15 +972,6 @@ Dependent block frames are not supported!!")
964972 (.get rv))
965973 rv))
966974
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-
976975
977976(defn- set-buffer-datatype
978977 [buffer dtype]
You can’t perform that action at this time.
0 commit comments