You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ji...@apache.org on 2018/10/23 06:40:38 UTC
[flink] branch release-1.6 updated: [FLINK-10639][docs] Fix java
syntax error in document
This is an automated email from the ASF dual-hosted git repository.
jincheng pushed a commit to branch release-1.6
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.6 by this push:
new bc43e5f [FLINK-10639][docs] Fix java syntax error in document
bc43e5f is described below
commit bc43e5f1b852fd440ebf39ef4e255e4244d1c4d0
Author: hequn8128 <ch...@gmail.com>
AuthorDate: Tue Oct 23 12:16:36 2018 +0800
[FLINK-10639][docs] Fix java syntax error in document
This closes #6902
---
docs/dev/table/sourceSinks.md | 14 +++++++-------
docs/dev/types_serialization.md | 2 +-
2 files changed, 8 insertions(+), 8 deletions(-)
diff --git a/docs/dev/table/sourceSinks.md b/docs/dev/table/sourceSinks.md
index 7b831b7..f14e89c 100644
--- a/docs/dev/table/sourceSinks.md
+++ b/docs/dev/table/sourceSinks.md
@@ -88,7 +88,7 @@ The `BatchTableSource` interface extends the `TableSource` interface and defines
<div class="codetabs" markdown="1">
<div data-lang="java" markdown="1">
{% highlight java %}
-BatchTableSource<T> extends TableSource<T> {
+BatchTableSource<T> implements TableSource<T> {
public DataSet<T> getDataSet(ExecutionEnvironment execEnv);
}
@@ -116,7 +116,7 @@ The `StreamTableSource` interface extends the `TableSource` interface and define
<div class="codetabs" markdown="1">
<div data-lang="java" markdown="1">
{% highlight java %}
-StreamTableSource<T> extends TableSource<T> {
+StreamTableSource<T> implements TableSource<T> {
public DataStream<T> getDataStream(StreamExecutionEnvironment execEnv);
}
@@ -374,7 +374,7 @@ The interface looks as follows:
<div class="codetabs" markdown="1">
<div data-lang="java" markdown="1">
{% highlight java %}
-BatchTableSink<T> extends TableSink<T> {
+BatchTableSink<T> implements TableSink<T> {
public void emitDataSet(DataSet<T> dataSet);
}
@@ -402,7 +402,7 @@ The interface looks as follows:
<div class="codetabs" markdown="1">
<div data-lang="java" markdown="1">
{% highlight java %}
-AppendStreamTableSink<T> extends TableSink<T> {
+AppendStreamTableSink<T> implements TableSink<T> {
public void emitDataStream(DataStream<T> dataStream);
}
@@ -432,7 +432,7 @@ The interface looks as follows:
<div class="codetabs" markdown="1">
<div data-lang="java" markdown="1">
{% highlight java %}
-RetractStreamTableSink<T> extends TableSink<Tuple2<Boolean, T>> {
+RetractStreamTableSink<T> implements TableSink<Tuple2<Boolean, T>> {
public TypeInformation<T> getRecordType();
@@ -466,7 +466,7 @@ The interface looks as follows:
<div class="codetabs" markdown="1">
<div data-lang="java" markdown="1">
{% highlight java %}
-UpsertStreamTableSink<T> extends TableSink<Tuple2<Boolean, T>> {
+UpsertStreamTableSink<T> implements TableSink<Tuple2<Boolean, T>> {
public void setKeyFields(String[] keys);
@@ -572,7 +572,7 @@ import java.util.HashMap;
import java.util.List;
import java.util.Map;
-class MySystemTableSourceFactory extends StreamTableSourceFactory<Row> {
+class MySystemTableSourceFactory implements StreamTableSourceFactory<Row> {
@Override
public Map<String, String> requiredContext() {
diff --git a/docs/dev/types_serialization.md b/docs/dev/types_serialization.md
index a0f497b..9bace8c 100644
--- a/docs/dev/types_serialization.md
+++ b/docs/dev/types_serialization.md
@@ -238,7 +238,7 @@ as possible via reflection, using the few bits that Java preserves (mainly funct
This logic also contains some simple type inference for cases where the return type of a function depends on its input type:
{% highlight java %}
-public class AppendOne<T> extends MapFunction<T, Tuple2<T, Long>> {
+public class AppendOne<T> implements MapFunction<T, Tuple2<T, Long>> {
public Tuple2<T, Long> map(T value) {
return new Tuple2<T, Long>(value, 1L);