Class: Teapot::TempestDB::TempestDBService::Client

Inherits:
Object
  • Object
show all
Includes:
Thrift::Client
Defined in:
lib/gen/tempest_d_b_service.rb

Instance Method Summary collapse

Instance Method Details

#addEdges(edgeType, sourceNodes, targetNodes) ⇒ Object 



311
312
313
314
 
# File 'lib/gen/tempest_d_b_service.rb', line 311

def addEdges(edgeType, sourceNodes, targetNodes)
  send_addEdges(edgeType, sourceNodes, targetNodes)
  recv_addEdges()
end

#addNode(node) ⇒ Object 



277
278
279
280
 
# File 'lib/gen/tempest_d_b_service.rb', line 277

def addNode(node)
  send_addNode(node)
  recv_addNode()
end

#connectedComponent(source, edgeTypes, maxSize) ⇒ Object 



120
121
122
123
 
# File 'lib/gen/tempest_d_b_service.rb', line 120

def connectedComponent(source, edgeTypes, maxSize)
  send_connectedComponent(source, edgeTypes, maxSize)
  return recv_connectedComponent()
end

#edgeCount(edgeType) ⇒ Object 



227
228
229
230
 
# File 'lib/gen/tempest_d_b_service.rb', line 227

def edgeCount(edgeType)
  send_edgeCount(edgeType)
  return recv_edgeCount()
end

#getMultiNodeAttributeAsJSON(nodes, attributeName) ⇒ Object 



260
261
262
263
 
# File 'lib/gen/tempest_d_b_service.rb', line 260

def getMultiNodeAttributeAsJSON(nodes, attributeName)
  send_getMultiNodeAttributeAsJSON(nodes, attributeName)
  return recv_getMultiNodeAttributeAsJSON()
end

#inDegree(edgeType, node) ⇒ Object 



33
34
35
36
 
# File 'lib/gen/tempest_d_b_service.rb', line 33

def inDegree(edgeType, node)
  send_inDegree(edgeType, node)
  return recv_inDegree()
end

#inNeighbor(edgeType, node, i) ⇒ Object 



102
103
104
105
 
# File 'lib/gen/tempest_d_b_service.rb', line 102

def inNeighbor(edgeType, node, i)
  send_inNeighbor(edgeType, node, i)
  return recv_inNeighbor()
end

#inNeighbors(edgeType, node) ⇒ Object 



67
68
69
70
 
# File 'lib/gen/tempest_d_b_service.rb', line 67

def inNeighbors(edgeType, node)
  send_inNeighbors(edgeType, node)
  return recv_inNeighbors()
end

#kStepInNeighborsFiltered(edgeType, source, k, sqlClause, filter, alternating) ⇒ Object 



157
158
159
160
 
# File 'lib/gen/tempest_d_b_service.rb', line 157

def kStepInNeighborsFiltered(edgeType, source, k, sqlClause, filter, alternating)
  send_kStepInNeighborsFiltered(edgeType, source, k, sqlClause, filter, alternating)
  return recv_kStepInNeighborsFiltered()
end

#kStepOutNeighborsFiltered(edgeType, source, k, sqlClause, filter, alternating) ⇒ Object 



138
139
140
141
 
# File 'lib/gen/tempest_d_b_service.rb', line 138

def kStepOutNeighborsFiltered(edgeType, source, k, sqlClause, filter, alternating)
  send_kStepOutNeighborsFiltered(edgeType, source, k, sqlClause, filter, alternating)
  return recv_kStepOutNeighborsFiltered()
end

#nodeCount(edgeType) ⇒ Object 



211
212
213
214
 
# File 'lib/gen/tempest_d_b_service.rb', line 211

def nodeCount(edgeType)
  send_nodeCount(edgeType)
  return recv_nodeCount()
end

#nodes(nodeType, sqlClause) ⇒ Object 



243
244
245
246
 
# File 'lib/gen/tempest_d_b_service.rb', line 243

