class Concord::Metadata

Wrapper over the ComputationMetadata object from the thrift interface

Attributes

istreams[RW]
name[RW]
ostreams[RW]

Public Class Methods

new(name: nil, istreams: [], ostreams: []) click to toggle source

Initialize a new ‘Metadata` object @param name [String] The globally unique identifier of the application @param istreams [Array] An array of input streams. These can be formatted 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. @param ostreams [Array] An array of `String` stream identifiers that this computation may produce records on.

# File lib/concord.rb, line 22
def initialize(name: nil, istreams: [], ostreams: [])
  self.name = name
  self.istreams = istreams
  self.ostreams = ostreams
end