cascading.lingual.platform
Class PlatformBroker<Config>

java.lang.Object
  cascading.lingual.platform.PlatformBroker<Config>

public abstract class PlatformBroker<Config>
extends Object

Class PlatformBroker is the base class of all platform specific implementations.

An instance of a PlatformBroker is created for the requested platform, where all implementations encapsulate necessary specific services.

PlatformBroker instances are returned by the PlatformBrokerFactory.

Field Summary

static String	CATALOG_FILE
static String	CATALOG_FILE_PROP
static String	META_DATA_PATH
static String	META_DATA_PATH_PROP

Constructor Summary

protected

PlatformBroker()

Method Summary

boolean	catalogLoaded()
void	closeCollectorCache()
void	closeConnection(LingualConnection connection)
abstract boolean	createPath(String path)
String	createSchemaNameFrom(String identifier)
String	createTableNameFrom(String identifier)
abstract boolean	deletePath(String path)
void	disableCollectorCache()
void	enableCollectorCache()
protected String	findActualPath(String parentIdentifier, String identifier)
CascadingServices	getCascadingServices()
SchemaCatalog	getCatalog()
abstract Class<? extends SchemaCatalog>	getCatalogClass()
protected CatalogManager	getCatalogManager()
String[]	getChildIdentifiers(FileType<Config> fileType)
String[]	getChildIdentifiers(String identifier)
Map<String,TupleEntryCollector>	getCollectorCache()
abstract Config	getConfig()
DebugLevel	getDebugLevel()
abstract String	getFileSeparator()
abstract FileType	getFileTypeFor(String identifier)
abstract FlowConnector	getFlowConnector()
LingualFlowFactory	getFlowFactory(Branch branch)
abstract FlowProcess<Config>	getFlowProcess()
String	getFullCatalogPath()
String	getFullMetadataPath()
abstract String	getFullPath(String identifier)
abstract InputStream	getInputStream(String path)
abstract String	getName()
abstract OutputStream	getOutputStream(String path)
cascading.flow.planner.PlatformInfo	getPlatformInfo()
Properties	getProperties()
String	getResultPath(String name)
abstract String	getTempPath()
String	getTempPath(String name)
boolean	initializeMetaData()
static String	makePath(String fileSeparator, String rootPath, String... elements)
SchemaCatalog	newCatalogInstance()
abstract boolean	pathExists(String path)
void	setProperties(Properties properties)
void	startConnection(LingualConnection connection)
void	writeCatalog()

Methods inherited from class java.lang.Object

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

Field Detail

META_DATA_PATH_PROP

public static final String META_DATA_PATH_PROP

See Also:

Constant Field Values

META_DATA_PATH

public static final String META_DATA_PATH

See Also:

Constant Field Values

CATALOG_FILE_PROP

public static final String CATALOG_FILE_PROP

See Also:

Constant Field Values

CATALOG_FILE

public static final String CATALOG_FILE

See Also:

Constant Field Values

Constructor Detail

PlatformBroker

protected PlatformBroker()

Method Detail

setProperties

public void setProperties(Properties properties)

getProperties

public Properties getProperties()

getName

public abstract String getName()

getConfig

public abstract Config getConfig()

getCascadingServices

public CascadingServices getCascadingServices()

startConnection

public void startConnection(LingualConnection connection)
                     throws SQLException

Throws:

SQLException

closeConnection

public void closeConnection(LingualConnection connection)

enableCollectorCache

public void enableCollectorCache()

disableCollectorCache

public void disableCollectorCache()

closeCollectorCache

public void closeCollectorCache()

getCollectorCache

public Map<String,TupleEntryCollector> getCollectorCache()

getFlowProcess

public abstract FlowProcess<Config> getFlowProcess()

getDebugLevel

public DebugLevel getDebugLevel()

catalogLoaded

public boolean catalogLoaded()

getCatalog

public SchemaCatalog getCatalog()

initializeMetaData

public boolean initializeMetaData()

getFullMetadataPath

public String getFullMetadataPath()

getFullCatalogPath

public String getFullCatalogPath()

writeCatalog

public void writeCatalog()

getCatalogManager

protected CatalogManager getCatalogManager()

getResultPath

public String getResultPath(String name)

getTempPath

public String getTempPath(String name)

makePath

public static String makePath(String fileSeparator,
                              String rootPath,
                              String... elements)

getFileSeparator

public abstract String getFileSeparator()

getTempPath

public abstract String getTempPath()

getFullPath

public abstract String getFullPath(String identifier)

pathExists

public abstract boolean pathExists(String path)

deletePath

public abstract boolean deletePath(String path)

createPath

public abstract boolean createPath(String path)

getInputStream

public abstract InputStream getInputStream(String path)

getOutputStream

public abstract OutputStream getOutputStream(String path)

createSchemaNameFrom

public String createSchemaNameFrom(String identifier)

createTableNameFrom

public String createTableNameFrom(String identifier)

getCatalogClass

public abstract Class<? extends SchemaCatalog> getCatalogClass()

getChildIdentifiers

public String[] getChildIdentifiers(String identifier)
                             throws IOException

Throws:

IOException

getFileTypeFor

public abstract FileType getFileTypeFor(String identifier)

getChildIdentifiers

public String[] getChildIdentifiers(FileType<Config> fileType)
                             throws IOException

Throws:

IOException

getPlatformInfo

public cascading.flow.planner.PlatformInfo getPlatformInfo()

getFlowConnector

public abstract FlowConnector getFlowConnector()

getFlowFactory

public LingualFlowFactory getFlowFactory(Branch branch)

newCatalogInstance

public SchemaCatalog newCatalogInstance()

findActualPath

protected String findActualPath(String parentIdentifier,
                                String identifier)