def nodes(nodeType, sqlClause)
  send_nodes(nodeType, sqlClause)
  return recv_nodes()
end

#outDegree(edgeType, node) ⇒ Object 



16
17
18
19
 
# File 'lib/gen/tempest_d_b_service.rb', line 16

def outDegree(edgeType, node)
  send_outDegree(edgeType, node)
  return recv_outDegree()
end

#outNeighbor(edgeType, node, i) ⇒ Object 



84
85
86
87
 
# File 'lib/gen/tempest_d_b_service.rb', line 84

def outNeighbor(edgeType, node, i)
  send_outNeighbor(edgeType, node, i)
  return recv_outNeighbor()
end

#outNeighbors(edgeType, node) ⇒ Object 



50
51
52
53
 
# File 'lib/gen/tempest_d_b_service.rb', line 50

def outNeighbors(edgeType, node)
  send_outNeighbors(edgeType, node)
  return recv_outNeighbors()
end

#pprSingleTarget(edgeType, seedNodes, targetNode, biPPRParams) ⇒ Object 



194
195
196
197
 
# File 'lib/gen/tempest_d_b_service.rb', line 194

def pprSingleTarget(edgeType, seedNodes, targetNode, biPPRParams)
  send_pprSingleTarget(edgeType, seedNodes, targetNode, biPPRParams)
  return recv_pprSingleTarget()
end

#pprUndirected(edgeTypes, seeds, pageRankParams) ⇒ Object 



176
177
178
179
 
# File 'lib/gen/tempest_d_b_service.rb', line 176

def pprUndirected(edgeTypes, seeds, pageRankParams)
  send_pprUndirected(edgeTypes, seeds, pageRankParams)
  return recv_pprUndirected()
end

#recv_addEdges ⇒ Object 



320
321
322
323
324
325
 
# File 'lib/gen/tempest_d_b_service.rb', line 320

def recv_addEdges()
  result = receive_message(AddEdges_result)
  raise result.error1 unless result.error1.nil?
  raise result.error2 unless result.error2.nil?
  return
end

#recv_addNode ⇒ Object 



286
287
288
289
290
291
292
 
# File 'lib/gen/tempest_d_b_service.rb', line 286

def recv_addNode()
  result = receive_message(AddNode_result)
  raise result.error1 unless result.error1.nil?
  raise result.error2 unless result.error2.nil?
  raise result.error3 unless result.error3.nil?
  return
end

#recv_connectedComponent ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


129
130
131
132
133
134
135
136
 
# File 'lib/gen/tempest_d_b_service.rb', line 129

def recv_connectedComponent()
  result = receive_message(ConnectedComponent_result)
  return result.success unless result.success.nil?
  raise result.error1 unless result.error1.nil?
  raise result.error2 unless result.error2.nil?
  raise result.error3 unless result.error3.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'connectedComponent failed: unknown result')
end

#recv_edgeCount ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


236
237
238
239
240
241
 
# File 'lib/gen/tempest_d_b_service.rb', line 236

def recv_edgeCount()
  result = receive_message(EdgeCount_result)
  return result.success unless result.success.nil?
  raise result.ex unless result.ex.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'edgeCount failed: unknown result')
end

#recv_getMultiNodeAttributeAsJSON ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


269
270
271
272
273
274
275
 
# File 'lib/gen/tempest_d_b_service.rb', line 269

def recv_getMultiNodeAttributeAsJSON()
  result = receive_message(GetMultiNodeAttributeAsJSON_result)
  return result.success unless result.success.nil?
  raise result.error1 unless result.error1.nil?
  raise result.error2 unless result.error2.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getMultiNodeAttributeAsJSON failed: unknown result')
end

#recv_inDegree ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


42
43
44
45
46
47
48
 
# File 'lib/gen/tempest_d_b_service.rb', line 42

def recv_inDegree()
  result = receive_message(InDegree_result)
  return result.success unless result.success.nil?
  raise result.ex1 unless result.ex1.nil?
  raise result.ex2 unless result.ex2.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'inDegree failed: unknown result')
