diff --git a/common/proto/apis/common/types.proto b/common/proto/apis/common/types.proto index 68aebb5..e408034 100644 --- a/common/proto/apis/common/types.proto +++ b/common/proto/apis/common/types.proto @@ -62,6 +62,8 @@ enum DataType { DT_VARIANT_REF = 121; DT_UINT32_REF = 122; DT_UINT64_REF = 123; + // for containing multiple field's type in a row + DT_MULTI_TYPE=-2; } // LINT.ThenChange( // https://www.tensorflow.org/code/tensorflow/c/c_api.h, @@ -70,4 +72,4 @@ enum DataType { // https://www.tensorflow.org/code/tensorflow/core/framework/types.h, // https://www.tensorflow.org/code/tensorflow/core/framework/types.cc, // https://www.tensorflow.org/code/tensorflow/python/framework/dtypes.py, -// https://www.tensorflow.org/code/tensorflow/python/framework/function.py) \ No newline at end of file +// https://www.tensorflow.org/code/tensorflow/python/framework/function.py) diff --git a/common/src/main/java/com/tencent/angel/config/ConfigProtos.java b/common/src/main/java/com/tencent/angel/config/ConfigProtos.java index 2663513..e982da3 100644 --- a/common/src/main/java/com/tencent/angel/config/ConfigProtos.java +++ b/common/src/main/java/com/tencent/angel/config/ConfigProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: config/config.proto diff --git a/common/src/main/java/com/tencent/angel/config/FileSystemStoragePathSourceConfigProtos.java b/common/src/main/java/com/tencent/angel/config/FileSystemStoragePathSourceConfigProtos.java index 0515e1a..884dcb6 100644 --- a/common/src/main/java/com/tencent/angel/config/FileSystemStoragePathSourceConfigProtos.java +++ b/common/src/main/java/com/tencent/angel/config/FileSystemStoragePathSourceConfigProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: config/file_system_storage_path_source.proto diff --git a/common/src/main/java/com/tencent/angel/config/LogCollectorConfigProtos.java b/common/src/main/java/com/tencent/angel/config/LogCollectorConfigProtos.java index dfb3e60..1c085b5 100644 --- a/common/src/main/java/com/tencent/angel/config/LogCollectorConfigProtos.java +++ b/common/src/main/java/com/tencent/angel/config/LogCollectorConfigProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: config/log_collector_config.proto diff --git a/common/src/main/java/com/tencent/angel/config/ModelServerConfigProtos.java b/common/src/main/java/com/tencent/angel/config/ModelServerConfigProtos.java index 8addb5a..0a912ec 100644 --- a/common/src/main/java/com/tencent/angel/config/ModelServerConfigProtos.java +++ b/common/src/main/java/com/tencent/angel/config/ModelServerConfigProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: config/model_server_config.proto diff --git a/common/src/main/java/com/tencent/angel/config/MonitoringConfigProtos.java b/common/src/main/java/com/tencent/angel/config/MonitoringConfigProtos.java index dba2ac2..e188132 100644 --- a/common/src/main/java/com/tencent/angel/config/MonitoringConfigProtos.java +++ b/common/src/main/java/com/tencent/angel/config/MonitoringConfigProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: config/monitoring_config.proto diff --git a/common/src/main/java/com/tencent/angel/config/NamedTensorProtos.java b/common/src/main/java/com/tencent/angel/config/NamedTensorProtos.java index e766378..b30fd55 100644 --- a/common/src/main/java/com/tencent/angel/config/NamedTensorProtos.java +++ b/common/src/main/java/com/tencent/angel/config/NamedTensorProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: config/named_tensor.proto diff --git a/common/src/main/java/com/tencent/angel/config/PlatformConfigProtos.java b/common/src/main/java/com/tencent/angel/config/PlatformConfigProtos.java index 100acf5..bfc2e53 100644 --- a/common/src/main/java/com/tencent/angel/config/PlatformConfigProtos.java +++ b/common/src/main/java/com/tencent/angel/config/PlatformConfigProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: config/platform_config.proto diff --git a/common/src/main/java/com/tencent/angel/config/ResourceProtos.java b/common/src/main/java/com/tencent/angel/config/ResourceProtos.java index 105001f..bdc5d24 100644 --- a/common/src/main/java/com/tencent/angel/config/ResourceProtos.java +++ b/common/src/main/java/com/tencent/angel/config/ResourceProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: config/resources.proto diff --git a/common/src/main/java/com/tencent/angel/config/SamplingConfigProtos.java b/common/src/main/java/com/tencent/angel/config/SamplingConfigProtos.java index 4553d61..15839e4 100644 --- a/common/src/main/java/com/tencent/angel/config/SamplingConfigProtos.java +++ b/common/src/main/java/com/tencent/angel/config/SamplingConfigProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: config/logging_config.proto diff --git a/common/src/main/java/com/tencent/angel/core/DebugProtos.java b/common/src/main/java/com/tencent/angel/core/DebugProtos.java index ad74577..d2fba93 100644 --- a/common/src/main/java/com/tencent/angel/core/DebugProtos.java +++ b/common/src/main/java/com/tencent/angel/core/DebugProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: core/debug.proto diff --git a/common/src/main/java/com/tencent/angel/core/LoggingProtos.java b/common/src/main/java/com/tencent/angel/core/LoggingProtos.java index ab367de..2dfaee3 100644 --- a/common/src/main/java/com/tencent/angel/core/LoggingProtos.java +++ b/common/src/main/java/com/tencent/angel/core/LoggingProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: core/logging.proto diff --git a/common/src/main/java/com/tencent/angel/core/graph/AttrValueProtos.java b/common/src/main/java/com/tencent/angel/core/graph/AttrValueProtos.java index d53986d..efb3fac 100644 --- a/common/src/main/java/com/tencent/angel/core/graph/AttrValueProtos.java +++ b/common/src/main/java/com/tencent/angel/core/graph/AttrValueProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: core/graph/attr_value.proto diff --git a/common/src/main/java/com/tencent/angel/core/graph/CostGraphProtos.java b/common/src/main/java/com/tencent/angel/core/graph/CostGraphProtos.java index efd3a62..da958c6 100644 --- a/common/src/main/java/com/tencent/angel/core/graph/CostGraphProtos.java +++ b/common/src/main/java/com/tencent/angel/core/graph/CostGraphProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: core/graph/cost_graph.proto diff --git a/common/src/main/java/com/tencent/angel/core/graph/FunctionProtos.java b/common/src/main/java/com/tencent/angel/core/graph/FunctionProtos.java index 1024e91..20c21db 100644 --- a/common/src/main/java/com/tencent/angel/core/graph/FunctionProtos.java +++ b/common/src/main/java/com/tencent/angel/core/graph/FunctionProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: core/graph/function.proto diff --git a/common/src/main/java/com/tencent/angel/core/graph/GraphProtos.java b/common/src/main/java/com/tencent/angel/core/graph/GraphProtos.java index 1018e2c..70799f3 100644 --- a/common/src/main/java/com/tencent/angel/core/graph/GraphProtos.java +++ b/common/src/main/java/com/tencent/angel/core/graph/GraphProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: core/graph/graph.proto diff --git a/common/src/main/java/com/tencent/angel/core/graph/NodeProto.java b/common/src/main/java/com/tencent/angel/core/graph/NodeProto.java index 07dddc4..113668d 100644 --- a/common/src/main/java/com/tencent/angel/core/graph/NodeProto.java +++ b/common/src/main/java/com/tencent/angel/core/graph/NodeProto.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: core/graph/node_def.proto diff --git a/common/src/main/java/com/tencent/angel/core/graph/OpDefProtos.java b/common/src/main/java/com/tencent/angel/core/graph/OpDefProtos.java index 250b3c5..196904a 100644 --- a/common/src/main/java/com/tencent/angel/core/graph/OpDefProtos.java +++ b/common/src/main/java/com/tencent/angel/core/graph/OpDefProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: core/graph/op_def.proto diff --git a/common/src/main/java/com/tencent/angel/core/graph/ResourceHandleProtos.java b/common/src/main/java/com/tencent/angel/core/graph/ResourceHandleProtos.java index 99966fa..e7bfda7 100644 --- a/common/src/main/java/com/tencent/angel/core/graph/ResourceHandleProtos.java +++ b/common/src/main/java/com/tencent/angel/core/graph/ResourceHandleProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: core/graph/resource_handle.proto diff --git a/common/src/main/java/com/tencent/angel/core/graph/TensorProtos.java b/common/src/main/java/com/tencent/angel/core/graph/TensorProtos.java index e55e6c3..b037d17 100644 --- a/common/src/main/java/com/tencent/angel/core/graph/TensorProtos.java +++ b/common/src/main/java/com/tencent/angel/core/graph/TensorProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: core/graph/tensor.proto diff --git a/common/src/main/java/com/tencent/angel/core/graph/VersionsProtos.java b/common/src/main/java/com/tencent/angel/core/graph/VersionsProtos.java index 4c14358..d2b67e6 100644 --- a/common/src/main/java/com/tencent/angel/core/graph/VersionsProtos.java +++ b/common/src/main/java/com/tencent/angel/core/graph/VersionsProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: core/graph/versions.proto diff --git a/common/src/main/java/com/tencent/angel/core/saver/MetaGraphProtos.java b/common/src/main/java/com/tencent/angel/core/saver/MetaGraphProtos.java index 0918bd2..4ad0e63 100644 --- a/common/src/main/java/com/tencent/angel/core/saver/MetaGraphProtos.java +++ b/common/src/main/java/com/tencent/angel/core/saver/MetaGraphProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: core/saver/meta_graph.proto diff --git a/common/src/main/java/com/tencent/angel/core/saver/SavedModelProtos.java b/common/src/main/java/com/tencent/angel/core/saver/SavedModelProtos.java index 88b846d..07598cf 100644 --- a/common/src/main/java/com/tencent/angel/core/saver/SavedModelProtos.java +++ b/common/src/main/java/com/tencent/angel/core/saver/SavedModelProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: core/saver/saved_model.proto diff --git a/common/src/main/java/com/tencent/angel/core/saver/SaverProtos.java b/common/src/main/java/com/tencent/angel/core/saver/SaverProtos.java index 619a07a..7a06ed2 100644 --- a/common/src/main/java/com/tencent/angel/core/saver/SaverProtos.java +++ b/common/src/main/java/com/tencent/angel/core/saver/SaverProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: core/saver/saver.proto diff --git a/common/src/main/java/com/tencent/angel/core/stats/AllocationDescriptionProtos.java b/common/src/main/java/com/tencent/angel/core/stats/AllocationDescriptionProtos.java index c9826e6..0731c74 100644 --- a/common/src/main/java/com/tencent/angel/core/stats/AllocationDescriptionProtos.java +++ b/common/src/main/java/com/tencent/angel/core/stats/AllocationDescriptionProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: core/stats/allocation_description.proto diff --git a/common/src/main/java/com/tencent/angel/core/stats/StepStatsProtos.java b/common/src/main/java/com/tencent/angel/core/stats/StepStatsProtos.java index 5bdec31..4ed5130 100644 --- a/common/src/main/java/com/tencent/angel/core/stats/StepStatsProtos.java +++ b/common/src/main/java/com/tencent/angel/core/stats/StepStatsProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: core/stats/step_stats.proto diff --git a/common/src/main/java/com/tencent/angel/core/stats/TensorDescriptionProtos.java b/common/src/main/java/com/tencent/angel/core/stats/TensorDescriptionProtos.java index 9b8c98c..b1498ec 100644 --- a/common/src/main/java/com/tencent/angel/core/stats/TensorDescriptionProtos.java +++ b/common/src/main/java/com/tencent/angel/core/stats/TensorDescriptionProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: core/stats/tensor_description.proto diff --git a/common/src/main/java/com/tencent/angel/metrics/ServingMetricsProtos.java b/common/src/main/java/com/tencent/angel/metrics/ServingMetricsProtos.java index 2e8d92b..4cc8416 100644 --- a/common/src/main/java/com/tencent/angel/metrics/ServingMetricsProtos.java +++ b/common/src/main/java/com/tencent/angel/metrics/ServingMetricsProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: metrics/serving_metrics.proto diff --git a/common/src/main/java/com/tencent/angel/servable/SavedModelBundleSourceAdapterConfigProtos.java b/common/src/main/java/com/tencent/angel/servable/SavedModelBundleSourceAdapterConfigProtos.java index f0ea6ed..8256435 100644 --- a/common/src/main/java/com/tencent/angel/servable/SavedModelBundleSourceAdapterConfigProtos.java +++ b/common/src/main/java/com/tencent/angel/servable/SavedModelBundleSourceAdapterConfigProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: servable/saved_model_bundle_source_adapter.proto diff --git a/common/src/main/java/com/tencent/angel/servable/SessionBundleConfigProtos.java b/common/src/main/java/com/tencent/angel/servable/SessionBundleConfigProtos.java index 2e471a6..e415254 100644 --- a/common/src/main/java/com/tencent/angel/servable/SessionBundleConfigProtos.java +++ b/common/src/main/java/com/tencent/angel/servable/SessionBundleConfigProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: servable/session_bundle_config.proto diff --git a/common/src/main/java/com/tencent/angel/servable/SessionBundleSourceAdapterConfigProtos.java b/common/src/main/java/com/tencent/angel/servable/SessionBundleSourceAdapterConfigProtos.java index fc0f6b6..a82478b 100644 --- a/common/src/main/java/com/tencent/angel/servable/SessionBundleSourceAdapterConfigProtos.java +++ b/common/src/main/java/com/tencent/angel/servable/SessionBundleSourceAdapterConfigProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: servable/session_bundle_source_adapter.proto diff --git a/common/src/main/java/com/tencent/angel/serving/apis/common/ExampleProtos.java b/common/src/main/java/com/tencent/angel/serving/apis/common/ExampleProtos.java index c20cc7e..8cf4fd6 100644 --- a/common/src/main/java/com/tencent/angel/serving/apis/common/ExampleProtos.java +++ b/common/src/main/java/com/tencent/angel/serving/apis/common/ExampleProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: apis/common/example.proto diff --git a/common/src/main/java/com/tencent/angel/serving/apis/common/FeatureProtos.java b/common/src/main/java/com/tencent/angel/serving/apis/common/FeatureProtos.java index 5b1d238..b4deeb0 100644 --- a/common/src/main/java/com/tencent/angel/serving/apis/common/FeatureProtos.java +++ b/common/src/main/java/com/tencent/angel/serving/apis/common/FeatureProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: apis/common/feature.proto diff --git a/common/src/main/java/com/tencent/angel/serving/apis/common/InputProtos.java b/common/src/main/java/com/tencent/angel/serving/apis/common/InputProtos.java index 32b0fe9..1eda3b2 100644 --- a/common/src/main/java/com/tencent/angel/serving/apis/common/InputProtos.java +++ b/common/src/main/java/com/tencent/angel/serving/apis/common/InputProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: apis/common/input.proto diff --git a/common/src/main/java/com/tencent/angel/serving/apis/common/InstanceProtos.java b/common/src/main/java/com/tencent/angel/serving/apis/common/InstanceProtos.java index 89cbe8e..2021972 100644 --- a/common/src/main/java/com/tencent/angel/serving/apis/common/InstanceProtos.java +++ b/common/src/main/java/com/tencent/angel/serving/apis/common/InstanceProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: apis/common/instance.proto diff --git a/common/src/main/java/com/tencent/angel/serving/apis/common/ModelSpecProtos.java b/common/src/main/java/com/tencent/angel/serving/apis/common/ModelSpecProtos.java index 2e656da..517c61e 100644 --- a/common/src/main/java/com/tencent/angel/serving/apis/common/ModelSpecProtos.java +++ b/common/src/main/java/com/tencent/angel/serving/apis/common/ModelSpecProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: apis/common/model.proto diff --git a/common/src/main/java/com/tencent/angel/serving/apis/common/TensorShapeProtos.java b/common/src/main/java/com/tencent/angel/serving/apis/common/TensorShapeProtos.java index dc19bb5..9aea1af 100644 --- a/common/src/main/java/com/tencent/angel/serving/apis/common/TensorShapeProtos.java +++ b/common/src/main/java/com/tencent/angel/serving/apis/common/TensorShapeProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: apis/common/tensor_shape.proto diff --git a/common/src/main/java/com/tencent/angel/serving/apis/common/TypesProtos.java b/common/src/main/java/com/tencent/angel/serving/apis/common/TypesProtos.java index 597de6c..9a67f0e 100644 --- a/common/src/main/java/com/tencent/angel/serving/apis/common/TypesProtos.java +++ b/common/src/main/java/com/tencent/angel/serving/apis/common/TypesProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: apis/common/types.proto @@ -278,6 +262,14 @@ public enum DataType * DT_UINT64_REF = 123; */ DT_UINT64_REF(123), + /** + * 
+     * for containing multiple field's type  in a row
+     *
+ * + * DT_MULTI_TYPE = -2; + */ + DT_MULTI_TYPE(-2), UNRECOGNIZED(-1), ; @@ -520,6 +512,14 @@ public enum DataType * DT_UINT64_REF = 123; */ public static final int DT_UINT64_REF_VALUE = 123; + /** + * 
+     * for containing multiple field's type  in a row
+     *
+ * + * DT_MULTI_TYPE = -2; + */ + public static final int DT_MULTI_TYPE_VALUE = -2; public final int getNumber() { @@ -587,6 +587,7 @@ public static DataType forNumber(int value) { case 121: return DT_VARIANT_REF; case 122: return DT_UINT32_REF; case 123: return DT_UINT64_REF; + case -2: return DT_MULTI_TYPE; default: return null; } } @@ -648,7 +649,7 @@ private DataType(int value) { descriptor; static { java.lang.String[] descriptorData = { - "\n\027apis/common/types.proto\022\005angel*\252\006\n\010Dat" + + "\n\027apis/common/types.proto\022\005angel*\306\006\n\010Dat" + "aType\022\016\n\nDT_INVALID\020\000\022\014\n\010DT_FLOAT\020\001\022\r\n\tD" + "T_DOUBLE\020\002\022\014\n\010DT_INT32\020\003\022\014\n\010DT_UINT8\020\004\022\014" + "\n\010DT_INT16\020\005\022\013\n\007DT_INT8\020\006\022\r\n\tDT_STRING\020\007" + @@ -669,8 +670,9 @@ private DataType(int value) { "_REF\020u\022\025\n\021DT_COMPLEX128_REF\020v\022\017\n\013DT_HALF" + "_REF\020w\022\023\n\017DT_RESOURCE_REF\020x\022\022\n\016DT_VARIAN" + "T_REF\020y\022\021\n\rDT_UINT32_REF\020z\022\021\n\rDT_UINT64_" + - "REF\020{B6\n%com.tencent.angel.serving.apis." + - "commonB\013TypesProtosP\000b\006proto3" + "REF\020{\022\032\n\rDT_MULTI_TYPE\020\376\377\377\377\377\377\377\377\377\001B6\n%com" + + ".tencent.angel.serving.apis.commonB\013Type" + + "sProtosP\000b\006proto3" }; com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner = new com.google.protobuf.Descriptors.FileDescriptor. InternalDescriptorAssigner() { diff --git a/common/src/main/java/com/tencent/angel/serving/apis/internal/SerializedInputProtos.java b/common/src/main/java/com/tencent/angel/serving/apis/internal/SerializedInputProtos.java index d286964..57e4ed2 100644 --- a/common/src/main/java/com/tencent/angel/serving/apis/internal/SerializedInputProtos.java +++ b/common/src/main/java/com/tencent/angel/serving/apis/internal/SerializedInputProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: apis/internal/serialized_input.proto diff --git a/common/src/main/java/com/tencent/angel/serving/apis/modelmgr/ErrorCodesProtos.java b/common/src/main/java/com/tencent/angel/serving/apis/modelmgr/ErrorCodesProtos.java index e73e959..e2c031e 100644 --- a/common/src/main/java/com/tencent/angel/serving/apis/modelmgr/ErrorCodesProtos.java +++ b/common/src/main/java/com/tencent/angel/serving/apis/modelmgr/ErrorCodesProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: apis/modelmgr/error_codes.proto diff --git a/common/src/main/java/com/tencent/angel/serving/apis/modelmgr/GetModelStatusProtos.java b/common/src/main/java/com/tencent/angel/serving/apis/modelmgr/GetModelStatusProtos.java index 91c3216..15aa538 100644 --- a/common/src/main/java/com/tencent/angel/serving/apis/modelmgr/GetModelStatusProtos.java +++ b/common/src/main/java/com/tencent/angel/serving/apis/modelmgr/GetModelStatusProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: apis/modelmgr/get_model_status.proto diff --git a/common/src/main/java/com/tencent/angel/serving/apis/modelmgr/ModelManagement.java b/common/src/main/java/com/tencent/angel/serving/apis/modelmgr/ModelManagement.java index da0bdd0..8703f7e 100644 --- a/common/src/main/java/com/tencent/angel/serving/apis/modelmgr/ModelManagement.java +++ b/common/src/main/java/com/tencent/angel/serving/apis/modelmgr/ModelManagement.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: apis/modelmgr/model_management.proto diff --git a/common/src/main/java/com/tencent/angel/serving/apis/modelmgr/ModelServiceGrpc.java b/common/src/main/java/com/tencent/angel/serving/apis/modelmgr/ModelServiceGrpc.java index ef109b0..63893ed 100644 --- a/common/src/main/java/com/tencent/angel/serving/apis/modelmgr/ModelServiceGrpc.java +++ b/common/src/main/java/com/tencent/angel/serving/apis/modelmgr/ModelServiceGrpc.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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. - * - */ package com.tencent.angel.serving.apis.modelmgr; import static io.grpc.MethodDescriptor.generateFullMethodName; diff --git a/common/src/main/java/com/tencent/angel/serving/apis/modelmgr/ModelServiceProtos.java b/common/src/main/java/com/tencent/angel/serving/apis/modelmgr/ModelServiceProtos.java index 2888d47..ae8de5a 100644 --- a/common/src/main/java/com/tencent/angel/serving/apis/modelmgr/ModelServiceProtos.java +++ b/common/src/main/java/com/tencent/angel/serving/apis/modelmgr/ModelServiceProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: apis/modelmgr/model_service.proto diff --git a/common/src/main/java/com/tencent/angel/serving/apis/modelmgr/StatusProtos.java b/common/src/main/java/com/tencent/angel/serving/apis/modelmgr/StatusProtos.java index a6708cf..a8bf1bc 100644 --- a/common/src/main/java/com/tencent/angel/serving/apis/modelmgr/StatusProtos.java +++ b/common/src/main/java/com/tencent/angel/serving/apis/modelmgr/StatusProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: apis/modelmgr/status.proto diff --git a/common/src/main/java/com/tencent/angel/serving/apis/prediction/GetModelMetadataProtos.java b/common/src/main/java/com/tencent/angel/serving/apis/prediction/GetModelMetadataProtos.java index 5e21f54..98e2b55 100644 --- a/common/src/main/java/com/tencent/angel/serving/apis/prediction/GetModelMetadataProtos.java +++ b/common/src/main/java/com/tencent/angel/serving/apis/prediction/GetModelMetadataProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: apis/prediction/get_model_metadata.proto diff --git a/common/src/main/java/com/tencent/angel/serving/apis/prediction/PredictionServiceGrpc.java b/common/src/main/java/com/tencent/angel/serving/apis/prediction/PredictionServiceGrpc.java index a9e5a47..3ede4e9 100644 --- a/common/src/main/java/com/tencent/angel/serving/apis/prediction/PredictionServiceGrpc.java +++ b/common/src/main/java/com/tencent/angel/serving/apis/prediction/PredictionServiceGrpc.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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. - * - */ package com.tencent.angel.serving.apis.prediction; import static io.grpc.MethodDescriptor.generateFullMethodName; diff --git a/common/src/main/java/com/tencent/angel/serving/apis/prediction/PredictionServiceProtos.java b/common/src/main/java/com/tencent/angel/serving/apis/prediction/PredictionServiceProtos.java index e102b1b..9224bf4 100644 --- a/common/src/main/java/com/tencent/angel/serving/apis/prediction/PredictionServiceProtos.java +++ b/common/src/main/java/com/tencent/angel/serving/apis/prediction/PredictionServiceProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: apis/prediction/prediction_service.proto diff --git a/common/src/main/java/com/tencent/angel/serving/apis/prediction/RequestProtos.java b/common/src/main/java/com/tencent/angel/serving/apis/prediction/RequestProtos.java index bed7bee..e5619e9 100644 --- a/common/src/main/java/com/tencent/angel/serving/apis/prediction/RequestProtos.java +++ b/common/src/main/java/com/tencent/angel/serving/apis/prediction/RequestProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: apis/prediction/request.proto diff --git a/common/src/main/java/com/tencent/angel/serving/apis/prediction/ResponseProtos.java b/common/src/main/java/com/tencent/angel/serving/apis/prediction/ResponseProtos.java index d0d3429..8729b01 100644 --- a/common/src/main/java/com/tencent/angel/serving/apis/prediction/ResponseProtos.java +++ b/common/src/main/java/com/tencent/angel/serving/apis/prediction/ResponseProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: apis/prediction/response.proto diff --git a/common/src/main/java/com/tencent/angel/serving/apis/session/SessionServiceGrpc.java b/common/src/main/java/com/tencent/angel/serving/apis/session/SessionServiceGrpc.java index 3e1a043..363e049 100644 --- a/common/src/main/java/com/tencent/angel/serving/apis/session/SessionServiceGrpc.java +++ b/common/src/main/java/com/tencent/angel/serving/apis/session/SessionServiceGrpc.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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. - * - */ package com.tencent.angel.serving.apis.session; import static io.grpc.MethodDescriptor.generateFullMethodName; diff --git a/common/src/main/java/com/tencent/angel/serving/apis/session/SessionServiceProtos.java b/common/src/main/java/com/tencent/angel/serving/apis/session/SessionServiceProtos.java index 07533fa..347f322 100644 --- a/common/src/main/java/com/tencent/angel/serving/apis/session/SessionServiceProtos.java +++ b/common/src/main/java/com/tencent/angel/serving/apis/session/SessionServiceProtos.java @@ -1,19 +1,3 @@ -/* - * Tencent is pleased to support the open source community by making Angel available. - * - * Copyright (C) 2017-2018 THL A29 Limited, a Tencent company. 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 - * - * https://opensource.org/licenses/Apache-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: apis/session/session_service.proto diff --git a/common/src/main/java/com/tencent/angel/utils/InstanceUtils.java b/common/src/main/java/com/tencent/angel/utils/InstanceUtils.java index 199e447..aa5bb3f 100644 --- a/common/src/main/java/com/tencent/angel/utils/InstanceUtils.java +++ b/common/src/main/java/com/tencent/angel/utils/InstanceUtils.java @@ -23,6 +23,7 @@ import com.tencent.angel.serving.apis.common.TypesProtos.*; import com.tencent.angel.serving.apis.common.InstanceProtos.*; +import java.util.HashMap; import java.util.Iterator; import java.util.Map; @@ -233,9 +234,29 @@ static public Vector getVector(Instance instance) { // for string key vector static public Map getStringKeyMap(Instance instance) { MapValue mapValue = instance.getMv(); - DataType dType = instance.getDType(); switch (dType) { + case DT_MULTI_TYPE: + Map result = new HashMap<>(); + if (mapValue.getS2IMapMap().size() > 0) { + result.putAll(mapValue.getS2IMapMap()); + } + if (mapValue.getS2SMapMap().size() > 0) { + result.putAll(mapValue.getS2SMapMap()); + } + if (mapValue.getS2DMapMap().size() > 0) { + result.putAll(mapValue.getS2DMapMap()); + } + if (mapValue.getS2BMapMap().size() > 0) { + result.putAll(mapValue.getS2BMapMap()); + } + if (mapValue.getS2LMapMap().size() > 0) { + result.putAll(mapValue.getS2LMapMap()); + } + if (mapValue.getS2FMapMap().size() > 0) { + result.putAll(mapValue.getS2FMapMap()); + } + return result; case DT_INT32: return mapValue.getS2IMapMap(); case DT_INT64: diff --git a/common/src/main/java/com/tencent/angel/utils/ProtoUtils.java b/common/src/main/java/com/tencent/angel/utils/ProtoUtils.java index 9c4a8f6..690435b 100644 --- a/common/src/main/java/com/tencent/angel/utils/ProtoUtils.java +++ b/common/src/main/java/com/tencent/angel/utils/ProtoUtils.java @@ -223,8 +223,9 @@ static private Tuple2 addElements(ListValue.Builder lvBuil static private int addElements(MapValue.Builder mvBuilder, Map values) throws Exception { int dtype = -1; + boolean multipleType = false; Iterator> iter = values.entrySet().iterator(); - if (iter.hasNext()) { + while (iter.hasNext()) { Map.Entry entry = iter.next(); K key = entry.getKey(); V value = entry.getValue(); @@ -238,6 +239,7 @@ static private int addElements(MapValue.Builder mvBuilder, Map valu dtype = 13; mvBuilder.putI2LMap((Integer) key, (Long) value); } else if (key instanceof Integer && value instanceof Float) { + dtype = 14; mvBuilder.putI2FMap((Integer) key, (Float) value); } else if (key instanceof Integer && value instanceof Double) { @@ -271,30 +273,55 @@ static private int addElements(MapValue.Builder mvBuilder, Map valu dtype = 27; mvBuilder.putL2BsMap((Long) key, (ByteString) value); } else if (key instanceof String && value instanceof Boolean) { + if (dtype != -1 && dtype != 31) { + multipleType = true; + } dtype = 31; mvBuilder.putS2BMap((String) key, (Boolean) value); } else if (key instanceof String && value instanceof Integer) { + if (dtype != -1 && dtype != 32) { + multipleType = true; + } dtype = 32; mvBuilder.putS2IMap((String) key, (Integer) value); } else if (key instanceof String && value instanceof Long) { + if (dtype != -1 && dtype != 33) { + multipleType = true; + } dtype = 33; mvBuilder.putS2LMap((String) key, (Long) value); } else if (key instanceof String && value instanceof Float) { + if (dtype != -1 && dtype != 34) { + multipleType = true; + } dtype = 34; mvBuilder.putS2FMap((String) key, (Float) value); } else if (key instanceof String && value instanceof Double) { + if (dtype != -1 && dtype != 35) { + multipleType = true; + } dtype = 35; mvBuilder.putS2DMap((String) key, (Double) value); } else if (key instanceof String && value instanceof String) { + if (dtype != -1 && dtype != 36) { + multipleType = true; + } dtype = 36; mvBuilder.putS2SMap((String) key, (String) value); } else if (key instanceof String && value instanceof ByteString) { + if (dtype != -1 && dtype != 36) { + multipleType = true; + } dtype = 36; mvBuilder.putS2BsMap((String) key, (ByteString) value); } else { throw new Exception("unsuported data type!"); } } + if (multipleType == true) { + return -2; + } + switch (dtype) { case 11: @@ -465,13 +492,19 @@ static private int addElements(MapValue.Builder mvBuilder, Map valu mvBuilder.putS2BsMap((String) key, (ByteString) value); } break; + + } + return dtype % 10; } static private void setDType(Instance.Builder instanceBuilder, int dtype) throws Exception { switch (dtype) { + case -2: + instanceBuilder.setDType(DataType.DT_MULTI_TYPE); + break; case 1: instanceBuilder.setDType(DataType.DT_BOOL); break; diff --git a/server/src/main/scala/com/tencent/angel/serving/service/jersey/util/Json2Instances.scala b/server/src/main/scala/com/tencent/angel/serving/service/jersey/util/Json2Instances.scala index 03edd1f..3006473 100644 --- a/server/src/main/scala/com/tencent/angel/serving/service/jersey/util/Json2Instances.scala +++ b/server/src/main/scala/com/tencent/angel/serving/service/jersey/util/Json2Instances.scala @@ -81,53 +81,13 @@ object Json2Instances { for ((_, values) <- ele.asInstanceOf[JObject].obj) { values match { case jObject: JObject => - valueType match { - case TypesProtos.DataType.DT_STRING => - example = jObject.values.map { - case (k, v: String) => (k, v) - case (_, v) => - throw new Exception(s"${v.getClass.getSimpleName} Data Type not match String") - } - case TypesProtos.DataType.DT_INT32 => - example = jObject.values.map { - case (k, v: Int) => (k, v) - case (k, v: String) => (k, v.toInt) - case (k, v: BigInt) => (k, v.toInt) - case (_, v) => - throw new Exception(s"${v.getClass.getSimpleName} Data Type not match Int") - } - case TypesProtos.DataType.DT_INT64 => - example = jObject.values.map { - case (k, v: Long) => (k, v) - case (k, v: Int) => (k, v.toLong) - case (k, v: String) => (k, v.toLong) - case (k, v: BigInt) => (k, v.toLong) - case (_, v) => - throw new Exception(s"${v.getClass.getSimpleName} Data Type not match Long") - } - case TypesProtos.DataType.DT_FLOAT => - example = jObject.values.map { - case (k, v: Double) => (k, v.toFloat) - case (k, v: Float) => (k, v) - case (k, v: Long) => (k, v.toFloat) - case (k, v: Int) => (k, v.toFloat) - case (k, v: String) => (k, v.toFloat) - case (k, v: BigInt) => (k, v.toFloat) - case (_, v) => - throw new Exception(s"${v.getClass.getSimpleName} Data Type not match Float") - } - case TypesProtos.DataType.DT_DOUBLE => - example = jObject.values.map { - case (k, v: Double) => (k, v) - case (k, v: Float) => (k, v.toDouble) - case (k, v: Long) => (k, v.toDouble) - case (k, v: Int) => (k, v.toDouble) - case (k, v: String) => (k, v.toDouble) - case (k, v: BigInt) => (k, v.toDouble) - case (_, v) => - throw new Exception(s"${v.getClass.getSimpleName} Data Type not match Double") - } - case _ => new Exception("unsuported data type!") + example = jObject.values.map { + case (k, v: BigInt) => (k, v.toInt) + case (k, v: Int) => (k, v) + case (k, v: String) => (k, v.toString) + case (k, v: Double) => (k, v.toDouble) + case (_, v) => + throw new Exception(s"${v.getClass.getSimpleName} Data Type not support") } case _ => instanceName = values.toString @@ -137,53 +97,13 @@ object Json2Instances { requestBuilder.addInstances(instance) } else { var example: Map[String, Any] = null - valueType match { - case TypesProtos.DataType.DT_STRING => - example = ele.asInstanceOf[JObject].values.map { - case (k, v: String) => (k, v) - case (_, v) => - throw new Exception(s"${v.getClass.getSimpleName} Data Type not match String") - } - case TypesProtos.DataType.DT_INT32 => - example = ele.asInstanceOf[JObject].values.map { - case (k, v: BigInt) => (k, v.toInt) - case (k, v: Int) => (k, v) - case (k, v: String) => (k, v.toInt) - case (_, v) => - throw new Exception(s"${v.getClass.getSimpleName} Data Type not match Int") - } - case TypesProtos.DataType.DT_INT64 => - example = ele.asInstanceOf[JObject].values.map { - case (k, v: BigInt) => (k, v.toLong) - case (k, v: Long) => (k, v) - case (k, v: Int) => (k, v.toLong) - case (k, v: String) => (k, v.toLong) - case (_, v) => - throw new Exception(s"${v.getClass.getSimpleName} Data Type not match Long") - } - case TypesProtos.DataType.DT_FLOAT => - example = ele.asInstanceOf[JObject].values.map { - case (k, v: Double) => (k, v.toFloat) - case (k, v: Float) => (k, v) - case (k, v: Long) => (k, v.toFloat) - case (k, v: Int) => (k, v.toFloat) - case (k, v: String) => (k, v.toFloat) - case (k, v: BigInt) => (k, v.toFloat) - case (_, v) => - throw new Exception(s"${v.getClass.getSimpleName} Data Type not match Float") - } - case TypesProtos.DataType.DT_DOUBLE => - example = ele.asInstanceOf[JObject].values.map { - case (k, v: Double) => (k, v) - case (k, v: Float) => (k, v.toDouble) - case (k, v: Long) => (k, v.toDouble) - case (k, v: Int) => (k, v.toDouble) - case (k, v: String) => (k, v.toDouble) - case (k, v: BigInt) => (k, v.toDouble) - case (_, v) => - throw new Exception(s"${v.getClass.getSimpleName} Data Type not match Double") - } - case _ => new Exception("unsuported data type!") + example = ele.asInstanceOf[JObject].values.map { + case (k, v: BigInt) => (k, v.toInt) + case (k, v: Int) => (k, v) + case (k, v: String) => (k, v.toString) + case (k, v: Double) => (k, v.toDouble) + case (_, v) => + throw new Exception(s"${v.getClass.getSimpleName} Data Type not support") } val instance = ProtoUtils.getInstance(example.asJava) requestBuilder.addInstances(instance)