public abstract class AbstractUserTopology extends Object
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
args
- main method argumentsException
- any expection occuring durch cluster setup or operationpublic abstract StormTopology getTopology()
Copyright © 2023 The Apache Software Foundation. All rights reserved.