Package org.apache.storm.jdbc.topology

Class AbstractUserTopology

java.lang.Object

org.apache.storm.jdbc.topology.AbstractUserTopology

Direct Known Subclasses:

UserPersistenceTopology, UserPersistenceTridentTopology

public abstract class AbstractUserTopology
extends Object

For topology-related code reusage.

Field Summary

Fields

Modifier and Type	Field	Description
protected ConnectionProvider	connectionProvider
protected static final String	JDBC_CONF
protected JdbcLookupMapper	jdbcLookupMapper
protected JdbcMapper	jdbcMapper
protected static final String	SELECT_QUERY
protected static final String	TABLE_NAME
protected UserSpout	userSpout

Constructor Summary

Constructors

Constructor	Description
AbstractUserTopology()

Method Summary

Modifier and Type	Method	Description
void	execute(String[] args)	A main method template to extend.
abstract StormTopology	getTopology()

Methods inherited from class java.lang.Object

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

Field Details

userSpout

protected UserSpout userSpout

jdbcMapper

protected JdbcMapper jdbcMapper

jdbcLookupMapper

protected JdbcLookupMapper jdbcLookupMapper

connectionProvider

protected ConnectionProvider connectionProvider

TABLE_NAME

protected static final String TABLE_NAME

See Also:

• Constant Field Values

JDBC_CONF

protected static final String JDBC_CONF

See Also:

• Constant Field Values

SELECT_QUERY

protected static final String SELECT_QUERY

See Also:

• Constant Field Values

Constructor Details

AbstractUserTopology

public AbstractUserTopology()

Method Details

execute

public void execute(String[] args)
             throws Exception

A main method template to extend.

Parameters:

args - main method arguments

Throws:

Exception - any expection occuring durch cluster setup or operation

getTopology

public abstract StormTopology getTopology()