class Cascading::MultiTap

A MultiTap represents one of Cascading’s aggregate taps and is built via static constructors that accept an array of Taps. In order for a mode (Cascading local or Hadoop) to be supported, all provided taps must support it.

Public Class Methods

multi_sink_tap(taps) click to toggle source

Static constructor that builds a MultiTap wrapping a c.t.MultiSinkTap from the given array of Taps. The resulting MultiTap will only be available in Cascading local mode or Hadoop mode if all input taps support them.

# File lib/cascading/tap.rb, line 93
def self.multi_sink_tap(taps)
  multi_tap(taps, Java::CascadingTap::MultiSinkTap)
end

multi_source_tap(taps) click to toggle source

Static constructor that builds a MultiTap wrapping a c.t.MultiSourceTap from the given array of Taps. The resulting MultiTap will only be available in Cascading local mode or Hadoop mode if all input taps support them.

# File lib/cascading/tap.rb, line 86
def self.multi_source_tap(taps)
  multi_tap(taps, Java::CascadingTap::MultiSourceTap)
end

new(local_tap, hadoop_tap) click to toggle source

Do not call this constructor directly; instead, use one of ::multi_source_tap or ::multi_sink_tap.

# File lib/cascading/tap.rb, line 78
def initialize(local_tap, hadoop_tap)
  super(local_tap, hadoop_tap)
end