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 <[email protected]> Authored: Fri Oct 21 17:27:12 2016 +0800 Committer: Robert Metzger <[email protected]> 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;
