Class: Jubatus::Anomaly::Client::Anomaly

Inherits:
Common::ClientBase show all
Includes:
Common
Defined in:
lib/jubatus/anomaly/client.rb

Instance Method Summary collapse

Methods included from Common

check_type, check_types

Methods inherited from Common::ClientBase

connect, #do_mix, #get_client, #get_config, #get_name, #get_proxy_status, #get_status, #load, #save, #set_name

Constructor Details

#initialize(host, port, name, timeout_sec = 10) ⇒ Anomaly

Returns a new instance of Anomaly.



16
17
18
 
# File 'lib/jubatus/anomaly/client.rb', line 16

def initialize(host, port, name, timeout_sec=10)
  super
end

Instance Method Details

#add(row) ⇒ Object 



24
25
26
 
# File 'lib/jubatus/anomaly/client.rb', line 24

def add(row)
  @jubatus_client.call("add", [row], TUserDef.new(IdWithScore), [TDatum.new])
end

#add_bulk(data) ⇒ Object 



28
29
30
31
 
# File 'lib/jubatus/anomaly/client.rb', line 28

def add_bulk(data)
  @jubatus_client.call("add_bulk", [data], TList.new(TString.new), [TList.new(
      TDatum.new)])
end

#calc_score(row) ⇒ Object 



47
48
49
 
# File 'lib/jubatus/anomaly/client.rb', line 47

def calc_score(row)
  @jubatus_client.call("calc_score", [row], TFloat.new, [TDatum.new])
end

#clear ⇒ Object 



43
44
45
 
# File 'lib/jubatus/anomaly/client.rb', line 43

def clear
  @jubatus_client.call("clear", [], TBool.new, [])
end

#clear_row(id) ⇒ Object 



20
21
22
 
# File 'lib/jubatus/anomaly/client.rb', line 20

def clear_row(id)
  @jubatus_client.call("clear_row", [id], TBool.new, [TString.new])
end

#get_all_rows ⇒ Object 



51
52
53
 
# File 'lib/jubatus/anomaly/client.rb', line 51

def get_all_rows
  @jubatus_client.call("get_all_rows", [], TList.new(TString.new), [])
end

#overwrite(id, row) ⇒ Object 



38
39
40
41
 
# File 'lib/jubatus/anomaly/client.rb', line 38

def overwrite(id, row)
  @jubatus_client.call("overwrite", [id, row], TFloat.new, [TString.new,
      TDatum.new])
end

#update(id, row) ⇒ Object 



33
34
35
36
 
# File 'lib/jubatus/anomaly/client.rb', line 33

def update(id, row)
  @jubatus_client.call("update", [id, row], TFloat.new, [TString.new,
      TDatum.new])
end