/
githubmirror
/
spark
Обзор
Документация
Войти
/
githubmirror
/
spark
Код
Запросы
0
Пакеты
0
Релизы
0
Аналитика
Безопасность
master
python/pyspark/sql/connect/proto/base_pb2.py
286 строк
48 KB
mehdigharam-db
[SPARK-58593][CONNECT] Add extension Any field to AnalyzePlanResponse
3 часа назад
3 часа назад
f868674
Код
Авторство
О чём код?
# # Licensed to the Apache Software Foundation (ASF) under one or more # contributor license agreements. See the NOTICE file distributed with # this work for additional information regarding copyright ownership. # The ASF licenses this file to You 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. # # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # NO CHECKED-IN PROTOBUF GENCODE # source: spark/connect/base.proto # Protobuf Python Version: 6.33.5 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool from google.protobuf import runtime_version as _runtime_version from google.protobuf import symbol_database as _symbol_database from google.protobuf.internal import builder as _builder _runtime_version.ValidateProtobufRuntimeVersion( _runtime_version.Domain.PUBLIC, 6, 33, 5, "", "spark/connect/base.proto" ) # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() from google.protobuf import any_pb2 as google_dot_protobuf_dot_any__pb2 from pyspark.sql.connect.proto import commands_pb2 as spark_dot_connect_dot_commands__pb2 from pyspark.sql.connect.proto import common_pb2 as spark_dot_connect_dot_common__pb2 from pyspark.sql.connect.proto import expressions_pb2 as spark_dot_connect_dot_expressions__pb2 from pyspark.sql.connect.proto import relations_pb2 as spark_dot_connect_dot_relations__pb2 from pyspark.sql.connect.proto import types_pb2 as spark_dot_connect_dot_types__pb2 from pyspark.sql.connect.proto import ml_pb2 as spark_dot_connect_dot_ml__pb2 from pyspark.sql.connect.proto import pipelines_pb2 as spark_dot_connect_dot_pipelines__pb2 DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile( b'\n\x18spark/connect/base.proto\x12\rspark.connect\x1a\x19google/protobuf/any.proto\x1a\x1cspark/connect/commands.proto\x1a\x1aspark/connect/common.proto\x1a\x1fspark/connect/expressions.proto\x1 … [Строка слишком длинная. Вы можете скачать файл] ) _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, "pyspark.sql.connect.proto.base_pb2", _globals) if not _descriptor._USE_C_DESCRIPTORS: _globals["DESCRIPTOR"]._loaded_options = None _globals[ "DESCRIPTOR" ]._serialized_options = b"\n\036org.apache.spark.connect.protoP\001Z\022internal/generated" _globals[ "_EXECUTEPLANRESPONSE_METRICS_METRICOBJECT_EXECUTIONMETRICSENTRY" ]._loaded_options = None _globals[ "_EXECUTEPLANRESPONSE_METRICS_METRICOBJECT_EXECUTIONMETRICSENTRY" ]._serialized_options = b"8\001" _globals["_ARTIFACTSTATUSESRESPONSE_STATUSESENTRY"]._loaded_options = None _globals["_ARTIFACTSTATUSESRESPONSE_STATUSESENTRY"]._serialized_options = b"8\001" _globals[ "_FETCHERRORDETAILSRESPONSE_SPARKTHROWABLE_MESSAGEPARAMETERSENTRY" ]._loaded_options = None _globals[ "_FETCHERRORDETAILSRESPONSE_SPARKTHROWABLE_MESSAGEPARAMETERSENTRY" ]._serialized_options = b"8\001" _globals["_COMPRESSIONCODEC"]._serialized_start = 20046 _globals["_COMPRESSIONCODEC"]._serialized_end = 20127 _globals["_PLAN"]._serialized_start = 275 _globals["_PLAN"]._serialized_end = 758 _globals["_PLAN_COMPRESSEDOPERATION"]._serialized_start = 477 _globals["_PLAN_COMPRESSEDOPERATION"]._serialized_end = 747 _globals["_PLAN_COMPRESSEDOPERATION_OPTYPE"]._serialized_start = 671 _globals["_PLAN_COMPRESSEDOPERATION_OPTYPE"]._serialized_end = 747 _globals["_USERCONTEXT"]._serialized_start = 760 _globals["_USERCONTEXT"]._serialized_end = 882 _globals["_ANALYZEPLANREQUEST"]._serialized_start = 885 _globals["_ANALYZEPLANREQUEST"]._serialized_end = 3562 _globals["_ANALYZEPLANREQUEST_SCHEMA"]._serialized_start = 2247 _globals["_ANALYZEPLANREQUEST_SCHEMA"]._serialized_end = 2296 _globals["_ANALYZEPLANREQUEST_EXPLAIN"]._serialized_start = 2299 _globals["_ANALYZEPLANREQUEST_EXPLAIN"]._serialized_end = 2614 _globals["_ANALYZEPLANREQUEST_EXPLAIN_EXPLAINMODE"]._serialized_start = 2442 _globals["_ANALYZEPLANREQUEST_EXPLAIN_EXPLAINMODE"]._serialized_end = 2614 _globals["_ANALYZEPLANREQUEST_TREESTRING"]._serialized_start = 2616 _globals["_ANALYZEPLANREQUEST_TREESTRING"]._serialized_end = 2706 _globals["_ANALYZEPLANREQUEST_ISLOCAL"]._serialized_start = 2708 _globals["_ANALYZEPLANREQUEST_ISLOCAL"]._serialized_end = 2758 _globals["_ANALYZEPLANREQUEST_ISSTREAMING"]._serialized_start = 2760 _globals["_ANALYZEPLANREQUEST_ISSTREAMING"]._serialized_end = 2814 _globals["_ANALYZEPLANREQUEST_INPUTFILES"]._serialized_start = 2816 _globals["_ANALYZEPLANREQUEST_INPUTFILES"]._serialized_end = 2869 _globals["_ANALYZEPLANREQUEST_SPARKVERSION"]._serialized_start = 2871 _globals["_ANALYZEPLANREQUEST_SPARKVERSION"]._serialized_end = 2885 _globals["_ANALYZEPLANREQUEST_DDLPARSE"]._serialized_start = 2887 _globals["_ANALYZEPLANREQUEST_DDLPARSE"]._serialized_end = 2928 _globals["_ANALYZEPLANREQUEST_SAMESEMANTICS"]._serialized_start = 2930 _globals["_ANALYZEPLANREQUEST_SAMESEMANTICS"]._serialized_end = 3051 _globals["_ANALYZEPLANREQUEST_SEMANTICHASH"]._serialized_start = 3053 _globals["_ANALYZEPLANREQUEST_SEMANTICHASH"]._serialized_end = 3108 _globals["_ANALYZEPLANREQUEST_PERSIST"]._serialized_start = 3111 _globals["_ANALYZEPLANREQUEST_PERSIST"]._serialized_end = 3262 _globals["_ANALYZEPLANREQUEST_UNPERSIST"]._serialized_start = 3264 _globals["_ANALYZEPLANREQUEST_UNPERSIST"]._serialized_end = 3374 _globals["_ANALYZEPLANREQUEST_GETSTORAGELEVEL"]._serialized_start = 3376 _globals["_ANALYZEPLANREQUEST_GETSTORAGELEVEL"]._serialized_end = 3446 _globals["_ANALYZEPLANREQUEST_JSONTODDL"]._serialized_start = 3448 _globals["_ANALYZEPLANREQUEST_JSONTODDL"]._serialized_end = 3492 _globals["_ANALYZEPLANRESPONSE"]._serialized_start = 3565 _globals["_ANALYZEPLANRESPONSE"]._serialized_end = 5486 _globals["_ANALYZEPLANRESPONSE_SCHEMA"]._serialized_start = 4861 _globals["_ANALYZEPLANRESPONSE_SCHEMA"]._serialized_end = 4918 _globals["_ANALYZEPLANRESPONSE_EXPLAIN"]._serialized_start = 4920 _globals["_ANALYZEPLANRESPONSE_EXPLAIN"]._serialized_end = 4968 _globals["_ANALYZEPLANRESPONSE_TREESTRING"]._serialized_start = 4970 _globals["_ANALYZEPLANRESPONSE_TREESTRING"]._serialized_end = 5015 _globals["_ANALYZEPLANRESPONSE_ISLOCAL"]._serialized_start = 5017 _globals["_ANALYZEPLANRESPONSE_ISLOCAL"]._serialized_end = 5053 _globals["_ANALYZEPLANRESPONSE_ISSTREAMING"]._serialized_start = 5055 _globals["_ANALYZEPLANRESPONSE_ISSTREAMING"]._serialized_end = 5103 _globals["_ANALYZEPLANRESPONSE_INPUTFILES"]._serialized_start = 5105 _globals["_ANALYZEPLANRESPONSE_INPUTFILES"]._serialized_end = 5139 _globals["_ANALYZEPLANRESPONSE_SPARKVERSION"]._serialized_start = 5141 _globals["_ANALYZEPLANRESPONSE_SPARKVERSION"]._serialized_end = 5181 _globals["_ANALYZEPLANRESPONSE_DDLPARSE"]._serialized_start = 5183 _globals["_ANALYZEPLANRESPONSE_DDLPARSE"]._serialized_end = 5242 _globals["_ANALYZEPLANRESPONSE_SAMESEMANTICS"]._serialized_start = 5244 _globals["_ANALYZEPLANRESPONSE_SAMESEMANTICS"]._serialized_end = 5283 _globals["_ANALYZEPLANRESPONSE_SEMANTICHASH"]._serialized_start = 5285 _globals["_ANALYZEPLANRESPONSE_SEMANTICHASH"]._serialized_end = 5323 _globals["_ANALYZEPLANRESPONSE_PERSIST"]._serialized_start = 3111 _globals["_ANALYZEPLANRESPONSE_PERSIST"]._serialized_end = 3120 _globals["_ANALYZEPLANRESPONSE_UNPERSIST"]._serialized_start = 3264 _globals["_ANALYZEPLANRESPONSE_UNPERSIST"]._serialized_end = 3275 _globals["_ANALYZEPLANRESPONSE_GETSTORAGELEVEL"]._serialized_start = 5349 _globals["_ANALYZEPLANRESPONSE_GETSTORAGELEVEL"]._serialized_end = 5432 _globals["_ANALYZEPLANRESPONSE_JSONTODDL"]._serialized_start = 5434 _globals["_ANALYZEPLANRESPONSE_JSONTODDL"]._serialized_end = 5476 _globals["_EXECUTEPLANREQUEST"]._serialized_start = 5489 _globals["_EXECUTEPLANREQUEST"]._serialized_end = 6260 _globals["_EXECUTEPLANREQUEST_REQUESTOPTION"]._serialized_start = 5923 _globals["_EXECUTEPLANREQUEST_REQUESTOPTION"]._serialized_end = 6184 _globals["_EXECUTEPLANRESPONSE"]._serialized_start = 6263 _globals["_EXECUTEPLANRESPONSE"]._serialized_end = 9854 _globals["_EXECUTEPLANRESPONSE_SQLCOMMANDRESULT"]._serialized_start = 8363 _globals["_EXECUTEPLANRESPONSE_SQLCOMMANDRESULT"]._serialized_end = 8434 _globals["_EXECUTEPLANRESPONSE_ARROWBATCH"]._serialized_start = 8437 _globals["_EXECUTEPLANRESPONSE_ARROWBATCH"]._serialized_end = 8685 _globals["_EXECUTEPLANRESPONSE_METRICS"]._serialized_start = 8688 _globals["_EXECUTEPLANRESPONSE_METRICS"]._serialized_end = 9205 _globals["_EXECUTEPLANRESPONSE_METRICS_METRICOBJECT"]._serialized_start = 8783 _globals["_EXECUTEPLANRESPONSE_METRICS_METRICOBJECT"]._serialized_end = 9115 _globals[ "_EXECUTEPLANRESPONSE_METRICS_METRICOBJECT_EXECUTIONMETRICSENTRY" ]._serialized_start = 8992 _globals[ "_EXECUTEPLANRESPONSE_METRICS_METRICOBJECT_EXECUTIONMETRICSENTRY" ]._serialized_end = 9115 _globals["_EXECUTEPLANRESPONSE_METRICS_METRICVALUE"]._serialized_start = 9117 _globals["_EXECUTEPLANRESPONSE_METRICS_METRICVALUE"]._serialized_end = 9205 _globals["_EXECUTEPLANRESPONSE_OBSERVEDMETRICS"]._serialized_start = 9208 _globals["_EXECUTEPLANRESPONSE_OBSERVEDMETRICS"]._serialized_end = 9483 _globals["_EXECUTEPLANRESPONSE_RESULTCOMPLETE"]._serialized_start = 9485 _globals["_EXECUTEPLANRESPONSE_RESULTCOMPLETE"]._serialized_end = 9501 _globals["_EXECUTEPLANRESPONSE_EXECUTIONPROGRESS"]._serialized_start = 9504 _globals["_EXECUTEPLANRESPONSE_EXECUTIONPROGRESS"]._serialized_end = 9837 _globals["_EXECUTEPLANRESPONSE_EXECUTIONPROGRESS_STAGEINFO"]._serialized_start = 9660 _globals["_EXECUTEPLANRESPONSE_EXECUTIONPROGRESS_STAGEINFO"]._serialized_end = 9837 _globals["_KEYVALUE"]._serialized_start = 9856 _globals["_KEYVALUE"]._serialized_end = 9921 _globals["_CONFIGREQUEST"]._serialized_start = 9924 _globals["_CONFIGREQUEST"]._serialized_end = 11123 _globals["_CONFIGREQUEST_OPERATION"]._serialized_start = 10232 _globals["_CONFIGREQUEST_OPERATION"]._serialized_end = 10730 _globals["_CONFIGREQUEST_SET"]._serialized_start = 10732 _globals["_CONFIGREQUEST_SET"]._serialized_end = 10824 _globals["_CONFIGREQUEST_GET"]._serialized_start = 10826 _globals["_CONFIGREQUEST_GET"]._serialized_end = 10851 _globals["_CONFIGREQUEST_GETWITHDEFAULT"]._serialized_start = 10853 _globals["_CONFIGREQUEST_GETWITHDEFAULT"]._serialized_end = 10916 _globals["_CONFIGREQUEST_GETOPTION"]._serialized_start = 10918 _globals["_CONFIGREQUEST_GETOPTION"]._serialized_end = 10949 _globals["_CONFIGREQUEST_GETALL"]._serialized_start = 10951 _globals["_CONFIGREQUEST_GETALL"]._serialized_end = 10999 _globals["_CONFIGREQUEST_UNSET"]._serialized_start = 11001 _globals["_CONFIGREQUEST_UNSET"]._serialized_end = 11028 _globals["_CONFIGREQUEST_ISMODIFIABLE"]._serialized_start = 11030 _globals["_CONFIGREQUEST_ISMODIFIABLE"]._serialized_end = 11064 _globals["_CONFIGRESPONSE"]._serialized_start = 11126 _globals["_CONFIGRESPONSE"]._serialized_end = 11301 _globals["_ADDARTIFACTSREQUEST"]._serialized_start = 11304 _globals["_ADDARTIFACTSREQUEST"]._serialized_end = 12306 _globals["_ADDARTIFACTSREQUEST_ARTIFACTCHUNK"]._serialized_start = 11779 _globals["_ADDARTIFACTSREQUEST_ARTIFACTCHUNK"]._serialized_end = 11832 _globals["_ADDARTIFACTSREQUEST_SINGLECHUNKARTIFACT"]._serialized_start = 11834 _globals["_ADDARTIFACTSREQUEST_SINGLECHUNKARTIFACT"]._serialized_end = 11945 _globals["_ADDARTIFACTSREQUEST_BATCH"]._serialized_start = 11947 _globals["_ADDARTIFACTSREQUEST_BATCH"]._serialized_end = 12040 _globals["_ADDARTIFACTSREQUEST_BEGINCHUNKEDARTIFACT"]._serialized_start = 12043 _globals["_ADDARTIFACTSREQUEST_BEGINCHUNKEDARTIFACT"]._serialized_end = 12236 _globals["_ADDARTIFACTSRESPONSE"]._serialized_start = 12309 _globals["_ADDARTIFACTSRESPONSE"]._serialized_end = 12581 _globals["_ADDARTIFACTSRESPONSE_ARTIFACTSUMMARY"]._serialized_start = 12500 _globals["_ADDARTIFACTSRESPONSE_ARTIFACTSUMMARY"]._serialized_end = 12581 _globals["_ARTIFACTSTATUSESREQUEST"]._serialized_start = 12584 _globals["_ARTIFACTSTATUSESREQUEST"]._serialized_end = 12910 _globals["_ARTIFACTSTATUSESRESPONSE"]._serialized_start = 12913 _globals["_ARTIFACTSTATUSESRESPONSE"]._serialized_end = 13265 _globals["_ARTIFACTSTATUSESRESPONSE_STATUSESENTRY"]._serialized_start = 13108 _globals["_ARTIFACTSTATUSESRESPONSE_STATUSESENTRY"]._serialized_end = 13223 _globals["_ARTIFACTSTATUSESRESPONSE_ARTIFACTSTATUS"]._serialized_start = 13225 _globals["_ARTIFACTSTATUSESRESPONSE_ARTIFACTSTATUS"]._serialized_end = 13265 _globals["_INTERRUPTREQUEST"]._serialized_start = 13268 _globals["_INTERRUPTREQUEST"]._serialized_end = 13871 _globals["_INTERRUPTREQUEST_INTERRUPTTYPE"]._serialized_start = 13671 _globals["_INTERRUPTREQUEST_INTERRUPTTYPE"]._serialized_end = 13799 _globals["_INTERRUPTRESPONSE"]._serialized_start = 13874 _globals["_INTERRUPTRESPONSE"]._serialized_end = 14018 _globals["_REATTACHOPTIONS"]._serialized_start = 14020 _globals["_REATTACHOPTIONS"]._serialized_end = 14073 _globals["_RESULTCHUNKINGOPTIONS"]._serialized_start = 14076 _globals["_RESULTCHUNKINGOPTIONS"]._serialized_end = 14257 _globals["_REATTACHEXECUTEREQUEST"]._serialized_start = 14260 _globals["_REATTACHEXECUTEREQUEST"]._serialized_end = 14666 _globals["_RELEASEEXECUTEREQUEST"]._serialized_start = 14669 _globals["_RELEASEEXECUTEREQUEST"]._serialized_end = 15254 _globals["_RELEASEEXECUTEREQUEST_RELEASEALL"]._serialized_start = 15123 _globals["_RELEASEEXECUTEREQUEST_RELEASEALL"]._serialized_end = 15135 _globals["_RELEASEEXECUTEREQUEST_RELEASEUNTIL"]._serialized_start = 15137 _globals["_RELEASEEXECUTEREQUEST_RELEASEUNTIL"]._serialized_end = 15184 _globals["_RELEASEEXECUTERESPONSE"]._serialized_start = 15257 _globals["_RELEASEEXECUTERESPONSE"]._serialized_end = 15422 _globals["_RELEASESESSIONREQUEST"]._serialized_start = 15425 _globals["_RELEASESESSIONREQUEST"]._serialized_end = 15637 _globals["_RELEASESESSIONRESPONSE"]._serialized_start = 15639 _globals["_RELEASESESSIONRESPONSE"]._serialized_end = 15747 _globals["_FETCHERRORDETAILSREQUEST"]._serialized_start = 15750 _globals["_FETCHERRORDETAILSREQUEST"]._serialized_end = 16082 _globals["_FETCHERRORDETAILSRESPONSE"]._serialized_start = 16085 _globals["_FETCHERRORDETAILSRESPONSE"]._serialized_end = 18094 _globals["_FETCHERRORDETAILSRESPONSE_STACKTRACEELEMENT"]._serialized_start = 16314 _globals["_FETCHERRORDETAILSRESPONSE_STACKTRACEELEMENT"]._serialized_end = 16488 _globals["_FETCHERRORDETAILSRESPONSE_QUERYCONTEXT"]._serialized_start = 16491 _globals["_FETCHERRORDETAILSRESPONSE_QUERYCONTEXT"]._serialized_end = 16859 _globals["_FETCHERRORDETAILSRESPONSE_QUERYCONTEXT_CONTEXTTYPE"]._serialized_start = 16822 _globals["_FETCHERRORDETAILSRESPONSE_QUERYCONTEXT_CONTEXTTYPE"]._serialized_end = 16859 _globals["_FETCHERRORDETAILSRESPONSE_SPARKTHROWABLE"]._serialized_start = 16862 _globals["_FETCHERRORDETAILSRESPONSE_SPARKTHROWABLE"]._serialized_end = 17412 _globals[ "_FETCHERRORDETAILSRESPONSE_SPARKTHROWABLE_MESSAGEPARAMETERSENTRY" ]._serialized_start = 17289 _globals[ "_FETCHERRORDETAILSRESPONSE_SPARKTHROWABLE_MESSAGEPARAMETERSENTRY" ]._serialized_end = 17357 _globals["_FETCHERRORDETAILSRESPONSE_BREAKINGCHANGEINFO"]._serialized_start = 17415 _globals["_FETCHERRORDETAILSRESPONSE_BREAKINGCHANGEINFO"]._serialized_end = 17665 _globals["_FETCHERRORDETAILSRESPONSE_MITIGATIONCONFIG"]._serialized_start = 17667 _globals["_FETCHERRORDETAILSRESPONSE_MITIGATIONCONFIG"]._serialized_end = 17725 _globals["_FETCHERRORDETAILSRESPONSE_ERROR"]._serialized_start = 17728 _globals["_FETCHERRORDETAILSRESPONSE_ERROR"]._serialized_end = 18075 _globals["_CHECKPOINTCOMMANDRESULT"]._serialized_start = 18096 _globals["_CHECKPOINTCOMMANDRESULT"]._serialized_end = 18186 _globals["_CLONESESSIONREQUEST"]._serialized_start = 18189 _globals["_CLONESESSIONREQUEST"]._serialized_end = 18551 _globals["_CLONESESSIONRESPONSE"]._serialized_start = 18554 _globals["_CLONESESSIONRESPONSE"]._serialized_end = 18758 _globals["_GETSTATUSREQUEST"]._serialized_start = 18761 _globals["_GETSTATUSREQUEST"]._serialized_end = 19356 _globals["_GETSTATUSREQUEST_OPERATIONSTATUSREQUEST"]._serialized_start = 19160 _globals["_GETSTATUSREQUEST_OPERATIONSTATUSREQUEST"]._serialized_end = 19276 _globals["_GETSTATUSRESPONSE"]._serialized_start = 19359 _globals["_GETSTATUSRESPONSE"]._serialized_end = 20044 _globals["_GETSTATUSRESPONSE_OPERATIONSTATUS"]._serialized_start = 19617 _globals["_GETSTATUSRESPONSE_OPERATIONSTATUS"]._serialized_end = 20044 _globals["_GETSTATUSRESPONSE_OPERATIONSTATUS_OPERATIONSTATE"]._serialized_start = 19814 _globals["_GETSTATUSRESPONSE_OPERATIONSTATUS_OPERATIONSTATE"]._serialized_end = 20044 _globals["_SPARKCONNECTSERVICE"]._serialized_start = 20130 _globals["_SPARKCONNECTSERVICE"]._serialized_end = 21249 # @@protoc_insertion_point(module_scope)