flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From trohrm...@apache.org
Subject [flink] branch master updated (a6afeb4 -> e627037)
Date Fri, 01 Nov 2019 14:45:23 GMT
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


Mime
View raw message