cascading.lingual.catalog
Class SchemaCatalog

java.lang.Object
  cascading.lingual.catalog.SchemaCatalog

All Implemented Interfaces:

Serializable

public abstract class SchemaCatalog
extends Object
implements Serializable

See Also:

Serialized Form

Constructor Summary

protected	SchemaCatalog()
protected	SchemaCatalog(Protocol defaultProtocol, Format defaultFormat)

Method Summary

void	addFormat(String schemaName, Format format, List<String> extensions)
void	addProtocol(String schemaName, Protocol format, List<String> uris)
boolean	addSchemaDef(String name, String protocolName, String formatName)
void	addSchemasTo(LingualConnection connection)
protected abstract List<cascading.bind.catalog.handler.FormatHandler<Protocol,Format>>	createFormatHandlers()
protected abstract List<cascading.bind.catalog.handler.ProtocolHandler<Protocol,Format>>	createProtocolHandlers()
SchemaDef	createSchemaDef(String name, String protocolName, String formatName, String identifier)
String	createSchemaDefAndTableDefsFor(String schemaIdentifier)
String	createSchemaDefAndTableDefsFor(String schemaName, String protocolName, String formatName, String schemaIdentifier)
boolean	createStereotype(String schemaName, String name, Fields fields)
protected String	createTableDefFor(SchemaDef schemaDef, String tableName, String tableIdentifier, String stereotypeName, Fields fields, Protocol protocol, Format format)
void	createTableDefFor(String identifier)
void	createTableDefFor(String schemaName, String tableName, String tableIdentifier, Fields fields, String protocolName, String formatName)
String	createTableDefFor(String schemaName, String tableName, String identifier, String stereotypeName, Protocol protocol, Format format)
Tap	createTapFor(String identifier, SinkMode sinkMode)
Tap	createTapFor(TableDef tableDef, SinkMode sinkMode)
boolean	equals(Object object)
cascading.bind.catalog.Stereotype<Protocol,Format>	findStereotypeFor(String identifier)
TableDef	findTableDefFor(String identifier)
Format	getDefaultFormatFor(String schemaName, String identifier)
Protocol	getDefaultProtocolFor(String schemaName, String identifier)
Fields	getFieldsFor(String identifier)
cascading.bind.catalog.handler.FormatHandlers<Protocol,Format>	getFormatHandlers()
Collection<String>	getFormatNames()
Collection<String>	getFormatNames(String schemaName)
protected cascading.bind.catalog.Point<Protocol,Format>	getPointFor(String identifier, String schemaName)
protected cascading.bind.catalog.Point<Protocol,Format>	getPointFor(String identifier, String schemaName, Protocol protocol, Format format)
cascading.bind.catalog.handler.ProtocolHandlers<Protocol,Format>	getProtocolHandlers()
Collection<String>	getProtocolNames()
Collection<String>	getProtocolNames(String schemaName)
cascading.bind.catalog.Resource<Protocol,Format,SinkMode>	getResourceFor(String identifier, SinkMode mode)
SchemaDef	getRootSchemaDef()
SchemaDef	getSchemaDef(String name)
Collection<String>	getSchemaNames()
cascading.bind.catalog.Stereotype	getStereoTypeFor(Fields fields)
cascading.bind.catalog.Stereotype	getStereoTypeFor(String schemaName, Fields fields)
Collection<String>	getStereotypeNames()
Collection<String>	getStereotypeNames(String schemaName)
Collection<String>	getTableNames(String schemaName)
int	hashCode()
void	initializeNew()
boolean	removeSchemaDef(String schemaName)
boolean	removeStereotype(String schemaName, String stereotypeName)
boolean	removeTableDef(String schemaName, String tableName)
boolean	renameSchemaDef(String schemaName, String newName)
boolean	renameStereotype(String schemaName, String name, String newName)
boolean	renameTableDef(String schemaName, String tableName, String renameName)
TableDef	resolveTableDef(String[] names)
void	setPlatformBroker(PlatformBroker platformBroker)

Methods inherited from class java.lang.Object

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

Constructor Detail

SchemaCatalog

protected SchemaCatalog()

SchemaCatalog

protected SchemaCatalog(Protocol defaultProtocol,
                        Format defaultFormat)

Method Detail

setPlatformBroker

public void setPlatformBroker(PlatformBroker platformBroker)

initializeNew

public void initializeNew()

getProtocolHandlers

public cascading.bind.catalog.handler.ProtocolHandlers<Protocol,Format> getProtocolHandlers()

getFormatHandlers

public cascading.bind.catalog.handler.FormatHandlers<Protocol,Format> getFormatHandlers()

