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
java.lang.String	coresProperty
java.lang.String	cpuMhzProperty
java.lang.String	jdbcPasswordProperty
java.lang.String	jdbcUrlProperty
java.lang.String	jdbcUserProperty

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

jsonSerializer

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	JdbcPlatformTemplate(java.lang.String platformName, java.lang.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.
java.sql.Connection	getConnection()
Executor.Factory	getExecutorFactory()
protected abstract java.lang.String	getJdbcDriverClassName()	Provide the name of the JDBC driver Class for this instance.
java.lang.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 Detail

cpuMhzProperty

public final java.lang.String cpuMhzProperty

coresProperty

public final java.lang.String coresProperty

jdbcUrlProperty

public final java.lang.String jdbcUrlProperty

jdbcUserProperty

public final java.lang.String jdbcUserProperty

jdbcPasswordProperty

public final java.lang.String jdbcPasswordProperty

Constructor Detail

JdbcPlatformTemplate

protected JdbcPlatformTemplate(java.lang.String platformName,
                               java.lang.String configName)

Method Detail

getConnection

public java.sql.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 java.lang.String getPlatformId()

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

Returns:

the platform ID

getJdbcDriverClassName

protected abstract java.lang.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