Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
doujutun3207
flink
提交
912f8d90
F
flink
项目概览
doujutun3207
/
flink
与 Fork 源项目一致
从无法访问的项目Fork
通知
24
Star
0
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
F
flink
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
体验新版 GitCode,发现更多精彩内容 >>
提交
912f8d90
编写于
5月 19, 2015
作者:
V
vasia
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
[gelly] renamed IncrementalSSSPExample -> IncrementalSSSP to match the new examples naming scheme
上级
a067d59c
变更
2
隐藏空白更改
内联
并排
Showing
2 changed file
with
8 addition
and
8 deletion
+8
-8
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/IncrementalSSSP.java
.../java/org/apache/flink/graph/example/IncrementalSSSP.java
+2
-2
flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/example/IncrementalSSSPITCase.java
...pache/flink/graph/test/example/IncrementalSSSPITCase.java
+6
-6
未找到文件。
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/IncrementalSSSP
Example
.java
→
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/IncrementalSSSP.java
浏览文件 @
912f8d90
...
...
@@ -60,14 +60,14 @@ import org.apache.flink.graph.utils.Tuple3ToEdgeMap;
* The propagation stops when a vertex with an alternative shortest path is reached
* or when we reach a vertex with no SP-in-neighbors.
*
* Usage <code>IncrementalSSSP
Example
<vertex path> <edge path> <edges in SSSP>
* Usage <code>IncrementalSSSP <vertex path> <edge path> <edges in SSSP>
* <src id edge to be removed> <trg id edge to be removed> <val edge to be removed>
* <result path> <number of iterations></code><br>
* If no parameters are provided, the program is run with default data from
* {@link org.apache.flink.graph.example.utils.IncrementalSSSPData}
*/
@SuppressWarnings
(
"serial"
)
public
class
IncrementalSSSP
Example
implements
ProgramDescription
{
public
class
IncrementalSSSP
implements
ProgramDescription
{
public
static
void
main
(
String
[]
args
)
throws
Exception
{
...
...
flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/example/IncrementalSSSPITCase.java
浏览文件 @
912f8d90
...
...
@@ -26,7 +26,7 @@ import org.apache.flink.graph.Edge;
import
org.apache.flink.graph.EdgeDirection
;
import
org.apache.flink.graph.Graph
;
import
org.apache.flink.graph.Vertex
;
import
org.apache.flink.graph.example.IncrementalSSSP
Example
;
import
org.apache.flink.graph.example.IncrementalSSSP
;
import
org.apache.flink.graph.example.utils.IncrementalSSSPData
;
import
org.apache.flink.graph.spargel.VertexCentricConfiguration
;
import
org.apache.flink.test.util.MultipleProgramsTestBase
;
...
...
@@ -78,8 +78,8 @@ public class IncrementalSSSPITCase extends MultipleProgramsTestBase {
}
@Test
public
void
testIncrementalSSSP
Example
()
throws
Exception
{
IncrementalSSSP
Example
.
main
(
new
String
[]{
verticesPath
,
edgesPath
,
edgesInSSSPPath
,
public
void
testIncrementalSSSP
()
throws
Exception
{
IncrementalSSSP
.
main
(
new
String
[]{
verticesPath
,
edgesPath
,
edgesInSSSPPath
,
IncrementalSSSPData
.
SRC_EDGE_TO_BE_REMOVED
,
IncrementalSSSPData
.
TRG_EDGE_TO_BE_REMOVED
,
IncrementalSSSPData
.
VAL_EDGE_TO_BE_REMOVED
,
resultPath
,
IncrementalSSSPData
.
NUM_VERTICES
+
""
});
expected
=
IncrementalSSSPData
.
RESULTED_VERTICES
;
...
...
@@ -103,15 +103,15 @@ public class IncrementalSSSPITCase extends MultipleProgramsTestBase {
// configure the iteration
VertexCentricConfiguration
parameters
=
new
VertexCentricConfiguration
();
if
(
IncrementalSSSP
Example
.
isInSSSP
(
edgeToBeRemoved
,
edgesInSSSP
))
{
if
(
IncrementalSSSP
.
isInSSSP
(
edgeToBeRemoved
,
edgesInSSSP
))
{
parameters
.
setDirection
(
EdgeDirection
.
IN
);
parameters
.
setOptDegrees
(
true
);
// run the vertex centric iteration to propagate info
Graph
<
Long
,
Double
,
Double
>
result
=
ssspGraph
.
runVertexCentricIteration
(
new
IncrementalSSSP
Example
.
VertexDistanceUpdater
(),
new
IncrementalSSSP
Example
.
InvalidateMessenger
(
edgeToBeRemoved
),
new
IncrementalSSSP
.
VertexDistanceUpdater
(),
new
IncrementalSSSP
.
InvalidateMessenger
(
edgeToBeRemoved
),
IncrementalSSSPData
.
NUM_VERTICES
,
parameters
);
DataSet
<
Vertex
<
Long
,
Double
>>
resultedVertices
=
result
.
getVertices
();
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录