Module: Spark::Connect
- Defined in:
- lib/spark_connect/proto/spark/connect/ml_pb.rb,
lib/spark_connect/proto/spark/connect/base_pb.rb,
lib/spark_connect/proto/spark/connect/types_pb.rb,
lib/spark_connect/proto/spark/connect/common_pb.rb,
lib/spark_connect/proto/spark/connect/catalog_pb.rb,
lib/spark_connect/proto/spark/connect/commands_pb.rb,
lib/spark_connect/proto/spark/connect/ml_common_pb.rb,
lib/spark_connect/proto/spark/connect/pipelines_pb.rb,
lib/spark_connect/proto/spark/connect/relations_pb.rb,
lib/spark_connect/proto/spark/connect/expressions_pb.rb,
lib/spark_connect/proto/spark/connect/base_services_pb.rb
Defined Under Namespace
Modules: SparkConnectService
Constant Summary collapse
- MlCommand =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.MlCommand").msgclass
- MlCommandResult =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.MlCommandResult").msgclass
- Plan =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.Plan").msgclass
- UserContext =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.UserContext").msgclass
- AnalyzePlanRequest =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.AnalyzePlanRequest").msgclass
- AnalyzePlanResponse =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.AnalyzePlanResponse").msgclass
- ExecutePlanRequest =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.ExecutePlanRequest").msgclass
- ExecutePlanResponse =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.ExecutePlanResponse").msgclass
- KeyValue =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.KeyValue").msgclass
- ConfigRequest =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.ConfigRequest").msgclass
- ConfigResponse =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.ConfigResponse").msgclass
- AddArtifactsRequest =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.AddArtifactsRequest").msgclass
- AddArtifactsResponse =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.AddArtifactsResponse").msgclass
- ArtifactStatusesRequest =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.ArtifactStatusesRequest").msgclass
- ArtifactStatusesResponse =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.ArtifactStatusesResponse").msgclass
- InterruptRequest =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.InterruptRequest").msgclass
- InterruptResponse =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.InterruptResponse").msgclass
- ReattachOptions =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.ReattachOptions").msgclass
- ResultChunkingOptions =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.ResultChunkingOptions").msgclass
- ReattachExecuteRequest =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.ReattachExecuteRequest").msgclass
- ReleaseExecuteRequest =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.ReleaseExecuteRequest").msgclass
- ReleaseExecuteResponse =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.ReleaseExecuteResponse").msgclass
- ReleaseSessionRequest =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.ReleaseSessionRequest").msgclass
- ReleaseSessionResponse =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.ReleaseSessionResponse").msgclass
- FetchErrorDetailsRequest =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.FetchErrorDetailsRequest").msgclass
- FetchErrorDetailsResponse =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.FetchErrorDetailsResponse").msgclass
- CheckpointCommandResult =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.CheckpointCommandResult").msgclass
- CloneSessionRequest =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.CloneSessionRequest").msgclass
- CloneSessionResponse =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.CloneSessionResponse").msgclass
- CompressionCodec =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.CompressionCodec").enummodule
- DataType =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.DataType").msgclass
- StorageLevel =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.StorageLevel").msgclass
- ResourceInformation =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.ResourceInformation").msgclass
- ExecutorResourceRequest =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.ExecutorResourceRequest").msgclass
- TaskResourceRequest =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.TaskResourceRequest").msgclass
- ResourceProfile =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.ResourceProfile").msgclass
- Origin =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.Origin").msgclass
- PythonOrigin =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.PythonOrigin").msgclass
- JvmOrigin =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.JvmOrigin").msgclass
- StackTraceElement =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.StackTraceElement").msgclass
- ResolvedIdentifier =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.ResolvedIdentifier").msgclass
- Bools =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.Bools").msgclass
- Ints =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.Ints").msgclass
- Longs =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.Longs").msgclass
- Floats =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.Floats").msgclass
- Doubles =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.Doubles").msgclass
- Strings =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.Strings").msgclass
- Catalog =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.Catalog").msgclass
- CurrentDatabase =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.CurrentDatabase").msgclass
- SetCurrentDatabase =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.SetCurrentDatabase").msgclass
- ListDatabases =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.ListDatabases").msgclass
- ListTables =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.ListTables").msgclass
- ListFunctions =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.ListFunctions").msgclass
- ListColumns =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.ListColumns").msgclass
- GetDatabase =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.GetDatabase").msgclass
- GetTable =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.GetTable").msgclass
- GetFunction =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.GetFunction").msgclass
- DatabaseExists =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.DatabaseExists").msgclass
- TableExists =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.TableExists").msgclass
- FunctionExists =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.FunctionExists").msgclass
- CreateExternalTable =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.CreateExternalTable").msgclass
- CreateTable =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.CreateTable").msgclass
- DropTempView =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.DropTempView").msgclass
- DropGlobalTempView =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.DropGlobalTempView").msgclass
- RecoverPartitions =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.RecoverPartitions").msgclass
- IsCached =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.IsCached").msgclass
- CacheTable =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.CacheTable").msgclass
- UncacheTable =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.UncacheTable").msgclass
- ClearCache =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.ClearCache").msgclass
- RefreshTable =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.RefreshTable").msgclass
- RefreshByPath =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.RefreshByPath").msgclass
- CurrentCatalog =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.CurrentCatalog").msgclass
- SetCurrentCatalog =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.SetCurrentCatalog").msgclass
- ListCatalogs =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.ListCatalogs").msgclass
- Command =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.Command").msgclass
- SqlCommand =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.SqlCommand").msgclass
- CreateDataFrameViewCommand =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.CreateDataFrameViewCommand").msgclass
- WriteOperation =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.WriteOperation").msgclass
- WriteOperationV2 =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.WriteOperationV2").msgclass
- WriteStreamOperationStart =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.WriteStreamOperationStart").msgclass
- StreamingForeachFunction =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.StreamingForeachFunction").msgclass
- WriteStreamOperationStartResult =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.WriteStreamOperationStartResult").msgclass
- StreamingQueryInstanceId =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.StreamingQueryInstanceId").msgclass
- StreamingQueryCommand =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.StreamingQueryCommand").msgclass
- StreamingQueryCommandResult =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.StreamingQueryCommandResult").msgclass
- StreamingQueryManagerCommand =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.StreamingQueryManagerCommand").msgclass
- StreamingQueryManagerCommandResult =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.StreamingQueryManagerCommandResult").msgclass
- StreamingQueryListenerBusCommand =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.StreamingQueryListenerBusCommand").msgclass
- StreamingQueryListenerEvent =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.StreamingQueryListenerEvent").msgclass
- StreamingQueryListenerEventsResult =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.StreamingQueryListenerEventsResult").msgclass
- GetResourcesCommand =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.GetResourcesCommand").msgclass
- GetResourcesCommandResult =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.GetResourcesCommandResult").msgclass
- CreateResourceProfileCommand =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.CreateResourceProfileCommand").msgclass
- CreateResourceProfileCommandResult =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.CreateResourceProfileCommandResult").msgclass
- RemoveCachedRemoteRelationCommand =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.RemoveCachedRemoteRelationCommand").msgclass
- CheckpointCommand =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.CheckpointCommand").msgclass
- MergeIntoTableCommand =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.MergeIntoTableCommand").msgclass
- ExecuteExternalCommand =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.ExecuteExternalCommand").msgclass
- StreamingQueryEventType =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.StreamingQueryEventType").enummodule
- MlParams =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.MlParams").msgclass
- MlOperator =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.MlOperator").msgclass
- ObjectRef =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.ObjectRef").msgclass
- PipelineCommand =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.PipelineCommand").msgclass
- PipelineCommandResult =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.PipelineCommandResult").msgclass
- PipelineEventResult =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.PipelineEventResult").msgclass
- PipelineEvent =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.PipelineEvent").msgclass
- SourceCodeLocation =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.SourceCodeLocation").msgclass
- PipelineQueryFunctionExecutionSignal =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.PipelineQueryFunctionExecutionSignal").msgclass
- PipelineAnalysisContext =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.PipelineAnalysisContext").msgclass
- OutputType =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.OutputType").enummodule
- Relation =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.Relation").msgclass
- MlRelation =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.MlRelation").msgclass
- Fetch =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.Fetch").msgclass
- Unknown =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.Unknown").msgclass
- RelationCommon =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.RelationCommon").msgclass
- SQL =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.SQL").msgclass
- WithRelations =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.WithRelations").msgclass
- Read =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.Read").msgclass
- Project =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.Project").msgclass
- Filter =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.Filter").msgclass
- Join =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.Join").msgclass
- SetOperation =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.SetOperation").msgclass
- Limit =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.Limit").msgclass
- Offset =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.Offset").msgclass
- Tail =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.Tail").msgclass
- Aggregate =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.Aggregate").msgclass
- Sort =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.Sort").msgclass
- Drop =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.Drop").msgclass
- Deduplicate =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.Deduplicate").msgclass
- LocalRelation =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.LocalRelation").msgclass
- CachedLocalRelation =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.CachedLocalRelation").msgclass
- ChunkedCachedLocalRelation =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.ChunkedCachedLocalRelation").msgclass
- CachedRemoteRelation =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.CachedRemoteRelation").msgclass
- Sample =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.Sample").msgclass
- Range =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.Range").msgclass
- SubqueryAlias =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.SubqueryAlias").msgclass
- Repartition =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.Repartition").msgclass
- ShowString =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.ShowString").msgclass
- HtmlString =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.HtmlString").msgclass
- StatSummary =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.StatSummary").msgclass
- StatDescribe =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.StatDescribe").msgclass
- StatCrosstab =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.StatCrosstab").msgclass
- StatCov =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.StatCov").msgclass
- StatCorr =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.StatCorr").msgclass
- StatApproxQuantile =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.StatApproxQuantile").msgclass
- StatFreqItems =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.StatFreqItems").msgclass
- StatSampleBy =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.StatSampleBy").msgclass
- NAFill =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.NAFill").msgclass
- NADrop =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.NADrop").msgclass
- NAReplace =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.NAReplace").msgclass
- ToDF =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.ToDF").msgclass
- WithColumnsRenamed =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.WithColumnsRenamed").msgclass
- WithColumns =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.WithColumns").msgclass
- WithWatermark =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.WithWatermark").msgclass
- Hint =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.Hint").msgclass
- Unpivot =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.Unpivot").msgclass
- Transpose =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.Transpose").msgclass
- UnresolvedTableValuedFunction =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.UnresolvedTableValuedFunction").msgclass
- ToSchema =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.ToSchema").msgclass
- RepartitionByExpression =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.RepartitionByExpression").msgclass
- MapPartitions =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.MapPartitions").msgclass
- GroupMap =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.GroupMap").msgclass
- TransformWithStateInfo =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.TransformWithStateInfo").msgclass
- CoGroupMap =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.CoGroupMap").msgclass
- ApplyInPandasWithState =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.ApplyInPandasWithState").msgclass
- CommonInlineUserDefinedTableFunction =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.CommonInlineUserDefinedTableFunction").msgclass
- PythonUDTF =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.PythonUDTF").msgclass
- CommonInlineUserDefinedDataSource =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.CommonInlineUserDefinedDataSource").msgclass
- PythonDataSource =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.PythonDataSource").msgclass
- CollectMetrics =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.CollectMetrics").msgclass
- Parse =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.Parse").msgclass
- AsOfJoin =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.AsOfJoin").msgclass
- LateralJoin =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.LateralJoin").msgclass
- Expression =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.Expression").msgclass
- ExpressionCommon =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.ExpressionCommon").msgclass
- CommonInlineUserDefinedFunction =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.CommonInlineUserDefinedFunction").msgclass
- PythonUDF =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.PythonUDF").msgclass
- ScalarScalaUDF =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.ScalarScalaUDF").msgclass
- JavaUDF =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.JavaUDF").msgclass
- TypedAggregateExpression =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.TypedAggregateExpression").msgclass
- CallFunction =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.CallFunction").msgclass
- NamedArgumentExpression =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.NamedArgumentExpression").msgclass
- MergeAction =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.MergeAction").msgclass
- SubqueryExpression =
::Google::Protobuf::DescriptorPool.generated_pool.lookup("spark.connect.SubqueryExpression").msgclass