Class: Concord::Metadata

Inherits:
Object
  • Object
show all
Defined in:
lib/concord.rb

Overview

Wrapper over the ComputationMetadata object from the thrift interface

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(name: nil, istreams: [], ostreams: []) ⇒ Metadata

Initialize a new ‘Metadata` object as either a `String` identifying the stream or an `Array` of length two, in which the first parameter is the `String` identifier and the second parameter is a `StreamGrouping` defining how incoming records should be routed. computation may produce records on.

Parameters:

  • name (String) (defaults to: nil) —

    The globally unique identifier of the application

  • istreams (Array) (defaults to: []) —

    An array of input streams. These can be formatted

  • ostreams (Array) (defaults to: []) —

    An array of ‘String` stream identifiers that this



22
23
24
25
26
 
# File 'lib/concord.rb', line 22

def initialize(name: nil, istreams: [], ostreams: [])
  self.name = name
  self.istreams = istreams
  self.ostreams = ostreams
end

Instance Attribute Details

#istreams ⇒ Object

Returns the value of attribute istreams.



11
12
13
 
# File 'lib/concord.rb', line 11

def istreams
  @istreams
end

#name ⇒ Object

Returns the value of attribute name.



11
12
13
 
# File 'lib/concord.rb', line 11

def name
  @name
end

#ostreams ⇒ Object

Returns the value of attribute ostreams.



11
12
13
 
# File 'lib/concord.rb', line 11

def ostreams
  @ostreams
end