end

#recv_inNeighbor ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


111
112
113
114
115
116
117
118
 
# File 'lib/gen/tempest_d_b_service.rb', line 111

def recv_inNeighbor()
  result = receive_message(InNeighbor_result)
  return result.success unless result.success.nil?
  raise result.ex1 unless result.ex1.nil?
  raise result.ex2 unless result.ex2.nil?
  raise result.ex3 unless result.ex3.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'inNeighbor failed: unknown result')
end

#recv_inNeighbors ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


76
77
78
79
80
81
82
 
# File 'lib/gen/tempest_d_b_service.rb', line 76

def recv_inNeighbors()
  result = receive_message(InNeighbors_result)
  return result.success unless result.success.nil?
  raise result.ex1 unless result.ex1.nil?
  raise result.ex2 unless result.ex2.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'inNeighbors failed: unknown result')
end

#recv_kStepInNeighborsFiltered ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


166
167
168
169
170
171
172
173
174
 
# File 'lib/gen/tempest_d_b_service.rb', line 166

def recv_kStepInNeighborsFiltered()
  result = receive_message(KStepInNeighborsFiltered_result)
  return result.success unless result.success.nil?
  raise result.error1 unless result.error1.nil?
  raise result.error2 unless result.error2.nil?
  raise result.error3 unless result.error3.nil?
  raise result.error4 unless result.error4.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'kStepInNeighborsFiltered failed: unknown result')
end

#recv_kStepOutNeighborsFiltered ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


147
148
149
150
151
152
153
154
155
 
# File 'lib/gen/tempest_d_b_service.rb', line 147

def recv_kStepOutNeighborsFiltered()
  result = receive_message(KStepOutNeighborsFiltered_result)
  return result.success unless result.success.nil?
  raise result.error1 unless result.error1.nil?
  raise result.error2 unless result.error2.nil?
  raise result.error3 unless result.error3.nil?
  raise result.error4 unless result.error4.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'kStepOutNeighborsFiltered failed: unknown result')
end

#recv_nodeCount ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


220
221
222
223
224
225
 
# File 'lib/gen/tempest_d_b_service.rb', line 220

def recv_nodeCount()
  result = receive_message(NodeCount_result)
  return result.success unless result.success.nil?
  raise result.ex unless result.ex.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'nodeCount failed: unknown result')
end

#recv_nodes ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


252
253
254
255
256
257
258
 
# File 'lib/gen/tempest_d_b_service.rb', line 252

def recv_nodes()
  result = receive_message(Nodes_result)
  return result.success unless result.success.nil?
  raise result.error1 unless result.error1.nil?
  raise result.error2 unless result.error2.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'nodes failed: unknown result')
end

#recv_outDegree ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


25
26
27
28
29
30
31
 
# File 'lib/gen/tempest_d_b_service.rb', line 25

def recv_outDegree()
  result = receive_message(OutDegree_result)
  return result.success unless result.success.nil?
  raise result.ex1 unless result.ex1.nil?
  raise result.ex2 unless result.ex2.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'outDegree failed: unknown result')
end

#recv_outNeighbor ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


93
94
95
96
97
98
99
100
 
# File 'lib/gen/tempest_d_b_service.rb', line 93

def recv_outNeighbor()
  result = receive_message(OutNeighbor_result)
  return result.success unless result.success.nil?
  raise result.ex1 unless result.ex1.nil?
  raise result.ex2 unless result.ex2.nil?
  raise result.ex3 unless result.ex3.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'outNeighbor failed: unknown result')
end

#recv_outNeighbors ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


59
60
61
62
63
64
65
 
# File 'lib/gen/tempest_d_b_service.rb', line 59

def recv_outNeighbors()
  result = receive_message(OutNeighbors_result)
  return result.success unless result.success.nil?
  raise result.ex1 unless result.ex1.nil?
  raise result.ex2 unless result.ex2.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'outNeighbors failed: unknown result')
end

#recv_pprSingleTarget ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


203
204
205
206
207
208
209
 
