flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rmetz...@apache.org
Subject incubator-flink git commit: [FLINK-1302] Make JDBCInputFormat implement the NonParallelInput interface
Date Fri, 12 Dec 2014 10:38:51 GMT
Repository: incubator-flink
Updated Branches:
  refs/heads/master 1b697496f -> 669159956


[FLINK-1302] Make JDBCInputFormat implement the NonParallelInput interface


Project: http://git-wip-us.apache.org/repos/asf/incubator-flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-flink/commit/66915995
Tree: http://git-wip-us.apache.org/repos/asf/incubator-flink/tree/66915995
Diff: http://git-wip-us.apache.org/repos/asf/incubator-flink/diff/66915995

Branch: refs/heads/master
Commit: 669159956f1d8fcd6105e5fdb48bc59e020898de
Parents: 1b69749
Author: Robert Metzger <rmetzger@apache.org>
Authored: Fri Dec 5 20:06:36 2014 +0100
Committer: Robert Metzger <rmetzger@apache.org>
Committed: Fri Dec 12 11:38:24 2014 +0100

----------------------------------------------------------------------
 .../java/org/apache/flink/api/java/io/jdbc/JDBCInputFormat.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/66915995/flink-addons/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormat.java
----------------------------------------------------------------------
diff --git a/flink-addons/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormat.java
b/flink-addons/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormat.java
index de42438..3cfaeb9 100644
--- a/flink-addons/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormat.java
+++ b/flink-addons/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormat.java
@@ -26,6 +26,7 @@ import java.sql.ResultSetMetaData;
 import java.sql.SQLException;
 import java.sql.Statement;
 
+import org.apache.flink.api.common.io.NonParallelInput;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -47,7 +48,7 @@ import org.apache.flink.types.NullValue;
  * @see Tuple
  * @see DriverManager
  */
-public class JDBCInputFormat<OUT extends Tuple> implements InputFormat<OUT, InputSplit>
{
+public class JDBCInputFormat<OUT extends Tuple> implements InputFormat<OUT, InputSplit>,
NonParallelInput {
 	private static final long serialVersionUID = 1L;
 
 	private static final Logger LOG = LoggerFactory.getLogger(JDBCInputFormat.class);


Mime
View raw message