Package org.apache.storm.jdbc.topology
Class AbstractUserTopology
java.lang.Object
org.apache.storm.jdbc.topology.AbstractUserTopology
- Direct Known Subclasses:
UserPersistenceTopology,UserPersistenceTridentTopology
For topology-related code reusage.
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected ConnectionProviderprotected static final Stringprotected JdbcLookupMapperprotected JdbcMapperprotected static final Stringprotected static final Stringprotected UserSpout -
Constructor Summary
Constructors -
Method Summary
-
Field Details
-
userSpout
-
jdbcMapper
-
jdbcLookupMapper
-
connectionProvider
-
TABLE_NAME
- See Also:
-
JDBC_CONF
- See Also:
-
SELECT_QUERY
- See Also:
-
-
Constructor Details
-
AbstractUserTopology
public AbstractUserTopology()
-
-
Method Details
-
execute
A main method template to extend.- Parameters:
args- main method arguments- Throws:
Exception- any expection occuring durch cluster setup or operation
-
getTopology
-