/
githubmirror
/
spark
Обзор
Документация
Войти
/
githubmirror
/
spark
Код
Запросы
0
Пакеты
0
Релизы
0
Аналитика
Безопасность
master
python/pyspark/sql/streaming/proto/StateMessage_pb2.py
150 строк
18 KB
yangjie01
[SPARK-55986][PYTHON] Upgrade black to 26.3.1
16 мар 2026, 19:20
16 мар 2026, 19:20
cbcee8c
Код
Авторство
О чём код?
# # 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: org/apache/spark/sql/execution/streaming/StateMessage.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, "", "org/apache/spark/sql/execution/streaming/StateMessage.proto", ) # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile( b'\n;org/apache/spark/sql/execution/streaming/StateMessage.proto\x12.org.apache.spark.sql.execution.streaming.state"\x84\x05\n\x0cStateRequest\x12\x18\n\x07version\x18\x01 \x01(\x05R\x07version\x1 … [Строка слишком длинная. Вы можете скачать файл] ) _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages( DESCRIPTOR, "pyspark.sql.streaming.proto.StateMessage_pb2", _globals ) if not _descriptor._USE_C_DESCRIPTORS: DESCRIPTOR._loaded_options = None _globals["_HANDLESTATE"]._serialized_start = 7489 _globals["_HANDLESTATE"]._serialized_end = 7599 _globals["_STATEREQUEST"]._serialized_start = 112 _globals["_STATEREQUEST"]._serialized_end = 756 _globals["_STATERESPONSE"]._serialized_start = 758 _globals["_STATERESPONSE"]._serialized_end = 863 _globals["_STATERESPONSEWITHLONGTYPEVAL"]._serialized_start = 865 _globals["_STATERESPONSEWITHLONGTYPEVAL"]._serialized_end = 985 _globals["_STATERESPONSEWITHSTRINGTYPEVAL"]._serialized_start = 987 _globals["_STATERESPONSEWITHSTRINGTYPEVAL"]._serialized_end = 1109 _globals["_STATERESPONSEWITHLISTGET"]._serialized_start = 1112 _globals["_STATERESPONSEWITHLISTGET"]._serialized_end = 1272 _globals["_STATERESPONSEWITHMAPKEYSORVALUES"]._serialized_start = 1275 _globals["_STATERESPONSEWITHMAPKEYSORVALUES"]._serialized_end = 1443 _globals["_KEYANDVALUEPAIR"]._serialized_start = 1445 _globals["_KEYANDVALUEPAIR"]._serialized_end = 1502 _globals["_STATERESPONSEWITHMAPITERATOR"]._serialized_start = 1505 _globals["_STATERESPONSEWITHMAPITERATOR"]._serialized_end = 1736 _globals["_TIMERINFO"]._serialized_start = 1738 _globals["_TIMERINFO"]._serialized_end = 1814 _globals["_STATERESPONSEWITHTIMER"]._serialized_start = 1817 _globals["_STATERESPONSEWITHTIMER"]._serialized_end = 2034 _globals["_STATEFULPROCESSORCALL"]._serialized_start = 2037 _globals["_STATEFULPROCESSORCALL"]._serialized_end = 2709 _globals["_STATEVARIABLEREQUEST"]._serialized_start = 2712 _globals["_STATEVARIABLEREQUEST"]._serialized_end = 3053 _globals["_IMPLICITGROUPINGKEYREQUEST"]._serialized_start = 3056 _globals["_IMPLICITGROUPINGKEYREQUEST"]._serialized_end = 3315 _globals["_TIMERREQUEST"]._serialized_start = 3318 _globals["_TIMERREQUEST"]._serialized_end = 3575 _globals["_TIMERVALUEREQUEST"]._serialized_start = 3578 _globals["_TIMERVALUEREQUEST"]._serialized_end = 3824 _globals["_EXPIRYTIMERREQUEST"]._serialized_start = 3826 _globals["_EXPIRYTIMERREQUEST"]._serialized_end = 3924 _globals["_GETPROCESSINGTIME"]._serialized_start = 3926 _globals["_GETPROCESSINGTIME"]._serialized_end = 3945 _globals["_GETWATERMARK"]._serialized_start = 3947 _globals["_GETWATERMARK"]._serialized_end = 3961 _globals["_UTILSREQUEST"]._serialized_start = 3964 _globals["_UTILSREQUEST"]._serialized_end = 4103 _globals["_PARSESTRINGSCHEMA"]._serialized_start = 4105 _globals["_PARSESTRINGSCHEMA"]._serialized_end = 4148 _globals["_STATECALLCOMMAND"]._serialized_start = 4151 _globals["_STATECALLCOMMAND"]._serialized_end = 4350 _globals["_TIMERSTATECALLCOMMAND"]._serialized_start = 4353 _globals["_TIMERSTATECALLCOMMAND"]._serialized_end = 4648 _globals["_VALUESTATECALL"]._serialized_start = 4651 _globals["_VALUESTATECALL"]._serialized_end = 5053 _globals["_LISTSTATECALL"]._serialized_start = 5056 _globals["_LISTSTATECALL"]._serialized_end = 5663 _globals["_MAPSTATECALL"]._serialized_start = 5666 _globals["_MAPSTATECALL"]._serialized_end = 6500 _globals["_SETIMPLICITKEY"]._serialized_start = 6502 _globals["_SETIMPLICITKEY"]._serialized_end = 6536 _globals["_REMOVEIMPLICITKEY"]._serialized_start = 6538 _globals["_REMOVEIMPLICITKEY"]._serialized_end = 6557 _globals["_EXISTS"]._serialized_start = 6559 _globals["_EXISTS"]._serialized_end = 6567 _globals["_GET"]._serialized_start = 6569 _globals["_GET"]._serialized_end = 6574 _globals["_REGISTERTIMER"]._serialized_start = 6576 _globals["_REGISTERTIMER"]._serialized_end = 6637 _globals["_DELETETIMER"]._serialized_start = 6639 _globals["_DELETETIMER"]._serialized_end = 6698 _globals["_LISTTIMERS"]._serialized_start = 6700 _globals["_LISTTIMERS"]._serialized_end = 6744 _globals["_VALUESTATEUPDATE"]._serialized_start = 6746 _globals["_VALUESTATEUPDATE"]._serialized_end = 6786 _globals["_CLEAR"]._serialized_start = 6788 _globals["_CLEAR"]._serialized_end = 6795 _globals["_LISTSTATEGET"]._serialized_start = 6797 _globals["_LISTSTATEGET"]._serialized_end = 6843 _globals["_LISTSTATEPUT"]._serialized_start = 6845 _globals["_LISTSTATEPUT"]._serialized_end = 6921 _globals["_APPENDVALUE"]._serialized_start = 6923 _globals["_APPENDVALUE"]._serialized_end = 6958 _globals["_APPENDLIST"]._serialized_start = 6960 _globals["_APPENDLIST"]._serialized_end = 7034 _globals["_GETVALUE"]._serialized_start = 7036 _globals["_GETVALUE"]._serialized_end = 7072 _globals["_CONTAINSKEY"]._serialized_start = 7074 _globals["_CONTAINSKEY"]._serialized_end = 7113 _globals["_UPDATEVALUE"]._serialized_start = 7115 _globals["_UPDATEVALUE"]._serialized_end = 7176 _globals["_ITERATOR"]._serialized_start = 7178 _globals["_ITERATOR"]._serialized_end = 7220 _globals["_KEYS"]._serialized_start = 7222 _globals["_KEYS"]._serialized_end = 7260 _globals["_VALUES"]._serialized_start = 7262 _globals["_VALUES"]._serialized_end = 7302 _globals["_REMOVEKEY"]._serialized_start = 7304 _globals["_REMOVEKEY"]._serialized_end = 7341 _globals["_SETHANDLESTATE"]._serialized_start = 7343 _globals["_SETHANDLESTATE"]._serialized_end = 7442 _globals["_TTLCONFIG"]._serialized_start = 7444 _globals["_TTLCONFIG"]._serialized_end = 7487 # @@protoc_insertion_point(module_scope)