diff --git a/python/paddle/fluid/distributed/__init__.py b/python/paddle/fluid/distributed/__init__.py deleted file mode 100644 index cd609c504078b907221a689fbb4e910ec8d54270..0000000000000000000000000000000000000000 --- a/python/paddle/fluid/distributed/__init__.py +++ /dev/null @@ -1,12 +0,0 @@ -# Copyright (c) 2018 PaddlePaddle Authors. All Rights Reserved. -# -# Licensed under the Apache License, Version 2.0 (the "License"); -# you may not use this file except in compliance with the License. -# You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and diff --git a/python/paddle/fluid/distributed/downpour.py b/python/paddle/fluid/distributed/downpour.py deleted file mode 100644 index 1f7e146c3f35b6abf4bb57255096fc81a7fd01b9..0000000000000000000000000000000000000000 --- a/python/paddle/fluid/distributed/downpour.py +++ /dev/null @@ -1,200 +0,0 @@ -# Copyright (c) 2018 PaddlePaddle Authors. All Rights Reserved. -# -# Licensed under the Apache License, Version 2.0 (the "License"); -# you may not use this file except in compliance with the License. -# You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and - -from .node import DownpourServer -from .node import DownpourWorker -from ..backward import append_backward -import ps_pb2 as pslib -from paddle.fluid.distribute_lookup_table import find_distributed_lookup_table -from paddle.fluid.distribute_lookup_table import ( - find_distributed_lookup_table_inputs, -) -from paddle.fluid.distribute_lookup_table import ( - find_distributed_lookup_table_outputs, -) -from google.protobuf import text_format - - -class DownpourSGD: - r""" - Distributed optimizer of downpour stochastic gradient descent - Standard implementation of Google's Downpour SGD - in Large Scale Distributed Deep Networks - - Args: - learning_rate (float): the learning rate used to update parameters. \ - Can be a float value - Examples: - .. code-block:: python - - opt = fluid.DistributedOptimizer(sgd_opt) - opt.minimize() - - downpour_sgd = fluid.distributed.DownpourSGD(learning_rate=0.2) - downpour_sgd.minimize(cost) - """ - - def __init__(self, learning_rate=0.001, window=1): - # todo(guru4elephant): add more optimizers here as argument - # todo(guru4elephant): make learning_rate as a variable - self.learning_rate_ = learning_rate - self.window_ = window - self.type = "downpour" - self.data_norm_name = [ - ".batch_size", - ".batch_square_sum", - ".batch_sum", - ".batch_size@GRAD", - ".batch_square_sum@GRAD", - ".batch_sum@GRAD", - ] - - def minimize( - self, - losses, - startup_program=None, - parameter_list=None, - no_grad_set=None, - ): - """ - DownpounSGD is a distributed optimizer so - that user can call minimize to generate backward - operators and optimization operators within minimize function - Args: - loss(Variable): loss variable defined by user - startup_program(Program): startup program that defined by user - parameter_list(str list): parameter names defined by users - no_grad_set(set): a set of variables that is defined by users - so that these variables do not need gradient computation - Returns: - [ps_param, worker_skipped_ops] - ps_param: parameter server protobuf desc - worker_skipped_ops: operator names that need - to be skipped during execution - """ - if not isinstance(losses, list): - raise ValueError('losses is a list, just lick [model.cost]') - table_name = find_distributed_lookup_table(losses[0].block.program) - prefetch_slots = find_distributed_lookup_table_inputs( - losses[0].block.program, table_name - ) - prefetch_slots_emb = find_distributed_lookup_table_outputs( - losses[0].block.program, table_name - ) - - ps_param = pslib.PSParameter() - server = DownpourServer() - worker = DownpourWorker(self.window_) - sparse_table_index = 0 - server.add_sparse_table( - sparse_table_index, - self.learning_rate_, - prefetch_slots, - prefetch_slots_emb, - ) - worker.add_sparse_table( - sparse_table_index, - self.learning_rate_, - prefetch_slots, - prefetch_slots_emb, - ) - dense_table_index = 1 - program_configs = [] - param_grads_list = [] - for loss_index in range(len(losses)): - program_config = ps_param.trainer_param.program_config.add() - program_config.program_id = str( - id(losses[loss_index].block.program) - ) - program_config.pull_sparse_table_id.extend([sparse_table_index]) - program_config.push_sparse_table_id.extend([sparse_table_index]) - params_grads = sorted( - append_backward( - losses[loss_index], parameter_list, no_grad_set - ), - key=lambda x: x[0].name, - ) - param_grads_list.append(params_grads) - params = [] - grads = [] - data_norm_params = [] - data_norm_grads = [] - for i in params_grads: - is_data_norm_data = False - for data_norm_name in self.data_norm_name: - if i[0].name.endswith(data_norm_name): - is_data_norm_data = True - data_norm_params.append(i[0]) - if not is_data_norm_data: - params.append(i[0]) - for i in params_grads: - is_data_norm_data = False - for data_norm_grad in self.data_norm_name: - if i[0].name.endswith(data_norm_grad): - is_data_norm_data = True - data_norm_grads.append(i[1]) - if not is_data_norm_data: - grads.append(i[1]) - server.add_dense_table( - dense_table_index, self.learning_rate_, params, grads - ) - worker.add_dense_table( - dense_table_index, self.learning_rate_, params, grads - ) - program_config.pull_dense_table_id.extend([dense_table_index]) - program_config.push_dense_table_id.extend([dense_table_index]) - if len(data_norm_params) != 0 and len(data_norm_grads) != 0: - dense_table_index += 1 - server.add_data_norm_table( - dense_table_index, - self.learning_rate_, - data_norm_params, - data_norm_grads, - ) - worker.add_dense_table( - dense_table_index, - self.learning_rate_, - data_norm_params, - data_norm_grads, - ) - program_config.pull_dense_table_id.extend([dense_table_index]) - program_config.push_dense_table_id.extend([dense_table_index]) - dense_table_index += 1 - program_configs.append(program_config) - ps_param.server_param.CopyFrom(server.get_desc()) - ps_param.trainer_param.CopyFrom(worker.get_desc()) - for program_config in program_configs: - ps_param.trainer_param.program_config.extend([program_config]) - # 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) - - # all fleet operations should be defined in operators in the future - # we want to return an object here containing: - # 1) worker execution strategy - # 2) pserver execution strategy - # 3) fleet configurations - # 4) skipped operators in runtime - # 5) distributed optimization - opt_info = {} - opt_info["trainer"] = "DistMultiTrainer" - opt_info["device_worker"] = "DownpourSGD" - opt_info["optimizer"] = "DownpourSGD" - opt_info["fleet_desc"] = ps_param - opt_info["worker_skipped_ops"] = worker_skipped_ops - - for loss in losses: - loss.block.program._fleet_opt = opt_info - - return None, param_grads_list diff --git a/python/paddle/fluid/distributed/fleet.py b/python/paddle/fluid/distributed/fleet.py deleted file mode 100644 index 552dc91598ba470699a9513d879f44b760bd2f8e..0000000000000000000000000000000000000000 --- a/python/paddle/fluid/distributed/fleet.py +++ /dev/null @@ -1,82 +0,0 @@ -# Copyright (c) 2019 PaddlePaddle Authors. All Rights Reserved. -# -# Licensed under the Apache License, Version 2.0 (the "License"); -# you may not use this file except in compliance with the License. -# You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -import sys -from .. import core -from . import ps_instance -from google.protobuf import text_format - -__all__ = ['Fleet'] - - -class Fleet: - """ """ - - def __init__(self): - self.instance_ = ps_instance.PaddlePSInstance() - self.fleet_ = core.FleetWrapper() - - def stop(self): - self.instance_.barrier_worker() - if self.instance.is_first_worker(): - self.fleet_.stop_server() - self.instance_.barrier_worker() - self.instance_.barrier_all() - self.instance.finalize() - - def init_pserver(self, opt_info): - if "fleet_desc" in opt_info: - self.dist_desc_str_ = text_format.MessageToString( - opt_info["fleet_desc"] - ) - self.dist_desc_ = opt_info["fleet_desc"] - else: - print( - "You should run distributed optimization to get opt_info first" - ) - sys.exit(-1) - self.fleet_.init_server(self.dist_desc_str_) - ip = self.fleet_.start_server() - self.instance_.set_ip(ip) - self.instance.barrier_all() - ips = self.instance.gather_ips() - self.fleet.gather_servers(ips, self.instance_.get_node_cnt()) - self.instance_.barrier_all() - - def init_worker(self, opt_info): - if "fleet_desc" in opt_info: - self.dist_desc_str_ = text_format.MessageToString( - opt_info["fleet_desc"] - ) - self.dist_desc_ = opt_info["fleet_desc"] - else: - print( - "You should run distributed optimization to get opt_info first" - ) - sys.exit(-1) - self.instance_.barrier_all() - ips = self.instance.gather_ips() - self.fleet_.init_worker( - self.dist_desc_str_, - ips, - self.instance_.get_node_cnt(), - self.instance._rankid, - ) - self.instance.barrier_worker() - - def init_pserver_model(self): - if self.instance_.is_first_worker(): - self.fleet_.init_model() - self.instance_.barrier_worker() - - def save_pserver_model(self, save_path): - self.fleet_.save_model(save_path) diff --git a/python/paddle/fluid/distributed/helper.py b/python/paddle/fluid/distributed/helper.py deleted file mode 100644 index 93cec48408367b436ca8398c4d5573f8ca3af7ca..0000000000000000000000000000000000000000 --- a/python/paddle/fluid/distributed/helper.py +++ /dev/null @@ -1,91 +0,0 @@ -# Copyright (c) 2018 PaddlePaddle Authors. All Rights Reserved. -# -# Licensed under the Apache License, Version 2.0 (the "License"); -# you may not use this file except in compliance with the License. -# You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. - - -class FileSystem: - """ - A file system that support hadoop client desc. - - Args: - fs_type (string): fs_type, for example is "afs" - user (string): hadoop param - passwd (string): hadoop param - hadoop bin (string): hadoop param - Examples: - fs = FileSystm() - """ - - def __init__( - self, - fs_type="afs", - uri="afs://xx", - user=None, - passwd=None, - hadoop_bin="", - ): - assert user is not None - assert passwd is not None - assert hadoop_bin is not None - import ps_pb2 as pslib - - self.fs_client = pslib.FsClientParameter() - self.fs_client.uri = uri - self.fs_client.user = user - self.fs_client.passwd = passwd - # self.fs_client.buffer_size = 0 - self.fs_client.hadoop_bin = hadoop_bin - # self.fs_client.afs_conf = afs_conf if not afs_conf else "" - - def get_desc(self): - """ - get hadoop desc. - """ - return self.fs_client - - -class MPIHelper: - """ - MPIHelper is a wrapper of mpi4py, support get_rank get_size etc. - Args: - No params - Examples: - mh = MPIHelper() - mh.get_ip() - """ - - def __init__(self): - from mpi4py import MPI - - self.comm = MPI.COMM_WORLD - self.MPI = MPI - - def get_rank(self): - return self.comm.Get_rank() - - def get_size(self): - return self.comm.Get_size() - - def get_ip(self): - import socket - - local_ip = socket.gethostbyname(socket.gethostname()) - return local_ip - - def get_hostname(self): - import socket - - return socket.gethostname() - - def finalize(self): - self.MPI.Finalize() diff --git a/python/paddle/fluid/distributed/node.py b/python/paddle/fluid/distributed/node.py deleted file mode 100644 index 19fa5ec20b96dc229e43a8dedef27087fb797512..0000000000000000000000000000000000000000 --- a/python/paddle/fluid/distributed/node.py +++ /dev/null @@ -1,196 +0,0 @@ -# Copyright (c) 2018 PaddlePaddle Authors. All Rights Reserved. -# -# Licensed under the Apache License, Version 2.0 (the "License"); -# you may not use this file except in compliance with the License. -# You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and - -import ps_pb2 as pslib - -# NOTE: reduce removed in fuctools in python3 -from functools import reduce - - -class Server: - """ - A Server basic class. - """ - - def __init__(self): - pass - - -class Worker: - """ - A Worker basic class. - """ - - def __init__(self): - pass - - -class DownpourServer(Server): - """ - DownpourServer class is used to generate server program_desc - Args: - server: it is pslib.ServerParameter() - Examples: - server = DownpourServer() - """ - - def __init__(self): - self.server_ = pslib.ServerParameter() - self.server_.downpour_server_param.service_param.start_server_port = 0 - self.server_.downpour_server_param.service_param.server_class = ( - "DownpourBrpcPsServer" - ) - self.server_.downpour_server_param.service_param.client_class = ( - "DownpourBrpcPsClient" - ) - self.server_.downpour_server_param.service_param.service_class = ( - "DownpourPsService" - ) - self.server_.downpour_server_param.service_param.server_thread_num = 12 - - def add_sparse_table( - self, table_id, learning_rate, slot_key_vars, slot_value_var - ): - r""" - Args: - table_id(int): id of sparse params table - learning_rate(float): the learning rate used to update parameters. \ - Can be a float value - slot_key_vars(string): slot key id - slot_value_var(string): slot key value after embedding - Returns: - return None - """ - table = self.server_.downpour_server_param.downpour_table_param.add() - table.table_id = table_id - table.table_class = "DownpourSparseTable" - table.type = pslib.PS_SPARSE_TABLE - table.accessor.accessor_class = "DownpourFeatureValueAccessor" - table.accessor.sparse_sgd_param.learning_rate = learning_rate - table.accessor.sparse_sgd_param.initial_g2sum = 3 - table.accessor.sparse_sgd_param.initial_range = 1e-4 - table.accessor.sparse_sgd_param.weight_bounds.extend([-10, 10]) - - table.accessor.embedx_dim = 8 - table.accessor.embedx_threshold = 5 - table.accessor.fea_dim = 11 - table.accessor.downpour_accessor_param.nonclk_coeff = 0.1 - table.accessor.downpour_accessor_param.click_coeff = 2 - table.accessor.downpour_accessor_param.base_threshold = 0.2 - table.accessor.downpour_accessor_param.delta_threshold = 0.15 - table.accessor.downpour_accessor_param.delta_keep_days = 31 - table.accessor.downpour_accessor_param.show_click_decay_rate = 0.999 - table.accessor.downpour_accessor_param.delete_threshold = 0.8 - - def add_dense_table(self, table_id, learning_rate, param_var, grad_var): - r""" - Args: - table_id(int): id of sparse params table - learning_rate(float): the learning rate used to update parameters. \ - Can be a float value - param_var(list): all dense param. it is a list. - grad_var(list): all dense grad parm it is a list. - Returns: - return None - """ - table = self.server_.downpour_server_param.downpour_table_param.add() - table.table_id = table_id - table.table_class = "DownpourDenseTable" - table.type = pslib.PS_DENSE_TABLE - table.accessor.accessor_class = "DownpourDenseValueAccessor" - table.accessor.dense_sgd_param.name = "adam" - table.accessor.dense_sgd_param.adam.learning_rate = learning_rate - table.accessor.dense_sgd_param.adam.avg_decay_rate = 0.999993 - table.accessor.dense_sgd_param.adam.ada_decay_rate = 0.9999 - table.accessor.dense_sgd_param.adam.ada_epsilon = 1e-8 - 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 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 - - def get_desc(self): - """ - Return downpour server program_desc - """ - return self.server_ - - -class DownpourWorker(Worker): - """ - DownpourWorker class is used to generate worker program_desc - Args: - window (int): push params frequency - worker: it is pslib.DownpourTrainerParameter - Examples: - worker = DownpourWorker(1) - """ - - def __init__(self, window): - self.window = window - self.worker_ = pslib.DownpourTrainerParameter() - - def add_sparse_table( - self, table_id, learning_rate, slot_key_vars, slot_value_vars - ): - r""" - Args: - table_id(int): id of sparse params table - learning_rate(float): the learning rate used to update parameters. \ - Can be a float value - slot_key_vars(string): slot key id - slot_value_var(string): slot key value after embedding - Returns: - return None - """ - table = self.worker_.sparse_table.add() - table.table_id = table_id - table.slot_key.extend([var.name for var in slot_key_vars]) - table.slot_value.extend([var.name for var in slot_value_vars]) - table.slot_gradient.extend( - [var.name + "@GRAD" for var in slot_value_vars] - ) - - def add_dense_table(self, table_id, learning_rate, param_vars, grad_vars): - r""" - Args: - table_id(int): id of sparse params table - learning_rate(float): the learning rate used to update parameters. \ - Can be a float value - param_var(list): all dense param. it is a list. - grad_var(list): all dense grad parm it is a list. - Returns: - return None - """ - table = self.worker_.dense_table.add() - table.table_id = table_id - table.dense_variable_name.extend( - filter( - lambda x: x.find("embedding") == -1, - [p.name for p in param_vars], - ) - ) - table.dense_gradient_variable_name.extend( - filter( - lambda x: x.find("embedding") == -1, [g.name for g in grad_vars] - ) - ) - - def get_desc(self): - """ - Return downpour worker program_desc - """ - return self.worker_ diff --git a/python/paddle/fluid/distributed/ps_instance.py b/python/paddle/fluid/distributed/ps_instance.py deleted file mode 100644 index 91388b97b01aa8472eb5460c8b14ad55e0d60437..0000000000000000000000000000000000000000 --- a/python/paddle/fluid/distributed/ps_instance.py +++ /dev/null @@ -1,160 +0,0 @@ -# Copyright (c) 2018 PaddlePaddle Authors. All Rights Reserved. -# -# Licensed under the Apache License, Version 2.0 (the "License"); -# you may not use this file except in compliance with the License. -# You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and - -from .helper import MPIHelper - - -class PaddlePSInstance: - """ - PaddlePSInstance class is used to generate A instance of server or worker - Args: - server_worker_mode: is a value 0 or 1, default is 1 - proc_per_node: process per node, default is 2 - Examples: - instance = PaddlePSInstance(1, 2) - """ - - def __init__(self, server_worker_mode=1, proc_per_node=2): - self.dh = MPIHelper() - self._rankid = self.dh.get_rank() - self._server_worker_mode = server_worker_mode - self._proc_per_node = proc_per_node - self._nodes = self.dh.get_size() - - self._ip = 0 - self._worker_num = self._nodes * self._proc_per_node / 2 - self._server_num = self._nodes * self._proc_per_node / 2 - self._total_server_worker = self._worker_num + self._server_num - self._node_type = None # IDLE=-1, WORKER=1, SERVER=0 - self._set_nodetype() - self._comm = None - self._split_comm() - - def _set_nodetype(self): - if self._server_worker_mode == 0: - if self._rankid < self._server_num: - self._node_type = 1 - elif self._rankid < self._total_server_worker: - self._node_type = 0 - else: - self._node_type = -1 - elif self._server_worker_mode == 1: - if self._rankid < self._total_server_worker: - if 0 == self._rankid % self._proc_per_node % 2: - self._node_type = 0 - else: - self._node_type = 1 - else: - self._node_type = -1 - else: - self._node_type = -1 - - def _split_comm(self): - if self.is_server(): - self._comm = self.dh.comm.Split(self._node_type) - elif self.is_worker(): - self._comm = self.dh.comm.Split(self._node_type) - pass - - def get_worker_id(self): - """ - Return worker index - """ - if self._server_worker_mode == 0: - return self._rankid == self.server_num - else: - return self._rankid / self._proc_per_node - - def get_server_id(self): - """ - Return server index - """ - if self._server_worker_mode == 0: - return self.rank_id - else: - return self.rank_id / self._proc_per_node - - def is_worker(self): - """ - Return instance is worker or not - """ - return self._node_type == 1 - - def is_server(self): - """ - Return instance is server or not - """ - return self._node_type == 0 - - def is_first_worker(self): - """ - Return instance is first worker or not - """ - return self.is_worker() and 0 == self.get_worker_id() - - def set_ip(self, ip): - """ - set server ip - """ - self._ip = ip - - def gather_ips(self): - """ - Return all servers and workers ip through mpi allgather - """ - self._ips = self.dh.comm.allgather(self._ip) - return self._ips - - def get_node_cnt(self): - """ - Return node cnt - """ - return self._nodes - - def get_worker_num(self): - """ - Return worker num - """ - return self._worker_num - - def get_server_num(self): - """ - Return server num - """ - return self._server_num - - def barrier_all(self): - """ - barrier workers and servers - """ - self.dh.comm.barrier() - - def barrier_worker(self): - """ - barrier workers - """ - if self.is_worker(): - self._comm.barrier() - pass - - def finalize(self): - """ - MPI finalize - """ - self.dh.finalize() - pass - - -if __name__ == "__main__": - instance = PaddlePSInstance(1, 2) - instance.barrier_all() diff --git a/python/paddle/fluid/distributed/ps_pb2.py b/python/paddle/fluid/distributed/ps_pb2.py deleted file mode 100644 index 8a131a2548c447b9a9be917110efcb11ca4ac736..0000000000000000000000000000000000000000 --- a/python/paddle/fluid/distributed/ps_pb2.py +++ /dev/null @@ -1,2602 +0,0 @@ -# Copyright (c) 2019 PaddlePaddle Authors. All Rights Reserved. -# -# Licensed under the Apache License, Version 2.0 (the "License"); -# you may not use this file except in compliance with the License. -# You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. - -# Generated by the protocol buffer compiler. DO NOT EDIT! -# source: ps.proto - -import sys - -_b = sys.version_info[0] < 3 and (lambda x: x) or (lambda x: x.encode('latin1')) -from google.protobuf.internal import enum_type_wrapper -from google.protobuf import descriptor as _descriptor -from google.protobuf import message as _message -from google.protobuf import reflection as _reflection -from google.protobuf import symbol_database as _symbol_database -from google.protobuf import descriptor_pb2 - -# @@protoc_insertion_point(imports) - -_sym_db = _symbol_database.Default() - -DESCRIPTOR = _descriptor.FileDescriptor( - name='ps.proto', - package='paddle', - syntax='proto2', - serialized_pb=_b( - '\n\x08ps.proto\x12\x06paddle\"\x9e\x02\n\x0bPSParameter\x12\x14\n\x0cworker_class\x18\x01 \x01(\t\x12\x14\n\x0cserver_class\x18\x02 \x01(\t\x12\x16\n\x0einstance_class\x18\x03 \x01(\t\x12-\n\x0cworker_param\x18\x65 \x01(\x0b\x32\x17.paddle.WorkerParameter\x12-\n\x0cserver_param\x18\x66 \x01(\x0b\x32\x17.paddle.ServerParameter\x12\x38\n\rtrainer_param\x18\xad\x02 \x01(\x0b\x32 .paddle.DownpourTrainerParameter\x12\x33\n\x0f\x66s_client_param\x18\xf5\x03 \x01(\x0b\x32\x19.paddle.FsClientParameter\"Q\n\x0fWorkerParameter\x12>\n\x15\x64ownpour_worker_param\x18\x01 \x01(\x0b\x32\x1f.paddle.DownpourWorkerParameter\"Q\n\x0fServerParameter\x12>\n\x15\x64ownpour_server_param\x18\x01 \x01(\x0b\x32\x1f.paddle.DownpourServerParameter\"O\n\x17\x44ownpourWorkerParameter\x12\x34\n\x14\x64ownpour_table_param\x18\x01 \x03(\x0b\x32\x16.paddle.TableParameter\"\xfd\x01\n\x18\x44ownpourTrainerParameter\x12\x30\n\x0b\x64\x65nse_table\x18\x01 \x03(\x0b\x32\x1b.paddle.DenseTableParameter\x12\x32\n\x0csparse_table\x18\x02 \x03(\x0b\x32\x1c.paddle.SparseTableParameter\x12\x1d\n\x15push_sparse_per_batch\x18\x03 \x01(\x05\x12\x1c\n\x14push_dense_per_batch\x18\x04 \x01(\x05\x12\x0f\n\x07skip_op\x18\x05 \x03(\t\x12-\n\x0eprogram_config\x18\x06 \x03(\x0b\x32\x15.paddle.ProgramConfig\"\x99\x01\n\rProgramConfig\x12\x12\n\nprogram_id\x18\x01 \x02(\t\x12\x1c\n\x14push_sparse_table_id\x18\x02 \x03(\x05\x12\x1b\n\x13push_dense_table_id\x18\x03 \x03(\x05\x12\x1c\n\x14pull_sparse_table_id\x18\x04 \x03(\x05\x12\x1b\n\x13pull_dense_table_id\x18\x05 \x03(\x05\"{\n\x13\x44\x65nseTableParameter\x12\x10\n\x08table_id\x18\x01 \x01(\x05\x12\x1b\n\x13\x64\x65nse_variable_name\x18\x02 \x03(\t\x12$\n\x1c\x64\x65nse_gradient_variable_name\x18\x03 \x03(\t\x12\x0f\n\x07\x66\x65\x61_dim\x18\x04 \x01(\x05\"z\n\x14SparseTableParameter\x12\x10\n\x08table_id\x18\x01 \x01(\x05\x12\x13\n\x0b\x66\x65\x61ture_dim\x18\x02 \x01(\x05\x12\x10\n\x08slot_key\x18\x03 \x03(\t\x12\x12\n\nslot_value\x18\x04 \x03(\t\x12\x15\n\rslot_gradient\x18\x05 \x03(\t\"\x86\x01\n\x17\x44ownpourServerParameter\x12\x34\n\x14\x64ownpour_table_param\x18\x01 \x03(\x0b\x32\x16.paddle.TableParameter\x12\x35\n\rservice_param\x18\x02 \x01(\x0b\x32\x1e.paddle.ServerServiceParameter\"\xd7\x01\n\x16ServerServiceParameter\x12*\n\x0cserver_class\x18\x01 \x01(\t:\x14\x44ownpourBrpcPsServer\x12*\n\x0c\x63lient_class\x18\x02 \x01(\t:\x14\x44ownpourBrpcPsClient\x12(\n\rservice_class\x18\x03 \x01(\t:\x11\x44ownpourPsService\x12\x1c\n\x11start_server_port\x18\x04 \x01(\r:\x01\x30\x12\x1d\n\x11server_thread_num\x18\x05 \x01(\r:\x02\x31\x32\"\xbf\x01\n\x0eTableParameter\x12\x10\n\x08table_id\x18\x01 \x01(\x04\x12\x13\n\x0btable_class\x18\x02 \x01(\t\x12\x12\n\nshared_num\x18\x03 \x01(\x04\x12\x30\n\x08\x61\x63\x63\x65ssor\x18\x04 \x01(\x0b\x32\x1e.paddle.TableAccessorParameter\x12\x1f\n\x04type\x18\x05 \x01(\x0e\x32\x11.paddle.TableType\x12\x1f\n\x10\x63ompress_in_save\x18\x06 \x01(\x08:\x05\x66\x61lse\"\xf1\x02\n\x16TableAccessorParameter\x12\x16\n\x0e\x61\x63\x63\x65ssor_class\x18\x01 \x01(\t\x12\x38\n\x10sparse_sgd_param\x18\x02 \x01(\x0b\x32\x1e.paddle.SparseSGDRuleParameter\x12\x36\n\x0f\x64\x65nse_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\nembedx_dim\x18\x05 \x01(\r\x12\x18\n\x10\x65mbedx_threshold\x18\x06 \x01(\r\x12G\n\x17\x64ownpour_accessor_param\x18\x07 \x01(\x0b\x32&.paddle.DownpourTableAccessorParameter\x12\x45\n\x19table_accessor_save_param\x18\x08 \x03(\x0b\x32\".paddle.TableAccessorSaveParameter\"\xce\x01\n\x1e\x44ownpourTableAccessorParameter\x12\x14\n\x0cnonclk_coeff\x18\x01 \x01(\x02\x12\x13\n\x0b\x63lick_coeff\x18\x02 \x01(\x02\x12\x16\n\x0e\x62\x61se_threshold\x18\x03 \x01(\x02\x12\x17\n\x0f\x64\x65lta_threshold\x18\x04 \x01(\x02\x12\x17\n\x0f\x64\x65lta_keep_days\x18\x05 \x01(\x02\x12\x1d\n\x15show_click_decay_rate\x18\x06 \x01(\x02\x12\x18\n\x10\x64\x65lete_threshold\x18\x07 \x01(\x02\"S\n\x1aTableAccessorSaveParameter\x12\r\n\x05param\x18\x01 \x01(\r\x12\x11\n\tconverter\x18\x02 \x01(\t\x12\x13\n\x0b\x64\x65\x63onverter\x18\x03 \x01(\t\"e\n\x10PsRequestMessage\x12\x0e\n\x06\x63md_id\x18\x01 \x02(\r\x12\x10\n\x08table_id\x18\x02 \x01(\r\x12\x0e\n\x06params\x18\x03 \x03(\x0c\x12\x11\n\tclient_id\x18\x04 \x01(\x05\x12\x0c\n\x04\x64\x61ta\x18\x05 \x01(\x0c\"w\n\x16SparseSGDRuleParameter\x12\x15\n\rlearning_rate\x18\x01 \x01(\x01\x12\x15\n\rinitial_g2sum\x18\x02 \x01(\x01\x12\x18\n\rinitial_range\x18\x03 \x01(\x01:\x01\x30\x12\x15\n\rweight_bounds\x18\x04 \x03(\x02\"\xe1\x01\n\x15\x44\x65nseSGDRuleParameter\x12\x0c\n\x04name\x18\x01 \x01(\t\x12&\n\x04\x61\x64\x61m\x18\x02 \x01(\x0b\x32\x18.paddle.AdamSGDParameter\x12(\n\x05naive\x18\x03 \x01(\x0b\x32\x19.paddle.NaiveSGDParameter\x12,\n\x07summary\x18\x04 \x01(\x0b\x32\x1b.paddle.SummarySGDParameter\x12:\n\x0emoving_average\x18\x05 \x01(\x0b\x32\".paddle.MovingAverageRuleParameter\"\x86\x01\n\x10\x41\x64\x61mSGDParameter\x12\x15\n\rlearning_rate\x18\x01 \x01(\x01\x12\x16\n\x0e\x61vg_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\x0emom_decay_rate\x18\x05 \x01(\x01\"B\n\x11NaiveSGDParameter\x12\x15\n\rlearning_rate\x18\x01 \x01(\x01\x12\x16\n\x0e\x61vg_decay_rate\x18\x02 \x01(\x01\";\n\x13SummarySGDParameter\x12$\n\x12summary_decay_rate\x18\x01 \x01(\x01:\x08\x30.999999\".\n\x1aMovingAverageRuleParameter\x12\x10\n\x08momentum\x18\x01 \x01(\x01\"I\n\x11PsResponseMessage\x12\x13\n\x08\x65rr_code\x18\x01 \x02(\x05:\x01\x30\x12\x11\n\x07\x65rr_msg\x18\x02 \x02(\t:\x00\x12\x0c\n\x04\x64\x61ta\x18\x03 \x01(\x0c\"\xd5\x01\n\x11\x46sClientParameter\x12:\n\x07\x66s_type\x18\x01 \x01(\x0e\x32#.paddle.FsClientParameter.FsApiType:\x04HDFS\x12\x0b\n\x03uri\x18\x02 \x01(\t\x12\x0c\n\x04user\x18\x03 \x01(\t\x12\x0e\n\x06passwd\x18\x04 \x01(\t\x12\x13\n\x0b\x62uffer_size\x18\x05 \x01(\x05\x12\x12\n\nhadoop_bin\x18\x33 \x01(\t\x12\x10\n\x08\x61\x66s_conf\x18\x65 \x01(\t\"\x1e\n\tFsApiType\x12\x08\n\x04HDFS\x10\x00\x12\x07\n\x03\x41\x46S\x10\x01*4\n\tTableType\x12\x13\n\x0fPS_SPARSE_TABLE\x10\x00\x12\x12\n\x0ePS_DENSE_TABLE\x10\x01*\xbd\x02\n\x07PsCmdID\x12\x17\n\x13PS_PULL_DENSE_TABLE\x10\x00\x12\x17\n\x13PS_PUSH_DENSE_TABLE\x10\x01\x12\x18\n\x14PS_PULL_SPARSE_TABLE\x10\x02\x12\x18\n\x14PS_PUSH_SPARSE_TABLE\x10\x03\x12\x13\n\x0fPS_SHRINK_TABLE\x10\x04\x12\x15\n\x11PS_SAVE_ONE_TABLE\x10\x05\x12\x15\n\x11PS_SAVE_ALL_TABLE\x10\x06\x12\x15\n\x11PS_LOAD_ONE_TABLE\x10\x07\x12\x15\n\x11PS_LOAD_ALL_TABLE\x10\x08\x12\x16\n\x12PS_CLEAR_ONE_TABLE\x10\t\x12\x16\n\x12PS_CLEAR_ALL_TABLE\x10\n\x12\x17\n\x13PS_PUSH_DENSE_PARAM\x10\x0b\x12\x12\n\x0ePS_STOP_SERVER\x10\x0c\x32K\n\tPsService\x12>\n\x07service\x12\x18.paddle.PsRequestMessage\x1a\x19.paddle.PsResponseMessageB\x03\x80\x01\x01' - ), -) -_sym_db.RegisterFileDescriptor(DESCRIPTOR) - -_TABLETYPE = _descriptor.EnumDescriptor( - name='TableType', - full_name='paddle.TableType', - filename=None, - file=DESCRIPTOR, - values=[ - _descriptor.EnumValueDescriptor( - name='PS_SPARSE_TABLE', index=0, number=0, options=None, type=None - ), - _descriptor.EnumValueDescriptor( - name='PS_DENSE_TABLE', index=1, number=1, options=None, type=None - ), - ], - containing_type=None, - options=None, - serialized_start=3489, - serialized_end=3541, -) -_sym_db.RegisterEnumDescriptor(_TABLETYPE) - -TableType = enum_type_wrapper.EnumTypeWrapper(_TABLETYPE) -_PSCMDID = _descriptor.EnumDescriptor( - name='PsCmdID', - full_name='paddle.PsCmdID', - filename=None, - file=DESCRIPTOR, - values=[ - _descriptor.EnumValueDescriptor( - name='PS_PULL_DENSE_TABLE', - index=0, - number=0, - options=None, - type=None, - ), - _descriptor.EnumValueDescriptor( - name='PS_PUSH_DENSE_TABLE', - index=1, - number=1, - options=None, - type=None, - ), - _descriptor.EnumValueDescriptor( - name='PS_PULL_SPARSE_TABLE', - index=2, - number=2, - options=None, - type=None, - ), - _descriptor.EnumValueDescriptor( - name='PS_PUSH_SPARSE_TABLE', - index=3, - number=3, - options=None, - type=None, - ), - _descriptor.EnumValueDescriptor( - name='PS_SHRINK_TABLE', index=4, number=4, options=None, type=None - ), - _descriptor.EnumValueDescriptor( - name='PS_SAVE_ONE_TABLE', index=5, number=5, options=None, type=None - ), - _descriptor.EnumValueDescriptor( - name='PS_SAVE_ALL_TABLE', index=6, number=6, options=None, type=None - ), - _descriptor.EnumValueDescriptor( - name='PS_LOAD_ONE_TABLE', index=7, number=7, options=None, type=None - ), - _descriptor.EnumValueDescriptor( - name='PS_LOAD_ALL_TABLE', index=8, number=8, options=None, type=None - ), - _descriptor.EnumValueDescriptor( - name='PS_CLEAR_ONE_TABLE', - index=9, - number=9, - options=None, - type=None, - ), - _descriptor.EnumValueDescriptor( - name='PS_CLEAR_ALL_TABLE', - index=10, - number=10, - options=None, - type=None, - ), - _descriptor.EnumValueDescriptor( - name='PS_PUSH_DENSE_PARAM', - index=11, - number=11, - options=None, - type=None, - ), - _descriptor.EnumValueDescriptor( - name='PS_STOP_SERVER', index=12, number=12, options=None, type=None - ), - ], - containing_type=None, - options=None, - serialized_start=3544, - serialized_end=3861, -) -_sym_db.RegisterEnumDescriptor(_PSCMDID) - -PsCmdID = enum_type_wrapper.EnumTypeWrapper(_PSCMDID) -PS_SPARSE_TABLE = 0 -PS_DENSE_TABLE = 1 -PS_PULL_DENSE_TABLE = 0 -PS_PUSH_DENSE_TABLE = 1 -PS_PULL_SPARSE_TABLE = 2 -PS_PUSH_SPARSE_TABLE = 3 -PS_SHRINK_TABLE = 4 -PS_SAVE_ONE_TABLE = 5 -PS_SAVE_ALL_TABLE = 6 -PS_LOAD_ONE_TABLE = 7 -PS_LOAD_ALL_TABLE = 8 -PS_CLEAR_ONE_TABLE = 9 -PS_CLEAR_ALL_TABLE = 10 -PS_PUSH_DENSE_PARAM = 11 -PS_STOP_SERVER = 12 - -_FSCLIENTPARAMETER_FSAPITYPE = _descriptor.EnumDescriptor( - name='FsApiType', - full_name='paddle.FsClientParameter.FsApiType', - filename=None, - file=DESCRIPTOR, - values=[ - _descriptor.EnumValueDescriptor( - name='HDFS', index=0, number=0, options=None, type=None - ), - _descriptor.EnumValueDescriptor( - name='AFS', index=1, number=1, options=None, type=None - ), - ], - containing_type=None, - options=None, - serialized_start=3457, - serialized_end=3487, -) -_sym_db.RegisterEnumDescriptor(_FSCLIENTPARAMETER_FSAPITYPE) - -_PSPARAMETER = _descriptor.Descriptor( - name='PSParameter', - full_name='paddle.PSParameter', - filename=None, - file=DESCRIPTOR, - containing_type=None, - fields=[ - _descriptor.FieldDescriptor( - name='worker_class', - full_name='paddle.PSParameter.worker_class', - index=0, - number=1, - type=9, - cpp_type=9, - label=1, - has_default_value=False, - default_value=_b("").decode('utf-8'), - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='server_class', - full_name='paddle.PSParameter.server_class', - index=1, - number=2, - type=9, - cpp_type=9, - label=1, - has_default_value=False, - default_value=_b("").decode('utf-8'), - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='instance_class', - full_name='paddle.PSParameter.instance_class', - index=2, - number=3, - type=9, - cpp_type=9, - label=1, - has_default_value=False, - default_value=_b("").decode('utf-8'), - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='worker_param', - full_name='paddle.PSParameter.worker_param', - index=3, - number=101, - type=11, - cpp_type=10, - label=1, - has_default_value=False, - default_value=None, - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='server_param', - full_name='paddle.PSParameter.server_param', - index=4, - number=102, - type=11, - cpp_type=10, - label=1, - has_default_value=False, - default_value=None, - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='trainer_param', - full_name='paddle.PSParameter.trainer_param', - index=5, - number=301, - type=11, - cpp_type=10, - label=1, - has_default_value=False, - default_value=None, - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='fs_client_param', - full_name='paddle.PSParameter.fs_client_param', - index=6, - number=501, - type=11, - cpp_type=10, - label=1, - has_default_value=False, - default_value=None, - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - ], - extensions=[], - nested_types=[], - enum_types=[], - options=None, - is_extendable=False, - syntax='proto2', - extension_ranges=[], - oneofs=[], - serialized_start=21, - serialized_end=307, -) - -_WORKERPARAMETER = _descriptor.Descriptor( - name='WorkerParameter', - full_name='paddle.WorkerParameter', - filename=None, - file=DESCRIPTOR, - containing_type=None, - fields=[ - _descriptor.FieldDescriptor( - name='downpour_worker_param', - full_name='paddle.WorkerParameter.downpour_worker_param', - index=0, - number=1, - type=11, - cpp_type=10, - label=1, - has_default_value=False, - default_value=None, - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - ], - extensions=[], - nested_types=[], - enum_types=[], - options=None, - is_extendable=False, - syntax='proto2', - extension_ranges=[], - oneofs=[], - serialized_start=309, - serialized_end=390, -) - -_SERVERPARAMETER = _descriptor.Descriptor( - name='ServerParameter', - full_name='paddle.ServerParameter', - filename=None, - file=DESCRIPTOR, - containing_type=None, - fields=[ - _descriptor.FieldDescriptor( - name='downpour_server_param', - full_name='paddle.ServerParameter.downpour_server_param', - index=0, - number=1, - type=11, - cpp_type=10, - label=1, - has_default_value=False, - default_value=None, - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - ], - extensions=[], - nested_types=[], - enum_types=[], - options=None, - is_extendable=False, - syntax='proto2', - extension_ranges=[], - oneofs=[], - serialized_start=392, - serialized_end=473, -) - -_DOWNPOURWORKERPARAMETER = _descriptor.Descriptor( - name='DownpourWorkerParameter', - full_name='paddle.DownpourWorkerParameter', - filename=None, - file=DESCRIPTOR, - containing_type=None, - fields=[ - _descriptor.FieldDescriptor( - name='downpour_table_param', - full_name='paddle.DownpourWorkerParameter.downpour_table_param', - index=0, - number=1, - type=11, - cpp_type=10, - 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=[], - nested_types=[], - enum_types=[], - options=None, - is_extendable=False, - syntax='proto2', - extension_ranges=[], - oneofs=[], - serialized_start=475, - serialized_end=554, -) - -_DOWNPOURTRAINERPARAMETER = _descriptor.Descriptor( - name='DownpourTrainerParameter', - full_name='paddle.DownpourTrainerParameter', - filename=None, - file=DESCRIPTOR, - containing_type=None, - fields=[ - _descriptor.FieldDescriptor( - name='dense_table', - full_name='paddle.DownpourTrainerParameter.dense_table', - index=0, - number=1, - type=11, - cpp_type=10, - 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, - ), - _descriptor.FieldDescriptor( - name='sparse_table', - full_name='paddle.DownpourTrainerParameter.sparse_table', - index=1, - number=2, - type=11, - cpp_type=10, - 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, - ), - _descriptor.FieldDescriptor( - name='push_sparse_per_batch', - full_name='paddle.DownpourTrainerParameter.push_sparse_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, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='push_dense_per_batch', - full_name='paddle.DownpourTrainerParameter.push_dense_per_batch', - index=3, - number=4, - type=5, - cpp_type=1, - label=1, - has_default_value=False, - default_value=0, - 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, - ), - _descriptor.FieldDescriptor( - name='program_config', - full_name='paddle.DownpourTrainerParameter.program_config', - index=5, - number=6, - type=11, - cpp_type=10, - 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=[], - nested_types=[], - enum_types=[], - options=None, - is_extendable=False, - syntax='proto2', - extension_ranges=[], - oneofs=[], - serialized_start=557, - serialized_end=810, -) - -_PROGRAMCONFIG = _descriptor.Descriptor( - name='ProgramConfig', - full_name='paddle.ProgramConfig', - filename=None, - file=DESCRIPTOR, - containing_type=None, - fields=[ - _descriptor.FieldDescriptor( - name='program_id', - full_name='paddle.ProgramConfig.program_id', - index=0, - number=1, - type=9, - cpp_type=9, - label=2, - has_default_value=False, - default_value=_b("").decode('utf-8'), - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='push_sparse_table_id', - full_name='paddle.ProgramConfig.push_sparse_table_id', - index=1, - number=2, - type=5, - cpp_type=1, - 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, - ), - _descriptor.FieldDescriptor( - name='push_dense_table_id', - full_name='paddle.ProgramConfig.push_dense_table_id', - index=2, - number=3, - type=5, - cpp_type=1, - 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, - ), - _descriptor.FieldDescriptor( - name='pull_sparse_table_id', - full_name='paddle.ProgramConfig.pull_sparse_table_id', - index=3, - number=4, - type=5, - cpp_type=1, - 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, - ), - _descriptor.FieldDescriptor( - name='pull_dense_table_id', - full_name='paddle.ProgramConfig.pull_dense_table_id', - index=4, - number=5, - type=5, - cpp_type=1, - 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=[], - nested_types=[], - enum_types=[], - options=None, - is_extendable=False, - syntax='proto2', - extension_ranges=[], - oneofs=[], - serialized_start=813, - serialized_end=966, -) - -_DENSETABLEPARAMETER = _descriptor.Descriptor( - name='DenseTableParameter', - full_name='paddle.DenseTableParameter', - filename=None, - file=DESCRIPTOR, - containing_type=None, - fields=[ - _descriptor.FieldDescriptor( - name='table_id', - full_name='paddle.DenseTableParameter.table_id', - index=0, - number=1, - type=5, - cpp_type=1, - label=1, - has_default_value=False, - default_value=0, - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='dense_variable_name', - full_name='paddle.DenseTableParameter.dense_variable_name', - index=1, - number=2, - 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, - ), - _descriptor.FieldDescriptor( - name='dense_gradient_variable_name', - full_name='paddle.DenseTableParameter.dense_gradient_variable_name', - index=2, - number=3, - 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, - ), - _descriptor.FieldDescriptor( - name='fea_dim', - full_name='paddle.DenseTableParameter.fea_dim', - index=3, - number=4, - type=5, - cpp_type=1, - label=1, - has_default_value=False, - default_value=0, - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - ], - extensions=[], - nested_types=[], - enum_types=[], - options=None, - is_extendable=False, - syntax='proto2', - extension_ranges=[], - oneofs=[], - serialized_start=968, - serialized_end=1091, -) - -_SPARSETABLEPARAMETER = _descriptor.Descriptor( - name='SparseTableParameter', - full_name='paddle.SparseTableParameter', - filename=None, - file=DESCRIPTOR, - containing_type=None, - fields=[ - _descriptor.FieldDescriptor( - name='table_id', - full_name='paddle.SparseTableParameter.table_id', - index=0, - number=1, - type=5, - cpp_type=1, - label=1, - has_default_value=False, - default_value=0, - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='feature_dim', - full_name='paddle.SparseTableParameter.feature_dim', - index=1, - number=2, - type=5, - cpp_type=1, - label=1, - has_default_value=False, - default_value=0, - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='slot_key', - full_name='paddle.SparseTableParameter.slot_key', - index=2, - number=3, - 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, - ), - _descriptor.FieldDescriptor( - name='slot_value', - full_name='paddle.SparseTableParameter.slot_value', - index=3, - number=4, - 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, - ), - _descriptor.FieldDescriptor( - name='slot_gradient', - full_name='paddle.SparseTableParameter.slot_gradient', - 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=[], - nested_types=[], - enum_types=[], - options=None, - is_extendable=False, - syntax='proto2', - extension_ranges=[], - oneofs=[], - serialized_start=1093, - serialized_end=1215, -) - -_DOWNPOURSERVERPARAMETER = _descriptor.Descriptor( - name='DownpourServerParameter', - full_name='paddle.DownpourServerParameter', - filename=None, - file=DESCRIPTOR, - containing_type=None, - fields=[ - _descriptor.FieldDescriptor( - name='downpour_table_param', - full_name='paddle.DownpourServerParameter.downpour_table_param', - index=0, - number=1, - type=11, - cpp_type=10, - 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, - ), - _descriptor.FieldDescriptor( - name='service_param', - full_name='paddle.DownpourServerParameter.service_param', - index=1, - number=2, - type=11, - cpp_type=10, - label=1, - has_default_value=False, - default_value=None, - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - ], - extensions=[], - nested_types=[], - enum_types=[], - options=None, - is_extendable=False, - syntax='proto2', - extension_ranges=[], - oneofs=[], - serialized_start=1218, - serialized_end=1352, -) - -_SERVERSERVICEPARAMETER = _descriptor.Descriptor( - name='ServerServiceParameter', - full_name='paddle.ServerServiceParameter', - filename=None, - file=DESCRIPTOR, - containing_type=None, - fields=[ - _descriptor.FieldDescriptor( - name='server_class', - full_name='paddle.ServerServiceParameter.server_class', - index=0, - number=1, - type=9, - cpp_type=9, - label=1, - has_default_value=True, - default_value=_b("DownpourBrpcPsServer").decode('utf-8'), - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='client_class', - full_name='paddle.ServerServiceParameter.client_class', - index=1, - number=2, - type=9, - cpp_type=9, - label=1, - has_default_value=True, - default_value=_b("DownpourBrpcPsClient").decode('utf-8'), - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='service_class', - full_name='paddle.ServerServiceParameter.service_class', - index=2, - number=3, - type=9, - cpp_type=9, - label=1, - has_default_value=True, - default_value=_b("DownpourPsService").decode('utf-8'), - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='start_server_port', - full_name='paddle.ServerServiceParameter.start_server_port', - index=3, - number=4, - type=13, - cpp_type=3, - label=1, - has_default_value=True, - default_value=0, - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='server_thread_num', - full_name='paddle.ServerServiceParameter.server_thread_num', - index=4, - number=5, - type=13, - cpp_type=3, - label=1, - has_default_value=True, - default_value=12, - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - ], - extensions=[], - nested_types=[], - enum_types=[], - options=None, - is_extendable=False, - syntax='proto2', - extension_ranges=[], - oneofs=[], - serialized_start=1355, - serialized_end=1570, -) - -_TABLEPARAMETER = _descriptor.Descriptor( - name='TableParameter', - full_name='paddle.TableParameter', - filename=None, - file=DESCRIPTOR, - containing_type=None, - fields=[ - _descriptor.FieldDescriptor( - name='table_id', - full_name='paddle.TableParameter.table_id', - index=0, - number=1, - type=4, - cpp_type=4, - label=1, - has_default_value=False, - default_value=0, - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='table_class', - full_name='paddle.TableParameter.table_class', - index=1, - number=2, - type=9, - cpp_type=9, - label=1, - has_default_value=False, - default_value=_b("").decode('utf-8'), - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='shared_num', - full_name='paddle.TableParameter.shared_num', - index=2, - number=3, - type=4, - cpp_type=4, - label=1, - has_default_value=False, - default_value=0, - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='accessor', - full_name='paddle.TableParameter.accessor', - index=3, - number=4, - type=11, - cpp_type=10, - label=1, - has_default_value=False, - default_value=None, - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='type', - full_name='paddle.TableParameter.type', - index=4, - number=5, - type=14, - cpp_type=8, - label=1, - has_default_value=False, - default_value=0, - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='compress_in_save', - full_name='paddle.TableParameter.compress_in_save', - index=5, - number=6, - type=8, - cpp_type=7, - label=1, - has_default_value=True, - default_value=False, - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - ], - extensions=[], - nested_types=[], - enum_types=[], - options=None, - is_extendable=False, - syntax='proto2', - extension_ranges=[], - oneofs=[], - serialized_start=1573, - serialized_end=1764, -) - -_TABLEACCESSORPARAMETER = _descriptor.Descriptor( - name='TableAccessorParameter', - full_name='paddle.TableAccessorParameter', - filename=None, - file=DESCRIPTOR, - containing_type=None, - fields=[ - _descriptor.FieldDescriptor( - name='accessor_class', - full_name='paddle.TableAccessorParameter.accessor_class', - index=0, - number=1, - type=9, - cpp_type=9, - label=1, - has_default_value=False, - default_value=_b("").decode('utf-8'), - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='sparse_sgd_param', - full_name='paddle.TableAccessorParameter.sparse_sgd_param', - index=1, - number=2, - type=11, - cpp_type=10, - label=1, - has_default_value=False, - default_value=None, - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='dense_sgd_param', - full_name='paddle.TableAccessorParameter.dense_sgd_param', - index=2, - number=3, - type=11, - cpp_type=10, - label=1, - has_default_value=False, - default_value=None, - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='fea_dim', - full_name='paddle.TableAccessorParameter.fea_dim', - index=3, - number=4, - type=13, - cpp_type=3, - label=1, - has_default_value=False, - default_value=0, - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='embedx_dim', - full_name='paddle.TableAccessorParameter.embedx_dim', - index=4, - number=5, - type=13, - cpp_type=3, - label=1, - has_default_value=False, - default_value=0, - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='embedx_threshold', - full_name='paddle.TableAccessorParameter.embedx_threshold', - index=5, - number=6, - type=13, - cpp_type=3, - label=1, - has_default_value=False, - default_value=0, - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='downpour_accessor_param', - full_name='paddle.TableAccessorParameter.downpour_accessor_param', - index=6, - number=7, - type=11, - cpp_type=10, - label=1, - has_default_value=False, - default_value=None, - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='table_accessor_save_param', - full_name='paddle.TableAccessorParameter.table_accessor_save_param', - index=7, - number=8, - type=11, - cpp_type=10, - 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=[], - nested_types=[], - enum_types=[], - options=None, - is_extendable=False, - syntax='proto2', - extension_ranges=[], - oneofs=[], - serialized_start=1767, - serialized_end=2136, -) - -_DOWNPOURTABLEACCESSORPARAMETER = _descriptor.Descriptor( - name='DownpourTableAccessorParameter', - full_name='paddle.DownpourTableAccessorParameter', - filename=None, - file=DESCRIPTOR, - containing_type=None, - fields=[ - _descriptor.FieldDescriptor( - name='nonclk_coeff', - full_name='paddle.DownpourTableAccessorParameter.nonclk_coeff', - index=0, - number=1, - type=2, - cpp_type=6, - label=1, - has_default_value=False, - default_value=float(0), - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='click_coeff', - full_name='paddle.DownpourTableAccessorParameter.click_coeff', - index=1, - number=2, - type=2, - cpp_type=6, - label=1, - has_default_value=False, - default_value=float(0), - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='base_threshold', - full_name='paddle.DownpourTableAccessorParameter.base_threshold', - index=2, - number=3, - type=2, - cpp_type=6, - label=1, - has_default_value=False, - default_value=float(0), - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='delta_threshold', - full_name='paddle.DownpourTableAccessorParameter.delta_threshold', - index=3, - number=4, - type=2, - cpp_type=6, - label=1, - has_default_value=False, - default_value=float(0), - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='delta_keep_days', - full_name='paddle.DownpourTableAccessorParameter.delta_keep_days', - index=4, - number=5, - type=2, - cpp_type=6, - label=1, - has_default_value=False, - default_value=float(0), - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='show_click_decay_rate', - full_name='paddle.DownpourTableAccessorParameter.show_click_decay_rate', - index=5, - number=6, - type=2, - cpp_type=6, - label=1, - has_default_value=False, - default_value=float(0), - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='delete_threshold', - full_name='paddle.DownpourTableAccessorParameter.delete_threshold', - index=6, - number=7, - type=2, - cpp_type=6, - label=1, - has_default_value=False, - default_value=float(0), - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - ], - extensions=[], - nested_types=[], - enum_types=[], - options=None, - is_extendable=False, - syntax='proto2', - extension_ranges=[], - oneofs=[], - serialized_start=2139, - serialized_end=2345, -) - -_TABLEACCESSORSAVEPARAMETER = _descriptor.Descriptor( - name='TableAccessorSaveParameter', - full_name='paddle.TableAccessorSaveParameter', - filename=None, - file=DESCRIPTOR, - containing_type=None, - fields=[ - _descriptor.FieldDescriptor( - name='param', - full_name='paddle.TableAccessorSaveParameter.param', - index=0, - number=1, - type=13, - cpp_type=3, - label=1, - has_default_value=False, - default_value=0, - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='converter', - full_name='paddle.TableAccessorSaveParameter.converter', - index=1, - number=2, - type=9, - cpp_type=9, - label=1, - has_default_value=False, - default_value=_b("").decode('utf-8'), - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='deconverter', - full_name='paddle.TableAccessorSaveParameter.deconverter', - index=2, - number=3, - type=9, - cpp_type=9, - label=1, - has_default_value=False, - default_value=_b("").decode('utf-8'), - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - ], - extensions=[], - nested_types=[], - enum_types=[], - options=None, - is_extendable=False, - syntax='proto2', - extension_ranges=[], - oneofs=[], - serialized_start=2347, - serialized_end=2430, -) - -_PSREQUESTMESSAGE = _descriptor.Descriptor( - name='PsRequestMessage', - full_name='paddle.PsRequestMessage', - filename=None, - file=DESCRIPTOR, - containing_type=None, - fields=[ - _descriptor.FieldDescriptor( - name='cmd_id', - full_name='paddle.PsRequestMessage.cmd_id', - index=0, - number=1, - type=13, - cpp_type=3, - label=2, - has_default_value=False, - default_value=0, - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='table_id', - full_name='paddle.PsRequestMessage.table_id', - index=1, - number=2, - type=13, - cpp_type=3, - label=1, - has_default_value=False, - default_value=0, - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='params', - full_name='paddle.PsRequestMessage.params', - index=2, - number=3, - type=12, - 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, - ), - _descriptor.FieldDescriptor( - name='client_id', - full_name='paddle.PsRequestMessage.client_id', - index=3, - number=4, - type=5, - cpp_type=1, - label=1, - has_default_value=False, - default_value=0, - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='data', - full_name='paddle.PsRequestMessage.data', - index=4, - number=5, - type=12, - cpp_type=9, - label=1, - has_default_value=False, - default_value=_b(""), - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - ], - extensions=[], - nested_types=[], - enum_types=[], - options=None, - is_extendable=False, - syntax='proto2', - extension_ranges=[], - oneofs=[], - serialized_start=2432, - serialized_end=2533, -) - -_SPARSESGDRULEPARAMETER = _descriptor.Descriptor( - name='SparseSGDRuleParameter', - full_name='paddle.SparseSGDRuleParameter', - filename=None, - file=DESCRIPTOR, - containing_type=None, - fields=[ - _descriptor.FieldDescriptor( - name='learning_rate', - full_name='paddle.SparseSGDRuleParameter.learning_rate', - index=0, - number=1, - type=1, - cpp_type=5, - label=1, - has_default_value=False, - default_value=float(0), - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='initial_g2sum', - full_name='paddle.SparseSGDRuleParameter.initial_g2sum', - index=1, - number=2, - type=1, - cpp_type=5, - label=1, - has_default_value=False, - default_value=float(0), - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='initial_range', - full_name='paddle.SparseSGDRuleParameter.initial_range', - index=2, - number=3, - type=1, - cpp_type=5, - label=1, - has_default_value=True, - default_value=float(0), - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='weight_bounds', - full_name='paddle.SparseSGDRuleParameter.weight_bounds', - index=3, - number=4, - type=2, - cpp_type=6, - 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=[], - nested_types=[], - enum_types=[], - options=None, - is_extendable=False, - syntax='proto2', - extension_ranges=[], - oneofs=[], - serialized_start=2535, - serialized_end=2654, -) - -_DENSESGDRULEPARAMETER = _descriptor.Descriptor( - name='DenseSGDRuleParameter', - full_name='paddle.DenseSGDRuleParameter', - filename=None, - file=DESCRIPTOR, - containing_type=None, - fields=[ - _descriptor.FieldDescriptor( - name='name', - full_name='paddle.DenseSGDRuleParameter.name', - index=0, - number=1, - type=9, - cpp_type=9, - label=1, - has_default_value=False, - default_value=_b("").decode('utf-8'), - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='adam', - full_name='paddle.DenseSGDRuleParameter.adam', - index=1, - number=2, - type=11, - cpp_type=10, - label=1, - has_default_value=False, - default_value=None, - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='naive', - full_name='paddle.DenseSGDRuleParameter.naive', - index=2, - number=3, - type=11, - cpp_type=10, - label=1, - has_default_value=False, - default_value=None, - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='summary', - full_name='paddle.DenseSGDRuleParameter.summary', - index=3, - number=4, - type=11, - cpp_type=10, - label=1, - has_default_value=False, - default_value=None, - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='moving_average', - full_name='paddle.DenseSGDRuleParameter.moving_average', - index=4, - number=5, - type=11, - cpp_type=10, - label=1, - has_default_value=False, - default_value=None, - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - ], - extensions=[], - nested_types=[], - enum_types=[], - options=None, - is_extendable=False, - syntax='proto2', - extension_ranges=[], - oneofs=[], - serialized_start=2657, - serialized_end=2882, -) - -_ADAMSGDPARAMETER = _descriptor.Descriptor( - name='AdamSGDParameter', - full_name='paddle.AdamSGDParameter', - filename=None, - file=DESCRIPTOR, - containing_type=None, - fields=[ - _descriptor.FieldDescriptor( - name='learning_rate', - full_name='paddle.AdamSGDParameter.learning_rate', - index=0, - number=1, - type=1, - cpp_type=5, - label=1, - has_default_value=False, - default_value=float(0), - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='avg_decay_rate', - full_name='paddle.AdamSGDParameter.avg_decay_rate', - index=1, - number=2, - type=1, - cpp_type=5, - label=1, - has_default_value=False, - default_value=float(0), - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='ada_decay_rate', - full_name='paddle.AdamSGDParameter.ada_decay_rate', - index=2, - number=3, - type=1, - cpp_type=5, - label=1, - has_default_value=False, - default_value=float(0), - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='ada_epsilon', - full_name='paddle.AdamSGDParameter.ada_epsilon', - index=3, - number=4, - type=1, - cpp_type=5, - label=1, - has_default_value=False, - default_value=float(0), - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='mom_decay_rate', - full_name='paddle.AdamSGDParameter.mom_decay_rate', - index=4, - number=5, - type=1, - cpp_type=5, - label=1, - has_default_value=False, - default_value=float(0), - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - ], - extensions=[], - nested_types=[], - enum_types=[], - options=None, - is_extendable=False, - syntax='proto2', - extension_ranges=[], - oneofs=[], - serialized_start=2885, - serialized_end=3019, -) - -_NAIVESGDPARAMETER = _descriptor.Descriptor( - name='NaiveSGDParameter', - full_name='paddle.NaiveSGDParameter', - filename=None, - file=DESCRIPTOR, - containing_type=None, - fields=[ - _descriptor.FieldDescriptor( - name='learning_rate', - full_name='paddle.NaiveSGDParameter.learning_rate', - index=0, - number=1, - type=1, - cpp_type=5, - label=1, - has_default_value=False, - default_value=float(0), - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='avg_decay_rate', - full_name='paddle.NaiveSGDParameter.avg_decay_rate', - index=1, - number=2, - type=1, - cpp_type=5, - label=1, - has_default_value=False, - default_value=float(0), - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - ], - extensions=[], - nested_types=[], - enum_types=[], - options=None, - is_extendable=False, - syntax='proto2', - extension_ranges=[], - oneofs=[], - serialized_start=3021, - serialized_end=3087, -) - -_SUMMARYSGDPARAMETER = _descriptor.Descriptor( - name='SummarySGDParameter', - full_name='paddle.SummarySGDParameter', - filename=None, - file=DESCRIPTOR, - containing_type=None, - fields=[ - _descriptor.FieldDescriptor( - name='summary_decay_rate', - full_name='paddle.SummarySGDParameter.summary_decay_rate', - index=0, - number=1, - type=1, - cpp_type=5, - label=1, - has_default_value=True, - default_value=float(0.999999), - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - ], - extensions=[], - nested_types=[], - enum_types=[], - options=None, - is_extendable=False, - syntax='proto2', - extension_ranges=[], - oneofs=[], - serialized_start=3089, - serialized_end=3148, -) - -_MOVINGAVERAGERULEPARAMETER = _descriptor.Descriptor( - name='MovingAverageRuleParameter', - full_name='paddle.MovingAverageRuleParameter', - filename=None, - file=DESCRIPTOR, - containing_type=None, - fields=[ - _descriptor.FieldDescriptor( - name='momentum', - full_name='paddle.MovingAverageRuleParameter.momentum', - index=0, - number=1, - type=1, - cpp_type=5, - label=1, - has_default_value=False, - default_value=float(0), - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - ], - extensions=[], - nested_types=[], - enum_types=[], - options=None, - is_extendable=False, - syntax='proto2', - extension_ranges=[], - oneofs=[], - serialized_start=3150, - serialized_end=3196, -) - -_PSRESPONSEMESSAGE = _descriptor.Descriptor( - name='PsResponseMessage', - full_name='paddle.PsResponseMessage', - filename=None, - file=DESCRIPTOR, - containing_type=None, - fields=[ - _descriptor.FieldDescriptor( - name='err_code', - full_name='paddle.PsResponseMessage.err_code', - index=0, - number=1, - type=5, - cpp_type=1, - label=2, - has_default_value=True, - default_value=0, - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='err_msg', - full_name='paddle.PsResponseMessage.err_msg', - index=1, - number=2, - type=9, - cpp_type=9, - label=2, - has_default_value=True, - default_value=_b("").decode('utf-8'), - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='data', - full_name='paddle.PsResponseMessage.data', - index=2, - number=3, - type=12, - cpp_type=9, - label=1, - has_default_value=False, - default_value=_b(""), - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - ], - extensions=[], - nested_types=[], - enum_types=[], - options=None, - is_extendable=False, - syntax='proto2', - extension_ranges=[], - oneofs=[], - serialized_start=3198, - serialized_end=3271, -) - -_FSCLIENTPARAMETER = _descriptor.Descriptor( - name='FsClientParameter', - full_name='paddle.FsClientParameter', - filename=None, - file=DESCRIPTOR, - containing_type=None, - fields=[ - _descriptor.FieldDescriptor( - name='fs_type', - full_name='paddle.FsClientParameter.fs_type', - index=0, - number=1, - type=14, - cpp_type=8, - label=1, - has_default_value=True, - default_value=0, - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='uri', - full_name='paddle.FsClientParameter.uri', - index=1, - number=2, - type=9, - cpp_type=9, - label=1, - has_default_value=False, - default_value=_b("").decode('utf-8'), - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='user', - full_name='paddle.FsClientParameter.user', - index=2, - number=3, - type=9, - cpp_type=9, - label=1, - has_default_value=False, - default_value=_b("").decode('utf-8'), - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='passwd', - full_name='paddle.FsClientParameter.passwd', - index=3, - number=4, - type=9, - cpp_type=9, - label=1, - has_default_value=False, - default_value=_b("").decode('utf-8'), - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='buffer_size', - full_name='paddle.FsClientParameter.buffer_size', - index=4, - number=5, - type=5, - cpp_type=1, - label=1, - has_default_value=False, - default_value=0, - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='hadoop_bin', - full_name='paddle.FsClientParameter.hadoop_bin', - index=5, - number=51, - type=9, - cpp_type=9, - label=1, - has_default_value=False, - default_value=_b("").decode('utf-8'), - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - _descriptor.FieldDescriptor( - name='afs_conf', - full_name='paddle.FsClientParameter.afs_conf', - index=6, - number=101, - type=9, - cpp_type=9, - label=1, - has_default_value=False, - default_value=_b("").decode('utf-8'), - message_type=None, - enum_type=None, - containing_type=None, - is_extension=False, - extension_scope=None, - options=None, - ), - ], - extensions=[], - nested_types=[], - enum_types=[ - _FSCLIENTPARAMETER_FSAPITYPE, - ], - options=None, - is_extendable=False, - syntax='proto2', - extension_ranges=[], - oneofs=[], - serialized_start=3274, - serialized_end=3487, -) - -_PSPARAMETER.fields_by_name['worker_param'].message_type = _WORKERPARAMETER -_PSPARAMETER.fields_by_name['server_param'].message_type = _SERVERPARAMETER -_PSPARAMETER.fields_by_name[ - 'trainer_param' -].message_type = _DOWNPOURTRAINERPARAMETER -_PSPARAMETER.fields_by_name['fs_client_param'].message_type = _FSCLIENTPARAMETER -_WORKERPARAMETER.fields_by_name[ - 'downpour_worker_param' -].message_type = _DOWNPOURWORKERPARAMETER -_SERVERPARAMETER.fields_by_name[ - 'downpour_server_param' -].message_type = _DOWNPOURSERVERPARAMETER -_DOWNPOURWORKERPARAMETER.fields_by_name[ - 'downpour_table_param' -].message_type = _TABLEPARAMETER -_DOWNPOURTRAINERPARAMETER.fields_by_name[ - 'dense_table' -].message_type = _DENSETABLEPARAMETER -_DOWNPOURTRAINERPARAMETER.fields_by_name[ - 'sparse_table' -].message_type = _SPARSETABLEPARAMETER -_DOWNPOURTRAINERPARAMETER.fields_by_name[ - 'program_config' -].message_type = _PROGRAMCONFIG -_DOWNPOURSERVERPARAMETER.fields_by_name[ - 'downpour_table_param' -].message_type = _TABLEPARAMETER -_DOWNPOURSERVERPARAMETER.fields_by_name[ - 'service_param' -].message_type = _SERVERSERVICEPARAMETER -_TABLEPARAMETER.fields_by_name[ - 'accessor' -].message_type = _TABLEACCESSORPARAMETER -_TABLEPARAMETER.fields_by_name['type'].enum_type = _TABLETYPE -_TABLEACCESSORPARAMETER.fields_by_name[ - 'sparse_sgd_param' -].message_type = _SPARSESGDRULEPARAMETER -_TABLEACCESSORPARAMETER.fields_by_name[ - 'dense_sgd_param' -].message_type = _DENSESGDRULEPARAMETER -_TABLEACCESSORPARAMETER.fields_by_name[ - 'downpour_accessor_param' -].message_type = _DOWNPOURTABLEACCESSORPARAMETER -_TABLEACCESSORPARAMETER.fields_by_name[ - 'table_accessor_save_param' -].message_type = _TABLEACCESSORSAVEPARAMETER -_DENSESGDRULEPARAMETER.fields_by_name['adam'].message_type = _ADAMSGDPARAMETER -_DENSESGDRULEPARAMETER.fields_by_name['naive'].message_type = _NAIVESGDPARAMETER -_DENSESGDRULEPARAMETER.fields_by_name[ - 'summary' -].message_type = _SUMMARYSGDPARAMETER -_DENSESGDRULEPARAMETER.fields_by_name[ - 'moving_average' -].message_type = _MOVINGAVERAGERULEPARAMETER -_FSCLIENTPARAMETER.fields_by_name[ - 'fs_type' -].enum_type = _FSCLIENTPARAMETER_FSAPITYPE -_FSCLIENTPARAMETER_FSAPITYPE.containing_type = _FSCLIENTPARAMETER -DESCRIPTOR.message_types_by_name['PSParameter'] = _PSPARAMETER -DESCRIPTOR.message_types_by_name['WorkerParameter'] = _WORKERPARAMETER -DESCRIPTOR.message_types_by_name['ServerParameter'] = _SERVERPARAMETER -DESCRIPTOR.message_types_by_name[ - 'DownpourWorkerParameter' -] = _DOWNPOURWORKERPARAMETER -DESCRIPTOR.message_types_by_name[ - 'DownpourTrainerParameter' -] = _DOWNPOURTRAINERPARAMETER -DESCRIPTOR.message_types_by_name['ProgramConfig'] = _PROGRAMCONFIG -DESCRIPTOR.message_types_by_name['DenseTableParameter'] = _DENSETABLEPARAMETER -DESCRIPTOR.message_types_by_name['SparseTableParameter'] = _SPARSETABLEPARAMETER -DESCRIPTOR.message_types_by_name[ - 'DownpourServerParameter' -] = _DOWNPOURSERVERPARAMETER -DESCRIPTOR.message_types_by_name[ - 'ServerServiceParameter' -] = _SERVERSERVICEPARAMETER -DESCRIPTOR.message_types_by_name['TableParameter'] = _TABLEPARAMETER -DESCRIPTOR.message_types_by_name[ - 'TableAccessorParameter' -] = _TABLEACCESSORPARAMETER -DESCRIPTOR.message_types_by_name[ - 'DownpourTableAccessorParameter' -] = _DOWNPOURTABLEACCESSORPARAMETER -DESCRIPTOR.message_types_by_name[ - 'TableAccessorSaveParameter' -] = _TABLEACCESSORSAVEPARAMETER -DESCRIPTOR.message_types_by_name['PsRequestMessage'] = _PSREQUESTMESSAGE -DESCRIPTOR.message_types_by_name[ - 'SparseSGDRuleParameter' -] = _SPARSESGDRULEPARAMETER -DESCRIPTOR.message_types_by_name[ - 'DenseSGDRuleParameter' -] = _DENSESGDRULEPARAMETER -DESCRIPTOR.message_types_by_name['AdamSGDParameter'] = _ADAMSGDPARAMETER -DESCRIPTOR.message_types_by_name['NaiveSGDParameter'] = _NAIVESGDPARAMETER -DESCRIPTOR.message_types_by_name['SummarySGDParameter'] = _SUMMARYSGDPARAMETER -DESCRIPTOR.message_types_by_name[ - 'MovingAverageRuleParameter' -] = _MOVINGAVERAGERULEPARAMETER -DESCRIPTOR.message_types_by_name['PsResponseMessage'] = _PSRESPONSEMESSAGE -DESCRIPTOR.message_types_by_name['FsClientParameter'] = _FSCLIENTPARAMETER -DESCRIPTOR.enum_types_by_name['TableType'] = _TABLETYPE -DESCRIPTOR.enum_types_by_name['PsCmdID'] = _PSCMDID - -PSParameter = _reflection.GeneratedProtocolMessageType( - 'PSParameter', - (_message.Message,), - dict( - DESCRIPTOR=_PSPARAMETER, - __module__='ps_pb2' - # @@protoc_insertion_point(class_scope:paddle.PSParameter) - ), -) -_sym_db.RegisterMessage(PSParameter) - -WorkerParameter = _reflection.GeneratedProtocolMessageType( - 'WorkerParameter', - (_message.Message,), - dict( - DESCRIPTOR=_WORKERPARAMETER, - __module__='ps_pb2' - # @@protoc_insertion_point(class_scope:paddle.WorkerParameter) - ), -) -_sym_db.RegisterMessage(WorkerParameter) - -ServerParameter = _reflection.GeneratedProtocolMessageType( - 'ServerParameter', - (_message.Message,), - dict( - DESCRIPTOR=_SERVERPARAMETER, - __module__='ps_pb2' - # @@protoc_insertion_point(class_scope:paddle.ServerParameter) - ), -) -_sym_db.RegisterMessage(ServerParameter) - -DownpourWorkerParameter = _reflection.GeneratedProtocolMessageType( - 'DownpourWorkerParameter', - (_message.Message,), - dict( - DESCRIPTOR=_DOWNPOURWORKERPARAMETER, - __module__='ps_pb2' - # @@protoc_insertion_point(class_scope:paddle.DownpourWorkerParameter) - ), -) -_sym_db.RegisterMessage(DownpourWorkerParameter) - -DownpourTrainerParameter = _reflection.GeneratedProtocolMessageType( - 'DownpourTrainerParameter', - (_message.Message,), - dict( - DESCRIPTOR=_DOWNPOURTRAINERPARAMETER, - __module__='ps_pb2' - # @@protoc_insertion_point(class_scope:paddle.DownpourTrainerParameter) - ), -) -_sym_db.RegisterMessage(DownpourTrainerParameter) - -ProgramConfig = _reflection.GeneratedProtocolMessageType( - 'ProgramConfig', - (_message.Message,), - dict( - DESCRIPTOR=_PROGRAMCONFIG, - __module__='ps_pb2' - # @@protoc_insertion_point(class_scope:paddle.ProgramConfig) - ), -) -_sym_db.RegisterMessage(ProgramConfig) - -DenseTableParameter = _reflection.GeneratedProtocolMessageType( - 'DenseTableParameter', - (_message.Message,), - dict( - DESCRIPTOR=_DENSETABLEPARAMETER, - __module__='ps_pb2' - # @@protoc_insertion_point(class_scope:paddle.DenseTableParameter) - ), -) -_sym_db.RegisterMessage(DenseTableParameter) - -SparseTableParameter = _reflection.GeneratedProtocolMessageType( - 'SparseTableParameter', - (_message.Message,), - dict( - DESCRIPTOR=_SPARSETABLEPARAMETER, - __module__='ps_pb2' - # @@protoc_insertion_point(class_scope:paddle.SparseTableParameter) - ), -) -_sym_db.RegisterMessage(SparseTableParameter) - -DownpourServerParameter = _reflection.GeneratedProtocolMessageType( - 'DownpourServerParameter', - (_message.Message,), - dict( - DESCRIPTOR=_DOWNPOURSERVERPARAMETER, - __module__='ps_pb2' - # @@protoc_insertion_point(class_scope:paddle.DownpourServerParameter) - ), -) -_sym_db.RegisterMessage(DownpourServerParameter) - -ServerServiceParameter = _reflection.GeneratedProtocolMessageType( - 'ServerServiceParameter', - (_message.Message,), - dict( - DESCRIPTOR=_SERVERSERVICEPARAMETER, - __module__='ps_pb2' - # @@protoc_insertion_point(class_scope:paddle.ServerServiceParameter) - ), -) -_sym_db.RegisterMessage(ServerServiceParameter) - -TableParameter = _reflection.GeneratedProtocolMessageType( - 'TableParameter', - (_message.Message,), - dict( - DESCRIPTOR=_TABLEPARAMETER, - __module__='ps_pb2' - # @@protoc_insertion_point(class_scope:paddle.TableParameter) - ), -) -_sym_db.RegisterMessage(TableParameter) - -TableAccessorParameter = _reflection.GeneratedProtocolMessageType( - 'TableAccessorParameter', - (_message.Message,), - dict( - DESCRIPTOR=_TABLEACCESSORPARAMETER, - __module__='ps_pb2' - # @@protoc_insertion_point(class_scope:paddle.TableAccessorParameter) - ), -) -_sym_db.RegisterMessage(TableAccessorParameter) - -DownpourTableAccessorParameter = _reflection.GeneratedProtocolMessageType( - 'DownpourTableAccessorParameter', - (_message.Message,), - dict( - DESCRIPTOR=_DOWNPOURTABLEACCESSORPARAMETER, - __module__='ps_pb2' - # @@protoc_insertion_point(class_scope:paddle.DownpourTableAccessorParameter) - ), -) -_sym_db.RegisterMessage(DownpourTableAccessorParameter) - -TableAccessorSaveParameter = _reflection.GeneratedProtocolMessageType( - 'TableAccessorSaveParameter', - (_message.Message,), - dict( - DESCRIPTOR=_TABLEACCESSORSAVEPARAMETER, - __module__='ps_pb2' - # @@protoc_insertion_point(class_scope:paddle.TableAccessorSaveParameter) - ), -) -_sym_db.RegisterMessage(TableAccessorSaveParameter) - -PsRequestMessage = _reflection.GeneratedProtocolMessageType( - 'PsRequestMessage', - (_message.Message,), - dict( - DESCRIPTOR=_PSREQUESTMESSAGE, - __module__='ps_pb2' - # @@protoc_insertion_point(class_scope:paddle.PsRequestMessage) - ), -) -_sym_db.RegisterMessage(PsRequestMessage) - -SparseSGDRuleParameter = _reflection.GeneratedProtocolMessageType( - 'SparseSGDRuleParameter', - (_message.Message,), - dict( - DESCRIPTOR=_SPARSESGDRULEPARAMETER, - __module__='ps_pb2' - # @@protoc_insertion_point(class_scope:paddle.SparseSGDRuleParameter) - ), -) -_sym_db.RegisterMessage(SparseSGDRuleParameter) - -DenseSGDRuleParameter = _reflection.GeneratedProtocolMessageType( - 'DenseSGDRuleParameter', - (_message.Message,), - dict( - DESCRIPTOR=_DENSESGDRULEPARAMETER, - __module__='ps_pb2' - # @@protoc_insertion_point(class_scope:paddle.DenseSGDRuleParameter) - ), -) -_sym_db.RegisterMessage(DenseSGDRuleParameter) - -AdamSGDParameter = _reflection.GeneratedProtocolMessageType( - 'AdamSGDParameter', - (_message.Message,), - dict( - DESCRIPTOR=_ADAMSGDPARAMETER, - __module__='ps_pb2' - # @@protoc_insertion_point(class_scope:paddle.AdamSGDParameter) - ), -) -_sym_db.RegisterMessage(AdamSGDParameter) - -NaiveSGDParameter = _reflection.GeneratedProtocolMessageType( - 'NaiveSGDParameter', - (_message.Message,), - dict( - DESCRIPTOR=_NAIVESGDPARAMETER, - __module__='ps_pb2' - # @@protoc_insertion_point(class_scope:paddle.NaiveSGDParameter) - ), -) -_sym_db.RegisterMessage(NaiveSGDParameter) - -SummarySGDParameter = _reflection.GeneratedProtocolMessageType( - 'SummarySGDParameter', - (_message.Message,), - dict( - DESCRIPTOR=_SUMMARYSGDPARAMETER, - __module__='ps_pb2' - # @@protoc_insertion_point(class_scope:paddle.SummarySGDParameter) - ), -) -_sym_db.RegisterMessage(SummarySGDParameter) - -MovingAverageRuleParameter = _reflection.GeneratedProtocolMessageType( - 'MovingAverageRuleParameter', - (_message.Message,), - dict( - DESCRIPTOR=_MOVINGAVERAGERULEPARAMETER, - __module__='ps_pb2' - # @@protoc_insertion_point(class_scope:paddle.MovingAverageRuleParameter) - ), -) -_sym_db.RegisterMessage(MovingAverageRuleParameter) - -PsResponseMessage = _reflection.GeneratedProtocolMessageType( - 'PsResponseMessage', - (_message.Message,), - dict( - DESCRIPTOR=_PSRESPONSEMESSAGE, - __module__='ps_pb2' - # @@protoc_insertion_point(class_scope:paddle.PsResponseMessage) - ), -) -_sym_db.RegisterMessage(PsResponseMessage) - -FsClientParameter = _reflection.GeneratedProtocolMessageType( - 'FsClientParameter', - (_message.Message,), - dict( - DESCRIPTOR=_FSCLIENTPARAMETER, - __module__='ps_pb2' - # @@protoc_insertion_point(class_scope:paddle.FsClientParameter) - ), -) -_sym_db.RegisterMessage(FsClientParameter) - -DESCRIPTOR.has_options = True -DESCRIPTOR._options = _descriptor._ParseOptions( - descriptor_pb2.FileOptions(), _b('\200\001\001') -) -# @@protoc_insertion_point(module_scope) diff --git a/python/setup.py.in b/python/setup.py.in index cb906b544585ac213c2f3c28210af2ec05e21f80..25a1204610d205f6535fca98c4b25f07d5e63121 100644 --- a/python/setup.py.in +++ b/python/setup.py.in @@ -333,7 +333,6 @@ packages=['paddle', 'paddle.fluid.dygraph', 'paddle.fluid.proto', 'paddle.fluid.proto.profiler', - 'paddle.fluid.distributed', 'paddle.fluid.layers', 'paddle.fluid.dataloader', 'paddle.fluid.contrib', diff --git a/setup.py b/setup.py index 39b33ba686a69ac24f935435ae93c42aacd673a5..14cbd27f5be929dda8b84714d93b5b758f93eae8 100644 --- a/setup.py +++ b/setup.py @@ -1232,7 +1232,6 @@ def get_setup_parameters(): 'paddle.fluid.dygraph', 'paddle.fluid.proto', 'paddle.fluid.proto.profiler', - 'paddle.fluid.distributed', 'paddle.fluid.layers', 'paddle.fluid.dataloader', 'paddle.fluid.contrib',