storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kabh...@apache.org
Subject storm git commit: Corrected ConnectionPrvoider to ConnectionProvider
Date Thu, 13 Aug 2015 09:22:03 GMT
Repository: storm
Updated Branches:
  refs/heads/0.10.x-branch 94b4458bc -> 28d7e69d5


Corrected ConnectionPrvoider to ConnectionProvider


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/28d7e69d
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/28d7e69d
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/28d7e69d

Branch: refs/heads/0.10.x-branch
Commit: 28d7e69d50ae25a0da48e49afb9d110fae9ffc9e
Parents: 94b4458
Author: Randy Gelhausen <rgelhau@gmail.com>
Authored: Wed Aug 12 02:36:24 2015 -0400
Committer: Jungtaek Lim <kabhwan@gmail.com>
Committed: Thu Aug 13 18:15:04 2015 +0900

----------------------------------------------------------------------
 external/storm-jdbc/README.md                                  | 6 +++---
 .../java/org/apache/storm/jdbc/trident/state/JdbcState.java    | 2 +-
 .../storm/jdbc/topology/UserPersistanceTridentTopology.java    | 2 +-
 3 files changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/28d7e69d/external/storm-jdbc/README.md
----------------------------------------------------------------------
diff --git a/external/storm-jdbc/README.md b/external/storm-jdbc/README.md
index 2d1301a..419e9f6 100644
--- a/external/storm-jdbc/README.md
+++ b/external/storm-jdbc/README.md
@@ -7,10 +7,10 @@ in a storm topology.
 The bolt and trident state included in this package for inserting data into a database tables
are tied to a single table.
 
 ### ConnectionProvider
-An interface that should be implemented by different connection pooling mechanism `org.apache.storm.jdbc.common.ConnectionPrvoider`
+An interface that should be implemented by different connection pooling mechanism `org.apache.storm.jdbc.common.ConnectionProvider`
 
 ```java
-public interface ConnectionPrvoider extends Serializable {
+public interface ConnectionProvider extends Serializable {
     /**
      * method must be idempotent.
      */
@@ -297,4 +297,4 @@ under the License.
 
 ## Committer Sponsors
  * P. Taylor Goetz ([ptgoetz@apache.org](mailto:ptgoetz@apache.org))
- * Sriharsha Chintalapani ([sriharsha@apache.org](mailto:sriharsha@apache.org)) 
\ No newline at end of file
+ * Sriharsha Chintalapani ([sriharsha@apache.org](mailto:sriharsha@apache.org)) 

http://git-wip-us.apache.org/repos/asf/storm/blob/28d7e69d/external/storm-jdbc/src/main/java/org/apache/storm/jdbc/trident/state/JdbcState.java
----------------------------------------------------------------------
diff --git a/external/storm-jdbc/src/main/java/org/apache/storm/jdbc/trident/state/JdbcState.java
b/external/storm-jdbc/src/main/java/org/apache/storm/jdbc/trident/state/JdbcState.java
index 8afc466..27c911c 100644
--- a/external/storm-jdbc/src/main/java/org/apache/storm/jdbc/trident/state/JdbcState.java
+++ b/external/storm-jdbc/src/main/java/org/apache/storm/jdbc/trident/state/JdbcState.java
@@ -60,7 +60,7 @@ public class JdbcState implements State {
         private String selectQuery;
         private Integer queryTimeoutSecs;
 
-        public Options withConnectionPrvoider(ConnectionProvider connectionProvider) {
+        public Options withConnectionProvider(ConnectionProvider connectionProvider) {
             this.connectionProvider = connectionProvider;
             return this;
         }

http://git-wip-us.apache.org/repos/asf/storm/blob/28d7e69d/external/storm-jdbc/src/test/java/org/apache/storm/jdbc/topology/UserPersistanceTridentTopology.java
----------------------------------------------------------------------
diff --git a/external/storm-jdbc/src/test/java/org/apache/storm/jdbc/topology/UserPersistanceTridentTopology.java
b/external/storm-jdbc/src/test/java/org/apache/storm/jdbc/topology/UserPersistanceTridentTopology.java
index 7cf0ce6..522d41a 100644
--- a/external/storm-jdbc/src/test/java/org/apache/storm/jdbc/topology/UserPersistanceTridentTopology.java
+++ b/external/storm-jdbc/src/test/java/org/apache/storm/jdbc/topology/UserPersistanceTridentTopology.java
@@ -44,7 +44,7 @@ public class UserPersistanceTridentTopology extends AbstractUserTopology
{
         TridentTopology topology = new TridentTopology();
 
         JdbcState.Options options = new JdbcState.Options()
-                .withConnectionPrvoider(connectionProvider)
+                .withConnectionProvider(connectionProvider)
                 .withMapper(this.jdbcMapper)
                 .withJdbcLookupMapper(new SimpleJdbcLookupMapper(new Fields("dept_name"),
Lists.newArrayList(new Column("user_id", Types.INTEGER))))
                 .withTableName(TABLE_NAME)


Mime
View raw message