Package org.apache.storm.jdbc.topology
Class UserPersistenceTopology
- java.lang.Object
-
- org.apache.storm.jdbc.topology.AbstractUserTopology
-
- org.apache.storm.jdbc.topology.UserPersistenceTopology
-
public class UserPersistenceTopology extends AbstractUserTopology
-
-
Field Summary
-
Fields inherited from class org.apache.storm.jdbc.topology.AbstractUserTopology
connectionProvider, JDBC_CONF, jdbcLookupMapper, jdbcMapper, SELECT_QUERY, TABLE_NAME, userSpout
-
-
Constructor Summary
Constructors Constructor Description UserPersistenceTopology()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description StormTopology
getTopology()
static void
main(String[] args)
-
Methods inherited from class org.apache.storm.jdbc.topology.AbstractUserTopology
execute
-
-
-
-
Method Detail
-
getTopology
public StormTopology getTopology()
- Specified by:
getTopology
in classAbstractUserTopology
-
-