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