You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by rm...@apache.org on 2014/12/12 11:38:51 UTC
incubator-flink git commit: [FLINK-1302] Make JDBCInputFormat
implement the NonParallelInput interface
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 <rm...@apache.org>
Authored: Fri Dec 5 20:06:36 2014 +0100
Committer: Robert Metzger <rm...@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);