Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
doujutun3207
flink
提交
a88d6efc
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,发现更多精彩内容 >>
未验证
提交
a88d6efc
编写于
7月 16, 2018
作者:
T
Till Rohrmann
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
[hotfix] Add EXCLUSIONS set to ConfigOptionsDocGenerator
上级
dbddf00b
变更
1
隐藏空白更改
内联
并排
Showing
1 changed file
with
17 addition
and
6 deletion
+17
-6
flink-docs/src/main/java/org/apache/flink/docs/configuration/ConfigOptionsDocGenerator.java
...e/flink/docs/configuration/ConfigOptionsDocGenerator.java
+17
-6
未找到文件。
flink-docs/src/main/java/org/apache/flink/docs/configuration/ConfigOptionsDocGenerator.java
浏览文件 @
a88d6efc
...
...
@@ -26,8 +26,6 @@ import org.apache.flink.api.java.tuple.Tuple2;
import
org.apache.flink.configuration.ConfigOption
;
import
org.apache.flink.util.function.ThrowingConsumer
;
import
static
org
.
apache
.
flink
.
docs
.
util
.
Utils
.
escapeCharacters
;
import
java.io.IOException
;
import
java.lang.reflect.Field
;
import
java.nio.charset.StandardCharsets
;
...
...
@@ -36,15 +34,20 @@ import java.nio.file.Files;
import
java.nio.file.Path
;
import
java.nio.file.Paths
;
import
java.util.ArrayList
;
import
java.util.Arrays
;
import
java.util.Collection
;
import
java.util.Collections
;
import
java.util.Comparator
;
import
java.util.HashMap
;
import
java.util.HashSet
;
import
java.util.List
;
import
java.util.Map
;
import
java.util.Set
;
import
java.util.regex.Matcher
;
import
java.util.regex.Pattern
;
import
static
org
.
apache
.
flink
.
docs
.
util
.
Utils
.
escapeCharacters
;
/**
* Class used for generating code based documentation of configuration parameters.
*/
...
...
@@ -56,9 +59,13 @@ public class ConfigOptionsDocGenerator {
new
OptionsClassLocation
(
"flink-yarn"
,
"org.apache.flink.yarn.configuration"
),
new
OptionsClassLocation
(
"flink-mesos"
,
"org.apache.flink.mesos.configuration"
),
new
OptionsClassLocation
(
"flink-mesos"
,
"org.apache.flink.mesos.runtime.clusterframework"
),
new
OptionsClassLocation
(
"flink-metrics/flink-metrics-prometheus"
,
"org.apache.flink.metrics.prometheus"
)
,
new
OptionsClassLocation
(
"flink-metrics/flink-metrics-prometheus"
,
"org.apache.flink.metrics.prometheus"
)
};
static
final
Set
<
String
>
EXCLUSIONS
=
new
HashSet
<>(
Arrays
.
asList
(
"org.apache.flink.configuration.ConfigOptions"
,
"org.apache.flink.contrib.streaming.state.PredefinedOptions"
));
static
final
String
DEFAULT_PATH_PREFIX
=
"src/main/java"
;
@VisibleForTesting
...
...
@@ -149,9 +156,13 @@ public class ConfigOptionsDocGenerator {
for
(
Path
entry
:
stream
)
{
String
fileName
=
entry
.
getFileName
().
toString
();
Matcher
matcher
=
CLASS_NAME_PATTERN
.
matcher
(
fileName
);
if
(!
fileName
.
equals
(
"ConfigOptions.java"
)
&&
matcher
.
matches
())
{
Class
<?>
optionsClass
=
Class
.
forName
(
packageName
+
'.'
+
matcher
.
group
(
CLASS_NAME_GROUP
));
classConsumer
.
accept
(
optionsClass
);
if
(
matcher
.
matches
())
{
final
String
className
=
packageName
+
'.'
+
matcher
.
group
(
CLASS_NAME_GROUP
);
if
(!
EXCLUSIONS
.
contains
(
className
))
{
Class
<?>
optionsClass
=
Class
.
forName
(
className
);
classConsumer
.
accept
(
optionsClass
);
}
}
}
}
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录