getRootSchemaDef

public SchemaDef getRootSchemaDef()

resolveTableDef

public TableDef resolveTableDef(String[] names)

getSchemaNames

public Collection<String> getSchemaNames()

getSchemaDef

public SchemaDef getSchemaDef(String name)

addSchemaDef

public boolean addSchemaDef(String name,
                            String protocolName,
                            String formatName)

createSchemaDef

public SchemaDef createSchemaDef(String name,
                                 String protocolName,
                                 String formatName,
                                 String identifier)

removeSchemaDef

public boolean removeSchemaDef(String schemaName)

renameSchemaDef

public boolean renameSchemaDef(String schemaName,
                               String newName)

createSchemaDefAndTableDefsFor

public String createSchemaDefAndTableDefsFor(String schemaIdentifier)

createSchemaDefAndTableDefsFor

public String createSchemaDefAndTableDefsFor(String schemaName,
                                             String protocolName,
                                             String formatName,
                                             String schemaIdentifier)

getTableNames

public Collection<String> getTableNames(String schemaName)

createTableDefFor

public void createTableDefFor(String identifier)

createTableDefFor

public void createTableDefFor(String schemaName,
                              String tableName,
                              String tableIdentifier,
                              Fields fields,
                              String protocolName,
                              String formatName)

removeTableDef

public boolean removeTableDef(String schemaName,
                              String tableName)

renameTableDef

public boolean renameTableDef(String schemaName,
                              String tableName,
                              String renameName)

createTableDefFor

public String createTableDefFor(String schemaName,
                                String tableName,
                                String identifier,
                                String stereotypeName,
                                Protocol protocol,
                                Format format)

createTableDefFor

protected String createTableDefFor(SchemaDef schemaDef,
                                   String tableName,
                                   String tableIdentifier,
                                   String stereotypeName,
                                   Fields fields,
                                   Protocol protocol,
                                   Format format)

addSchemasTo

public void addSchemasTo(LingualConnection connection)
                  throws SQLException

Throws:

SQLException

getFormatNames

public Collection<String> getFormatNames()

getFormatNames

public Collection<String> getFormatNames(String schemaName)

getProtocolNames

public Collection<String> getProtocolNames()

getProtocolNames

public Collection<String> getProtocolNames(String schemaName)

getPointFor

protected cascading.bind.catalog.Point<Protocol,Format> getPointFor(String identifier,
                                                                    String schemaName)

getPointFor

protected cascading.bind.catalog.Point<Protocol,Format> getPointFor(String identifier,
                                                                    String schemaName,
                                                                    Protocol protocol,
                                                                    Format format)

getDefaultProtocolFor

public Protocol getDefaultProtocolFor(String schemaName,
                                      String identifier)

getDefaultFormatFor

public Format getDefaultFormatFor(String schemaName,
                                  String identifier)

getStereotypeNames

public Collection<String> getStereotypeNames()

getStereotypeNames

public Collection<String> getStereotypeNames(String schemaName)

removeStereotype

public boolean removeStereotype(String schemaName,
                                String stereotypeName)

renameStereotype

public boolean renameStereotype(String schemaName,
                                String name,
                                String newName)

findTableDefFor

public TableDef findTableDefFor(String identifier)

findStereotypeFor

public cascading.bind.catalog.Stereotype<Protocol,Format> findStereotypeFor(String identifier)

createStereotype

public boolean createStereotype(String schemaName,
                                String name,
                                Fields fields)

getStereoTypeFor

public cascading.bind.catalog.Stereotype getStereoTypeFor(Fields fields)

getStereoTypeFor

public cascading.bind.catalog.Stereotype getStereoTypeFor(String schemaName,
                                                          Fields fields)

getFieldsFor

public Fields getFieldsFor(String identifier)

createTapFor

public Tap createTapFor(String identifier,
                        SinkMode sinkMode)

createTapFor

public Tap createTapFor(TableDef tableDef,
                        SinkMode sinkMode)

getResourceFor

public cascading.bind.catalog.Resource<Protocol,Format,SinkMode> getResourceFor(String identifier,
                                                                                SinkMode mode)

createProtocolHandlers

protected abstract List<cascading.bind.catalog.handler.ProtocolHandler<Protocol,Format>> createProtocolHandlers()

createFormatHandlers

protected abstract List<cascading.bind.catalog.handler.FormatHandler<Protocol,Format>> createFormatHandlers()

addFormat

public void addFormat(String schemaName,
                      Format format,
                      List<String> extensions)

addProtocol

public void addProtocol(String schemaName,
                        Protocol format,
                        List<String> uris)

equals

public boolean equals(Object object)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object