Class: Jubatus::Clustering::Client::Clustering

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

Instance Method Summary collapse

Methods included from Jubatus::Common

check_type, check_types

Methods inherited from Jubatus::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) ⇒ Clustering

Returns a new instance of Clustering.



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

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

Instance Method Details

#clear ⇒ Object 



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

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

#get_core_members ⇒ Object 



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

def get_core_members
  @jubatus_client.call("get_core_members", [], TList.new(TList.new(
      TUserDef.new(WeightedDatum))), [])
end

#get_k_center ⇒ Object 



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

def get_k_center
  @jubatus_client.call("get_k_center", [], TList.new(TDatum.new), [])
end

#get_nearest_center(point) ⇒ Object 



37
38
39
40
 
# File 'lib/jubatus/clustering/client.rb', line 37

def get_nearest_center(point)
  @jubatus_client.call("get_nearest_center", [point], TDatum.new,
      [TDatum.new])
end

#get_nearest_members(point) ⇒ Object 



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

def get_nearest_members(point)
  @jubatus_client.call("get_nearest_members", [point], TList.new(TUserDef.new(
      WeightedDatum)), [TDatum.new])
end

#get_revision ⇒ Object 



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

def get_revision
  @jubatus_client.call("get_revision", [], TInt.new(false, 4), [])
end

#push(points) ⇒ Object 



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

def push(points)
  @jubatus_client.call("push", [points], TBool.new, [TList.new(TDatum.new)])
end