Module: Trino::Client::ModelVersions::V351

Defined in:

lib/trino/client/model_versions/351.rb

Overview

lib/trino/client/model_versions/*.rb is automatically generated using “rake modelgen:all” command. You should not edit this file directly. To modify the class definitions, edit modelgen/model_versions.rb file and run “rake modelgen:all”.

Defined Under Namespace

Modules: OperatorInfo, PlanNode Classes: Aggregation=Base.new(:resolved_function,:arguments,:distinct,:filter,:ordering_scheme,:mask), AggregationNode=Base.new(:id,:source,:aggregations,:grouping_sets,:pre_grouped_symbols,:step,:hash_symbol,:group_id_symbol), AnalyzeTableHandle=Base.new(:catalog_name,:transaction_handle,:connector_handle), ApplyNode=Base.new(:id,:input,:subquery,:subquery_assignments,:correlation,:origin_subquery), ArgumentBinding=Base.new(:expression,:constant), AssignUniqueId=Base.new(:id,:source,:id_column), Assignments=Base.new(:assignments), Base, BasicQueryInfo=Base.new(:query_id,:session,:resource_group_id,:state,:memory_pool,:scheduled,:self,:query,:update_type,:prepared_query,:query_stats,:error_type,:error_code,:query_type), BasicQueryStats=Base.new(:create_time,:end_time,:queued_time,:elapsed_time,:execution_time,:total_drivers,:queued_drivers,:running_drivers,:completed_drivers,:raw_input_data_size,:raw_input_positions,:physical_input_data_size,:cumulative_user_memory,:user_memory_reservation,:total_memory_reservation,:peak_user_memory_reservation,:peak_total_memory_reservation,:total_cpu_time,:total_scheduled_time,:fully_blocked,:blocked_reasons,:progress_percentage), BoundSignature=Base.new(:name,:return_type,:argument_types), BufferInfo=Base.new(:buffer_id,:finished,:buffered_pages,:pages_sent,:page_buffer_info), ClientColumn=Base.new(:name,:type,:type_signature), ClientStageStats=Base.new(:stage_id,:state,:done,:nodes,:total_splits,:queued_splits,:running_splits,:completed_splits,:cpu_time_millis,:wall_time_millis,:processed_rows,:processed_bytes,:physical_input_bytes,:sub_stages), ClientTypeSignature=Base.new(:raw_type,:arguments), ClientTypeSignatureParameter=Base.new(:kind,:value), Code=Base.new(:code,:name), Column=Base.new(:name,:type), ColumnStatisticMetadata=Base.new(:column_name,:statistic_type), ConnectorSession, CorrelatedJoinNode=Base.new(:id,:input,:subquery,:correlation,:type,:filter,:origin_subquery), CreateTarget=Base.new(:handle,:schema_table_name), DeleteNode=Base.new(:id,:source,:target,:row_id,:outputs), DeleteTarget=Base.new(:handle,:schema_table_name), DistinctLimitNode=Base.new(:id,:source,:limit,:partial,:distinct_symbols,:hash_symbol), DistributionSnapshot=Base.new(:max_error,:count,:total,:p01,:p05,:p10,:p25,:p50,:p75,:p90,:p95,:p99,:min,:max), DriverStats=Base.new(:lifespan,:create_time,:start_time,:end_time,:queued_time,:elapsed_time,:user_memory_reservation,:revocable_memory_reservation,:system_memory_reservation,:total_scheduled_time,:total_cpu_time,:total_blocked_time,:fully_blocked,:blocked_reasons,:physical_input_data_size,:physical_input_positions,:physical_input_read_time,:internal_network_input_data_size,:internal_network_input_positions,:internal_network_input_read_time,:raw_input_data_size,:raw_input_positions,:raw_input_read_time,:processed_input_data_size,:processed_input_positions,:output_data_size,:output_positions,:physical_written_data_size,:operator_stats), DriverWindowInfo=Base.new(:sum_squared_differences_positions_of_index,:sum_squared_differences_size_of_index,:sum_squared_differences_size_in_partition,:total_partitions_count,:total_rows_count,:number_of_indexes), DynamicFilterDomainStats=Base.new(:dynamic_filter_id,:simplified_domain,:range_count,:discrete_values_count,:collection_duration), DynamicFiltersStats=Base.new(:dynamic_filter_domain_stats,:lazy_dynamic_filters,:replicated_dynamic_filters,:total_dynamic_filters,:dynamic_filters_completed), EnforceSingleRowNode=Base.new(:id,:source), EquiJoinClause=Base.new(:left,:right,:probe,:index), ErrorCode=Base.new(:code,:name,:type), ErrorLocation=Base.new(:line_number,:column_number), ExchangeClientStatus=Base.new(:buffered_bytes,:max_buffered_bytes,:average_bytes_per_request,:successful_requests_count,:buffered_pages,:no_more_locations,:page_buffer_client_statuses), ExchangeNode=Base.new(:id,:type,:scope,:partitioning_scheme,:sources,:inputs,:ordering_scheme), ExecutionFailureInfo=Base.new(:type,:message,:cause,:suppressed,:stack,:error_location,:error_code,:remote_host), ExplainAnalyzeNode=Base.new(:id,:source,:output_symbol,:actual_outputs,:verbose), FailureInfo=Base.new(:type,:message,:cause,:suppressed,:stack,:error_location), FilterNode=Base.new(:id,:source,:predicate), Function=Base.new(:resolved_function,:arguments,:frame,:ignore_nulls), GroupIdNode=Base.new(:id,:source,:grouping_sets,:grouping_columns,:aggregation_arguments,:group_id_symbol), GroupingSetDescriptor=Base.new(:grouping_keys,:grouping_set_count,:global_grouping_sets), HashCollisionsInfo=Base.new(:weighted_hash_collisions,:weighted_sum_squared_hash_collisions,:weighted_expectedHash_collisions), IndexHandle=Base.new(:catalog_name,:transaction_handle,:connector_handle), IndexJoinNode=Base.new(:id,:type,:probe_source,:index_source,:criteria,:probe_hash_symbol,:index_hash_symbol), IndexSourceNode=Base.new(:id,:index_handle,:table_handle,:lookup_symbols,:output_symbols,:assignments), Input=Base.new(:catalog_name,:schema,:table,:connector_info,:columns,:fragment_id,:plan_node_id), InsertTableHandle=Base.new(:catalog_name,:transaction_handle,:connector_handle), InsertTarget=Base.new(:handle,:schema_table_name), IntersectNode=Base.new(:id,:sources,:output_to_inputs,:outputs,:distinct), JoinNode=Base.new(:id,:type,:left,:right,:criteria,:left_output_symbols,:right_output_symbols,:filter,:left_hash_symbol,:right_hash_symbol,:distribution_type,:spillable,:dynamic_filters,:reorder_join_stats_and_cost), JoinOperatorInfo=Base.new(:join_type,:log_histogram_probes,:log_histogram_output,:lookup_source_positions), Lifespan, LimitNode=Base.new(:id,:source,:count,:ties_resolving_scheme,:partial), LocalCostEstimate=Base.new(:cpu_cost,:max_memory,:network_cost), LocalExchangeBufferInfo=Base.new(:buffered_bytes,:buffered_pages), Mapping=Base.new(:input,:outputs), MarkDistinctNode=Base.new(:id,:source,:marker_symbol,:distinct_symbols,:hash_symbol), OperatorStats=Base.new(:stage_id,:pipeline_id,:operator_id,:plan_node_id,:operator_type,:total_drivers,:add_input_calls,:add_input_wall,:add_input_cpu,:physical_input_data_size,:physical_input_positions,:internal_network_input_data_size,:internal_network_input_positions,:raw_input_data_size,:input_data_size,:input_positions,:sum_squared_input_positions,:get_output_calls,:get_output_wall,:get_output_cpu,:output_data_size,:output_positions,:dynamic_filter_splits_processed,:physical_written_data_size,:blocked_wall,:finish_calls,:finish_wall,:finish_cpu,:user_memory_reservation,:revocable_memory_reservation,:system_memory_reservation,:peak_user_memory_reservation,:peak_system_memory_reservation,:peak_revocable_memory_reservation,:peak_total_memory_reservation,:spilled_data_size,:blocked_reason,:info), OrderingScheme=Base.new(:order_by,:orderings), Output=Base.new(:catalog_name,:schema,:table), OutputBufferInfo=Base.new(:type,:state,:can_add_buffers,:can_add_pages,:total_buffered_bytes,:total_buffered_pages,:total_rows_sent,:total_pages_sent,:buffers), OutputNode=Base.new(:id,:source,:columns,:outputs), OutputTableHandle=Base.new(:catalog_name,:transaction_handle,:connector_handle), PageBufferClientStatus=Base.new(:uri,:state,:last_update,:rows_received,:pages_received,:rows_rejected,:pages_rejected,:requests_scheduled,:requests_completed,:requests_failed,:http_request_state), PageBufferInfo=Base.new(:partition,:buffered_pages,:buffered_bytes,:rows_added,:pages_added), PartitionedOutputInfo=Base.new(:rows_added,:pages_added,:output_buffer_peak_memory_usage), Partitioning=Base.new(:handle,:arguments), PartitioningHandle=Base.new(:connector_id,:transaction_handle,:connector_handle), PartitioningScheme=Base.new(:partitioning,:output_layout,:hash_column,:replicate_nulls_and_any,:bucket_to_partition), PipelineStats=Base.new(:pipeline_id,:first_start_time,:last_start_time,:last_end_time,:input_pipeline,:output_pipeline,:total_drivers,:queued_drivers,:queued_partitioned_drivers,:running_drivers,:running_partitioned_drivers,:blocked_drivers,:completed_drivers,:user_memory_reservation,:revocable_memory_reservation,:system_memory_reservation,:queued_time,:elapsed_time,:total_scheduled_time,:total_cpu_time,:total_blocked_time,:fully_blocked,:blocked_reasons,:physical_input_data_size,:physical_input_positions,:physical_input_read_time,:internal_network_input_data_size,:internal_network_input_positions,:raw_input_data_size,:raw_input_positions,:processed_input_data_size,:processed_input_positions,:output_data_size,:output_positions,:physical_written_data_size,:operator_summaries,:drivers), PlanCostEstimate=Base.new(:cpu_cost,:max_memory,:max_memory_when_outputting,:network_cost,:root_node_local_cost_estimate), PlanFragment=Base.new(:id,:root,:symbols,:partitioning,:partitioned_sources,:partitioning_scheme,:stage_execution_descriptor,:stats_and_costs,:json_representation), PlanNodeStatsAndCostSummary=Base.new(:output_row_count,:output_size_in_bytes,:cpu_cost,:memory_cost,:network_cost), PlanNodeStatsEstimate=Base.new(:output_row_count,:symbol_statistics), ProjectNode=Base.new(:id,:source,:assignments), QueryError=Base.new(:message,:sql_state,:error_code,:error_name,:error_type,:error_location,:failure_info), QueryInfo=Base.new(:query_id,:session,:state,:memory_pool,:scheduled,:self,:field_names,:query,:prepared_query,:query_stats,:set_catalog,:set_schema,:set_path,:set_session_properties,:reset_session_properties,:set_roles,:added_prepared_statements,:deallocated_prepared_statements,:started_transaction_id,:clear_transaction_id,:update_type,:output_stage,:failure_info,:error_code,:warnings,:inputs,:output,:referenced_tables,:routines,:complete_info,:resource_group_id,:query_type,:final_query_info), QueryResults=Base.new(:id,:info_uri,:partial_cancel_uri,:next_uri,:columns,:data,:stats,:error,:warnings,:update_type,:update_count), QueryStats=Base.new(:create_time,:execution_start_time,:last_heartbeat,:end_time,:elapsed_time,:queued_time,:resource_waiting_time,:dispatching_time,:execution_time,:analysis_time,:planning_time,:finishing_time,:total_tasks,:running_tasks,:completed_tasks,:total_drivers,:queued_drivers,:running_drivers,:blocked_drivers,:completed_drivers,:cumulative_user_memory,:user_memory_reservation,:revocable_memory_reservation,:total_memory_reservation,:peak_user_memory_reservation,:peak_revocable_memory_reservation,:peak_non_revocable_memory_reservation,:peak_total_memory_reservation,:peak_task_user_memory,:peak_task_revocable_memory,:peak_task_total_memory,:scheduled,:total_scheduled_time,:total_cpu_time,:total_blocked_time,:fully_blocked,:blocked_reasons,:physical_input_data_size,:physical_input_positions,:physical_input_read_time,:internal_network_input_data_size,:internal_network_input_positions,:raw_input_data_size,:raw_input_positions,:processed_input_data_size,:processed_input_positions,:output_data_size,:output_positions,:physical_written_data_size,:stage_gc_statistics,:dynamic_filters_stats,:operator_summaries), RefreshMaterializedViewTarget=Base.new(:table_handle,:insert_handle,:schema_table_name,:source_table_handles), RemoteSourceNode=Base.new(:id,:source_fragment_ids,:outputs,:ordering_scheme,:exchange_type), ResolvedFunction=Base.new(:signature,:id,:type_dependencies,:function_dependencies), ResourceEstimates=Base.new(:execution_time,:cpu_time,:peak_memory_bytes), ResourceGroupId, RoutineInfo=Base.new(:routine,:authorization), RowNumberNode=Base.new(:id,:source,:partition_by,:order_sensitive,:row_number_symbol,:max_row_count_per_partition,:hash_symbol), SampleNode=Base.new(:id,:source,:sample_ratio,:sample_type), SchemaTableName=Base.new(:schema,:table), SelectedRole=Base.new(:type,:role), SemiJoinNode=Base.new(:id,:source,:filtering_source,:source_join_symbol,:filtering_source_join_symbol,:semi_join_output,:source_hash_symbol,:filtering_source_hash_symbol,:distribution_type,:dynamic_filter_id), SessionRepresentation=Base.new(:query_id,:transaction_id,:client_transaction_support,:user,:groups,:principal,:source,:catalog,:schema,:path,:trace_token,:time_zone_key,:locale,:remote_user_address,:user_agent,:client_info,:client_tags,:client_capabilities,:resource_estimates,:start,:system_properties,:catalog_properties,:unprocessed_catalog_properties,:roles,:prepared_statements,:protocol_name), SortNode=Base.new(:id,:source,:ordering_scheme,:partial), SpatialJoinNode=Base.new(:id,:type,:left,:right,:output_symbols,:filter,:left_partition_symbol,:right_partition_symbol,:kdb_tree), Specification=Base.new(:partition_by,:ordering_scheme), SplitOperatorInfo=Base.new(:catalog_name,:split_info), SqlPath=Base.new(:raw_path), StageExecutionDescriptor=Base.new(:strategy,:grouped_execution_scan_nodes), StageGcStatistics=Base.new(:stage_id,:tasks,:full_gc_tasks,:min_full_gc_sec,:max_full_gc_sec,:total_full_gc_sec,:average_full_gc_sec), StageId, StageInfo=Base.new(:stage_id,:state,:plan,:types,:stage_stats,:tasks,:sub_stages,:tables,:failure_cause), StageStats=Base.new(:scheduling_complete,:get_split_distribution,:total_tasks,:running_tasks,:completed_tasks,:total_drivers,:queued_drivers,:running_drivers,:blocked_drivers,:completed_drivers,:cumulative_user_memory,:user_memory_reservation,:revocable_memory_reservation,:total_memory_reservation,:peak_user_memory_reservation,:peak_revocable_memory_reservation,:total_scheduled_time,:total_cpu_time,:total_blocked_time,:fully_blocked,:blocked_reasons,:physical_input_data_size,:physical_input_positions,:physical_input_read_time,:internal_network_input_data_size,:internal_network_input_positions,:raw_input_data_size,:raw_input_positions,:processed_input_data_size,:processed_input_positions,:buffered_data_size,:output_data_size,:output_positions,:physical_written_data_size,:gc_info,:operator_summaries), StatementStats=Base.new(:state,:queued,:scheduled,:nodes,:total_splits,:queued_splits,:running_splits,:completed_splits,:cpu_time_millis,:wall_time_millis,:queued_time_millis,:elapsed_time_millis,:processed_rows,:processed_bytes,:physical_input_bytes,:peak_memory_bytes,:spilled_bytes,:root_stage), StatisticAggregations=Base.new(:aggregations,:grouping_symbols), StatisticAggregationsDescriptor_Symbol=Base.new(:grouping,:table_statistics,:column_statistics), StatisticsWriterNode=Base.new(:id,:source,:target,:row_count_symbol,:row_count_enabled,:descriptor), StatsAndCosts=Base.new(:stats,:costs), SymbolStatsEstimate=Base.new(:low_value,:high_value,:nulls_fraction,:average_row_size,:distinct_values_count), TableFinishInfo=Base.new(:connector_output_metadata,:json_length_limit_exceeded,:statistics_wall_time,:statistics_cpu_time), TableFinishNode=Base.new(:id,:source,:target,:row_count_symbol,:statistics_aggregation,:statistics_aggregation_descriptor), TableHandle=Base.new(:catalog_name,:connector_handle,:transaction,:layout), TableInfo=Base.new(:table_name,:predicate), TableScanNode=Base.new(:id,:table,:output_symbols,:assignments,:for_delete), TableWriterInfo=Base.new(:page_sink_peak_memory_usage,:statistics_wall_time,:statistics_cpu_time,:validation_cpu_time), TableWriterNode=Base.new(:id,:source,:target,:row_count_symbol,:fragment_symbol,:columns,:column_names,:not_null_column_symbols,:partitioning_scheme,:statistics_aggregation,:statistics_aggregation_descriptor), TaskId, TaskInfo=Base.new(:task_status,:last_heartbeat,:output_buffers,:no_more_splits,:stats,:needs_plan), TaskStats=Base.new(:create_time,:first_start_time,:last_start_time,:last_end_time,:end_time,:elapsed_time,:queued_time,:total_drivers,:queued_drivers,:queued_partitioned_drivers,:running_drivers,:running_partitioned_drivers,:blocked_drivers,:completed_drivers,:cumulative_user_memory,:user_memory_reservation,:revocable_memory_reservation,:system_memory_reservation,:total_scheduled_time,:total_cpu_time,:total_blocked_time,:fully_blocked,:blocked_reasons,:physical_input_data_size,:physical_input_positions,:physical_input_read_time,:internal_network_input_data_size,:internal_network_input_positions,:raw_input_data_size,:raw_input_positions,:processed_input_data_size,:processed_input_positions,:output_data_size,:output_positions,:physical_written_data_size,:full_gc_count,:full_gc_time,:pipelines), TaskStatus=Base.new(:task_id,:task_instance_id,:version,:state,:self,:node_id,:completed_driver_groups,:failures,:queued_partitioned_drivers,:running_partitioned_drivers,:output_buffer_overutilized,:physical_written_data_size,:memory_reservation,:system_memory_reservation,:revocable_memory_reservation,:full_gc_count,:full_gc_time,:dynamic_filters_version), TopNNode=Base.new(:id,:source,:count,:ordering_scheme,:step), TopNRowNumberNode=Base.new(:id,:source,:specification,:row_number_symbol,:max_row_count_per_partition,:partial,:hash_symbol), TrinoWarning=Base.new(:warning_code,:message), UnionNode=Base.new(:id,:sources,:output_to_inputs,:outputs), UnnestNode=Base.new(:id,:source,:replicate_symbols,:mappings,:ordinality_symbol,:join_type,:filter), ValuesNode=Base.new(:id,:output_symbols,:row_count,:rows), Warning=Base.new(:warning_code,:message), WarningCode=Base.new(:code,:name), WindowInfo=Base.new(:window_infos), WindowNode=Base.new(:id,:source,:specification,:window_functions,:hash_symbol,:pre_partitioned_inputs,:pre_sorted_order_prefix), WriteStatisticsHandle=Base.new(:handle), WriteStatisticsTarget=Base.new(:type,:handle), WriterTarget=Base.new(:type,:handle)