# File 'lib/gen/tempest_d_b_service.rb', line 203

def recv_pprSingleTarget()
  result = receive_message(PprSingleTarget_result)
  return result.success unless result.success.nil?
  raise result.ex1 unless result.ex1.nil?
  raise result.ex2 unless result.ex2.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'pprSingleTarget failed: unknown result')
end

#recv_pprUndirected ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


185
186
187
188
189
190
191
192
 
# File 'lib/gen/tempest_d_b_service.rb', line 185

def recv_pprUndirected()
  result = receive_message(PprUndirected_result)
  return result.success unless result.success.nil?
  raise result.error1 unless result.error1.nil?
  raise result.error2 unless result.error2.nil?
  raise result.error3 unless result.error3.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'pprUndirected failed: unknown result')
end

#recv_setNodeAttribute ⇒ Object 



303
304
305
306
307
308
309
 
# File 'lib/gen/tempest_d_b_service.rb', line 303

def recv_setNodeAttribute()
  result = receive_message(SetNodeAttribute_result)
  raise result.error1 unless result.error1.nil?
  raise result.error2 unless result.error2.nil?
  raise result.error3 unless result.error3.nil?
  return
end

#send_addEdges(edgeType, sourceNodes, targetNodes) ⇒ Object 



316
317
318
 
# File 'lib/gen/tempest_d_b_service.rb', line 316

def send_addEdges(edgeType, sourceNodes, targetNodes)
  send_message('addEdges', AddEdges_args, :edgeType => edgeType, :sourceNodes => sourceNodes, :targetNodes => targetNodes)
end

#send_addNode(node) ⇒ Object 



282
283
284
 
# File 'lib/gen/tempest_d_b_service.rb', line 282

def send_addNode(node)
  send_message('addNode', AddNode_args, :node => node)
end

#send_connectedComponent(source, edgeTypes, maxSize) ⇒ Object 



125
126
127
 
# File 'lib/gen/tempest_d_b_service.rb', line 125

def send_connectedComponent(source, edgeTypes, maxSize)
  send_message('connectedComponent', ConnectedComponent_args, :source => source, :edgeTypes => edgeTypes, :maxSize => maxSize)
end

#send_edgeCount(edgeType) ⇒ Object 



232
233
234
 
# File 'lib/gen/tempest_d_b_service.rb', line 232

def send_edgeCount(edgeType)
  send_message('edgeCount', EdgeCount_args, :edgeType => edgeType)
end

#send_getMultiNodeAttributeAsJSON(nodes, attributeName) ⇒ Object 



265
266
267
 
# File 'lib/gen/tempest_d_b_service.rb', line 265

def send_getMultiNodeAttributeAsJSON(nodes, attributeName)
  send_message('getMultiNodeAttributeAsJSON', GetMultiNodeAttributeAsJSON_args, :nodes => nodes, :attributeName => attributeName)
end

#send_inDegree(edgeType, node) ⇒ Object 



38
39
40
 
# File 'lib/gen/tempest_d_b_service.rb', line 38

def send_inDegree(edgeType, node)
  send_message('inDegree', InDegree_args, :edgeType => edgeType, :node => node)
end

#send_inNeighbor(edgeType, node, i) ⇒ Object 



107
108
109
 
# File 'lib/gen/tempest_d_b_service.rb', line 107

def send_inNeighbor(edgeType, node, i)
  send_message('inNeighbor', InNeighbor_args, :edgeType => edgeType, :node => node, :i => i)
end

#send_inNeighbors(edgeType, node) ⇒ Object 



72
73
74
 
# File 'lib/gen/tempest_d_b_service.rb', line 72

def send_inNeighbors(edgeType, node)
  send_message('inNeighbors', InNeighbors_args, :edgeType => edgeType, :node => node)
end

#send_kStepInNeighborsFiltered(edgeType, source, k, sqlClause, filter, alternating) ⇒ Object 



162
163
164
 
# File 'lib/gen/tempest_d_b_service.rb', line 162

