org.apache.beam.it.jdbc

Class JDBCResourceManager.JDBCSchema

java.lang.Object

org.apache.beam.it.jdbc.JDBCResourceManager.JDBCSchema

Enclosing interface:

JDBCResourceManager

public static class JDBCResourceManager.JDBCSchema
extends java.lang.Object

Object for managing JDBC table schemas in JDBCResourceManager instances.

Constructor Summary

Constructors

Constructor and Description
JDBCSchema(java.util.Map<java.lang.String,java.lang.String> columns, java.lang.String idColumn) Creates a JDBCResourceManager.JDBCSchema object using the map given and assigns the unique id column to the given idColumn.

Method Summary

Modifier and Type	Method and Description
java.lang.String	getIdColumn() Returns the name of the column used as the unique ID column.
java.lang.String	toSqlStatement() Return this schema object as a SQL statement.

Methods inherited from class java.lang.Object

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

Constructor Detail

JDBCSchema

public JDBCSchema(java.util.Map<java.lang.String,java.lang.String> columns,
                  java.lang.String idColumn)

Creates a JDBCResourceManager.JDBCSchema object using the map given and assigns the unique id column to the given idColumn.

The columns map should map column name to SQL type. For example, {{"example": "VARCHAR(200)}, {"example2": "INTEGER"}, {"example3": "BOOLEAN"}}

Parameters:

columns - a map containing the schema columns.

idColumn - the unique id column.

Method Detail

getIdColumn

public java.lang.String getIdColumn()

Returns the name of the column used as the unique ID column.

Returns:

the id column.

toSqlStatement

public java.lang.String toSqlStatement()

Return this schema object as a SQL statement.

Returns:

this schema object as a SQL statement.