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