We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3d7c441 commit 69a054aCopy full SHA for 69a054a
http/get_simple/ruby/client/client.rb
@@ -21,11 +21,8 @@
21
uri = URI("http://localhost:8008")
22
23
start = Time.now
24
-arrows_data = Net::HTTP.get(uri)
25
-input = Arrow::BufferInputStream.new(arrows_data)
26
-reader = Arrow::RecordBatchStreamReader.new(input)
27
-schema = reader.schema
28
-table = reader.read_all
+arrows_data = Net::HTTP.get(uri).freeze
+table = Arrow::Table.load(Arrow::Buffer.new(arrows_data), format: :arrows)
29
elapsed_time = Time.now - start
30
31
n_received_record_batches = table[0].data.n_chunks
0 commit comments