public abstract class AbstractUserTopology extends Object
For topology-related code reusage.
| Modifier and Type | Field and Description |
|---|---|
protected ConnectionProvider |
connectionProvider |
protected static String |
JDBC_CONF |
protected JdbcLookupMapper |
jdbcLookupMapper |
protected JdbcMapper |
jdbcMapper |
protected static String |
SELECT_QUERY |
protected static String |
TABLE_NAME |
protected UserSpout |
userSpout |
| Constructor and Description |
|---|
AbstractUserTopology() |
| Modifier and Type | Method and Description |
|---|---|
void |
execute(String[] args)
A main method template to extend.
|
abstract StormTopology |
getTopology() |
protected UserSpout userSpout
protected JdbcMapper jdbcMapper
protected JdbcLookupMapper jdbcLookupMapper
protected ConnectionProvider connectionProvider
protected static final String TABLE_NAME
protected static final String JDBC_CONF
protected static final String SELECT_QUERY
public void execute(String[] args) throws Exception
A main method template to extend.
args - main method argumentsException - any expection occuring durch cluster setup or operationpublic abstract StormTopology getTopology()
Copyright © 2021 The Apache Software Foundation. All rights reserved.