Package org.apache.wayang.jdbc.platform

Class JdbcPlatformTemplate

java.lang.Object

org.apache.wayang.core.platform.Platform

org.apache.wayang.jdbc.platform.JdbcPlatformTemplate

Direct Known Subclasses:

GenericJdbcPlatform, PostgresPlatform, Sqlite3Platform

public abstract class JdbcPlatformTemplate
extends Platform

Platform implementation for a JDBC-accessible database.

Field Summary

Fields

Modifier and Type	Field	Description
final String	coresProperty
final String	cpuMhzProperty
final String	jdbcPasswordProperty
final String	jdbcUrlProperty
final String	jdbcUserProperty

Fields inherited from class org.apache.wayang.core.platform.Platform

jsonSerializer

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	JdbcPlatformTemplate(String platformName, String configName)

Method Summary

Modifier and Type	Method	Description
void	configureDefaults(Configuration configuration)	Configure default settings for this instance, e.g., to be able to create LoadProfileToTimeConverters.
DatabaseDescriptor	createDatabaseDescriptor(Configuration configuration)	Creates a new DatabaseDescriptor for this instance and the given Configuration.
LoadProfileToTimeConverter	createLoadProfileToTimeConverter(Configuration configuration)
TimeToCostConverter	createTimeToCostConverter(Configuration configuration)	Creates a TimeToCostConverter for this instance.
Connection	getConnection()
Executor.Factory	getExecutorFactory()
protected abstract String	getJdbcDriverClassName()	Provide the name of the JDBC driver Class for this instance.
String	getPlatformId()	Provide a unique identifier for this kind of platform.
SqlQueryChannel.Descriptor	getSqlQueryChannelDescriptor()	Retrieve a SqlQueryChannel.Descriptor for this instance.

Methods inherited from class org.apache.wayang.core.platform.Platform

createExecutor, getConfigurationName, getInitializeMillis, getName, isSinglePlatformExecutionPossible, load, toString, warmUp

Methods inherited from class java.lang.Object

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

Field Details

cpuMhzProperty

public final String cpuMhzProperty

coresProperty

public final String coresProperty

jdbcUrlProperty

public final String jdbcUrlProperty

jdbcUserProperty

public final String jdbcUserProperty

jdbcPasswordProperty

public final String jdbcPasswordProperty

Constructor Details

JdbcPlatformTemplate

protected JdbcPlatformTemplate(String platformName,
 String configName)

Method Details

getConnection

public Connection getConnection()

configureDefaults

public void configureDefaults(Configuration configuration)

Description copied from class: Platform

Configure default settings for this instance, e.g., to be able to create LoadProfileToTimeConverters.

Specified by:

configureDefaults in class Platform

Parameters:

configuration - that should be configured

getExecutorFactory

public Executor.Factory getExecutorFactory()

Specified by:

getExecutorFactory in class Platform

createLoadProfileToTimeConverter

public LoadProfileToTimeConverter createLoadProfileToTimeConverter(Configuration configuration)

Specified by:

createLoadProfileToTimeConverter in class Platform

Returns:

a default LoadProfileToTimeConverter

createTimeToCostConverter

public TimeToCostConverter createTimeToCostConverter(Configuration configuration)

Description copied from class: Platform

Creates a TimeToCostConverter for this instance.

Specified by:

createTimeToCostConverter in class Platform

Parameters:

configuration - configures the TimeToCostConverter

Returns:

the TimeToCostConverter

getPlatformId

public String getPlatformId()

Provide a unique identifier for this kind of platform. Should consist of alphanumerical characters only.

Returns:

the platform ID

getJdbcDriverClassName

protected abstract String getJdbcDriverClassName()

Provide the name of the JDBC driver Class for this instance.

Returns:

the driver Class name

getSqlQueryChannelDescriptor

public SqlQueryChannel.Descriptor getSqlQueryChannelDescriptor()

Retrieve a SqlQueryChannel.Descriptor for this instance.

Returns:

the SqlQueryChannel.Descriptor

createDatabaseDescriptor

public DatabaseDescriptor createDatabaseDescriptor(Configuration configuration)

Creates a new DatabaseDescriptor for this instance and the given Configuration.

Parameters:

configuration - provides configuration information for the result

Returns:

the DatabaseDescriptor