Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
s920243400
PaddleDetection
提交
60d71a9e
P
PaddleDetection
项目概览
s920243400
/
PaddleDetection
与 Fork 源项目一致
Fork自
PaddlePaddle / PaddleDetection
通知
2
Star
0
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
P
PaddleDetection
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
提交
60d71a9e
编写于
12月 11, 2018
作者:
H
heqiaozhi
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
skip op py file
上级
016a0687
变更
3
隐藏空白更改
内联
并排
Showing
3 changed file
with
52 addition
and
44 deletion
+52
-44
python/paddle/fluid/distributed/downpour.py
python/paddle/fluid/distributed/downpour.py
+1
-0
python/paddle/fluid/distributed/node.py
python/paddle/fluid/distributed/node.py
+1
-1
python/paddle/fluid/distributed/ps_pb2.py
python/paddle/fluid/distributed/ps_pb2.py
+50
-43
未找到文件。
python/paddle/fluid/distributed/downpour.py
浏览文件 @
60d71a9e
...
...
@@ -66,5 +66,6 @@ class DownpourSGD(object):
# Todo(guru4elephant): figure out how to support more sparse parameters
# currently only support lookup_table
worker_skipped_ops
=
[
"lookup_table"
,
"lookup_table_grad"
]
ps_param
.
trainer_param
.
skip_op
.
extend
(
worker_skipped_ops
)
ps_param_str
=
text_format
.
MessageToString
(
ps_param
)
return
[
ps_param
,
worker_skipped_ops
]
python/paddle/fluid/distributed/node.py
浏览文件 @
60d71a9e
...
...
@@ -60,7 +60,7 @@ class DownpourServer(Server):
table
.
accessor
.
dense_sgd_param
.
adam
.
mom_decay_rate
=
0.99
table
.
accessor
.
dense_sgd_param
.
naive
.
learning_rate
=
0.0002
fea_dim
=
0
for
param
in
param_var
:
for
param
in
filter
(
lambda
x
:
x
.
name
.
find
(
"embedding"
)
==
-
1
,
param_var
)
:
fea_dim
+=
reduce
(
lambda
x
,
y
:
x
*
y
,
param
.
shape
,
1
)
table
.
accessor
.
fea_dim
=
fea_dim
...
...
python/paddle/fluid/distributed/ps_pb2.py
浏览文件 @
60d71a9e
...
...
@@ -20,7 +20,7 @@ DESCRIPTOR = _descriptor.FileDescriptor(
name
=
'ps.proto'
,
package
=
'paddle'
,
syntax
=
'proto2'
,
serialized_pb
=
_b
(
'
\n\x08
ps.proto
\x12\x06
paddle
\"\x9e\x02\n\x0b
PSParameter
\x12\x14\n\x0c
worker_class
\x18\x01
\x01
(
\t\x12\x14\n\x0c
server_class
\x18\x02
\x01
(
\t\x12\x16\n\x0e
instance_class
\x18\x03
\x01
(
\t\x12
-
\n\x0c
worker_param
\x18\x65
\x01
(
\x0b\x32\x17
.paddle.WorkerParameter
\x12
-
\n\x0c
server_param
\x18\x66
\x01
(
\x0b\x32\x17
.paddle.ServerParameter
\x12\x38\n\r
trainer_param
\x18\xad\x02
\x01
(
\x0b\x32
.paddle.DownpourTrainerParameter
\x12\x33\n\x0f\x66
s_client_param
\x18\xf5\x03
\x01
(
\x0b\x32\x19
.paddle.FsClientParameter
\"
Q
\n\x0f
WorkerParameter
\x12
>
\n\x15\x64
ownpour_worker_param
\x18\x01
\x01
(
\x0b\x32\x1f
.paddle.DownpourWorkerParameter
\"
Q
\n\x0f
ServerParameter
\x12
>
\n\x15\x64
ownpour_server_param
\x18\x01
\x01
(
\x0b\x32\x1f
.paddle.DownpourServerParameter
\"
O
\n\x17\x44
ownpourWorkerParameter
\x12\x34\n\x14\x64
ownpour_table_param
\x18\x01
\x03
(
\x0b\x32\x16
.paddle.TableParameter
\"\x
bc\x01\n\x18\x44
ownpourTrainerParameter
\x12\x30\n\x0b\x64\x65
nse_table
\x18\x01
\x03
(
\x0b\x32\x1b
.paddle.DenseTableParameter
\x12\x32\n\x0c
sparse_table
\x18\x02
\x03
(
\x0b\x32\x1c
.paddle.SparseTableParameter
\x12\x1c\n\x14
pull_dense_per_batch
\x18\x03
\x01
(
\x05\x12\x1c\n\x14
push_dense_per_batch
\x18\x04
\x01
(
\x05\"
{
\n\x13\x44\x65
nseTableParameter
\x12\x10\n\x08
table_id
\x18\x01
\x01
(
\x05\x12\x1b\n\x13\x64\x65
nse_variable_name
\x18\x02
\x03
(
\t\x12
$
\n\x1c\x64\x65
nse_gradient_variable_name
\x18\x03
\x03
(
\t\x12\x0f\n\x07\x66\x65\x61
_dim
\x18\x04
\x01
(
\x05\"
z
\n\x14
SparseTableParameter
\x12\x10\n\x08
table_id
\x18\x01
\x01
(
\x05\x12\x13\n\x0b\x66\x65\x61
ture_dim
\x18\x02
\x01
(
\x05\x12\x10\n\x08
slot_key
\x18\x03
\x03
(
\t\x12\x12\n\n
slot_value
\x18\x04
\x03
(
\t\x12\x15\n\r
slot_gradient
\x18\x05
\x03
(
\t\"\x86\x01\n\x17\x44
ownpourServerParameter
\x12\x34\n\x14\x64
ownpour_table_param
\x18\x01
\x03
(
\x0b\x32\x16
.paddle.TableParameter
\x12\x35\n\r
service_param
\x18\x02
\x01
(
\x0b\x32\x1e
.paddle.ServerServiceParameter
\"\xd1\x01\n\x16
ServerServiceParameter
\x12
(
\n\x0c
server_class
\x18\x01
\x01
(
\t
:
\x12\x41\x62\x61\x63
usBrpcPsServer
\x12
(
\n\x0c\x63
lient_class
\x18\x02
\x01
(
\t
:
\x12\x41\x62\x61\x63
usBrpcPsClient
\x12
&
\n\r
service_class
\x18\x03
\x01
(
\t
:
\x0f\x41\x62\x61\x63
us
PsService
\x12\x1c\n\x11
start_server_port
\x18\x04
\x01
(
\r
:
\x01\x30\x12\x1d\n\x11
server_thread_num
\x18\x05
\x01
(
\r
:
\x02\x31\x32\"\xbf\x01\n\x0e
TableParameter
\x12\x10\n\x08
table_id
\x18\x01
\x01
(
\x04\x12\x13\n\x0b
table_class
\x18\x02
\x01
(
\t\x12\x12\n\n
shared_num
\x18\x03
\x01
(
\x04\x12\x30\n\x08\x61\x63\x63\x65
ssor
\x18\x04
\x01
(
\x0b\x32\x1e
.paddle.TableAccessorParameter
\x12\x1f\n\x04
type
\x18\x05
\x01
(
\x0e\x32\x11
.paddle.TableType
\x12\x1f\n\x10\x63
ompress_in_save
\x18\x06
\x01
(
\x08
:
\x05\x66\x61
lse
\"\xf1\x02\n\x16
TableAccessorParameter
\x12\x16\n\x0e\x61\x63\x63\x65
ssor_class
\x18\x01
\x01
(
\t\x12\x38\n\x10
sparse_sgd_param
\x18\x02
\x01
(
\x0b\x32\x1e
.paddle.SparseSGDRuleParameter
\x12\x36\n\x0f\x64\x65
nse_sgd_param
\x18\x03
\x01
(
\x0b\x32\x1d
.paddle.DenseSGDRuleParameter
\x12\x0f\n\x07\x66\x65\x61
_dim
\x18\x04
\x01
(
\r\x12\x12\n\n
embedx_dim
\x18\x05
\x01
(
\r\x12\x18\n\x10\x65
mbedx_threshold
\x18\x06
\x01
(
\r\x12
G
\n\x17\x64
ownpour_accessor_param
\x18\x07
\x01
(
\x0b\x32
&.paddle.DownpourTableAccessorParameter
\x12\x45\n\x19
table_accessor_save_param
\x18\x08
\x03
(
\x0b\x32\"
.paddle.TableAccessorSaveParameter
\"\xce\x01\n\x1e\x44
ownpourTableAccessorParameter
\x12\x14\n\x0c
nonclk_coeff
\x18\x01
\x01
(
\x02\x12\x13\n\x0b\x63
lick_coeff
\x18\x02
\x01
(
\x02\x12\x16\n\x0e\x62\x61
se_threshold
\x18\x03
\x01
(
\x02\x12\x17\n\x0f\x64\x65
lta_threshold
\x18\x04
\x01
(
\x02\x12\x17\n\x0f\x64\x65
lta_keep_days
\x18\x05
\x01
(
\x02\x12\x1d\n\x15
show_click_decay_rate
\x18\x06
\x01
(
\x02\x12\x18\n\x10\x64\x65
lete_threshold
\x18\x07
\x01
(
\x02\"
S
\n\x1a
TableAccessorSaveParameter
\x12\r\n\x05
param
\x18\x01
\x01
(
\r\x12\x11\n\t
converter
\x18\x02
\x01
(
\t\x12\x13\n\x0b\x64\x65\x63
onverter
\x18\x03
\x01
(
\t\"
e
\n\x10
PsRequestMessage
\x12\x0e\n\x06\x63
md_id
\x18\x01
\x02
(
\r\x12\x10\n\x08
table_id
\x18\x02
\x01
(
\r\x12\x0e\n\x06
params
\x18\x03
\x03
(
\x0c\x12\x11\n\t
client_id
\x18\x04
\x01
(
\x05\x12\x0c\n\x04\x64\x61
ta
\x18\x05
\x01
(
\x0c\"
w
\n\x16
SparseSGDRuleParameter
\x12\x15\n\r
learning_rate
\x18\x01
\x01
(
\x01\x12\x15\n\r
initial_g2sum
\x18\x02
\x01
(
\x01\x12\x18\n\r
initial_range
\x18\x03
\x01
(
\x01
:
\x01\x30\x12\x15\n\r
weight_bounds
\x18\x04
\x03
(
\x02\"\xe1\x01\n\x15\x44\x65
nseSGDRuleParameter
\x12\x0c\n\x04
name
\x18\x01
\x01
(
\t\x12
&
\n\x04\x61\x64\x61
m
\x18\x02
\x01
(
\x0b\x32\x18
.paddle.AdamSGDParameter
\x12
(
\n\x05
naive
\x18\x03
\x01
(
\x0b\x32\x19
.paddle.NaiveSGDParameter
\x12
,
\n\x07
summary
\x18\x04
\x01
(
\x0b\x32\x1b
.paddle.SummarySGDParameter
\x12
:
\n\x0e
moving_average
\x18\x05
\x01
(
\x0b\x32\"
.paddle.MovingAverageRuleParameter
\"\x86\x01\n\x10\x41\x64\x61
mSGDParameter
\x12\x15\n\r
learning_rate
\x18\x01
\x01
(
\x01\x12\x16\n\x0e\x61
vg_decay_rate
\x18\x02
\x01
(
\x01\x12\x16\n\x0e\x61\x64\x61
_decay_rate
\x18\x03
\x01
(
\x01\x12\x13\n\x0b\x61\x64\x61
_epsilon
\x18\x04
\x01
(
\x01\x12\x16\n\x0e
mom_decay_rate
\x18\x05
\x01
(
\x01\"
B
\n\x11
NaiveSGDParameter
\x12\x15\n\r
learning_rate
\x18\x01
\x01
(
\x01\x12\x16\n\x0e\x61
vg_decay_rate
\x18\x02
\x01
(
\x01\"
;
\n\x13
SummarySGDParameter
\x12
$
\n\x12
summary_decay_rate
\x18\x01
\x01
(
\x01
:
\x08\x30
.999999
\"
.
\n\x1a
MovingAverageRuleParameter
\x12\x10\n\x08
momentum
\x18\x01
\x01
(
\x01\"
I
\n\x11
PsResponseMessage
\x12\x13\n\x08\x65
rr_code
\x18\x01
\x02
(
\x05
:
\x01\x30\x12\x11\n\x07\x65
rr_msg
\x18\x02
\x02
(
\t
:
\x00\x12\x0c\n\x04\x64\x61
ta
\x18\x03
\x01
(
\x0c\"\xd5\x01\n\x11\x46
sClientParameter
\x12
:
\n\x07\x66
s_type
\x18\x01
\x01
(
\x0e\x32
#.paddle.FsClientParameter.FsApiType:
\x04
HDFS
\x12\x0b\n\x03
uri
\x18\x02
\x01
(
\t\x12\x0c\n\x04
user
\x18\x03
\x01
(
\t\x12\x0e\n\x06
passwd
\x18\x04
\x01
(
\t\x12\x13\n\x0b\x62
uffer_size
\x18\x05
\x01
(
\x05\x12\x12\n\n
hadoop_bin
\x18\x33
\x01
(
\t\x12\x10\n\x08\x61\x66
s_conf
\x18\x65
\x01
(
\t\"\x1e\n\t
FsApiType
\x12\x08\n\x04
HDFS
\x10\x00\x12\x07\n\x03\x41\x46
S
\x10\x01
*4
\n\t
TableType
\x12\x13\n\x0f
PS_SPARSE_TABLE
\x10\x00\x12\x12\n\x0e
PS_DENSE_TABLE
\x10\x01
*
\xbd\x02\n\x07
PsCmdID
\x12\x17\n\x13
PS_PULL_DENSE_TABLE
\x10\x00\x12\x17\n\x13
PS_PUSH_DENSE_TABLE
\x10\x01\x12\x18\n\x14
PS_PULL_SPARSE_TABLE
\x10\x02\x12\x18\n\x14
PS_PUSH_SPARSE_TABLE
\x10\x03\x12\x13\n\x0f
PS_SHRINK_TABLE
\x10\x04\x12\x15\n\x11
PS_SAVE_ONE_TABLE
\x10\x05\x12\x15\n\x11
PS_SAVE_ALL_TABLE
\x10\x06\x12\x15\n\x11
PS_LOAD_ONE_TABLE
\x10\x07\x12\x15\n\x11
PS_LOAD_ALL_TABLE
\x10\x08\x12\x16\n\x12
PS_CLEAR_ONE_TABLE
\x10\t\x12\x16\n\x12
PS_CLEAR_ALL_TABLE
\x10\n\x12\x17\n\x13
PS_PUSH_DENSE_PARAM
\x10\x0b\x12\x12\n\x0e
PS_STOP_SERVER
\x10\x0c\x32
K
\n\t
PsService
\x12
>
\n\x07
service
\x12\x18
.paddle.PsRequestMessage
\x1a\x19
.paddle.PsResponseMessageB
\x03\x80\x01\x01
'
)
serialized_pb
=
_b
(
'
\n\x08
ps.proto
\x12\x06
paddle
\"\x9e\x02\n\x0b
PSParameter
\x12\x14\n\x0c
worker_class
\x18\x01
\x01
(
\t\x12\x14\n\x0c
server_class
\x18\x02
\x01
(
\t\x12\x16\n\x0e
instance_class
\x18\x03
\x01
(
\t\x12
-
\n\x0c
worker_param
\x18\x65
\x01
(
\x0b\x32\x17
.paddle.WorkerParameter
\x12
-
\n\x0c
server_param
\x18\x66
\x01
(
\x0b\x32\x17
.paddle.ServerParameter
\x12\x38\n\r
trainer_param
\x18\xad\x02
\x01
(
\x0b\x32
.paddle.DownpourTrainerParameter
\x12\x33\n\x0f\x66
s_client_param
\x18\xf5\x03
\x01
(
\x0b\x32\x19
.paddle.FsClientParameter
\"
Q
\n\x0f
WorkerParameter
\x12
>
\n\x15\x64
ownpour_worker_param
\x18\x01
\x01
(
\x0b\x32\x1f
.paddle.DownpourWorkerParameter
\"
Q
\n\x0f
ServerParameter
\x12
>
\n\x15\x64
ownpour_server_param
\x18\x01
\x01
(
\x0b\x32\x1f
.paddle.DownpourServerParameter
\"
O
\n\x17\x44
ownpourWorkerParameter
\x12\x34\n\x14\x64
ownpour_table_param
\x18\x01
\x03
(
\x0b\x32\x16
.paddle.TableParameter
\"\x
ce\x01\n\x18\x44
ownpourTrainerParameter
\x12\x30\n\x0b\x64\x65
nse_table
\x18\x01
\x03
(
\x0b\x32\x1b
.paddle.DenseTableParameter
\x12\x32\n\x0c
sparse_table
\x18\x02
\x03
(
\x0b\x32\x1c
.paddle.SparseTableParameter
\x12\x1d\n\x15
push_sparse_per_batch
\x18\x03
\x01
(
\x05\x12\x1c\n\x14
push_dense_per_batch
\x18\x04
\x01
(
\x05\x12\x0f\n\x07
skip_op
\x18\x05
\x03
(
\t\"
{
\n\x13\x44\x65
nseTableParameter
\x12\x10\n\x08
table_id
\x18\x01
\x01
(
\x05\x12\x1b\n\x13\x64\x65
nse_variable_name
\x18\x02
\x03
(
\t\x12
$
\n\x1c\x64\x65
nse_gradient_variable_name
\x18\x03
\x03
(
\t\x12\x0f\n\x07\x66\x65\x61
_dim
\x18\x04
\x01
(
\x05\"
z
\n\x14
SparseTableParameter
\x12\x10\n\x08
table_id
\x18\x01
\x01
(
\x05\x12\x13\n\x0b\x66\x65\x61
ture_dim
\x18\x02
\x01
(
\x05\x12\x10\n\x08
slot_key
\x18\x03
\x03
(
\t\x12\x12\n\n
slot_value
\x18\x04
\x03
(
\t\x12\x15\n\r
slot_gradient
\x18\x05
\x03
(
\t\"\x86\x01\n\x17\x44
ownpourServerParameter
\x12\x34\n\x14\x64
ownpour_table_param
\x18\x01
\x03
(
\x0b\x32\x16
.paddle.TableParameter
\x12\x35\n\r
service_param
\x18\x02
\x01
(
\x0b\x32\x1e
.paddle.ServerServiceParameter
\"\xd7\x01\n\x16
ServerServiceParameter
\x12
*
\n\x0c
server_class
\x18\x01
\x01
(
\t
:
\x14\x44
ownpourBrpcPsServer
\x12
*
\n\x0c\x63
lient_class
\x18\x02
\x01
(
\t
:
\x14\x44
ownpourBrpcPsClient
\x12
(
\n\r
service_class
\x18\x03
\x01
(
\t
:
\x11\x44
ownpour
PsService
\x12\x1c\n\x11
start_server_port
\x18\x04
\x01
(
\r
:
\x01\x30\x12\x1d\n\x11
server_thread_num
\x18\x05
\x01
(
\r
:
\x02\x31\x32\"\xbf\x01\n\x0e
TableParameter
\x12\x10\n\x08
table_id
\x18\x01
\x01
(
\x04\x12\x13\n\x0b
table_class
\x18\x02
\x01
(
\t\x12\x12\n\n
shared_num
\x18\x03
\x01
(
\x04\x12\x30\n\x08\x61\x63\x63\x65
ssor
\x18\x04
\x01
(
\x0b\x32\x1e
.paddle.TableAccessorParameter
\x12\x1f\n\x04
type
\x18\x05
\x01
(
\x0e\x32\x11
.paddle.TableType
\x12\x1f\n\x10\x63
ompress_in_save
\x18\x06
\x01
(
\x08
:
\x05\x66\x61
lse
\"\xf1\x02\n\x16
TableAccessorParameter
\x12\x16\n\x0e\x61\x63\x63\x65
ssor_class
\x18\x01
\x01
(
\t\x12\x38\n\x10
sparse_sgd_param
\x18\x02
\x01
(
\x0b\x32\x1e
.paddle.SparseSGDRuleParameter
\x12\x36\n\x0f\x64\x65
nse_sgd_param
\x18\x03
\x01
(
\x0b\x32\x1d
.paddle.DenseSGDRuleParameter
\x12\x0f\n\x07\x66\x65\x61
_dim
\x18\x04
\x01
(
\r\x12\x12\n\n
embedx_dim
\x18\x05
\x01
(
\r\x12\x18\n\x10\x65
mbedx_threshold
\x18\x06
\x01
(
\r\x12
G
\n\x17\x64
ownpour_accessor_param
\x18\x07
\x01
(
\x0b\x32
&.paddle.DownpourTableAccessorParameter
\x12\x45\n\x19
table_accessor_save_param
\x18\x08
\x03
(
\x0b\x32\"
.paddle.TableAccessorSaveParameter
\"\xce\x01\n\x1e\x44
ownpourTableAccessorParameter
\x12\x14\n\x0c
nonclk_coeff
\x18\x01
\x01
(
\x02\x12\x13\n\x0b\x63
lick_coeff
\x18\x02
\x01
(
\x02\x12\x16\n\x0e\x62\x61
se_threshold
\x18\x03
\x01
(
\x02\x12\x17\n\x0f\x64\x65
lta_threshold
\x18\x04
\x01
(
\x02\x12\x17\n\x0f\x64\x65
lta_keep_days
\x18\x05
\x01
(
\x02\x12\x1d\n\x15
show_click_decay_rate
\x18\x06
\x01
(
\x02\x12\x18\n\x10\x64\x65
lete_threshold
\x18\x07
\x01
(
\x02\"
S
\n\x1a
TableAccessorSaveParameter
\x12\r\n\x05
param
\x18\x01
\x01
(
\r\x12\x11\n\t
converter
\x18\x02
\x01
(
\t\x12\x13\n\x0b\x64\x65\x63
onverter
\x18\x03
\x01
(
\t\"
e
\n\x10
PsRequestMessage
\x12\x0e\n\x06\x63
md_id
\x18\x01
\x02
(
\r\x12\x10\n\x08
table_id
\x18\x02
\x01
(
\r\x12\x0e\n\x06
params
\x18\x03
\x03
(
\x0c\x12\x11\n\t
client_id
\x18\x04
\x01
(
\x05\x12\x0c\n\x04\x64\x61
ta
\x18\x05
\x01
(
\x0c\"
w
\n\x16
SparseSGDRuleParameter
\x12\x15\n\r
learning_rate
\x18\x01
\x01
(
\x01\x12\x15\n\r
initial_g2sum
\x18\x02
\x01
(
\x01\x12\x18\n\r
initial_range
\x18\x03
\x01
(
\x01
:
\x01\x30\x12\x15\n\r
weight_bounds
\x18\x04
\x03
(
\x02\"\xe1\x01\n\x15\x44\x65
nseSGDRuleParameter
\x12\x0c\n\x04
name
\x18\x01
\x01
(
\t\x12
&
\n\x04\x61\x64\x61
m
\x18\x02
\x01
(
\x0b\x32\x18
.paddle.AdamSGDParameter
\x12
(
\n\x05
naive
\x18\x03
\x01
(
\x0b\x32\x19
.paddle.NaiveSGDParameter
\x12
,
\n\x07
summary
\x18\x04
\x01
(
\x0b\x32\x1b
.paddle.SummarySGDParameter
\x12
:
\n\x0e
moving_average
\x18\x05
\x01
(
\x0b\x32\"
.paddle.MovingAverageRuleParameter
\"\x86\x01\n\x10\x41\x64\x61
mSGDParameter
\x12\x15\n\r
learning_rate
\x18\x01
\x01
(
\x01\x12\x16\n\x0e\x61
vg_decay_rate
\x18\x02
\x01
(
\x01\x12\x16\n\x0e\x61\x64\x61
_decay_rate
\x18\x03
\x01
(
\x01\x12\x13\n\x0b\x61\x64\x61
_epsilon
\x18\x04
\x01
(
\x01\x12\x16\n\x0e
mom_decay_rate
\x18\x05
\x01
(
\x01\"
B
\n\x11
NaiveSGDParameter
\x12\x15\n\r
learning_rate
\x18\x01
\x01
(
\x01\x12\x16\n\x0e\x61
vg_decay_rate
\x18\x02
\x01
(
\x01\"
;
\n\x13
SummarySGDParameter
\x12
$
\n\x12
summary_decay_rate
\x18\x01
\x01
(
\x01
:
\x08\x30
.999999
\"
.
\n\x1a
MovingAverageRuleParameter
\x12\x10\n\x08
momentum
\x18\x01
\x01
(
\x01\"
I
\n\x11
PsResponseMessage
\x12\x13\n\x08\x65
rr_code
\x18\x01
\x02
(
\x05
:
\x01\x30\x12\x11\n\x07\x65
rr_msg
\x18\x02
\x02
(
\t
:
\x00\x12\x0c\n\x04\x64\x61
ta
\x18\x03
\x01
(
\x0c\"\xd5\x01\n\x11\x46
sClientParameter
\x12
:
\n\x07\x66
s_type
\x18\x01
\x01
(
\x0e\x32
#.paddle.FsClientParameter.FsApiType:
\x04
HDFS
\x12\x0b\n\x03
uri
\x18\x02
\x01
(
\t\x12\x0c\n\x04
user
\x18\x03
\x01
(
\t\x12\x0e\n\x06
passwd
\x18\x04
\x01
(
\t\x12\x13\n\x0b\x62
uffer_size
\x18\x05
\x01
(
\x05\x12\x12\n\n
hadoop_bin
\x18\x33
\x01
(
\t\x12\x10\n\x08\x61\x66
s_conf
\x18\x65
\x01
(
\t\"\x1e\n\t
FsApiType
\x12\x08\n\x04
HDFS
\x10\x00\x12\x07\n\x03\x41\x46
S
\x10\x01
*4
\n\t
TableType
\x12\x13\n\x0f
PS_SPARSE_TABLE
\x10\x00\x12\x12\n\x0e
PS_DENSE_TABLE
\x10\x01
*
\xbd\x02\n\x07
PsCmdID
\x12\x17\n\x13
PS_PULL_DENSE_TABLE
\x10\x00\x12\x17\n\x13
PS_PUSH_DENSE_TABLE
\x10\x01\x12\x18\n\x14
PS_PULL_SPARSE_TABLE
\x10\x02\x12\x18\n\x14
PS_PUSH_SPARSE_TABLE
\x10\x03\x12\x13\n\x0f
PS_SHRINK_TABLE
\x10\x04\x12\x15\n\x11
PS_SAVE_ONE_TABLE
\x10\x05\x12\x15\n\x11
PS_SAVE_ALL_TABLE
\x10\x06\x12\x15\n\x11
PS_LOAD_ONE_TABLE
\x10\x07\x12\x15\n\x11
PS_LOAD_ALL_TABLE
\x10\x08\x12\x16\n\x12
PS_CLEAR_ONE_TABLE
\x10\t\x12\x16\n\x12
PS_CLEAR_ALL_TABLE
\x10\n\x12\x17\n\x13
PS_PUSH_DENSE_PARAM
\x10\x0b\x12\x12\n\x0e
PS_STOP_SERVER
\x10\x0c\x32
K
\n\t
PsService
\x12
>
\n\x07
service
\x12\x18
.paddle.PsRequestMessage
\x1a\x19
.paddle.PsResponseMessageB
\x03\x80\x01\x01
'
)
)
_sym_db
.
RegisterFileDescriptor
(
DESCRIPTOR
)
...
...
@@ -41,8 +41,8 @@ _TABLETYPE = _descriptor.EnumDescriptor(
],
containing_type
=
None
,
options
=
None
,
serialized_start
=
32
62
,
serialized_end
=
33
14
,
serialized_start
=
32
86
,
serialized_end
=
33
38
,
)
_sym_db
.
RegisterEnumDescriptor
(
_TABLETYPE
)
...
...
@@ -108,8 +108,8 @@ _PSCMDID = _descriptor.EnumDescriptor(
],
containing_type
=
None
,
options
=
None
,
serialized_start
=
33
17
,
serialized_end
=
36
34
,
serialized_start
=
33
41
,
serialized_end
=
36
58
,
)
_sym_db
.
RegisterEnumDescriptor
(
_PSCMDID
)
...
...
@@ -148,8 +148,8 @@ _FSCLIENTPARAMETER_FSAPITYPE = _descriptor.EnumDescriptor(
],
containing_type
=
None
,
options
=
None
,
serialized_start
=
32
30
,
serialized_end
=
32
60
,
serialized_start
=
32
54
,
serialized_end
=
32
84
,
)
_sym_db
.
RegisterEnumDescriptor
(
_FSCLIENTPARAMETER_FSAPITYPE
)
...
...
@@ -342,7 +342,7 @@ _DOWNPOURTRAINERPARAMETER = _descriptor.Descriptor(
is_extension
=
False
,
extension_scope
=
None
,
options
=
None
),
_descriptor
.
FieldDescriptor
(
name
=
'pu
ll_dense_per_batch'
,
full_name
=
'paddle.DownpourTrainerParameter.pull_den
se_per_batch'
,
index
=
2
,
name
=
'pu
sh_sparse_per_batch'
,
full_name
=
'paddle.DownpourTrainerParameter.push_spar
se_per_batch'
,
index
=
2
,
number
=
3
,
type
=
5
,
cpp_type
=
1
,
label
=
1
,
has_default_value
=
False
,
default_value
=
0
,
message_type
=
None
,
enum_type
=
None
,
containing_type
=
None
,
...
...
@@ -355,6 +355,13 @@ _DOWNPOURTRAINERPARAMETER = _descriptor.Descriptor(
message_type
=
None
,
enum_type
=
None
,
containing_type
=
None
,
is_extension
=
False
,
extension_scope
=
None
,
options
=
None
),
_descriptor
.
FieldDescriptor
(
name
=
'skip_op'
,
full_name
=
'paddle.DownpourTrainerParameter.skip_op'
,
index
=
4
,
number
=
5
,
type
=
9
,
cpp_type
=
9
,
label
=
3
,
has_default_value
=
False
,
default_value
=
[],
message_type
=
None
,
enum_type
=
None
,
containing_type
=
None
,
is_extension
=
False
,
extension_scope
=
None
,
options
=
None
),
],
extensions
=
[
],
...
...
@@ -368,7 +375,7 @@ _DOWNPOURTRAINERPARAMETER = _descriptor.Descriptor(
oneofs
=
[
],
serialized_start
=
557
,
serialized_end
=
7
45
,
serialized_end
=
7
63
,
)
...
...
@@ -419,8 +426,8 @@ _DENSETABLEPARAMETER = _descriptor.Descriptor(
extension_ranges
=
[],
oneofs
=
[
],
serialized_start
=
7
47
,
serialized_end
=
8
70
,
serialized_start
=
7
65
,
serialized_end
=
8
88
,
)
...
...
@@ -478,8 +485,8 @@ _SPARSETABLEPARAMETER = _descriptor.Descriptor(
extension_ranges
=
[],
oneofs
=
[
],
serialized_start
=
8
72
,
serialized_end
=
994
,
serialized_start
=
8
90
,
serialized_end
=
1012
,
)
...
...
@@ -516,8 +523,8 @@ _DOWNPOURSERVERPARAMETER = _descriptor.Descriptor(
extension_ranges
=
[],
oneofs
=
[
],
serialized_start
=
997
,
serialized_end
=
11
31
,
serialized_start
=
1015
,
serialized_end
=
11
49
,
)
...
...
@@ -575,8 +582,8 @@ _SERVERSERVICEPARAMETER = _descriptor.Descriptor(
extension_ranges
=
[],
oneofs
=
[
],
serialized_start
=
11
34
,
serialized_end
=
13
43
,
serialized_start
=
11
52
,
serialized_end
=
13
67
,
)
...
...
@@ -641,8 +648,8 @@ _TABLEPARAMETER = _descriptor.Descriptor(
extension_ranges
=
[],
oneofs
=
[
],
serialized_start
=
13
46
,
serialized_end
=
15
37
,
serialized_start
=
13
70
,
serialized_end
=
15
61
,
)
...
...
@@ -721,8 +728,8 @@ _TABLEACCESSORPARAMETER = _descriptor.Descriptor(
extension_ranges
=
[],
oneofs
=
[
],
serialized_start
=
15
40
,
serialized_end
=
19
09
,
serialized_start
=
15
64
,
serialized_end
=
19
33
,
)
...
...
@@ -794,8 +801,8 @@ _DOWNPOURTABLEACCESSORPARAMETER = _descriptor.Descriptor(
extension_ranges
=
[],
oneofs
=
[
],
serialized_start
=
19
12
,
serialized_end
=
21
18
,
serialized_start
=
19
36
,
serialized_end
=
21
42
,
)
...
...
@@ -839,8 +846,8 @@ _TABLEACCESSORSAVEPARAMETER = _descriptor.Descriptor(
extension_ranges
=
[],
oneofs
=
[
],
serialized_start
=
21
20
,
serialized_end
=
22
03
,
serialized_start
=
21
44
,
serialized_end
=
22
27
,
)
...
...
@@ -898,8 +905,8 @@ _PSREQUESTMESSAGE = _descriptor.Descriptor(
extension_ranges
=
[],
oneofs
=
[
],
serialized_start
=
22
05
,
serialized_end
=
23
06
,
serialized_start
=
22
29
,
serialized_end
=
23
30
,
)
...
...
@@ -950,8 +957,8 @@ _SPARSESGDRULEPARAMETER = _descriptor.Descriptor(
extension_ranges
=
[],
oneofs
=
[
],
serialized_start
=
23
08
,
serialized_end
=
24
27
,
serialized_start
=
23
32
,
serialized_end
=
24
51
,
)
...
...
@@ -1009,8 +1016,8 @@ _DENSESGDRULEPARAMETER = _descriptor.Descriptor(
extension_ranges
=
[],
oneofs
=
[
],
serialized_start
=
24
30
,
serialized_end
=
26
55
,
serialized_start
=
24
54
,
serialized_end
=
26
79
,
)
...
...
@@ -1068,8 +1075,8 @@ _ADAMSGDPARAMETER = _descriptor.Descriptor(
extension_ranges
=
[],
oneofs
=
[
],
serialized_start
=
26
58
,
serialized_end
=
2
792
,
serialized_start
=
26
82
,
serialized_end
=
2
816
,
)
...
...
@@ -1106,8 +1113,8 @@ _NAIVESGDPARAMETER = _descriptor.Descriptor(
extension_ranges
=
[],
oneofs
=
[
],
serialized_start
=
2
794
,
serialized_end
=
28
60
,
serialized_start
=
2
818
,
serialized_end
=
28
84
,
)
...
...
@@ -1137,8 +1144,8 @@ _SUMMARYSGDPARAMETER = _descriptor.Descriptor(
extension_ranges
=
[],
oneofs
=
[
],
serialized_start
=
28
62
,
serialized_end
=
29
21
,
serialized_start
=
28
86
,
serialized_end
=
29
45
,
)
...
...
@@ -1168,8 +1175,8 @@ _MOVINGAVERAGERULEPARAMETER = _descriptor.Descriptor(
extension_ranges
=
[],
oneofs
=
[
],
serialized_start
=
29
23
,
serialized_end
=
29
69
,
serialized_start
=
29
47
,
serialized_end
=
29
93
,
)
...
...
@@ -1213,8 +1220,8 @@ _PSRESPONSEMESSAGE = _descriptor.Descriptor(
extension_ranges
=
[],
oneofs
=
[
],
serialized_start
=
29
71
,
serialized_end
=
30
44
,
serialized_start
=
29
95
,
serialized_end
=
30
68
,
)
...
...
@@ -1287,8 +1294,8 @@ _FSCLIENTPARAMETER = _descriptor.Descriptor(
extension_ranges
=
[],
oneofs
=
[
],
serialized_start
=
30
47
,
serialized_end
=
32
60
,
serialized_start
=
30
71
,
serialized_end
=
32
84
,
)
_PSPARAMETER
.
fields_by_name
[
'worker_param'
].
message_type
=
_WORKERPARAMETER
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录