This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from a6afeb4 [FLINK-12939][docs-zh] Translate "Apache Kafka Connector"
page into Chinese
add 7009ddb [hotfix][runtime] Fix code style violations in JobVertexD and
IntermediateDataSetID
add dbbbcdc [FLINK-14312][runtime] Introduce LogicalTopology
add ee2fb10 [FLINK-14312][runtime] Introduce LogicalPipelinedRegion
add e627037 [FLINK-14312][runtime] Introduce DefaultLogicalTopology
No new revisions were added by this update.
Summary of changes:
.../runtime/jobgraph/IntermediateDataSetID.java | 18 +--
.../apache/flink/runtime/jobgraph/JobVertexID.java | 8 +-
.../jobgraph/topology/DefaultLogicalResult.java | 74 ++++++++++++
.../jobgraph/topology/DefaultLogicalTopology.java | 114 ++++++++++++++++++
.../jobgraph/topology/DefaultLogicalVertex.java | 71 +++++++++++
.../topology/LogicalPipelinedRegion.java} | 31 +++--
.../topology/LogicalResult.java} | 14 +--
.../topology/LogicalTopology.java} | 13 +-
.../topology/LogicalVertex.java} | 14 +--
.../topology/DefaultLogicalResultTest.java | 129 ++++++++++++++++++++
.../topology/DefaultLogicalTopologyTest.java | 134 +++++++++++++++++++++
.../topology/DefaultLogicalVertexTest.java | 133 ++++++++++++++++++++
12 files changed, 714 insertions(+), 39 deletions(-)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/topology/DefaultLogicalResult.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/topology/DefaultLogicalTopology.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/topology/DefaultLogicalVertex.java
copy
flink-runtime/src/main/java/org/apache/flink/runtime/{scheduler/DefaultExecutionSlotAllocatorFactory.java
=> jobgraph/topology/LogicalPipelinedRegion.java} (55%)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/{executiongraph/failover/flip1/FailoverResultPartition.java
=> jobgraph/topology/LogicalResult.java} (60%)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/{executiongraph/failover/flip1/FailoverTopology.java
=> jobgraph/topology/LogicalTopology.java} (66%)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/{executiongraph/failover/flip1/FailoverVertex.java
=> jobgraph/topology/LogicalVertex.java} (63%)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/jobgraph/topology/DefaultLogicalResultTest.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/jobgraph/topology/DefaultLogicalTopologyTest.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/jobgraph/topology/DefaultLogicalVertexTest.java
