flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rmetz...@apache.org
Subject flink git commit: [FLINK-4879] Make KafkaTableSource public
Date Mon, 24 Oct 2016 13:48:50 GMT
Repository: flink
Updated Branches:
  refs/heads/master 2b31ec93a -> e33243729


[FLINK-4879] Make KafkaTableSource public

This closes #2678


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

Branch: refs/heads/master
Commit: e332437297197659fabaed3da5ad1e00608f246e
Parents: 2b31ec9
Author: hzyuemeng1 <hzyuemeng1@corp.netease.com>
Authored: Fri Oct 21 17:27:12 2016 +0800
Committer: Robert Metzger <rmetzger@apache.org>
Committed: Mon Oct 24 15:48:25 2016 +0200

----------------------------------------------------------------------
 .../apache/flink/streaming/connectors/kafka/KafkaTableSource.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/e3324372/flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java
----------------------------------------------------------------------
diff --git a/flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java
b/flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java
index 446f203..fd423d7 100644
--- a/flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java
+++ b/flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java
@@ -37,7 +37,7 @@ import static org.apache.flink.streaming.connectors.kafka.internals.TypeUtil.toT
  * <p>The version-specific Kafka consumers need to extend this class and
  * override {@link #getKafkaConsumer(String, Properties, DeserializationSchema)}}.
  */
-abstract class KafkaTableSource implements StreamTableSource<Row> {
+public abstract class KafkaTableSource implements StreamTableSource<Row> {
 
 	/** The Kafka topic to consume. */
 	private final String topic;


Mime
View raw message