You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by fh...@apache.org on 2017/12/26 19:57:19 UTC
flink git commit: [FLINK-8278] [docs] Fix Scala examples of metrics
docs (var initialization).
Repository: flink
Updated Branches:
refs/heads/master edf10c714 -> d74869f8a
[FLINK-8278] [docs] Fix Scala examples of metrics docs (var initialization).
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d74869f8
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d74869f8
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/d74869f8
Branch: refs/heads/master
Commit: d74869f8a4642fec0064ae0d0a2911aa2dea3ce4
Parents: edf10c7
Author: Xingcan Cui <xi...@gmail.com>
Authored: Mon Dec 18 21:55:30 2017 +0800
Committer: Fabian Hueske <fh...@apache.org>
Committed: Tue Dec 26 20:53:49 2017 +0100
----------------------------------------------------------------------
docs/dev/stream/state/state.md | 2 +-
docs/monitoring/metrics.md | 12 ++++++------
2 files changed, 7 insertions(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/d74869f8/docs/dev/stream/state/state.md
----------------------------------------------------------------------
diff --git a/docs/dev/stream/state/state.md b/docs/dev/stream/state/state.md
index e9770bd..9956998 100644
--- a/docs/dev/stream/state/state.md
+++ b/docs/dev/stream/state/state.md
@@ -397,7 +397,7 @@ class BufferingSink(threshold: Int = 0)
with CheckpointedRestoring[List[(String, Int)]] {
@transient
- private var checkpointedState: ListState[(String, Int)] = null
+ private var checkpointedState: ListState[(String, Int)] = _
private val bufferedElements = ListBuffer[(String, Int)]()
http://git-wip-us.apache.org/repos/asf/flink/blob/d74869f8/docs/monitoring/metrics.md
----------------------------------------------------------------------
diff --git a/docs/monitoring/metrics.md b/docs/monitoring/metrics.md
index 6c80036..eac73f7 100644
--- a/docs/monitoring/metrics.md
+++ b/docs/monitoring/metrics.md
@@ -69,7 +69,7 @@ public class MyMapper extends RichMapFunction<String, String> {
{% highlight scala %}
class MyMapper extends RichMapFunction[String,String] {
- @transient private var counter: Counter
+ @transient private var counter: Counter = _
override def open(parameters: Configuration): Unit = {
counter = getRuntimeContext()
@@ -119,7 +119,7 @@ public class MyMapper extends RichMapFunction<String, String> {
{% highlight scala %}
class MyMapper extends RichMapFunction[String,String] {
- @transient private var counter: Counter
+ @transient private var counter: Counter = _
override def open(parameters: Configuration): Unit = {
counter = getRuntimeContext()
@@ -229,7 +229,7 @@ public class MyMapper extends RichMapFunction<Long, Long> {
{% highlight scala %}
class MyMapper extends RichMapFunction[Long,Long] {
- @transient private var histogram: Histogram
+ @transient private var histogram: Histogram = _
override def open(parameters: Configuration): Unit = {
histogram = getRuntimeContext()
@@ -289,7 +289,7 @@ public class MyMapper extends RichMapFunction<Long, Long> {
{% highlight scala %}
class MyMapper extends RichMapFunction[Long, Long] {
- @transient private var histogram: Histogram
+ @transient private var histogram: Histogram = _
override def open(config: Configuration): Unit = {
com.codahale.metrics.Histogram dropwizardHistogram =
@@ -342,7 +342,7 @@ public class MyMapper extends RichMapFunction<Long, Long> {
{% highlight scala %}
class MyMapper extends RichMapFunction[Long,Long] {
- @transient private var meter: Meter
+ @transient private var meter: Meter = _
override def open(config: Configuration): Unit = {
meter = getRuntimeContext()
@@ -401,7 +401,7 @@ public class MyMapper extends RichMapFunction<Long, Long> {
{% highlight scala %}
class MyMapper extends RichMapFunction[Long,Long] {
- @transient private var meter: Meter
+ @transient private var meter: Meter = _
override def open(config: Configuration): Unit = {
com.codahale.metrics.Meter dropwizardMeter = new com.codahale.metrics.Meter()