From b8b0331247fe6d023d4da44868cb1f3526b62c62 Mon Sep 17 00:00:00 2001 From: David Anderson Date: Mon, 20 Apr 2020 10:43:34 +0200 Subject: [PATCH] [hotfix][docs] Fix overlapping text --- docs/fig/program_dataflow.svg | 1062 +++++++++++++++++---------------- 1 file changed, 542 insertions(+), 520 deletions(-) diff --git a/docs/fig/program_dataflow.svg b/docs/fig/program_dataflow.svg index 67ce15732ea7e..4565de713102c 100644 --- a/docs/fig/program_dataflow.svg +++ b/docs/fig/program_dataflow.svg @@ -1,34 +1,39 @@ - - - + width="632.86151" + version="1.1"> + image/svg+xml - + - - Source - DataStream - < - String - > - lines = - env. - addSource - ( - new - FlinkKafkaConsumer - <>(…)); - DataStream - < - Event - > events = - lines. - map - ((line) - - - > - parse - (line)); - DataStream - < - Statistics - > stats = events - . - keyBy - ( - "id" - ) - . - timeWindow - ( - Time.seconds - (10)) - . - apply - ( - new - MyWindowAggregationFunction - ()); - stats. - addSink - ( - new - BucketingSink - (path)); - - Source - - map() - - - - - - Transformation - Transformation - Source - Operator - - - keyBy - ()/ - window()/ - apply() - - - Sink - - Transformation - Operators - Sink - Operator - - - - - - Stream - - - Sink - - Streaming Dataflow - + Source + DataStream + < + String + > + lines = + env. + addSource + ( + new + FlinkKafkaConsumer + <>(…)); + DataStream + < + Event + > events = + lines. + map + ((line) + - + > + parse + (line)); + DataStream + < + Statistics + > stats = events + . + keyBy + ( + "id" + ) + . + timeWindow + ( + Time.seconds + (10)) + . + apply + ( + new + MyWindowAggregationFunction + ()); + stats. + addSink + ( + new + BucketingSink + (path)); + + Source + + map() + + + + + + Transformation + Transformation + Source + Operator + + + keyBy + ()/ + window()/ + apply() + + + Sink + + Transformation + Operators + Sink + Operator + + + + + + Stream + + + Sink + + Streaming Dataflow + - + id="tspan3259" />