def send_kStepInNeighborsFiltered(edgeType, source, k, sqlClause, filter, alternating)
  send_message('kStepInNeighborsFiltered', KStepInNeighborsFiltered_args, :edgeType => edgeType, :source => source, :k => k, :sqlClause => sqlClause, :filter => filter, :alternating => alternating)
end

#send_kStepOutNeighborsFiltered(edgeType, source, k, sqlClause, filter, alternating) ⇒ Object 



143
144
145
 
# File 'lib/gen/tempest_d_b_service.rb', line 143

def send_kStepOutNeighborsFiltered(edgeType, source, k, sqlClause, filter, alternating)
  send_message('kStepOutNeighborsFiltered', KStepOutNeighborsFiltered_args, :edgeType => edgeType, :source => source, :k => k, :sqlClause => sqlClause, :filter => filter, :alternating => alternating)
end

#send_nodeCount(edgeType) ⇒ Object 



216
217
218
 
# File 'lib/gen/tempest_d_b_service.rb', line 216

def send_nodeCount(edgeType)
  send_message('nodeCount', NodeCount_args, :edgeType => edgeType)
end

#send_nodes(nodeType, sqlClause) ⇒ Object 



248
249
250
 
# File 'lib/gen/tempest_d_b_service.rb', line 248

def send_nodes(nodeType, sqlClause)
  send_message('nodes', Nodes_args, :nodeType => nodeType, :sqlClause => sqlClause)
end

#send_outDegree(edgeType, node) ⇒ Object 



21
22
23
 
# File 'lib/gen/tempest_d_b_service.rb', line 21

def send_outDegree(edgeType, node)
  send_message('outDegree', OutDegree_args, :edgeType => edgeType, :node => node)
end

#send_outNeighbor(edgeType, node, i) ⇒ Object 



89
90
91
 
# File 'lib/gen/tempest_d_b_service.rb', line 89

def send_outNeighbor(edgeType, node, i)
  send_message('outNeighbor', OutNeighbor_args, :edgeType => edgeType, :node => node, :i => i)
end

#send_outNeighbors(edgeType, node) ⇒ Object 



55
56
57
 
# File 'lib/gen/tempest_d_b_service.rb', line 55

def send_outNeighbors(edgeType, node)
  send_message('outNeighbors', OutNeighbors_args, :edgeType => edgeType, :node => node)
end

#send_pprSingleTarget(edgeType, seedNodes, targetNode, biPPRParams) ⇒ Object 



199
200
201
 
# File 'lib/gen/tempest_d_b_service.rb', line 199

def send_pprSingleTarget(edgeType, seedNodes, targetNode, biPPRParams)
  send_message('pprSingleTarget', PprSingleTarget_args, :edgeType => edgeType, :seedNodes => seedNodes, :targetNode => targetNode, :biPPRParams => biPPRParams)
end

#send_pprUndirected(edgeTypes, seeds, pageRankParams) ⇒ Object 



181
182
183
 
# File 'lib/gen/tempest_d_b_service.rb', line 181

def send_pprUndirected(edgeTypes, seeds, pageRankParams)
  send_message('pprUndirected', PprUndirected_args, :edgeTypes => edgeTypes, :seeds => seeds, :pageRankParams => pageRankParams)
end

#send_setNodeAttribute(node, attributeName, attributeValue) ⇒ Object 



299
300
301
 
# File 'lib/gen/tempest_d_b_service.rb', line 299

def send_setNodeAttribute(node, attributeName, attributeValue)
  send_message('setNodeAttribute', SetNodeAttribute_args, :node => node, :attributeName => attributeName, :attributeValue => attributeValue)
end

#setNodeAttribute(node, attributeName, attributeValue) ⇒ Object 



294
295
296
297
 
# File 'lib/gen/tempest_d_b_service.rb', line 294

def setNodeAttribute(node, attributeName, attributeValue)
  send_setNodeAttribute(node, attributeName, attributeValue)
  recv_setNodeAttribute()
end