class Riak::TimeSeries::Submission
Attributes
client[R]
@!attribute [r] client @return [Riak::Client] the client to write submissions to
measurements[RW]
@!attributes [rw] measurements @return [Array<Array<Object>>] measurements to write to Riak
TS
table_name[R]
@!attribute [r] table_name
@return [String] the table name to write submissions to
Public Class Methods
new(client, table_name)
click to toggle source
Initializes the submission object with a client and table name
@param [Riak::Client] client the client connected to the Riak
TS cluster @param [String] table_name
the table name in the cluster
# File lib/riak/time_series/submission.rb, line 20 def initialize(client, table_name) @client = client @table_name = table_name end
Public Instance Methods
write!()
click to toggle source
Write the submitted data to Riak
.
# File lib/riak/time_series/submission.rb, line 26 def write! client.backend do |be| be.time_series_put_operator.put(table_name, measurements) end end