cascading.lingual.platform
Class LingualFlowFactory

java.lang.Object
  cascading.bind.factory.Factory<Process>
      cascading.bind.process.ProcessFactory<Flow,cascading.bind.catalog.Resource<Protocol,Format,SinkMode>>
          cascading.bind.process.FlowFactory<Protocol,Format>
              cascading.lingual.platform.LingualFlowFactory

public class LingualFlowFactory
extends cascading.bind.process.FlowFactory<Protocol,Format>

Class LingualFlowFactory is an implementation of the FlowFactory base class.

This FlowFactory can dynamically resolve source and sink taps across any platform and return a Flow for that platform without any coupling to a given platform implementation.

Field Summary

Fields inherited from class cascading.bind.process.FlowFactory

name, protocolHandlers

Constructor Summary

LingualFlowFactory(PlatformBroker platformBroker, LingualConnection lingualConnection, String name, Branch branch)
Instantiates a new Lingual flow factory.

Method Summary

void	addSink(String sinkName, String path)
void	addSource(String sourceName, String path)
Flow	create()
protected FlowConnector	getFlowConnector()

Methods inherited from class cascading.bind.process.FlowFactory

createFlowFrom, createFlowFrom, getName, getProtocolHandlers, getSinkTapFor, getSinkTapFor, getSinkTapsFor, getSinkTapsMap, getSourceTapFor, getSourceTapFor, getSourceTapsFor, getSourceTapsMap

Methods inherited from class cascading.bind.process.ProcessFactory

addSinkResource, addSourceResource, clearSinkResources, clearSourceResources, getAllSinkResources, getAllSourceResources, getSinkNames, getSinkResources, getSinkStereotype, getSinkStereotypeFor, getSourceNames, getSourceResources, getSourceStereotype, getSourceStereotypeFor, replaceSinkResource, replaceSourceResource, setSinkStereotype, setSourceStereotype

Methods inherited from class cascading.bind.factory.Factory

getProperties, setProperties

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LingualFlowFactory

public LingualFlowFactory(PlatformBroker platformBroker,
                          LingualConnection lingualConnection,
                          String name,
                          Branch branch)

Instantiates a new Lingual flow factory.

Parameters:

platformBroker - the platform broker

name - the name

branch - the branch

Method Detail

getFlowConnector

protected FlowConnector getFlowConnector()

Specified by:

getFlowConnector in class cascading.bind.process.FlowFactory<Protocol,Format>

addSource

public void addSource(String sourceName,
                      String path)

addSink

public void addSink(String sinkName,
                    String path)

create

public Flow create()

Specified by:

create in class cascading.bind.factory.Factory<Flow>