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 2016/10/24 13:48:50 UTC
flink git commit: [FLINK-4879] Make KafkaTableSource public
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 <hz...@corp.netease.com>
Authored: Fri Oct 21 17:27:12 2016 +0800
Committer: Robert Metzger <rm...@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;