Method List
Search:
-
#advance Presto::Client::StatementClient
-
#advance Presto::Client::Query
-
#cancel Presto::Client::Query
-
#cancel_leaf_stage Presto::Client::StatementClient
-
#client_aborted? Presto::Client::StatementClient
-
#client_error? Presto::Client::StatementClient
-
#close Presto::Client::StatementClient
-
#close Presto::Client::Query
-
#columns Presto::Client::Query
-
#current_results Presto::Client::Query
-
#current_results Presto::Client::StatementClient
-
#current_results_headers Presto::Client::Query
-
#current_results_headers Presto::Client::StatementClient
-
#debug? Presto::Client::StatementClient
-
decode Presto::Client::ModelVersions::V0_205::TaskInfo=Base.new(:task_status,:last_heartbeat,:output_buffers,:no_more_splits,:stats,:needs_plan,:complete)
-
decode Presto::Client::ModelVersions::V0_205::QueryResults=Base.new(:id,:info_uri,:partial_cancel_uri,:next_uri,:columns,:data,:stats,:error,:update_type,:update_count)
-
decode Presto::Client::ModelVersions::V316::RowNumberNode=Base.new(:id,:source,:partition_by,:row_number_symbol,:max_row_count_per_partition,:hash_symbol)
-
decode Presto::Client::ModelVersions::V0_205::UnnestNode=Base.new(:id,:source,:replicate_symbols,:unnest_symbols,:ordinality_symbol)
-
decode Presto::Client::ModelVersions::V0_205::LimitNode=Base.new(:id,:source,:count,:partial)
-
decode Presto::Client::ModelVersions::V0_205::QueryStats=Base.new(:create_time,:execution_start_time,:last_heartbeat,:end_time,:elapsed_time,:queued_time,:resource_waiting_time,:analysis_time,:distributed_planning_time,:total_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,:total_memory_reservation,:peak_user_memory_reservation,:peak_total_memory_reservation,:peak_task_total_memory,:scheduled,:total_scheduled_time,:total_cpu_time,:total_user_time,:total_blocked_time,:fully_blocked,:blocked_reasons,: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,:operator_summaries)
-
decode Presto::Client::ModelVersions::V0_205::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,:full_gc_count,:full_gc_time)
-
decode Presto::Client::ModelVersions::V0_205::StageStats=Base.new(:scheduling_complete,:get_split_distribution,:schedule_task_distribution,:add_split_distribution,:total_tasks,:running_tasks,:completed_tasks,:total_drivers,:queued_drivers,:running_drivers,:blocked_drivers,:completed_drivers,:cumulative_user_memory,:user_memory_reservation,:total_memory_reservation,:peak_user_memory_reservation,:total_scheduled_time,:total_cpu_time,:total_user_time,:total_blocked_time,:fully_blocked,:blocked_reasons,: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)
-
decode Presto::Client::ModelVersions::V0_205::OutputNode=Base.new(:id,:source,:columns,:outputs)
-
decode Presto::Client::ModelVersions::V0_205::PageBufferClientStatus=Base.new(:uri,:state,:last_update,:rows_received,:pages_received,:rows_rejected,:pages_rejected,:requests_scheduled,:requests_completed,:requests_failed,:http_request_state)
-
decode Presto::Client::ModelVersions::V0_205::WindowNode=Base.new(:id,:source,:specification,:window_functions,:hash_symbol,:pre_partitioned_inputs,:pre_sorted_order_prefix)
-
decode Presto::Client::ModelVersions::V0_205::OrderingScheme=Base.new(:order_by,:orderings)
-
decode Presto::Client::ModelVersions::V0_205::AggregationNode=Base.new(:id,:source,:aggregations,:grouping_sets,:pre_grouped_symbols,:step,:hash_symbol,:group_id_symbol)
-
decode Presto::Client::ModelVersions::V0_205::SplitOperatorInfo=Base.new(:split_info)
-
decode Presto::Client::ModelVersions::V0_205::RemoteSourceNode=Base.new(:id,:source_fragment_ids,:outputs)
-
decode Presto::Client::ModelVersions::V0_205::TableFinishInfo=Base.new(:connector_output_metadata)
-
decode Presto::Client::ModelVersions::V0_205::InsertHandle=Base.new(:handle,:schema_table_name)
-
decode Presto::Client::ModelVersions::V0_205::LongVariableConstraint=Base.new(:name,:expression)
-
decode Presto::Client::ModelVersions::V0_205::ClientTypeSignature=Base.new(:raw_type,:type_arguments,:literal_arguments,:arguments)
-
decode Presto::Client::ModelVersions::V0_205::LocalExchangeBufferInfo=Base.new(:buffered_bytes,:buffered_pages)
-
decode Presto::Client::ModelVersions::V0_205::ClientColumn=Base.new(:name,:type,:type_signature)
-
decode Presto::Client::ModelVersions::V0_205::PageBufferInfo=Base.new(:partition,:buffered_pages,:buffered_bytes,:rows_added,:pages_added)
-
decode Presto::Client::ModelVersions::V0_205::JoinNode=Base.new(:id,:type,:left,:right,:criteria,:output_symbols,:filter,:left_hash_symbol,:right_hash_symbol,:distribution_type)
-
decode Presto::Client::ModelVersions::V303::GroupIdNode=Base.new(:id,:source,:grouping_sets,:grouping_columns,:aggregation_arguments,:group_id_symbol)
-
decode Presto::Client::ModelVersions::V0_205::TableWriterNode=Base.new(:id,:source,:target,:columns,:column_names,:outputs,:partitioning_scheme)
-
decode Presto::Client::ModelVersions::V0_205::JoinOperatorInfo=Base.new(:join_type,:log_histogram_probes,:log_histogram_output,:lookup_source_positions)
-
decode Presto::Client::ModelVersions::V0_153::Output=Base.new(:connector_id,:schema,:table)
-
decode Presto::Client::ModelVersions::V0_205::StageInfo=Base.new(:stage_id,:state,:self,:plan,:types,:stage_stats,:tasks,:sub_stages,:failure_cause)
-
decode Presto::Client::ModelVersions::V0_205::ProjectNode=Base.new(:id,:source,:assignments)
-
decode Presto::Client::ModelVersions::V0_205::PlanNode
-
decode Presto::Client::ModelVersions::V0_178::UnnestNode=Base.new(:id,:source,:replicate_symbols,:unnest_symbols,:ordinality_symbol)
-
decode Presto::Client::ModelVersions::V0_205::PartitioningHandle=Base.new(:connector_id,:transaction_handle,:connector_handle)
-
decode Presto::Client::ModelVersions::V0_205::TableWriterInfo=Base.new(:page_sink_peak_memory_usage)
-
decode Presto::Client::ModelVersions::V0_205::TopNNode=Base.new(:id,:source,:count,:ordering_scheme,:step)
-
decode Presto::Client::ModelVersions::V0_205::Function=Base.new(:function_call,:signature,:frame)
-
decode Presto::Client::ModelVersions::V0_205::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_user_time,:total_blocked_time,:fully_blocked,:blocked_reasons,: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)
-
decode Presto::Client::ModelVersions::V0_205::SchemaTableName=Base.new(:schema,:table)
-
decode Presto::Client::ModelVersions::V0_205::CreateHandle=Base.new(:handle,:schema_table_name)
-
decode Presto::Client::ModelVersions::V303::TableWriterNode=Base.new(:id,:source,:target,:row_count_symbol,:fragment_symbol,:columns,:column_names,:partitioning_scheme,:statistics_aggregation,:statistics_aggregation_descriptor)
-
decode Presto::Client::ModelVersions::V0_205::TableLayoutHandle=Base.new(:connector_id,:transaction_handle,:connector_handle)
-
decode Presto::Client::ModelVersions::V0_205::TableFinishNode=Base.new(:id,:source,:target,:outputs)
-
decode Presto::Client::ModelVersions::V0_205::WriterTarget=Base.new(:type,:handle)
-
decode Presto::Client::ModelVersions::V0_205::QueryInfo=Base.new(:query_id,:session,:state,:memory_pool,:scheduled,:self,:field_names,:query,:query_stats,:set_catalog,:set_schema,:set_session_properties,:reset_session_properties,:added_prepared_statements,:deallocated_prepared_statements,:started_transaction_id,:clear_transaction_id,:update_type,:output_stage,:failure_info,:error_code,:inputs,:output,:complete_info,:resource_group_name,:final_query_info)
-
decode Presto::Client::ModelVersions::V0_205::TableScanNode=Base.new(:id,:table,:output_symbols,:assignments,:layout,:current_constraint,:original_constraint)
-
decode Presto::Client::ModelVersions::V0_205::IndexSourceNode=Base.new(:id,:index_handle,:table_handle,:table_layout,:lookup_symbols,:output_symbols,:assignments,:current_constraint)
-
decode Presto::Client::ModelVersions::V0_205::ResourceEstimates=Base.new(:execution_time,:cpu_time,:peak_memory)
-
decode Presto::Client::ModelVersions::V0_205::ExecutionFailureInfo=Base.new(:type,:message,:cause,:suppressed,:stack,:error_location,:error_code,:remote_host)
-
decode Presto::Client::ModelVersions::V0_205::FailureInfo=Base.new(:type,:message,:cause,:suppressed,:stack,:error_location)
-
decode Presto::Client::ModelVersions::V0_205::IndexJoinNode=Base.new(:id,:type,:probe_source,:index_source,:criteria,:probe_hash_symbol,:index_hash_symbol)
-
decode Presto::Client::ModelVersions::V0_205::GroupIdNode=Base.new(:id,:source,:grouping_sets,:grouping_set_mappings,:argument_mappings,:group_id_symbol)
-
decode Presto::Client::ModelVersions::V0_205::DistinctLimitNode=Base.new(:id,:source,:limit,:partial,:distinct_symbols,:hash_symbol)
-
decode Presto::Client::ModelVersions::V0_205::MarkDistinctNode=Base.new(:id,:source,:marker_symbol,:distinct_symbols,:hash_symbol)
-
decode Presto::Client::ModelVersions::V0_205::TypeVariableConstraint=Base.new(:name,:comparable_required,:orderable_required,:variadic_bound)
-
decode Presto::Client::ModelVersions::V303::PlanNode
-
decode Presto::Client::ModelVersions::V303::DistributionSnapshot=Base.new(:max_error,:count,:total,:p01,:p05,:p10,:p25,:p50,:p75,:p90,:p95,:p99,:min,:max)
-
decode Presto::Client::ModelVersions::V303::EquiJoinClause=Base.new(:left,:right,:probe,:index)
-
decode Presto::Client::ModelVersions::V303::WriterTarget=Base.new(:type,:handle)
-
decode Presto::Client::ModelVersions::V303::WriteStatisticsTarget=Base.new(:type,:handle)
-
decode Presto::Client::ModelVersions::V303::OperatorInfo
-
decode Presto::Client::ModelVersions::V303::HashCollisionsInfo=Base.new(:weighted_hash_collisions,:weighted_sum_squared_hash_collisions,:weighted_expectedHash_collisions)
-
decode Presto::Client::ModelVersions::V303::Aggregation=Base.new(:call,:signature,:mask)
-
decode Presto::Client::ModelVersions::V303::Assignments=Base.new(:assignments)
-
decode Presto::Client::ModelVersions::V303::AggregationNode=Base.new(:id,:source,:aggregations,:grouping_sets,:pre_grouped_symbols,:step,:hash_symbol,:group_id_symbol)
-
decode Presto::Client::ModelVersions::V303::AnalyzeTableHandle=Base.new(:connector_id,:transaction_handle,:connector_handle)
-
decode Presto::Client::ModelVersions::V303::ApplyNode=Base.new(:id,:input,:subquery,:subquery_assignments,:correlation,:origin_subquery)
-
decode Presto::Client::ModelVersions::V303::ArgumentBinding=Base.new(:expression,:constant)
-
decode Presto::Client::ModelVersions::V303::AssignUniqueId=Base.new(:id,:source,:id_column)
-
decode Presto::Client::ModelVersions::V303::ColumnStatisticMetadata=Base.new(:column_name,:statistic_type)
-
decode Presto::Client::ModelVersions::V303::BasicQueryInfo=Base.new(:query_id,:session,:resource_group_id,:state,:memory_pool,:scheduled,:self,:query,:query_stats,:error_type,:error_code)
-
decode Presto::Client::ModelVersions::V303::BasicQueryStats=Base.new(:create_time,:end_time,:queued_time,:elapsed_time,:execution_time,:total_drivers,:queued_drivers,:running_drivers,:completed_drivers,:physical_input_data_size,:physical_input_positions,:internal_network_input_data_size,:internal_network_input_positions,:raw_input_data_size,:raw_input_positions,:cumulative_user_memory,:user_memory_reservation,:total_memory_reservation,:peak_user_memory_reservation,:total_cpu_time,:total_scheduled_time,:fully_blocked,:blocked_reasons,:progress_percentage)
-
decode Presto::Client::ModelVersions::V303::BufferInfo=Base.new(:buffer_id,:finished,:buffered_pages,:pages_sent,:page_buffer_info)
-
decode Presto::Client::ModelVersions::V303::ClientColumn=Base.new(:name,:type,:type_signature)
-
decode Presto::Client::ModelVersions::V303::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,:sub_stages)
-
decode Presto::Client::ModelVersions::V303::ClientTypeSignature=Base.new(:raw_type,:type_arguments,:literal_arguments,:arguments)
-
decode Presto::Client::ModelVersions::V303::ClientTypeSignatureParameter=Base.new(:kind,:value)
-
decode Presto::Client::ModelVersions::V303::Code=Base.new(:code,:name)
-
decode Presto::Client::ModelVersions::V303::Column=Base.new(:name,:type)
-
decode Presto::Client::ModelVersions::V303::Function=Base.new(:function_call,:signature,:frame)
-
decode Presto::Client::ModelVersions::V303::CreateHandle=Base.new(:handle,:schema_table_name)
-
decode Presto::Client::ModelVersions::V303::DeleteHandle=Base.new(:handle,:schema_table_name)
-
decode Presto::Client::ModelVersions::V303::DeleteNode=Base.new(:id,:source,:target,:row_id,:outputs)
-
decode Presto::Client::ModelVersions::V303::DistinctLimitNode=Base.new(:id,:source,:limit,:partial,:distinct_symbols,:hash_symbol)
-
decode Presto::Client::ModelVersions::V303::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)
-
decode Presto::Client::ModelVersions::V303::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)
-
decode Presto::Client::ModelVersions::V303::EnforceSingleRowNode=Base.new(:id,:source)
-
decode Presto::Client::ModelVersions::V303::ErrorCode=Base.new(:code,:name,:type)
-
decode Presto::Client::ModelVersions::V303::ErrorLocation=Base.new(:line_number,:column_number)
-
decode Presto::Client::ModelVersions::V303::ExchangeClientStatus=Base.new(:buffered_bytes,:max_buffered_bytes,:average_bytes_per_request,:successful_requests_count,:buffered_pages,:no_more_locations,:page_buffer_client_statuses)
-
decode Presto::Client::ModelVersions::V303::ExchangeNode=Base.new(:id,:type,:scope,:partitioning_scheme,:sources,:inputs,:ordering_scheme)
-
decode Presto::Client::ModelVersions::V303::ExecutionFailureInfo=Base.new(:type,:message,:cause,:suppressed,:stack,:error_location,:error_code,:remote_host)
-
decode Presto::Client::ModelVersions::V303::ExplainAnalyzeNode=Base.new(:id,:source,:output_symbol,:verbose)
-
decode Presto::Client::ModelVersions::V303::FailureInfo=Base.new(:type,:message,:cause,:suppressed,:stack,:error_location)
-
decode Presto::Client::ModelVersions::V303::FilterNode=Base.new(:id,:source,:predicate)
-
decode Presto::Client::ModelVersions::V0_205::FilterNode=Base.new(:id,:source,:predicate)
-
decode Presto::Client::ModelVersions::V0_205::DistributionSnapshot=Base.new(:max_error,:count,:total,:p01,:p05,:p10,:p25,:p50,:p75,:p90,:p95,:p99,:min,:max)
-
decode Presto::Client::ModelVersions::V303::GroupingSetDescriptor=Base.new(:grouping_keys,:grouping_set_count,:global_grouping_sets)
-
decode Presto::Client::ModelVersions::V303::IndexHandle=Base.new(:connector_id,:transaction_handle,:connector_handle)
-
decode Presto::Client::ModelVersions::V303::IndexJoinNode=Base.new(:id,:type,:probe_source,:index_source,:criteria,:probe_hash_symbol,:index_hash_symbol)
-
decode Presto::Client::ModelVersions::V303::IndexSourceNode=Base.new(:id,:index_handle,:table_handle,:table_layout,:lookup_symbols,:output_symbols,:assignments,:current_constraint)
-
decode Presto::Client::ModelVersions::V303::Input=Base.new(:connector_id,:schema,:table,:connector_info,:columns)
-
decode Presto::Client::ModelVersions::V303::InsertHandle=Base.new(:handle,:schema_table_name)
-
decode Presto::Client::ModelVersions::V303::InsertTableHandle=Base.new(:connector_id,:transaction_handle,:connector_handle)
-
decode Presto::Client::ModelVersions::V303::IntersectNode=Base.new(:id,:sources,:output_to_inputs,:outputs)
-
decode Presto::Client::ModelVersions::V303::JoinNode=Base.new(:id,:type,:left,:right,:criteria,:output_symbols,:filter,:left_hash_symbol,:right_hash_symbol,:distribution_type)
-
decode Presto::Client::ModelVersions::V303::JoinOperatorInfo=Base.new(:join_type,:log_histogram_probes,:log_histogram_output,:lookup_source_positions)
-
decode Presto::Client::ModelVersions::V303::LateralJoinNode=Base.new(:id,:input,:subquery,:correlation,:type,:origin_subquery)
-
decode Presto::Client::ModelVersions::V303::LimitNode=Base.new(:id,:source,:count,:partial)
-
decode Presto::Client::ModelVersions::V303::LocalExchangeBufferInfo=Base.new(:buffered_bytes,:buffered_pages)
-
decode Presto::Client::ModelVersions::V303::LongVariableConstraint=Base.new(:name,:expression)
-
decode Presto::Client::ModelVersions::V303::MarkDistinctNode=Base.new(:id,:source,:marker_symbol,:distinct_symbols,:hash_symbol)
-
decode Presto::Client::ModelVersions::V303::MetadataDeleteNode=Base.new(:id,:target,:output,:table_layout)
-
decode Presto::Client::ModelVersions::V303::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,:internal_network_input_data_size,: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,: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_total_memory_reservation,:spilled_data_size,:blocked_reason,:info)
-
decode Presto::Client::ModelVersions::V303::OrderingScheme=Base.new(:order_by,:orderings)
-
decode Presto::Client::ModelVersions::V303::Output=Base.new(:connector_id,:schema,:table)
-
decode Presto::Client::ModelVersions::V303::OutputBufferInfo=Base.new(:type,:state,:can_add_buffers,:can_add_pages,:total_buffered_bytes,:total_buffered_pages,:total_rows_sent,:total_pages_sent,:buffers)
-
decode Presto::Client::ModelVersions::V303::OutputNode=Base.new(:id,:source,:columns,:outputs)
-
decode Presto::Client::ModelVersions::V303::OutputTableHandle=Base.new(:connector_id,:transaction_handle,:connector_handle)
-
decode Presto::Client::ModelVersions::V303::PageBufferClientStatus=Base.new(:uri,:state,:last_update,:rows_received,:pages_received,:rows_rejected,:pages_rejected,:requests_scheduled,:requests_completed,:requests_failed,:http_request_state)
-
decode Presto::Client::ModelVersions::V303::PageBufferInfo=Base.new(:partition,:buffered_pages,:buffered_bytes,:rows_added,:pages_added)
-
decode Presto::Client::ModelVersions::V303::PartitionedOutputInfo=Base.new(:rows_added,:pages_added,:output_buffer_peak_memory_usage)
-
decode Presto::Client::ModelVersions::V303::Partitioning=Base.new(:handle,:arguments)
-
decode Presto::Client::ModelVersions::V303::PartitioningHandle=Base.new(:connector_id,:transaction_handle,:connector_handle)
-
decode Presto::Client::ModelVersions::V303::PartitioningScheme=Base.new(:partitioning,:output_layout,:hash_column,:replicate_nulls_and_any,:bucket_to_partition)
-
decode Presto::Client::ModelVersions::V303::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,: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)
-
decode Presto::Client::ModelVersions::V303::PlanFragment=Base.new(:id,:root,:symbols,:partitioning,:partitioned_sources,:partitioning_scheme,:stage_execution_descriptor,:stats_and_costs,:json_representation)
-
decode Presto::Client::ModelVersions::V303::PlanNodeCostEstimate=Base.new(:cpu_cost,:memory_cost,:network_cost)
-
decode Presto::Client::ModelVersions::V303::PlanNodeStatsEstimate=Base.new(:output_row_count,:symbol_statistics)
-
decode Presto::Client::ModelVersions::V303::PrestoWarning=Base.new(:warning_code,:message)
-
decode Presto::Client::ModelVersions::V303::ProjectNode=Base.new(:id,:source,:assignments)
-
decode Presto::Client::ModelVersions::V303::QueryError=Base.new(:message,:sql_state,:error_code,:error_name,:error_type,:error_location,:failure_info)
-
decode Presto::Client::ModelVersions::V303::QueryInfo=Base.new(:query_id,:session,:state,:memory_pool,:scheduled,:self,:field_names,: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,:complete_info,:resource_group_id,:final_query_info)
-
decode Presto::Client::ModelVersions::V303::QueryResults=Base.new(:id,:info_uri,:partial_cancel_uri,:next_uri,:columns,:data,:stats,:error,:warnings,:update_type,:update_count)
-
decode Presto::Client::ModelVersions::V303::QueryStats=Base.new(:create_time,:execution_start_time,:last_heartbeat,:end_time,:elapsed_time,:queued_time,:resource_waiting_time,:execution_time,:analysis_time,:distributed_planning_time,:total_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,:total_memory_reservation,:peak_user_memory_reservation,:peak_total_memory_reservation,:peak_task_user_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,: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,:operator_summaries)
-
decode Presto::Client::ModelVersions::V303::RemoteSourceNode=Base.new(:id,:source_fragment_ids,:outputs,:ordering_scheme,:exchange_type)
-
decode Presto::Client::ModelVersions::V303::ResourceEstimates=Base.new(:execution_time,:cpu_time,:peak_memory)
-
decode Presto::Client::ModelVersions::V303::RowNumberNode=Base.new(:id,:source,:partition_by,:row_number_symbol,:max_row_count_per_partition,:hash_symbol)
-
decode Presto::Client::ModelVersions::V303::SampleNode=Base.new(:id,:source,:sample_ratio,:sample_type)
-
decode Presto::Client::ModelVersions::V303::SchemaTableName=Base.new(:schema,:table)
-
decode Presto::Client::ModelVersions::V303::SelectedRole=Base.new(:type,:role)
-
decode Presto::Client::ModelVersions::V303::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)
-
decode Presto::Client::ModelVersions::V303::SessionRepresentation=Base.new(:query_id,:transaction_id,:client_transaction_support,:user,: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_time,:system_properties,:catalog_properties,:unprocessed_catalog_properties,:roles,:prepared_statements)
-
decode Presto::Client::ModelVersions::V303::Signature=Base.new(:name,:kind,:type_variable_constraints,:long_variable_constraints,:return_type,:argument_types,:variable_arity)
-
decode Presto::Client::ModelVersions::V303::SortNode=Base.new(:id,:source,:ordering_scheme)
-
decode Presto::Client::ModelVersions::V303::Specification=Base.new(:partition_by,:ordering_scheme)
-
decode Presto::Client::ModelVersions::V303::SplitOperatorInfo=Base.new(:split_info)
-
decode Presto::Client::ModelVersions::V303::SqlPath=Base.new(:raw_path)
-
decode Presto::Client::ModelVersions::V303::StageExecutionDescriptor=Base.new(:grouped_execution_scan_nodes)
-
decode Presto::Client::ModelVersions::V303::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)
-
decode Presto::Client::ModelVersions::V303::StageInfo=Base.new(:stage_id,:state,:self,:plan,:types,:stage_stats,:tasks,:sub_stages,:failure_cause)
-
decode Presto::Client::ModelVersions::V303::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,:total_memory_reservation,:peak_user_memory_reservation,:total_scheduled_time,:total_cpu_time,:total_blocked_time,:fully_blocked,:blocked_reasons,:physical_input_data_size,:physical_input_positions,: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)
-
decode Presto::Client::ModelVersions::V303::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,:peak_memory_bytes,:spilled_bytes,:root_stage)
-
decode Presto::Client::ModelVersions::V303::StatisticAggregations=Base.new(:aggregations,:grouping_symbols)
-
decode Presto::Client::ModelVersions::V303::StatisticAggregationsDescriptor_Symbol=Base.new(:grouping,:table_statistics,:column_statistics)
-
decode Presto::Client::ModelVersions::V303::StatisticsWriterNode=Base.new(:id,:source,:target,:row_count_symbol,:row_count_enabled,:descriptor)
-
decode Presto::Client::ModelVersions::V303::StatsAndCosts=Base.new(:stats,:costs)
-
decode Presto::Client::ModelVersions::V303::SymbolStatsEstimate=Base.new(:low_value,:high_value,:nulls_fraction,:average_row_size,:distinct_values_count)
-
decode Presto::Client::ModelVersions::V303::TableFinishInfo=Base.new(:connector_output_metadata,:json_length_limit_exceeded,:statistics_wall_time,:statistics_cpu_time)
-
decode Presto::Client::ModelVersions::V303::TableFinishNode=Base.new(:id,:source,:target,:row_count_symbol,:statistics_aggregation,:statistics_aggregation_descriptor)
-
decode Presto::Client::ModelVersions::V303::TableHandle=Base.new(:connector_id,:connector_handle)
-
decode Presto::Client::ModelVersions::V303::TableLayoutHandle=Base.new(:connector_id,:transaction_handle,:connector_handle)
-
decode Presto::Client::ModelVersions::V303::TableScanNode=Base.new(:id,:table,:output_symbols,:assignments,:layout)
-
decode Presto::Client::ModelVersions::V303::TableWriterInfo=Base.new(:page_sink_peak_memory_usage,:statistics_wall_time,:statistics_cpu_time,:validation_cpu_time)
-
decode Presto::Client::ModelVersions::V0_178::ValuesNode=Base.new(:id,:output_symbols,:rows)
-
decode Presto::Client::ModelVersions::V303::TaskInfo=Base.new(:task_status,:last_heartbeat,:output_buffers,:no_more_splits,:stats,:needs_plan)
-
decode Presto::Client::ModelVersions::V303::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,: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)
-
decode Presto::Client::ModelVersions::V303::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,:full_gc_count,:full_gc_time)
-
decode Presto::Client::ModelVersions::V303::TopNNode=Base.new(:id,:source,:count,:ordering_scheme,:step)
-
decode Presto::Client::ModelVersions::V303::TopNRowNumberNode=Base.new(:id,:source,:specification,:row_number_symbol,:max_row_count_per_partition,:partial,:hash_symbol)
-
decode Presto::Client::ModelVersions::V303::TypeVariableConstraint=Base.new(:name,:comparable_required,:orderable_required,:variadic_bound)
-
decode Presto::Client::ModelVersions::V303::UnionNode=Base.new(:id,:sources,:output_to_inputs,:outputs)
-
decode Presto::Client::ModelVersions::V303::UnnestNode=Base.new(:id,:source,:replicate_symbols,:unnest_symbols,:ordinality_symbol)
-
decode Presto::Client::ModelVersions::V303::ValuesNode=Base.new(:id,:output_symbols,:rows)
-
decode Presto::Client::ModelVersions::V303::Warning=Base.new(:warning_code,:message)
-
decode Presto::Client::ModelVersions::V303::WarningCode=Base.new(:code,:name)
-
decode Presto::Client::ModelVersions::V303::WindowInfo=Base.new(:window_infos)
-
decode Presto::Client::ModelVersions::V303::WindowNode=Base.new(:id,:source,:specification,:window_functions,:hash_symbol,:pre_partitioned_inputs,:pre_sorted_order_prefix)
-
decode Presto::Client::ModelVersions::V303::WriteStatisticsHandle=Base.new(:handle)
-
decode Presto::Client::ModelVersions::V316::ResourceEstimates=Base.new(:execution_time,:cpu_time,:peak_memory)
-
decode Presto::Client::ModelVersions::V0_205::TableHandle=Base.new(:connector_id,:connector_handle)
-
decode Presto::Client::ModelVersions::V316::FilterNode=Base.new(:id,:source,:predicate)
-
decode Presto::Client::ModelVersions::V0_205::PlanFragment=Base.new(:id,:root,:symbols,:partitioning,:partitioned_sources,:partitioning_scheme,:pipeline_execution_strategy)
-
decode Presto::Client::ModelVersions::V0_205::StatementStats=Base.new(:state,:queued,:scheduled,:nodes,:total_splits,:queued_splits,:running_splits,:completed_splits,:user_time_millis,:cpu_time_millis,:wall_time_millis,:queued_time_millis,:elapsed_time_millis,:processed_rows,:processed_bytes,:peak_memory_bytes,:root_stage)
-
decode Presto::Client::ModelVersions::V0_205::ExchangeNode=Base.new(:id,:type,:scope,:partitioning_scheme,:sources,:inputs)
-
decode Presto::Client::ModelVersions::V316::AssignUniqueId=Base.new(:id,:source,:id_column)
-
decode Presto::Client::ModelVersions::V0_205::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)
-
decode Presto::Client::ModelVersions::V0_205::OutputTableHandle=Base.new(:connector_id,:transaction_handle,:connector_handle)
-
decode Presto::Client::ModelVersions::V0_205::ClientTypeSignatureParameter=Base.new(:kind,:value)
-
decode Presto::Client::ModelVersions::V0_205::ErrorCode=Base.new(:code,:name,:type)
-
decode Presto::Client::ModelVersions::V316::EquiJoinClause=Base.new(:left,:right,:probe,:index)
-
decode Presto::Client::ModelVersions::V316::PlanNode
-
decode Presto::Client::ModelVersions::V316::HashCollisionsInfo=Base.new(:weighted_hash_collisions,:weighted_sum_squared_hash_collisions,:weighted_expectedHash_collisions)
-
decode Presto::Client::ModelVersions::V316::DistributionSnapshot=Base.new(:max_error,:count,:total,:p01,:p05,:p10,:p25,:p50,:p75,:p90,:p95,:p99,:min,:max)
-
decode Presto::Client::ModelVersions::V316::ArgumentBinding=Base.new(:expression,:constant)
-
decode Presto::Client::ModelVersions::V316::WriterTarget=Base.new(:type,:handle)
-
decode Presto::Client::ModelVersions::V316::WriteStatisticsTarget=Base.new(:type,:handle)
-
decode Presto::Client::ModelVersions::V316::OperatorInfo
-
decode Presto::Client::ModelVersions::V0_205::ExchangeClientStatus=Base.new(:buffered_bytes,:max_buffered_bytes,:average_bytes_per_request,:successful_requests_count,:buffered_pages,:no_more_locations,:page_buffer_client_statuses)
-
decode Presto::Client::ModelVersions::V316::AggregationNode=Base.new(:id,:source,:aggregations,:grouping_sets,:pre_grouped_symbols,:step,:hash_symbol,:group_id_symbol)
-
decode Presto::Client::ModelVersions::V316::Aggregation=Base.new(:signature,:arguments,:distinct,:filter,:ordering_scheme,:mask)
-
decode Presto::Client::ModelVersions::V316::ApplyNode=Base.new(:id,:input,:subquery,:subquery_assignments,:correlation,:origin_subquery)
-
decode Presto::Client::ModelVersions::V316::AnalyzeTableHandle=Base.new(:catalog_name,:transaction_handle,:connector_handle)
-
decode Presto::Client::ModelVersions::V0_205::ExplainAnalyzeNode=Base.new(:id,:source,:output_symbol,:verbose)
-
decode Presto::Client::ModelVersions::V0_205::Aggregation=Base.new(:call,:signature,:mask)
-
decode Presto::Client::ModelVersions::V0_205::ArgumentBinding=Base.new(:column,:constant)
-
decode Presto::Client::ModelVersions::V316::Assignments=Base.new(:assignments)
-
decode Presto::Client::ModelVersions::V316::BasicQueryInfo=Base.new(:query_id,:session,:resource_group_id,:state,:memory_pool,:scheduled,:self,:query,:prepared_query,:query_stats,:error_type,:error_code)
-
decode Presto::Client::ModelVersions::V316::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,: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)
-
decode Presto::Client::ModelVersions::V316::BufferInfo=Base.new(:buffer_id,:finished,:buffered_pages,:pages_sent,:page_buffer_info)
-
decode Presto::Client::ModelVersions::V316::ClientColumn=Base.new(:name,:type,:type_signature)
-
decode Presto::Client::ModelVersions::V316::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,:sub_stages)
-
decode Presto::Client::ModelVersions::V316::ClientTypeSignature=Base.new(:raw_type,:type_arguments,:literal_arguments,:arguments)
-
decode Presto::Client::ModelVersions::V316::ClientTypeSignatureParameter=Base.new(:kind,:value)
-
decode Presto::Client::ModelVersions::V316::Code=Base.new(:code,:name)
-
decode Presto::Client::ModelVersions::V316::Column=Base.new(:name,:type)
-
decode Presto::Client::ModelVersions::V316::ColumnStatisticMetadata=Base.new(:column_name,:statistic_type)
-
decode Presto::Client::ModelVersions::V316::CreateTarget=Base.new(:handle,:schema_table_name)
-
decode Presto::Client::ModelVersions::V316::DeleteNode=Base.new(:id,:source,:target,:row_id,:outputs)
-
decode Presto::Client::ModelVersions::V316::DeleteTarget=Base.new(:handle,:schema_table_name)
-
decode Presto::Client::ModelVersions::V316::DistinctLimitNode=Base.new(:id,:source,:limit,:partial,:distinct_symbols,:hash_symbol)
-
decode Presto::Client::ModelVersions::V316::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)
-
decode Presto::Client::ModelVersions::V316::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)
-
decode Presto::Client::ModelVersions::V316::EnforceSingleRowNode=Base.new(:id,:source)
-
decode Presto::Client::ModelVersions::V316::ErrorCode=Base.new(:code,:name,:type)
-
decode Presto::Client::ModelVersions::V316::ErrorLocation=Base.new(:line_number,:column_number)
-
decode Presto::Client::ModelVersions::V316::ExchangeClientStatus=Base.new(:buffered_bytes,:max_buffered_bytes,:average_bytes_per_request,:successful_requests_count,:buffered_pages,:no_more_locations,:page_buffer_client_statuses)
-
decode Presto::Client::ModelVersions::V316::ExchangeNode=Base.new(:id,:type,:scope,:partitioning_scheme,:sources,:inputs,:ordering_scheme)
-
decode Presto::Client::ModelVersions::V316::ExecutionFailureInfo=Base.new(:type,:message,:cause,:suppressed,:stack,:error_location,:error_code,:semantic_error_code,:remote_host)
-
decode Presto::Client::ModelVersions::V316::ExplainAnalyzeNode=Base.new(:id,:source,:output_symbol,:verbose)
-
decode Presto::Client::ModelVersions::V316::FailureInfo=Base.new(:type,:message,:cause,:suppressed,:stack,:error_location)
-
decode Presto::Client::ModelVersions::V0_178::TableScanNode=Base.new(:id,:table,:output_symbols,:assignments,:layout,:current_constraint,:original_constraint)
-
decode Presto::Client::ModelVersions::V316::Function=Base.new(:signature,:arguments,:frame)
-
decode Presto::Client::ModelVersions::V316::GroupIdNode=Base.new(:id,:source,:grouping_sets,:grouping_columns,:aggregation_arguments,:group_id_symbol)
-
decode Presto::Client::ModelVersions::V316::GroupingSetDescriptor=Base.new(:grouping_keys,:grouping_set_count,:global_grouping_sets)
-
decode Presto::Client::ModelVersions::V316::IndexHandle=Base.new(:catalog_name,:transaction_handle,:connector_handle)
-
decode Presto::Client::ModelVersions::V316::IndexJoinNode=Base.new(:id,:type,:probe_source,:index_source,:criteria,:probe_hash_symbol,:index_hash_symbol)
-
decode Presto::Client::ModelVersions::V316::IndexSourceNode=Base.new(:id,:index_handle,:table_handle,:lookup_symbols,:output_symbols,:assignments,:current_constraint)
-
decode Presto::Client::ModelVersions::V316::Input=Base.new(:catalog_name,:schema,:table,:connector_info,:columns)
-
decode Presto::Client::ModelVersions::V316::InsertTableHandle=Base.new(:catalog_name,:transaction_handle,:connector_handle)
-
decode Presto::Client::ModelVersions::V316::InsertTarget=Base.new(:handle,:schema_table_name)
-
decode Presto::Client::ModelVersions::V316::IntersectNode=Base.new(:id,:sources,:output_to_inputs,:outputs)
-
decode Presto::Client::ModelVersions::V316::JoinNode=Base.new(:id,:type,:left,:right,:criteria,:output_symbols,:filter,:left_hash_symbol,:right_hash_symbol,:distribution_type,:spillable,:dynamic_filters)
-
decode Presto::Client::ModelVersions::V316::JoinOperatorInfo=Base.new(:join_type,:log_histogram_probes,:log_histogram_output,:lookup_source_positions)
-
decode Presto::Client::ModelVersions::V316::LateralJoinNode=Base.new(:id,:input,:subquery,:correlation,:type,:filter,:origin_subquery)
-
decode Presto::Client::ModelVersions::V316::LimitNode=Base.new(:id,:source,:count,:ties_resolving_scheme,:partial)
-
decode Presto::Client::ModelVersions::V316::LocalCostEstimate=Base.new(:cpu_cost,:max_memory,:network_cost)
-
decode Presto::Client::ModelVersions::V316::LocalExchangeBufferInfo=Base.new(:buffered_bytes,:buffered_pages)
-
decode Presto::Client::ModelVersions::V316::LongVariableConstraint=Base.new(:name,:expression)
-
decode Presto::Client::ModelVersions::V316::MarkDistinctNode=Base.new(:id,:source,:marker_symbol,:distinct_symbols,:hash_symbol)
-
decode Presto::Client::ModelVersions::V316::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,: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)
-
decode Presto::Client::ModelVersions::V316::OrderingScheme=Base.new(:order_by,:orderings)
-
decode Presto::Client::ModelVersions::V316::Output=Base.new(:catalog_name,:schema,:table)
-
decode Presto::Client::ModelVersions::V316::OutputBufferInfo=Base.new(:type,:state,:can_add_buffers,:can_add_pages,:total_buffered_bytes,:total_buffered_pages,:total_rows_sent,:total_pages_sent,:buffers)
-
decode Presto::Client::ModelVersions::V316::OutputNode=Base.new(:id,:source,:columns,:outputs)
-
decode Presto::Client::ModelVersions::V316::OutputTableHandle=Base.new(:catalog_name,:transaction_handle,:connector_handle)
-
decode Presto::Client::ModelVersions::V316::PageBufferClientStatus=Base.new(:uri,:state,:last_update,:rows_received,:pages_received,:rows_rejected,:pages_rejected,:requests_scheduled,:requests_completed,:requests_failed,:http_request_state)
-
decode Presto::Client::ModelVersions::V316::PageBufferInfo=Base.new(:partition,:buffered_pages,:buffered_bytes,:rows_added,:pages_added)
-
decode Presto::Client::ModelVersions::V316::PartitionedOutputInfo=Base.new(:rows_added,:pages_added,:output_buffer_peak_memory_usage)
-
decode Presto::Client::ModelVersions::V316::Partitioning=Base.new(:handle,:arguments)
-
decode Presto::Client::ModelVersions::V316::PartitioningHandle=Base.new(:connector_id,:transaction_handle,:connector_handle)
-
decode Presto::Client::ModelVersions::V316::PartitioningScheme=Base.new(:partitioning,:output_layout,:hash_column,:replicate_nulls_and_any,:bucket_to_partition)
-
decode Presto::Client::ModelVersions::V316::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,: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)
-
decode Presto::Client::ModelVersions::V316::PlanCostEstimate=Base.new(:cpu_cost,:max_memory,:max_memory_when_outputting,:network_cost,:root_node_local_cost_estimate)
-
decode Presto::Client::ModelVersions::V316::PlanFragment=Base.new(:id,:root,:symbols,:partitioning,:partitioned_sources,:partitioning_scheme,:stage_execution_descriptor,:stats_and_costs,:json_representation)
-
decode Presto::Client::ModelVersions::V316::PlanNodeStatsEstimate=Base.new(:output_row_count,:symbol_statistics)
-
decode Presto::Client::ModelVersions::V316::PrestoWarning=Base.new(:warning_code,:message)
-
decode Presto::Client::ModelVersions::V316::ProjectNode=Base.new(:id,:source,:assignments)
-
decode Presto::Client::ModelVersions::V316::QueryError=Base.new(:message,:sql_state,:error_code,:error_name,:semantic_error_name,:error_type,:error_location,:failure_info)
-
decode Presto::Client::ModelVersions::V316::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,:complete_info,:resource_group_id,:final_query_info)
-
decode Presto::Client::ModelVersions::V316::QueryResults=Base.new(:id,:info_uri,:partial_cancel_uri,:next_uri,:columns,:data,:stats,:error,:warnings,:update_type,:update_count)
-
decode Presto::Client::ModelVersions::V316::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,:distributed_planning_time,:total_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_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,: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,:operator_summaries)
-
decode Presto::Client::ModelVersions::V316::RemoteSourceNode=Base.new(:id,:source_fragment_ids,:outputs,:ordering_scheme,:exchange_type)
-
decode Presto::Client::ModelVersions::V0_205::ErrorLocation=Base.new(:line_number,:column_number)
-
decode Presto::Client::ModelVersions::V0_178::WindowNode=Base.new(:id,:source,:specification,:window_functions,:hash_symbol,:pre_partitioned_inputs,:pre_sorted_order_prefix)
-
decode Presto::Client::ModelVersions::V316::SampleNode=Base.new(:id,:source,:sample_ratio,:sample_type)
-
decode Presto::Client::ModelVersions::V316::SchemaTableName=Base.new(:schema,:table)
-
decode Presto::Client::ModelVersions::V316::SelectedRole=Base.new(:type,:role)
-
decode Presto::Client::ModelVersions::V316::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)
-
decode Presto::Client::ModelVersions::V316::SessionRepresentation=Base.new(:query_id,:transaction_id,:client_transaction_support,:user,: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_time,:system_properties,:catalog_properties,:unprocessed_catalog_properties,:roles,:prepared_statements)
-
decode Presto::Client::ModelVersions::V316::Signature=Base.new(:name,:kind,:type_variable_constraints,:long_variable_constraints,:return_type,:argument_types,:variable_arity)
-
decode Presto::Client::ModelVersions::V316::SortNode=Base.new(:id,:source,:ordering_scheme,:partial)
-
decode Presto::Client::ModelVersions::V316::Specification=Base.new(:partition_by,:ordering_scheme)
-
decode Presto::Client::ModelVersions::V316::SplitOperatorInfo=Base.new(:split_info)
-
decode Presto::Client::ModelVersions::V316::SqlPath=Base.new(:raw_path)
-
decode Presto::Client::ModelVersions::V316::StageExecutionDescriptor=Base.new(:strategy,:grouped_execution_scan_nodes)
-
decode Presto::Client::ModelVersions::V316::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)
-
decode Presto::Client::ModelVersions::V316::StageInfo=Base.new(:stage_id,:state,:self,:plan,:types,:stage_stats,:tasks,:sub_stages,:tables,:failure_cause)
-
decode Presto::Client::ModelVersions::V316::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,: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)
-
decode Presto::Client::ModelVersions::V316::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,:peak_memory_bytes,:spilled_bytes,:root_stage)
-
decode Presto::Client::ModelVersions::V316::StatisticAggregations=Base.new(:aggregations,:grouping_symbols)
-
decode Presto::Client::ModelVersions::V316::StatisticAggregationsDescriptor_Symbol=Base.new(:grouping,:table_statistics,:column_statistics)
-
decode Presto::Client::ModelVersions::V316::StatisticsWriterNode=Base.new(:id,:source,:target,:row_count_symbol,:row_count_enabled,:descriptor)
-
decode Presto::Client::ModelVersions::V316::StatsAndCosts=Base.new(:stats,:costs)
-
decode Presto::Client::ModelVersions::V316::SymbolStatsEstimate=Base.new(:low_value,:high_value,:nulls_fraction,:average_row_size,:distinct_values_count)
-
decode Presto::Client::ModelVersions::V316::TableFinishInfo=Base.new(:connector_output_metadata,:json_length_limit_exceeded,:statistics_wall_time,:statistics_cpu_time)
-
decode Presto::Client::ModelVersions::V316::TableFinishNode=Base.new(:id,:source,:target,:row_count_symbol,:statistics_aggregation,:statistics_aggregation_descriptor)
-
decode Presto::Client::ModelVersions::V316::TableHandle=Base.new(:catalog_name,:connector_handle,:transaction,:layout)
-
decode Presto::Client::ModelVersions::V316::TableInfo=Base.new(:table_name,:predicate)
-
decode Presto::Client::ModelVersions::V316::TableScanNode=Base.new(:id,:table,:output_symbols,:assignments)
-
decode Presto::Client::ModelVersions::V316::TableWriterInfo=Base.new(:page_sink_peak_memory_usage,:statistics_wall_time,:statistics_cpu_time,:validation_cpu_time)
-
decode Presto::Client::ModelVersions::V316::TableWriterNode=Base.new(:id,:source,:target,:row_count_symbol,:fragment_symbol,:columns,:column_names,:partitioning_scheme,:statistics_aggregation,:statistics_aggregation_descriptor)
-
decode Presto::Client::ModelVersions::V316::TaskInfo=Base.new(:task_status,:last_heartbeat,:output_buffers,:no_more_splits,:stats,:needs_plan)
-
decode Presto::Client::ModelVersions::V316::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,: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)
-
decode Presto::Client::ModelVersions::V316::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)
-
decode Presto::Client::ModelVersions::V316::TopNNode=Base.new(:id,:source,:count,:ordering_scheme,:step)
-
decode Presto::Client::ModelVersions::V316::TopNRowNumberNode=Base.new(:id,:source,:specification,:row_number_symbol,:max_row_count_per_partition,:partial,:hash_symbol)
-
decode Presto::Client::ModelVersions::V316::TypeVariableConstraint=Base.new(:name,:comparable_required,:orderable_required,:variadic_bound)
-
decode Presto::Client::ModelVersions::V316::UnionNode=Base.new(:id,:sources,:output_to_inputs,:outputs)
-
decode Presto::Client::ModelVersions::V316::UnnestNode=Base.new(:id,:source,:replicate_symbols,:unnest_symbols,:ordinality_symbol)
-
decode Presto::Client::ModelVersions::V316::ValuesNode=Base.new(:id,:output_symbols,:rows)
-
decode Presto::Client::ModelVersions::V316::Warning=Base.new(:warning_code,:message)
-
decode Presto::Client::ModelVersions::V316::WarningCode=Base.new(:code,:name)
-
decode Presto::Client::ModelVersions::V316::WindowInfo=Base.new(:window_infos)
-
decode Presto::Client::ModelVersions::V316::WindowNode=Base.new(:id,:source,:specification,:window_functions,:hash_symbol,:pre_partitioned_inputs,:pre_sorted_order_prefix)
-
decode Presto::Client::ModelVersions::V316::WriteStatisticsHandle=Base.new(:handle)
-
decode Presto::Client::ModelVersions::V0_149::DeleteNode=Base.new(:id,:source,:target,:row_id,:outputs)
-
decode Presto::Client::ModelVersions::V0_149::DeleteHandle=Base.new(:handle)
-
decode Presto::Client::ModelVersions::V0_149::Signature=Base.new(:name,:kind,:type_variable_constraints,:long_variable_constraints,:return_type,:argument_types,:variable_arity)
-
decode Presto::Client::ModelVersions::V0_153::OperatorStats=Base.new(:operator_id,:plan_node_id,:operator_type,:add_input_calls,:add_input_wall,:add_input_cpu,:add_input_user,:input_data_size,:input_positions,:get_output_calls,:get_output_wall,:get_output_cpu,:get_output_user,:output_data_size,:output_positions,:blocked_wall,:finish_calls,:finish_wall,:finish_cpu,:finish_user,:memory_reservation,:system_memory_reservation,:blocked_reason,:info)
-
decode Presto::Client::ModelVersions::V0_205::SessionRepresentation=Base.new(:query_id,:transaction_id,:client_transaction_support,:user,:principal,:source,:catalog,:schema,:trace_token,:time_zone_key,:locale,:remote_user_address,:user_agent,:client_info,:client_tags,:resource_estimates,:start_time,:system_properties,:catalog_properties,:prepared_statements)
-
decode Presto::Client::ModelVersions::V0_149::Column=Base.new(:name,:type)
-
decode Presto::Client::ModelVersions::V0_205::WindowInfo=Base.new(:window_infos)
-
decode Presto::Client::ModelVersions::V0_205::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_user_time,:total_blocked_time,:fully_blocked,:blocked_reasons,: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)
-
decode Presto::Client::ModelVersions::V0_205::OutputBufferInfo=Base.new(:type,:state,:can_add_buffers,:can_add_pages,:total_buffered_bytes,:total_buffered_pages,:total_rows_sent,:total_pages_sent,:buffers)
-
decode Presto::Client::ModelVersions::V0_149::DistributionSnapshot=Base.new(:max_error,:count,:total,:p01,:p05,:p10,:p25,:p50,:p75,:p90,:p95,:p99,:min,:max)
-
decode Presto::Client::ModelVersions::V0_149::PlanNode
-
decode Presto::Client::ModelVersions::V0_149::WriterTarget=Base.new(:type,:handle)
-
decode Presto::Client::ModelVersions::V0_149::EquiJoinClause=Base.new(:left,:right,:probe,:index)
-
decode Presto::Client::ModelVersions::V0_205::SortNode=Base.new(:id,:source,:ordering_scheme)
-
decode Presto::Client::ModelVersions::V0_205::EnforceSingleRowNode=Base.new(:id,:source)
-
decode Presto::Client::ModelVersions::V0_149::Specification=Base.new(:partition_by,:order_by,:orderings,:frame,:pages_added)
-
decode Presto::Client::ModelVersions::V0_149::ArgumentBinding=Base.new(:column,:constant)
-
decode Presto::Client::ModelVersions::V0_149::AggregationNode=Base.new(:id,:source,:group_by,:aggregations,:functions,:masks,:grouping_sets,:step,:sample_weight,:confidence,:hash_symbol)
-
decode Presto::Client::ModelVersions::V0_149::ApplyNode=Base.new(:id,:input,:subquery,:correlation)
-
decode Presto::Client::ModelVersions::V0_149::BufferInfo=Base.new(:buffer_id,:finished,:buffered_pages,:pages_sent,:page_buffer_info)
-
decode Presto::Client::ModelVersions::V0_149::ClientColumn=Base.new(:name,:type,:type_signature)
-
decode Presto::Client::ModelVersions::V0_149::ClientStageStats=Base.new(:stage_id,:state,:done,:nodes,:total_splits,:queued_splits,:running_splits,:completed_splits,:user_time_millis,:cpu_time_millis,:wall_time_millis,:processed_rows,:processed_bytes,:sub_stages)
-
decode Presto::Client::ModelVersions::V0_149::ClientTypeSignature=Base.new(:raw_type,:type_arguments,:literal_arguments,:arguments)
-
decode Presto::Client::ModelVersions::V0_149::ClientTypeSignatureParameter=Base.new(:kind,:value)
-
decode Presto::Client::ModelVersions::V0_205::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_user_time,:total_blocked_time,:fully_blocked,:blocked_reasons,: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)
-
decode Presto::Client::ModelVersions::V0_205::Column=Base.new(:name,:type)
-
decode Presto::Client::ModelVersions::V0_149::DistinctLimitNode=Base.new(:id,:source,:limit,:partial,:hash_symbol)
-
decode Presto::Client::ModelVersions::V0_149::DriverStats=Base.new(:create_time,:start_time,:end_time,:queued_time,:elapsed_time,:memory_reservation,:system_memory_reservation,:total_scheduled_time,:total_cpu_time,:total_user_time,:total_blocked_time,:fully_blocked,:blocked_reasons,:raw_input_data_size,:raw_input_positions,:raw_input_read_time,:processed_input_data_size,:processed_input_positions,:output_data_size,:output_positions,:operator_stats)
-
decode Presto::Client::ModelVersions::V0_149::EnforceSingleRowNode=Base.new(:id,:source)
-
decode Presto::Client::ModelVersions::V0_149::ErrorCode=Base.new(:code,:name)
-
decode Presto::Client::ModelVersions::V0_149::ErrorLocation=Base.new(:line_number,:column_number)
-
decode Presto::Client::ModelVersions::V0_149::ExchangeNode=Base.new(:id,:type,:scope,:partitioning_scheme,:sources,:inputs)
-
decode Presto::Client::ModelVersions::V0_149::ExecutionFailureInfo=Base.new(:type,:message,:cause,:suppressed,:stack,:error_location,:error_code)
-
decode Presto::Client::ModelVersions::V0_149::ExplainAnalyzeNode=Base.new(:id,:source,:output_symbol)
-
decode Presto::Client::ModelVersions::V0_149::FailureInfo=Base.new(:type,:message,:cause,:suppressed,:stack,:error_location)
-
decode Presto::Client::ModelVersions::V0_149::FilterNode=Base.new(:id,:source,:predicate)
-
decode Presto::Client::ModelVersions::V0_149::GroupIdNode=Base.new(:id,:source,:grouping_sets,:identity_mappings,:group_id_symbol)
-
decode Presto::Client::ModelVersions::V0_149::IndexHandle=Base.new(:connector_id,:transaction_handle,:connector_handle)
-
decode Presto::Client::ModelVersions::V0_149::IndexJoinNode=Base.new(:id,:type,:probe_source,:index_source,:criteria,:probe_hash_symbol,:index_hash_symbol)
-
decode Presto::Client::ModelVersions::V0_149::IndexSourceNode=Base.new(:id,:index_handle,:table_handle,:lookup_symbols,:output_symbols,:assignments,:effective_tuple_domain)
-
decode Presto::Client::ModelVersions::V0_149::Input=Base.new(:connector_id,:schema,:table,:columns)
-
decode Presto::Client::ModelVersions::V0_149::InsertTableHandle=Base.new(:connector_id,:transaction_handle,:connector_handle)
-
decode Presto::Client::ModelVersions::V0_149::JoinNode=Base.new(:id,:type,:left,:right,:criteria,:filter,:left_hash_symbol,:right_hash_symbol)
-
decode Presto::Client::ModelVersions::V0_149::LimitNode=Base.new(:id,:source,:count,:partial)
-
decode Presto::Client::ModelVersions::V0_149::LongVariableConstraint=Base.new(:name,:expression)
-
decode Presto::Client::ModelVersions::V0_149::MarkDistinctNode=Base.new(:id,:source,:marker_symbol,:distinct_symbols,:hash_symbol)
-
decode Presto::Client::ModelVersions::V0_149::MetadataDeleteNode=Base.new(:id,:target,:output,:table_layout)
-
decode Presto::Client::ModelVersions::V0_149::OperatorStats=Base.new(:operator_id,:plan_node_id,:operator_type,:add_input_calls,:add_input_wall,:add_input_cpu,:add_input_user,:input_data_size,:input_positions,:get_output_calls,:get_output_wall,:get_output_cpu,:get_output_user,:output_data_size,:output_positions,:blocked_wall,:finish_calls,:finish_wall,:finish_cpu,:finish_user,:memory_reservation,:system_memory_reservation,:blocked_reason,:info)
-
decode Presto::Client::ModelVersions::V0_149::OutputNode=Base.new(:id,:source,:columns,:outputs)
-
decode Presto::Client::ModelVersions::V0_149::OutputTableHandle=Base.new(:connector_id,:transaction_handle,:connector_handle)
-
decode Presto::Client::ModelVersions::V0_149::PageBufferInfo=Base.new(:partition,:buffered_pages,:buffered_bytes,:rows_added,:pages_added)
-
decode Presto::Client::ModelVersions::V0_149::Partitioning=Base.new(:handle,:arguments)
-
decode Presto::Client::ModelVersions::V0_149::PartitioningHandle=Base.new(:connector_id,:transaction_handle,:connector_handle)
-
decode Presto::Client::ModelVersions::V0_149::PartitioningScheme=Base.new(:partitioning,:output_layout,:hash_column,:replicate_nulls,:bucket_to_partition)
-
decode Presto::Client::ModelVersions::V0_149::PipelineStats=Base.new(: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,:completed_drivers,:memory_reservation,:system_memory_reservation,:queued_time,:elapsed_time,:total_scheduled_time,:total_cpu_time,:total_user_time,:total_blocked_time,:fully_blocked,:blocked_reasons,:raw_input_data_size,:raw_input_positions,:processed_input_data_size,:processed_input_positions,:output_data_size,:output_positions,:operator_summaries,:drivers)
-
decode Presto::Client::ModelVersions::V0_149::PlanFragment=Base.new(:id,:root,:symbols,:partitioning,:partitioned_sources,:partitioning_scheme)
-
decode Presto::Client::ModelVersions::V0_149::ProjectNode=Base.new(:id,:source,:assignments)
-
decode Presto::Client::ModelVersions::V0_149::QueryError=Base.new(:message,:sql_state,:error_code,:error_name,:error_type,:error_location,:failure_info)
-
decode Presto::Client::ModelVersions::V0_149::QueryInfo=Base.new(:query_id,:session,:state,:memory_pool,:scheduled,:self,:field_names,:query,:query_stats,:set_session_properties,:reset_session_properties,:added_prepared_statements,:deallocated_prepared_statements,:started_transaction_id,:clear_transaction_id,:update_type,:output_stage,:failure_info,:error_code,:inputs)
-
decode Presto::Client::ModelVersions::V0_149::QueryResults=Base.new(:id,:info_uri,:partial_cancel_uri,:next_uri,:columns,:data,:stats,:error,:update_type,:update_count)
-
decode Presto::Client::ModelVersions::V0_149::QueryStats=Base.new(:create_time,:execution_start_time,:last_heartbeat,:end_time,:elapsed_time,:queued_time,:analysis_time,:distributed_planning_time,:total_planning_time,:finishing_time,:total_tasks,:running_tasks,:completed_tasks,:total_drivers,:queued_drivers,:running_drivers,:completed_drivers,:cumulative_memory,:total_memory_reservation,:peak_memory_reservation,:total_scheduled_time,:total_cpu_time,:total_user_time,:total_blocked_time,:fully_blocked,:blocked_reasons,:raw_input_data_size,:raw_input_positions,:processed_input_data_size,:processed_input_positions,:output_data_size,:output_positions)
-
decode Presto::Client::ModelVersions::V0_149::RemoteSourceNode=Base.new(:id,:source_fragment_ids,:outputs)
-
decode Presto::Client::ModelVersions::V0_149::RowNumberNode=Base.new(:id,:source,:partition_by,:row_number_symbol,:max_row_count_per_partition,:hash_symbol)
-
decode Presto::Client::ModelVersions::V0_149::SampleNode=Base.new(:id,:source,:sample_ratio,:sample_type,:rescaled,:sample_weight_symbol)
-
decode Presto::Client::ModelVersions::V0_149::SemiJoinNode=Base.new(:id,:source,:filtering_source,:source_join_symbol,:filtering_source_join_symbol,:semi_join_output,:source_hash_symbol,:filtering_source_hash_symbol)
-
decode Presto::Client::ModelVersions::V0_149::SessionRepresentation=Base.new(:query_id,:transaction_id,:client_transaction_support,:user,:principal,:source,:catalog,:schema,:time_zone_key,:locale,:remote_user_address,:user_agent,:start_time,:system_properties,:catalog_properties,:prepared_statements)
-
decode Presto::Client::ModelVersions::V0_149::SharedBufferInfo=Base.new(:state,:can_add_buffers,:can_add_pages,:total_buffered_bytes,:total_buffered_pages,:total_rows_sent,:total_pages_sent,:buffers)
-
decode Presto::Client::ModelVersions::V0_205::ApplyNode=Base.new(:id,:input,:subquery,:subquery_assignments,:correlation,:origin_subquery)
-
decode Presto::Client::ModelVersions::V0_149::SortNode=Base.new(:id,:source,:order_by,:orderings)
-
decode Presto::Client::ModelVersions::V0_149::StageInfo=Base.new(:stage_id,:state,:self,:plan,:types,:stage_stats,:tasks,:sub_stages,:failure_cause)
-
decode Presto::Client::ModelVersions::V0_149::StageStats=Base.new(:scheduling_complete,:get_split_distribution,:schedule_task_distribution,:add_split_distribution,:total_tasks,:running_tasks,:completed_tasks,:total_drivers,:queued_drivers,:running_drivers,:completed_drivers,:cumulative_memory,:total_memory_reservation,:peak_memory_reservation,:total_scheduled_time,:total_cpu_time,:total_user_time,:total_blocked_time,:fully_blocked,:blocked_reasons,:raw_input_data_size,:raw_input_positions,:processed_input_data_size,:processed_input_positions,:output_data_size,:output_positions)
-
decode Presto::Client::ModelVersions::V0_149::StatementStats=Base.new(:state,:queued,:scheduled,:nodes,:total_splits,:queued_splits,:running_splits,:completed_splits,:user_time_millis,:cpu_time_millis,:wall_time_millis,:processed_rows,:processed_bytes,:root_stage)
-
decode Presto::Client::ModelVersions::V0_149::TableFinishNode=Base.new(:id,:source,:target,:outputs)
-
decode Presto::Client::ModelVersions::V0_149::TableHandle=Base.new(:connector_id,:connector_handle)
-
decode Presto::Client::ModelVersions::V0_149::TableLayoutHandle=Base.new(:connector_id,:transaction_handle,:connector_handle)
-
decode Presto::Client::ModelVersions::V0_149::TableScanNode=Base.new(:id,:table,:output_symbols,:assignments,:layout,:current_constraint,:original_constraint)
-
decode Presto::Client::ModelVersions::V0_149::TableWriterNode=Base.new(:id,:source,:target,:columns,:column_names,:outputs,:sample_weight_symbol,:partitioning_scheme)
-
decode Presto::Client::ModelVersions::V0_149::TaskInfo=Base.new(:task_status,:last_heartbeat,:output_buffers,:no_more_splits,:stats,:needs_plan)
-
decode Presto::Client::ModelVersions::V0_149::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,:completed_drivers,:cumulative_memory,:memory_reservation,:system_memory_reservation,:total_scheduled_time,:total_cpu_time,:total_user_time,:total_blocked_time,:fully_blocked,:blocked_reasons,:raw_input_data_size,:raw_input_positions,:processed_input_data_size,:processed_input_positions,:output_data_size,:output_positions,:pipelines)
-
decode Presto::Client::ModelVersions::V0_149::TaskStatus=Base.new(:task_id,:task_instance_id,:version,:state,:self,:failures,:queued_partitioned_drivers,:running_partitioned_drivers,:memory_reservation)
-
decode Presto::Client::ModelVersions::V0_149::TopNNode=Base.new(:id,:source,:count,:order_by,:orderings,:partial)
-
decode Presto::Client::ModelVersions::V0_149::TopNRowNumberNode=Base.new(:id,:source,:partition_by,:order_by,:orderings,:row_number_symbol,:max_row_count_per_partition,:partial,:hash_symbol)
-
decode Presto::Client::ModelVersions::V0_149::TypeVariableConstraint=Base.new(:name,:comparable_required,:orderable_required,:variadic_bound)
-
decode Presto::Client::ModelVersions::V0_149::UnionNode=Base.new(:id,:sources,:output_to_inputs,:outputs)
-
decode Presto::Client::ModelVersions::V0_149::UnnestNode=Base.new(:id,:source,:replicate_symbols,:unnest_symbols,:ordinality_symbol)
-
decode Presto::Client::ModelVersions::V0_149::ValuesNode=Base.new(:id,:output_symbols,:rows)
-
decode Presto::Client::ModelVersions::V0_149::WindowNode=Base.new(:id,:source,:specification,:window_functions,:signatures,:hash_symbol,:pre_partitioned_inputs,:pre_sorted_order_prefix)
-
decode Presto::Client::ModelVersions::V0_205::Specification=Base.new(:partition_by,:ordering_scheme)
-
decode Presto::Client::ModelVersions::V0_205::Signature=Base.new(:name,:kind,:type_variable_constraints,:long_variable_constraints,:return_type,:argument_types,:variable_arity)
-
decode Presto::Client::ModelVersions::V0_153::MetadataDeleteNode=Base.new(:id,:target,:output,:table_layout)
-
decode Presto::Client::ModelVersions::V0_205::PartitioningScheme=Base.new(:partitioning,:output_layout,:hash_column,:replicate_nulls_and_any,:bucket_to_partition)
-
decode Presto::Client::ModelVersions::V0_205::OperatorStats=Base.new(:pipeline_id,:operator_id,:plan_node_id,:operator_type,:total_drivers,:add_input_calls,:add_input_wall,:add_input_cpu,:add_input_user,:input_data_size,:input_positions,:sum_squared_input_positions,:get_output_calls,:get_output_wall,:get_output_cpu,:get_output_user,:output_data_size,:output_positions,:physical_written_data_size,:blocked_wall,:finish_calls,:finish_wall,:finish_cpu,:finish_user,:user_memory_reservation,:revocable_memory_reservation,:system_memory_reservation,:blocked_reason,:info)
-
decode Presto::Client::ModelVersions::V0_205::DeleteHandle=Base.new(:handle,:schema_table_name)
-
decode Presto::Client::ModelVersions::V0_153::PlanNode
-
decode Presto::Client::ModelVersions::V0_153::DeleteHandle=Base.new(:handle)
-
decode Presto::Client::ModelVersions::V0_153::ClientStageStats=Base.new(:stage_id,:state,:done,:nodes,:total_splits,:queued_splits,:running_splits,:completed_splits,:user_time_millis,:cpu_time_millis,:wall_time_millis,:processed_rows,:processed_bytes,:sub_stages)
-
decode Presto::Client::ModelVersions::V0_153::ClientColumn=Base.new(:name,:type,:type_signature)
-
decode Presto::Client::ModelVersions::V0_205::TopNRowNumberNode=Base.new(:id,:source,:specification,:row_number_symbol,:max_row_count_per_partition,:partial,:hash_symbol)
-
decode Presto::Client::ModelVersions::V0_153::DistributionSnapshot=Base.new(:max_error,:count,:total,:p01,:p05,:p10,:p25,:p50,:p75,:p90,:p95,:p99,:min,:max)
-
decode Presto::Client::ModelVersions::V0_153::EquiJoinClause=Base.new(:left,:right,:probe,:index)
-
decode Presto::Client::ModelVersions::V0_153::WriterTarget=Base.new(:type,:handle)
-
decode Presto::Client::ModelVersions::V0_205::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)
-
decode Presto::Client::ModelVersions::V0_153::Specification=Base.new(:partition_by,:order_by,:orderings,:frame,:pages_added)
-
decode Presto::Client::ModelVersions::V0_153::ArgumentBinding=Base.new(:column,:constant)
-
decode Presto::Client::ModelVersions::V0_153::AggregationNode=Base.new(:id,:source,:aggregations,:functions,:masks,:grouping_sets,:step,:sample_weight,:confidence,:hash_symbol,:group_id_symbol)
-
decode Presto::Client::ModelVersions::V0_153::ApplyNode=Base.new(:id,:input,:subquery,:correlation)
-
decode Presto::Client::ModelVersions::V0_153::BufferInfo=Base.new(:buffer_id,:finished,:buffered_pages,:pages_sent,:page_buffer_info)
-
decode Presto::Client::ModelVersions::V0_205::DeleteNode=Base.new(:id,:source,:target,:row_id,:outputs)
-
decode Presto::Client::ModelVersions::V0_205::OperatorInfo
-
decode Presto::Client::ModelVersions::V0_153::ClientTypeSignature=Base.new(:raw_type,:type_arguments,:literal_arguments,:arguments)
-
decode Presto::Client::ModelVersions::V0_153::ClientTypeSignatureParameter=Base.new(:kind,:value)
-
decode Presto::Client::ModelVersions::V0_153::Column=Base.new(:name,:type)
-
decode Presto::Client::ModelVersions::V0_153::DeleteNode=Base.new(:id,:source,:target,:row_id,:outputs)
-
decode Presto::Client::ModelVersions::V0_153::DistinctLimitNode=Base.new(:id,:source,:limit,:partial,:hash_symbol)
-
decode Presto::Client::ModelVersions::V0_153::DriverStats=Base.new(:create_time,:start_time,:end_time,:queued_time,:elapsed_time,:memory_reservation,:system_memory_reservation,:total_scheduled_time,:total_cpu_time,:total_user_time,:total_blocked_time,:fully_blocked,:blocked_reasons,:raw_input_data_size,:raw_input_positions,:raw_input_read_time,:processed_input_data_size,:processed_input_positions,:output_data_size,:output_positions,:operator_stats)
-
decode Presto::Client::ModelVersions::V0_153::EnforceSingleRowNode=Base.new(:id,:source)
-
decode Presto::Client::ModelVersions::V0_153::ErrorCode=Base.new(:code,:name,:type)
-
decode Presto::Client::ModelVersions::V0_153::ErrorLocation=Base.new(:line_number,:column_number)
-
decode Presto::Client::ModelVersions::V0_153::ExchangeNode=Base.new(:id,:type,:scope,:partitioning_scheme,:sources,:inputs)
-
decode Presto::Client::ModelVersions::V0_153::ExecutionFailureInfo=Base.new(:type,:message,:cause,:suppressed,:stack,:error_location,:error_code)
-
decode Presto::Client::ModelVersions::V0_153::ExplainAnalyzeNode=Base.new(:id,:source,:output_symbol)
-
decode Presto::Client::ModelVersions::V0_153::FailureInfo=Base.new(:type,:message,:cause,:suppressed,:stack,:error_location)
-
decode Presto::Client::ModelVersions::V0_153::FilterNode=Base.new(:id,:source,:predicate)
-
decode Presto::Client::ModelVersions::V0_153::GroupIdNode=Base.new(:id,:source,:grouping_sets,:identity_mappings,:group_id_symbol)
-
decode Presto::Client::ModelVersions::V0_153::IndexHandle=Base.new(:connector_id,:transaction_handle,:connector_handle)
-
decode Presto::Client::ModelVersions::V0_153::IndexJoinNode=Base.new(:id,:type,:probe_source,:index_source,:criteria,:probe_hash_symbol,:index_hash_symbol)
-
decode Presto::Client::ModelVersions::V0_153::IndexSourceNode=Base.new(:id,:index_handle,:table_handle,:table_layout,:lookup_symbols,:output_symbols,:assignments,:effective_tuple_domain)
-
decode Presto::Client::ModelVersions::V0_153::Input=Base.new(:connector_id,:schema,:table,:connector_info,:columns)
-
decode Presto::Client::ModelVersions::V0_153::InsertTableHandle=Base.new(:connector_id,:transaction_handle,:connector_handle)
-
decode Presto::Client::ModelVersions::V0_153::IntersectNode=Base.new(:id,:sources,:output_to_inputs,:outputs)
-
decode Presto::Client::ModelVersions::V0_153::JoinNode=Base.new(:id,:type,:left,:right,:criteria,:filter,:left_hash_symbol,:right_hash_symbol)
-
decode Presto::Client::ModelVersions::V0_153::LimitNode=Base.new(:id,:source,:count,:partial)
-
decode Presto::Client::ModelVersions::V0_153::LongVariableConstraint=Base.new(:name,:expression)
-
decode Presto::Client::ModelVersions::V0_153::MarkDistinctNode=Base.new(:id,:source,:marker_symbol,:distinct_symbols,:hash_symbol)
-
decode Presto::Client::ModelVersions::V0_205::HashCollisionsInfo=Base.new(:weighted_hash_collisions,:weighted_sum_squared_hash_collisions,:weighted_expectedHash_collisions)
-
decode Presto::Client::ModelVersions::V0_205::EquiJoinClause=Base.new(:left,:right,:probe,:index)
-
decode Presto::Client::ModelVersions::V0_178::TopNNode=Base.new(:id,:source,:count,:order_by,:orderings,:step)
-
decode Presto::Client::ModelVersions::V0_153::OutputBufferInfo=Base.new(:type,:state,:can_add_buffers,:can_add_pages,:total_buffered_bytes,:total_buffered_pages,:total_rows_sent,:total_pages_sent,:buffers)
-
decode Presto::Client::ModelVersions::V0_153::OutputNode=Base.new(:id,:source,:columns,:outputs)
-
decode Presto::Client::ModelVersions::V0_153::OutputTableHandle=Base.new(:connector_id,:transaction_handle,:connector_handle)
-
decode Presto::Client::ModelVersions::V0_153::PageBufferInfo=Base.new(:partition,:buffered_pages,:buffered_bytes,:rows_added,:pages_added)
-
decode Presto::Client::ModelVersions::V0_153::Partitioning=Base.new(:handle,:arguments)
-
decode Presto::Client::ModelVersions::V0_153::PartitioningHandle=Base.new(:connector_id,:transaction_handle,:connector_handle)
-
decode Presto::Client::ModelVersions::V0_153::PartitioningScheme=Base.new(:partitioning,:output_layout,:hash_column,:replicate_nulls,:bucket_to_partition)
-
decode Presto::Client::ModelVersions::V0_153::PipelineStats=Base.new(: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,:completed_drivers,:memory_reservation,:system_memory_reservation,:queued_time,:elapsed_time,:total_scheduled_time,:total_cpu_time,:total_user_time,:total_blocked_time,:fully_blocked,:blocked_reasons,:raw_input_data_size,:raw_input_positions,:processed_input_data_size,:processed_input_positions,:output_data_size,:output_positions,:operator_summaries,:drivers)
-
decode Presto::Client::ModelVersions::V0_153::PlanFragment=Base.new(:id,:root,:symbols,:partitioning,:partitioned_sources,:partitioning_scheme)
-
decode Presto::Client::ModelVersions::V0_153::ProjectNode=Base.new(:id,:source,:assignments)
-
decode Presto::Client::ModelVersions::V0_153::QueryError=Base.new(:message,:sql_state,:error_code,:error_name,:error_type,:error_location,:failure_info)
-
decode Presto::Client::ModelVersions::V0_153::QueryInfo=Base.new(:query_id,:session,:state,:memory_pool,:scheduled,:self,:field_names,:query,:query_stats,:set_session_properties,:reset_session_properties,:added_prepared_statements,:deallocated_prepared_statements,:started_transaction_id,:clear_transaction_id,:update_type,:output_stage,:failure_info,:error_code,:inputs,:output,:complete_info)
-
decode Presto::Client::ModelVersions::V0_153::QueryResults=Base.new(:id,:info_uri,:partial_cancel_uri,:next_uri,:columns,:data,:stats,:error,:update_type,:update_count)
-
decode Presto::Client::ModelVersions::V0_153::QueryStats=Base.new(:create_time,:execution_start_time,:last_heartbeat,:end_time,:elapsed_time,:queued_time,:analysis_time,:distributed_planning_time,:total_planning_time,:finishing_time,:total_tasks,:running_tasks,:completed_tasks,:total_drivers,:queued_drivers,:running_drivers,:completed_drivers,:cumulative_memory,:total_memory_reservation,:peak_memory_reservation,:total_scheduled_time,:total_cpu_time,:total_user_time,:total_blocked_time,:fully_blocked,:blocked_reasons,:raw_input_data_size,:raw_input_positions,:processed_input_data_size,:processed_input_positions,:output_data_size,:output_positions)
-
decode Presto::Client::ModelVersions::V0_153::RemoteSourceNode=Base.new(:id,:source_fragment_ids,:outputs)
-
decode Presto::Client::ModelVersions::V0_153::RowNumberNode=Base.new(:id,:source,:partition_by,:row_number_symbol,:max_row_count_per_partition,:hash_symbol)
-
decode Presto::Client::ModelVersions::V0_153::SampleNode=Base.new(:id,:source,:sample_ratio,:sample_type,:rescaled,:sample_weight_symbol)
-
decode Presto::Client::ModelVersions::V0_153::SemiJoinNode=Base.new(:id,:source,:filtering_source,:source_join_symbol,:filtering_source_join_symbol,:semi_join_output,:source_hash_symbol,:filtering_source_hash_symbol)
-
decode Presto::Client::ModelVersions::V0_153::SessionRepresentation=Base.new(:query_id,:transaction_id,:client_transaction_support,:user,:principal,:source,:catalog,:schema,:time_zone_key,:locale,:remote_user_address,:user_agent,:start_time,:system_properties,:catalog_properties,:prepared_statements)
-
decode Presto::Client::ModelVersions::V0_153::Signature=Base.new(:name,:kind,:type_variable_constraints,:long_variable_constraints,:return_type,:argument_types,:variable_arity)
-
decode Presto::Client::ModelVersions::V0_153::SortNode=Base.new(:id,:source,:order_by,:orderings)
-
decode Presto::Client::ModelVersions::V0_153::StageInfo=Base.new(:stage_id,:state,:self,:plan,:types,:stage_stats,:tasks,:sub_stages,:failure_cause)
-
decode Presto::Client::ModelVersions::V0_153::StageStats=Base.new(:scheduling_complete,:get_split_distribution,:schedule_task_distribution,:add_split_distribution,:total_tasks,:running_tasks,:completed_tasks,:total_drivers,:queued_drivers,:running_drivers,:completed_drivers,:cumulative_memory,:total_memory_reservation,:peak_memory_reservation,:total_scheduled_time,:total_cpu_time,:total_user_time,:total_blocked_time,:fully_blocked,:blocked_reasons,:raw_input_data_size,:raw_input_positions,:processed_input_data_size,:processed_input_positions,:output_data_size,:output_positions)
-
decode Presto::Client::ModelVersions::V0_153::StatementStats=Base.new(:state,:queued,:scheduled,:nodes,:total_splits,:queued_splits,:running_splits,:completed_splits,:user_time_millis,:cpu_time_millis,:wall_time_millis,:processed_rows,:processed_bytes,:root_stage)
-
decode Presto::Client::ModelVersions::V0_153::TableFinishNode=Base.new(:id,:source,:target,:outputs)
-
decode Presto::Client::ModelVersions::V0_153::TableHandle=Base.new(:connector_id,:connector_handle)
-
decode Presto::Client::ModelVersions::V0_153::TableLayoutHandle=Base.new(:connector_id,:transaction_handle,:connector_handle)
-
decode Presto::Client::ModelVersions::V0_153::TableScanNode=Base.new(:id,:table,:output_symbols,:assignments,:layout,:current_constraint,:original_constraint)
-
decode Presto::Client::ModelVersions::V0_153::TableWriterNode=Base.new(:id,:source,:target,:columns,:column_names,:outputs,:sample_weight_symbol,:partitioning_scheme)
-
decode Presto::Client::ModelVersions::V0_153::TaskInfo=Base.new(:task_status,:last_heartbeat,:output_buffers,:no_more_splits,:stats,:needs_plan,:complete)
-
decode Presto::Client::ModelVersions::V0_153::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,:completed_drivers,:cumulative_memory,:memory_reservation,:system_memory_reservation,:total_scheduled_time,:total_cpu_time,:total_user_time,:total_blocked_time,:fully_blocked,:blocked_reasons,:raw_input_data_size,:raw_input_positions,:processed_input_data_size,:processed_input_positions,:output_data_size,:output_positions,:pipelines)
-
decode Presto::Client::ModelVersions::V0_153::TaskStatus=Base.new(:task_id,:task_instance_id,:version,:state,:self,:failures,:queued_partitioned_drivers,:running_partitioned_drivers,:memory_reservation)
-
decode Presto::Client::ModelVersions::V0_153::TopNNode=Base.new(:id,:source,:count,:order_by,:orderings,:partial)
-
decode Presto::Client::ModelVersions::V0_153::TopNRowNumberNode=Base.new(:id,:source,:specification,:row_number_symbol,:max_row_count_per_partition,:partial,:hash_symbol)
-
decode Presto::Client::ModelVersions::V0_153::TypeVariableConstraint=Base.new(:name,:comparable_required,:orderable_required,:variadic_bound)
-
decode Presto::Client::ModelVersions::V0_153::UnionNode=Base.new(:id,:sources,:output_to_inputs,:outputs)
-
decode Presto::Client::ModelVersions::V0_153::UnnestNode=Base.new(:id,:source,:replicate_symbols,:unnest_symbols,:ordinality_symbol)
-
decode Presto::Client::ModelVersions::V0_153::ValuesNode=Base.new(:id,:output_symbols,:rows)
-
decode Presto::Client::ModelVersions::V0_153::WindowNode=Base.new(:id,:source,:specification,:window_functions,:hash_symbol,:pre_partitioned_inputs,:pre_sorted_order_prefix)
-
decode Presto::Client::ModelVersions::V0_205::ValuesNode=Base.new(:id,:output_symbols,:rows)
-
decode Presto::Client::ModelVersions::V0_205::UnionNode=Base.new(:id,:sources,:output_to_inputs,:outputs)
-
decode Presto::Client::ModelVersions::V0_173::ArgumentBinding=Base.new(:column,:constant)
-
decode Presto::Client::ModelVersions::V0_173::DeleteNode=Base.new(:id,:source,:target,:row_id,:outputs)
-
decode Presto::Client::ModelVersions::V0_173::SortNode=Base.new(:id,:source,:order_by,:orderings)
-
decode Presto::Client::ModelVersions::V0_173::DistinctLimitNode=Base.new(:id,:source,:limit,:partial,:hash_symbol)
-
decode Presto::Client::ModelVersions::V0_205::SampleNode=Base.new(:id,:source,:sample_ratio,:sample_type)
-
decode Presto::Client::ModelVersions::V0_173::PlanNode
-
decode Presto::Client::ModelVersions::V0_178::IntersectNode=Base.new(:id,:sources,:output_to_inputs,:outputs)
-
decode Presto::Client::ModelVersions::V0_205::Partitioning=Base.new(:handle,:arguments)
-
decode Presto::Client::ModelVersions::V0_205::Output=Base.new(:connector_id,:schema,:table)
-
decode Presto::Client::ModelVersions::V0_173::DistributionSnapshot=Base.new(:max_error,:count,:total,:p01,:p05,:p10,:p25,:p50,:p75,:p90,:p95,:p99,:min,:max)
-
decode Presto::Client::ModelVersions::V0_173::EquiJoinClause=Base.new(:left,:right,:probe,:index)
-
decode Presto::Client::ModelVersions::V0_173::WriterTarget=Base.new(:type,:handle)
-
decode Presto::Client::ModelVersions::V0_173::DeleteHandle=Base.new(:handle)
-
decode Presto::Client::ModelVersions::V0_173::Specification=Base.new(:partition_by,:order_by,:orderings,:frame,:pages_added)
-
decode Presto::Client::ModelVersions::V0_205::MetadataDeleteNode=Base.new(:id,:target,:output,:table_layout)
-
decode Presto::Client::ModelVersions::V0_173::AggregationNode=Base.new(:id,:source,:assignments,:grouping_sets,:step,:hash_symbol,:group_id_symbol)
-
decode Presto::Client::ModelVersions::V0_173::ApplyNode=Base.new(:id,:input,:subquery,:subquery_assignments,:correlation)
-
decode Presto::Client::ModelVersions::V0_173::Assignments=Base.new(:assignments)
-
decode Presto::Client::ModelVersions::V0_173::BufferInfo=Base.new(:buffer_id,:finished,:buffered_pages,:pages_sent,:page_buffer_info)
-
decode Presto::Client::ModelVersions::V0_173::ClientColumn=Base.new(:name,:type,:type_signature)
-
decode Presto::Client::ModelVersions::V0_173::ClientStageStats=Base.new(:stage_id,:state,:done,:nodes,:total_splits,:queued_splits,:running_splits,:completed_splits,:user_time_millis,:cpu_time_millis,:wall_time_millis,:processed_rows,:processed_bytes,:sub_stages)
-
decode Presto::Client::ModelVersions::V0_173::ClientTypeSignature=Base.new(:raw_type,:type_arguments,:literal_arguments,:arguments)
-
decode Presto::Client::ModelVersions::V0_173::ClientTypeSignatureParameter=Base.new(:kind,:value)
-
decode Presto::Client::ModelVersions::V0_173::Column=Base.new(:name,:type)
-
decode Presto::Client::ModelVersions::V0_205::IntersectNode=Base.new(:id,:sources,:output_to_inputs,:outputs)
-
decode Presto::Client::ModelVersions::V0_205::AssignUniqueId=Base.new(:id,:source,:id_column)
-
decode Presto::Client::ModelVersions::V0_173::DriverStats=Base.new(:create_time,:start_time,:end_time,:queued_time,:elapsed_time,:memory_reservation,:peak_memory_reservation,:system_memory_reservation,:total_scheduled_time,:total_cpu_time,:total_user_time,:total_blocked_time,:fully_blocked,:blocked_reasons,:raw_input_data_size,:raw_input_positions,:raw_input_read_time,:processed_input_data_size,:processed_input_positions,:output_data_size,:output_positions,:operator_stats)
-
decode Presto::Client::ModelVersions::V0_173::EnforceSingleRowNode=Base.new(:id,:source)
-
decode Presto::Client::ModelVersions::V0_173::ErrorCode=Base.new(:code,:name,:type)
-
decode Presto::Client::ModelVersions::V0_173::ErrorLocation=Base.new(:line_number,:column_number)
-
decode Presto::Client::ModelVersions::V0_173::ExchangeNode=Base.new(:id,:type,:scope,:partitioning_scheme,:sources,:inputs)
-
decode Presto::Client::ModelVersions::V0_173::ExecutionFailureInfo=Base.new(:type,:message,:cause,:suppressed,:stack,:error_location,:error_code)
-
decode Presto::Client::ModelVersions::V0_173::ExplainAnalyzeNode=Base.new(:id,:source,:output_symbol)
-
decode Presto::Client::ModelVersions::V0_173::FailureInfo=Base.new(:type,:message,:cause,:suppressed,:stack,:error_location)
-
decode Presto::Client::ModelVersions::V0_173::FilterNode=Base.new(:id,:source,:predicate)
-
decode Presto::Client::ModelVersions::V0_173::GroupIdNode=Base.new(:id,:source,:grouping_sets,:grouping_set_mappings,:argument_mappings,:group_id_symbol)
-
decode Presto::Client::ModelVersions::V0_173::IndexHandle=Base.new(:connector_id,:transaction_handle,:connector_handle)
-
decode Presto::Client::ModelVersions::V0_173::IndexJoinNode=Base.new(:id,:type,:probe_source,:index_source,:criteria,:probe_hash_symbol,:index_hash_symbol)
-
decode Presto::Client::ModelVersions::V0_173::IndexSourceNode=Base.new(:id,:index_handle,:table_handle,:table_layout,:lookup_symbols,:output_symbols,:assignments,:effective_tuple_domain)
-
decode Presto::Client::ModelVersions::V0_173::Input=Base.new(:connector_id,:schema,:table,:connector_info,:columns)
-
decode Presto::Client::ModelVersions::V0_173::InsertTableHandle=Base.new(:connector_id,:transaction_handle,:connector_handle)
-
decode Presto::Client::ModelVersions::V0_173::IntersectNode=Base.new(:id,:sources,:output_to_inputs,:outputs)
-
decode Presto::Client::ModelVersions::V0_173::JoinNode=Base.new(:id,:type,:left,:right,:criteria,:output_symbols,:filter,:left_hash_symbol,:right_hash_symbol,:distribution_type)
-
decode Presto::Client::ModelVersions::V0_173::LimitNode=Base.new(:id,:source,:count,:partial)
-
decode Presto::Client::ModelVersions::V0_173::MarkDistinctNode=Base.new(:id,:source,:marker_symbol,:distinct_symbols,:hash_symbol)
-
decode Presto::Client::ModelVersions::V0_173::MetadataDeleteNode=Base.new(:id,:target,:output,:table_layout)
-
decode Presto::Client::ModelVersions::V0_173::OperatorStats=Base.new(:pipeline_id,:operator_id,:plan_node_id,:operator_type,:total_drivers,:add_input_calls,:add_input_wall,:add_input_cpu,:add_input_user,:input_data_size,:input_positions,:sum_squared_input_positions,:get_output_calls,:get_output_wall,:get_output_cpu,:get_output_user,:output_data_size,:output_positions,:blocked_wall,:finish_calls,:finish_wall,:finish_cpu,:finish_user,:memory_reservation,:system_memory_reservation,:blocked_reason,:info)
-
decode Presto::Client::ModelVersions::V0_173::Output=Base.new(:connector_id,:schema,:table)
-
decode Presto::Client::ModelVersions::V0_173::OutputBufferInfo=Base.new(:type,:state,:can_add_buffers,:can_add_pages,:total_buffered_bytes,:total_buffered_pages,:total_rows_sent,:total_pages_sent,:buffers)
-
decode Presto::Client::ModelVersions::V0_173::OutputNode=Base.new(:id,:source,:columns,:outputs)
-
decode Presto::Client::ModelVersions::V0_173::OutputTableHandle=Base.new(:connector_id,:transaction_handle,:connector_handle)
-
decode Presto::Client::ModelVersions::V0_173::PageBufferInfo=Base.new(:partition,:buffered_pages,:buffered_bytes,:rows_added,:pages_added)
-
decode Presto::Client::ModelVersions::V0_173::Partitioning=Base.new(:handle,:arguments)
-
decode Presto::Client::ModelVersions::V0_173::PartitioningHandle=Base.new(:connector_id,:transaction_handle,:connector_handle)
-
decode Presto::Client::ModelVersions::V0_173::PartitioningScheme=Base.new(:partitioning,:output_layout,:hash_column,:replicate_nulls,:bucket_to_partition)
-
decode Presto::Client::ModelVersions::V0_173::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,:completed_drivers,:memory_reservation,:system_memory_reservation,:queued_time,:elapsed_time,:total_scheduled_time,:total_cpu_time,:total_user_time,:total_blocked_time,:fully_blocked,:blocked_reasons,:raw_input_data_size,:raw_input_positions,:processed_input_data_size,:processed_input_positions,:output_data_size,:output_positions,:operator_summaries,:drivers)
-
decode Presto::Client::ModelVersions::V0_173::PlanFragment=Base.new(:id,:root,:symbols,:partitioning,:partitioned_sources,:partitioning_scheme)
-
decode Presto::Client::ModelVersions::V0_173::ProjectNode=Base.new(:id,:source,:assignments)
-
decode Presto::Client::ModelVersions::V0_173::QueryError=Base.new(:message,:sql_state,:error_code,:error_name,:error_type,:error_location,:failure_info)
-
decode Presto::Client::ModelVersions::V0_173::QueryInfo=Base.new(:query_id,:session,:state,:memory_pool,:scheduled,:self,:field_names,:query,:query_stats,:set_session_properties,:reset_session_properties,:added_prepared_statements,:deallocated_prepared_statements,:started_transaction_id,:clear_transaction_id,:update_type,:output_stage,:failure_info,:error_code,:inputs,:output,:complete_info,:resource_group_name)
-
decode Presto::Client::ModelVersions::V0_173::QueryResults=Base.new(:id,:info_uri,:partial_cancel_uri,:next_uri,:columns,:data,:stats,:error,:update_type,:update_count)
-
decode Presto::Client::ModelVersions::V0_173::QueryStats=Base.new(:create_time,:execution_start_time,:last_heartbeat,:end_time,:elapsed_time,:queued_time,:analysis_time,:distributed_planning_time,:total_planning_time,:finishing_time,:total_tasks,:running_tasks,:completed_tasks,:total_drivers,:queued_drivers,:running_drivers,:completed_drivers,:cumulative_memory,:total_memory_reservation,:peak_memory_reservation,:scheduled,:total_scheduled_time,:total_cpu_time,:total_user_time,:total_blocked_time,:fully_blocked,:blocked_reasons,:raw_input_data_size,:raw_input_positions,:processed_input_data_size,:processed_input_positions,:output_data_size,:output_positions,:operator_summaries)
-
decode Presto::Client::ModelVersions::V0_173::RemoteSourceNode=Base.new(:id,:source_fragment_ids,:outputs)
-
decode Presto::Client::ModelVersions::V0_173::RowNumberNode=Base.new(:id,:source,:partition_by,:row_number_symbol,:max_row_count_per_partition,:hash_symbol)
-
decode Presto::Client::ModelVersions::V0_173::SampleNode=Base.new(:id,:source,:sample_ratio,:sample_type)
-
decode Presto::Client::ModelVersions::V0_173::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)
-
decode Presto::Client::ModelVersions::V0_173::SessionRepresentation=Base.new(:query_id,:transaction_id,:client_transaction_support,:user,:principal,:source,:catalog,:schema,:time_zone_key,:locale,:remote_user_address,:user_agent,:client_info,:start_time,:system_properties,:catalog_properties,:prepared_statements)
-
decode Presto::Client::ModelVersions::V0_205::ClientStageStats=Base.new(:stage_id,:state,:done,:nodes,:total_splits,:queued_splits,:running_splits,:completed_splits,:user_time_millis,:cpu_time_millis,:wall_time_millis,:processed_rows,:processed_bytes,:sub_stages)
-
decode Presto::Client::ModelVersions::V0_173::StageInfo=Base.new(:stage_id,:state,:self,:plan,:types,:stage_stats,:tasks,:sub_stages,:failure_cause)
-
decode Presto::Client::ModelVersions::V0_173::StageStats=Base.new(:scheduling_complete,:get_split_distribution,:schedule_task_distribution,:add_split_distribution,:total_tasks,:running_tasks,:completed_tasks,:total_drivers,:queued_drivers,:running_drivers,:completed_drivers,:cumulative_memory,:total_memory_reservation,:peak_memory_reservation,:total_scheduled_time,:total_cpu_time,:total_user_time,:total_blocked_time,:fully_blocked,:blocked_reasons,:raw_input_data_size,:raw_input_positions,:processed_input_data_size,:processed_input_positions,:output_data_size,:output_positions,:operator_summaries)
-
decode Presto::Client::ModelVersions::V0_173::StatementStats=Base.new(:state,:queued,:scheduled,:nodes,:total_splits,:queued_splits,:running_splits,:completed_splits,:user_time_millis,:cpu_time_millis,:wall_time_millis,:processed_rows,:processed_bytes,:root_stage)
-
decode Presto::Client::ModelVersions::V0_173::TableFinishNode=Base.new(:id,:source,:target,:outputs)
-
decode Presto::Client::ModelVersions::V0_173::TableHandle=Base.new(:connector_id,:connector_handle)
-
decode Presto::Client::ModelVersions::V0_173::TableLayoutHandle=Base.new(:connector_id,:transaction_handle,:connector_handle)
-
decode Presto::Client::ModelVersions::V0_173::TableScanNode=Base.new(:id,:table,:output_symbols,:assignments,:layout,:current_constraint,:original_constraint)
-
decode Presto::Client::ModelVersions::V0_173::TableWriterNode=Base.new(:id,:source,:target,:columns,:column_names,:outputs,:partitioning_scheme)
-
decode Presto::Client::ModelVersions::V0_173::TaskInfo=Base.new(:task_status,:last_heartbeat,:output_buffers,:no_more_splits,:stats,:needs_plan,:complete)
-
decode Presto::Client::ModelVersions::V0_173::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,:completed_drivers,:cumulative_memory,:memory_reservation,:system_memory_reservation,:total_scheduled_time,:total_cpu_time,:total_user_time,:total_blocked_time,:fully_blocked,:blocked_reasons,:raw_input_data_size,:raw_input_positions,:processed_input_data_size,:processed_input_positions,:output_data_size,:output_positions,:pipelines)
-
decode Presto::Client::ModelVersions::V0_173::TaskStatus=Base.new(:task_id,:task_instance_id,:version,:state,:self,:failures,:queued_partitioned_drivers,:running_partitioned_drivers,:memory_reservation)
-
decode Presto::Client::ModelVersions::V0_173::TopNNode=Base.new(:id,:source,:count,:order_by,:orderings,:partial)
-
decode Presto::Client::ModelVersions::V0_173::TopNRowNumberNode=Base.new(:id,:source,:specification,:row_number_symbol,:max_row_count_per_partition,:partial,:hash_symbol)
-
decode Presto::Client::ModelVersions::V0_173::UnionNode=Base.new(:id,:sources,:output_to_inputs,:outputs)
-
decode Presto::Client::ModelVersions::V0_173::UnnestNode=Base.new(:id,:source,:replicate_symbols,:unnest_symbols,:ordinality_symbol)
-
decode Presto::Client::ModelVersions::V0_173::ValuesNode=Base.new(:id,:output_symbols,:rows)
-
decode Presto::Client::ModelVersions::V0_173::WindowNode=Base.new(:id,:source,:specification,:window_functions,:hash_symbol,:pre_partitioned_inputs,:pre_sorted_order_prefix)
-
decode Presto::Client::ModelVersions::V0_205::LateralJoinNode=Base.new(:id,:input,:subquery,:correlation,:type,:origin_subquery)
-
decode Presto::Client::ModelVersions::V0_178::InsertTableHandle=Base.new(:connector_id,:transaction_handle,:connector_handle)
-
decode Presto::Client::ModelVersions::V0_205::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)
-
decode Presto::Client::ModelVersions::V0_178::ClientColumn=Base.new(:name,:type,:type_signature)
-
decode Presto::Client::ModelVersions::V0_205::RowNumberNode=Base.new(:id,:source,:partition_by,:row_number_symbol,:max_row_count_per_partition,:hash_symbol)
-
decode Presto::Client::ModelVersions::V0_205::QueryError=Base.new(:message,:sql_state,:error_code,:error_name,:error_type,:error_location,:failure_info)
-
decode Presto::Client::ModelVersions::V0_205::PartitionedOutputInfo=Base.new(:rows_added,:pages_added,:output_buffer_peak_memory_usage)
-
decode Presto::Client::ModelVersions::V0_205::InsertTableHandle=Base.new(:connector_id,:transaction_handle,:connector_handle)
-
decode Presto::Client::ModelVersions::V0_178::EquiJoinClause=Base.new(:left,:right,:probe,:index)
-
decode Presto::Client::ModelVersions::V0_178::PlanNode
-
decode Presto::Client::ModelVersions::V0_178::Aggregation=Base.new(:call,:signature,:mask)
-
decode Presto::Client::ModelVersions::V0_178::DistributionSnapshot=Base.new(:max_error,:count,:total,:p01,:p05,:p10,:p25,:p50,:p75,:p90,:p95,:p99,:min,:max)
-
decode Presto::Client::ModelVersions::V0_178::BufferInfo=Base.new(:buffer_id,:finished,:buffered_pages,:pages_sent,:page_buffer_info)
-
decode Presto::Client::ModelVersions::V0_178::WriterTarget=Base.new(:type,:handle)
-
decode Presto::Client::ModelVersions::V0_178::OperatorInfo
-
decode Presto::Client::ModelVersions::V0_178::HashCollisionsInfo=Base.new(:weighted_hash_collisions,:weighted_sum_squared_hash_collisions,:weighted_expectedHash_collisions)
-
decode Presto::Client::ModelVersions::V0_205::IndexHandle=Base.new(:connector_id,:transaction_handle,:connector_handle)
-
decode Presto::Client::ModelVersions::V0_178::AggregationNode=Base.new(:id,:source,:assignments,:grouping_sets,:step,:hash_symbol,:group_id_symbol)
-
decode Presto::Client::ModelVersions::V0_178::ApplyNode=Base.new(:id,:input,:subquery,:subquery_assignments,:correlation)
-
decode Presto::Client::ModelVersions::V0_178::ArgumentBinding=Base.new(:column,:constant)
-
decode Presto::Client::ModelVersions::V0_178::AssignUniqueId=Base.new(:id,:source,:id_column)
-
decode Presto::Client::ModelVersions::V0_178::Assignments=Base.new(:assignments)
-
decode Presto::Client::ModelVersions::V0_205::Input=Base.new(:connector_id,:schema,:table,:connector_info,:columns)
-
decode Presto::Client::ModelVersions::V0_205::Assignments=Base.new(:assignments)
-
decode Presto::Client::ModelVersions::V0_178::ClientStageStats=Base.new(:stage_id,:state,:done,:nodes,:total_splits,:queued_splits,:running_splits,:completed_splits,:user_time_millis,:cpu_time_millis,:wall_time_millis,:processed_rows,:processed_bytes,:sub_stages)
-
decode Presto::Client::ModelVersions::V0_178::ClientTypeSignature=Base.new(:raw_type,:type_arguments,:literal_arguments,:arguments)
-
decode Presto::Client::ModelVersions::V0_178::ClientTypeSignatureParameter=Base.new(:kind,:value)
-
decode Presto::Client::ModelVersions::V0_178::Column=Base.new(:name,:type)
-
decode Presto::Client::ModelVersions::V0_178::CreateHandle=Base.new(:handle,:schema_table_name)
-
decode Presto::Client::ModelVersions::V0_178::DeleteHandle=Base.new(:handle,:schema_table_name)
-
decode Presto::Client::ModelVersions::V0_178::DeleteNode=Base.new(:id,:source,:target,:row_id,:outputs)
-
decode Presto::Client::ModelVersions::V0_178::DistinctLimitNode=Base.new(:id,:source,:limit,:partial,:distinct_symbols,:hash_symbol)
-
decode Presto::Client::ModelVersions::V0_178::DriverStats=Base.new(:create_time,:start_time,:end_time,:queued_time,:elapsed_time,:memory_reservation,:peak_memory_reservation,:system_memory_reservation,:total_scheduled_time,:total_cpu_time,:total_user_time,:total_blocked_time,:fully_blocked,:blocked_reasons,:raw_input_data_size,:raw_input_positions,:raw_input_read_time,:processed_input_data_size,:processed_input_positions,:output_data_size,:output_positions,:operator_stats)
-
decode Presto::Client::ModelVersions::V0_178::EnforceSingleRowNode=Base.new(:id,:source)
-
decode Presto::Client::ModelVersions::V0_178::ErrorCode=Base.new(:code,:name,:type)
-
decode Presto::Client::ModelVersions::V0_178::ErrorLocation=Base.new(:line_number,:column_number)
-
decode Presto::Client::ModelVersions::V0_178::ExchangeClientStatus=Base.new(:buffered_bytes,:max_buffered_bytes,:average_bytes_per_request,:successful_requests_count,:buffered_pages,:no_more_locations,:page_buffer_client_statuses)
-
decode Presto::Client::ModelVersions::V0_178::ExchangeNode=Base.new(:id,:type,:scope,:partitioning_scheme,:sources,:inputs)
-
decode Presto::Client::ModelVersions::V0_178::ExecutionFailureInfo=Base.new(:type,:message,:cause,:suppressed,:stack,:error_location,:error_code,:remote_host)
-
decode Presto::Client::ModelVersions::V0_178::ExplainAnalyzeNode=Base.new(:id,:source,:output_symbol)
-
decode Presto::Client::ModelVersions::V0_178::FailureInfo=Base.new(:type,:message,:cause,:suppressed,:stack,:error_location)
-
decode Presto::Client::ModelVersions::V0_178::FilterNode=Base.new(:id,:source,:predicate)
-
decode Presto::Client::ModelVersions::V0_178::Function=Base.new(:function_call,:signature,:frame)
-
decode Presto::Client::ModelVersions::V0_178::GroupIdNode=Base.new(:id,:source,:grouping_sets,:grouping_set_mappings,:argument_mappings,:group_id_symbol)
-
decode Presto::Client::ModelVersions::V0_178::IndexHandle=Base.new(:connector_id,:transaction_handle,:connector_handle)
-
decode Presto::Client::ModelVersions::V0_178::IndexJoinNode=Base.new(:id,:type,:probe_source,:index_source,:criteria,:probe_hash_symbol,:index_hash_symbol)
-
decode Presto::Client::ModelVersions::V0_178::IndexSourceNode=Base.new(:id,:index_handle,:table_handle,:table_layout,:lookup_symbols,:output_symbols,:assignments,:effective_tuple_domain)
-
decode Presto::Client::ModelVersions::V0_178::Input=Base.new(:connector_id,:schema,:table,:connector_info,:columns)
-
decode Presto::Client::ModelVersions::V0_178::InsertHandle=Base.new(:handle,:schema_table_name)
-
decode Presto::Client::ModelVersions::V0_205::BufferInfo=Base.new(:buffer_id,:finished,:buffered_pages,:pages_sent,:page_buffer_info)
-
decode Presto::Client::ModelVersions::V0_178::UnionNode=Base.new(:id,:sources,:output_to_inputs,:outputs)
-
decode Presto::Client::ModelVersions::V0_178::JoinNode=Base.new(:id,:type,:left,:right,:criteria,:output_symbols,:filter,:left_hash_symbol,:right_hash_symbol,:distribution_type)
-
decode Presto::Client::ModelVersions::V0_178::LimitNode=Base.new(:id,:source,:count,:partial)
-
decode Presto::Client::ModelVersions::V0_178::LocalExchangeBufferInfo=Base.new(:buffered_bytes,:buffered_pages)
-
decode Presto::Client::ModelVersions::V0_178::LongVariableConstraint=Base.new(:name,:expression)
-
decode Presto::Client::ModelVersions::V0_178::MarkDistinctNode=Base.new(:id,:source,:marker_symbol,:distinct_symbols,:hash_symbol)
-
decode Presto::Client::ModelVersions::V0_178::MetadataDeleteNode=Base.new(:id,:target,:output,:table_layout)
-
decode Presto::Client::ModelVersions::V0_178::OperatorStats=Base.new(:pipeline_id,:operator_id,:plan_node_id,:operator_type,:total_drivers,:add_input_calls,:add_input_wall,:add_input_cpu,:add_input_user,:input_data_size,:input_positions,:sum_squared_input_positions,:get_output_calls,:get_output_wall,:get_output_cpu,:get_output_user,:output_data_size,:output_positions,:blocked_wall,:finish_calls,:finish_wall,:finish_cpu,:finish_user,:memory_reservation,:system_memory_reservation,:blocked_reason,:info)
-
decode Presto::Client::ModelVersions::V0_178::Output=Base.new(:connector_id,:schema,:table)
-
decode Presto::Client::ModelVersions::V0_178::OutputBufferInfo=Base.new(:type,:state,:can_add_buffers,:can_add_pages,:total_buffered_bytes,:total_buffered_pages,:total_rows_sent,:total_pages_sent,:buffers)
-
decode Presto::Client::ModelVersions::V0_178::OutputNode=Base.new(:id,:source,:columns,:outputs)
-
decode Presto::Client::ModelVersions::V0_178::OutputTableHandle=Base.new(:connector_id,:transaction_handle,:connector_handle)
-
decode Presto::Client::ModelVersions::V0_178::PageBufferClientStatus=Base.new(:uri,:state,:last_update,:rows_received,:pages_received,:rows_rejected,:pages_rejected,:requests_scheduled,:requests_completed,:requests_failed,:http_request_state)
-
decode Presto::Client::ModelVersions::V0_178::PageBufferInfo=Base.new(:partition,:buffered_pages,:buffered_bytes,:rows_added,:pages_added)
-
decode Presto::Client::ModelVersions::V0_178::Partitioning=Base.new(:handle,:arguments)
-
decode Presto::Client::ModelVersions::V0_178::PartitioningHandle=Base.new(:connector_id,:transaction_handle,:connector_handle)
-
decode Presto::Client::ModelVersions::V0_178::PartitioningScheme=Base.new(:partitioning,:output_layout,:hash_column,:replicate_nulls_and_any,:bucket_to_partition)
-
decode Presto::Client::ModelVersions::V0_178::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,:memory_reservation,:system_memory_reservation,:queued_time,:elapsed_time,:total_scheduled_time,:total_cpu_time,:total_user_time,:total_blocked_time,:fully_blocked,:blocked_reasons,:raw_input_data_size,:raw_input_positions,:processed_input_data_size,:processed_input_positions,:output_data_size,:output_positions,:operator_summaries,:drivers)
-
decode Presto::Client::ModelVersions::V0_178::PlanFragment=Base.new(:id,:root,:symbols,:partitioning,:partitioned_sources,:partitioning_scheme)
-
decode Presto::Client::ModelVersions::V0_178::ProjectNode=Base.new(:id,:source,:assignments)
-
decode Presto::Client::ModelVersions::V0_178::QueryError=Base.new(:message,:sql_state,:error_code,:error_name,:error_type,:error_location,:failure_info)
-
decode Presto::Client::ModelVersions::V0_178::QueryInfo=Base.new(:query_id,:session,:state,:memory_pool,:scheduled,:self,:field_names,:query,:query_stats,:set_session_properties,:reset_session_properties,:added_prepared_statements,:deallocated_prepared_statements,:started_transaction_id,:clear_transaction_id,:update_type,:output_stage,:failure_info,:error_code,:inputs,:output,:complete_info,:resource_group_name,:final_query_info)
-
decode Presto::Client::ModelVersions::V0_178::QueryResults=Base.new(:id,:info_uri,:partial_cancel_uri,:next_uri,:columns,:data,:stats,:error,:update_type,:update_count)
-
decode Presto::Client::ModelVersions::V0_178::QueryStats=Base.new(:create_time,:execution_start_time,:last_heartbeat,:end_time,:elapsed_time,:queued_time,:analysis_time,:distributed_planning_time,:total_planning_time,:finishing_time,:total_tasks,:running_tasks,:completed_tasks,:total_drivers,:queued_drivers,:running_drivers,:blocked_drivers,:completed_drivers,:cumulative_memory,:total_memory_reservation,:peak_memory_reservation,:scheduled,:total_scheduled_time,:total_cpu_time,:total_user_time,:total_blocked_time,:fully_blocked,:blocked_reasons,:raw_input_data_size,:raw_input_positions,:processed_input_data_size,:processed_input_positions,:output_data_size,:output_positions,:operator_summaries)
-
decode Presto::Client::ModelVersions::V0_178::RemoteSourceNode=Base.new(:id,:source_fragment_ids,:outputs)
-
decode Presto::Client::ModelVersions::V0_178::RowNumberNode=Base.new(:id,:source,:partition_by,:row_number_symbol,:max_row_count_per_partition,:hash_symbol)
-
decode Presto::Client::ModelVersions::V0_178::SampleNode=Base.new(:id,:source,:sample_ratio,:sample_type)
-
decode Presto::Client::ModelVersions::V0_178::SchemaTableName=Base.new(:schema,:table)
-
decode Presto::Client::ModelVersions::V0_178::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)
-
decode Presto::Client::ModelVersions::V0_178::SessionRepresentation=Base.new(:query_id,:transaction_id,:client_transaction_support,:user,:principal,:source,:catalog,:schema,:time_zone_key,:locale,:remote_user_address,:user_agent,:client_info,:start_time,:system_properties,:catalog_properties,:prepared_statements)
-
decode Presto::Client::ModelVersions::V0_178::Signature=Base.new(:name,:kind,:type_variable_constraints,:long_variable_constraints,:return_type,:argument_types,:variable_arity)
-
decode Presto::Client::ModelVersions::V0_178::SortNode=Base.new(:id,:source,:order_by,:orderings)
-
decode Presto::Client::ModelVersions::V0_178::Specification=Base.new(:partition_by,:order_by,:orderings)
-
decode Presto::Client::ModelVersions::V0_178::SplitOperatorInfo=Base.new(:split_info)
-
decode Presto::Client::ModelVersions::V0_178::StageInfo=Base.new(:stage_id,:state,:self,:plan,:types,:stage_stats,:tasks,:sub_stages,:failure_cause)
-
decode Presto::Client::ModelVersions::V0_178::StageStats=Base.new(:scheduling_complete,:get_split_distribution,:schedule_task_distribution,:add_split_distribution,:total_tasks,:running_tasks,:completed_tasks,:total_drivers,:queued_drivers,:running_drivers,:blocked_drivers,:completed_drivers,:cumulative_memory,:total_memory_reservation,:peak_memory_reservation,:total_scheduled_time,:total_cpu_time,:total_user_time,:total_blocked_time,:fully_blocked,:blocked_reasons,:raw_input_data_size,:raw_input_positions,:processed_input_data_size,:processed_input_positions,:buffered_data_size,:output_data_size,:output_positions,:operator_summaries)
-
decode Presto::Client::ModelVersions::V0_178::StatementStats=Base.new(:state,:queued,:scheduled,:nodes,:total_splits,:queued_splits,:running_splits,:completed_splits,:user_time_millis,:cpu_time_millis,:wall_time_millis,:processed_rows,:processed_bytes,:root_stage)
-
decode Presto::Client::ModelVersions::V0_178::TableFinishInfo=Base.new(:connector_output_metadata)
-
decode Presto::Client::ModelVersions::V0_178::TableFinishNode=Base.new(:id,:source,:target,:outputs)
-
decode Presto::Client::ModelVersions::V0_178::TableHandle=Base.new(:connector_id,:connector_handle)
-
decode Presto::Client::ModelVersions::V0_178::TableLayoutHandle=Base.new(:connector_id,:transaction_handle,:connector_handle)
-
decode Presto::Client::ModelVersions::V0_178::TopNRowNumberNode=Base.new(:id,:source,:specification,:row_number_symbol,:max_row_count_per_partition,:partial,:hash_symbol)
-
decode Presto::Client::ModelVersions::V0_178::TableWriterNode=Base.new(:id,:source,:target,:columns,:column_names,:outputs,:partitioning_scheme)
-
decode Presto::Client::ModelVersions::V0_178::TaskInfo=Base.new(:task_status,:last_heartbeat,:output_buffers,:no_more_splits,:stats,:needs_plan,:complete)
-
decode Presto::Client::ModelVersions::V0_178::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_memory,:memory_reservation,:system_memory_reservation,:total_scheduled_time,:total_cpu_time,:total_user_time,:total_blocked_time,:fully_blocked,:blocked_reasons,:raw_input_data_size,:raw_input_positions,:processed_input_data_size,:processed_input_positions,:output_data_size,:output_positions,:pipelines)
-
decode Presto::Client::ModelVersions::V0_178::TaskStatus=Base.new(:task_id,:task_instance_id,:version,:state,:self,:failures,:queued_partitioned_drivers,:running_partitioned_drivers,:memory_reservation)
-
decode Presto::Client::ModelVersions::V0_178::TypeVariableConstraint=Base.new(:name,:comparable_required,:orderable_required,:variadic_bound)
-
#each_row Presto::Client::Query
-
#each_row_chunk Presto::Client::Query
-
#error_code Presto::Client::PrestoQueryError
-
#error_location Presto::Client::PrestoQueryError
-
#error_name Presto::Client::PrestoQueryError
-
#error_type Presto::Client::PrestoQueryError
-
#exception! Presto::Client::StatementClient
-
#failure_info Presto::Client::PrestoQueryError
-
faraday_client Presto::Client
-
faraday_client Presto::Client::Query
-
#faraday_get_with_retry Presto::Client::StatementClient
-
#finished? Presto::Client::StatementClient
-
#group_id Presto::Client::ModelVersions::V316::Lifespan
-
#group_id Presto::Client::ModelVersions::V303::Lifespan
-
#group_id Presto::Client::ModelVersions::V0_205::Lifespan
-
#grouped Presto::Client::ModelVersions::V316::Lifespan
-
#grouped Presto::Client::ModelVersions::V303::Lifespan
-
#grouped Presto::Client::ModelVersions::V0_205::Lifespan
-
#has_next? Presto::Client::StatementClient
-
#id Presto::Client::ModelVersions::V0_153::TaskId
-
#id Presto::Client::ModelVersions::V0_153::StageId
-
#id Presto::Client::ModelVersions::V0_149::TaskId
-
#id Presto::Client::ModelVersions::V0_149::StageId
-
#id Presto::Client::ModelVersions::V316::TaskId
-
#id Presto::Client::ModelVersions::V316::StageId
-
#id Presto::Client::ModelVersions::V303::TaskId
-
#id Presto::Client::ModelVersions::V303::StageId
-
#id Presto::Client::ModelVersions::V0_178::TaskId
-
#id Presto::Client::ModelVersions::V0_178::StageId
-
#id Presto::Client::ModelVersions::V0_173::TaskId
-
#id Presto::Client::ModelVersions::V0_173::StageId
-
#id Presto::Client::ModelVersions::V0_205::TaskId
-
#id Presto::Client::ModelVersions::V0_205::StageId
-
#initialize Presto::Client::ModelVersions::V0_153::ConnectorSession
-
#initialize Presto::Client::ModelVersions::V0_153::StageId
-
#initialize Presto::Client::ModelVersions::V0_153::TaskId
-
#initialize Presto::Client::ModelVersions::V0_149::ConnectorSession
-
#initialize Presto::Client::ModelVersions::V0_149::TaskId
-
#initialize Presto::Client::ModelVersions::V0_149::StageId
-
#initialize Presto::Client::ModelVersions::V316::ResourceGroupId
-
#initialize Presto::Client::ModelVersions::V316::ConnectorSession
-
#initialize Presto::Client::ModelVersions::V316::Lifespan
-
#initialize Presto::Client::ModelVersions::V316::StageId
-
#initialize Presto::Client::ModelVersions::V316::TaskId
-
#initialize Presto::Client::ModelVersions::V303::ResourceGroupId
-
#initialize Presto::Client::ModelVersions::V303::Lifespan
-
#initialize Presto::Client::ModelVersions::V303::TaskId
-
#initialize Presto::Client::ModelVersions::V303::StageId
-
#initialize Presto::Client::PrestoQueryError
-
#initialize Presto::Client::StatementClient
-
#initialize Presto::Client::ModelVersions::V303::ConnectorSession
-
#initialize Presto::Client::Client
-
#initialize Presto::Client::PrestoHttpError
-
#initialize Presto::Client::Query
-
#initialize Presto::Client::ModelVersions::V0_178::ConnectorSession
-
#initialize Presto::Client::ModelVersions::V0_178::TaskId
-
#initialize Presto::Client::ModelVersions::V0_178::StageId
-
#initialize Presto::Client::ModelVersions::V0_173::ConnectorSession
-
#initialize Presto::Client::ModelVersions::V0_173::TaskId
-
#initialize Presto::Client::ModelVersions::V0_205::Lifespan
-
#initialize Presto::Client::ModelVersions::V0_205::TaskId
-
#initialize Presto::Client::ModelVersions::V0_205::ConnectorSession
-
#initialize Presto::Client::ModelVersions::V0_205::StageId
-
#initialize Presto::Client::ModelVersions::V0_173::StageId
-
#kill Presto::Client::Client
-
kill Presto::Client::Query
-
new Presto::Client::ModelVersions::V0_205::Base
-
new Presto::Client::ModelVersions::V0_178::Base
-
new Presto::Client::ModelVersions::V0_173::Base
-
new Presto::Client::ModelVersions::V0_153::Base
-
new Presto::Client::ModelVersions::V0_149::Base
-
new Presto::Client::ModelVersions::V316::Base
-
new Presto::Client::ModelVersions::V303::Base
-
new Presto::Client
-
new_struct Presto::Client::ModelVersions::V0_205::Base
-
new_struct Presto::Client::ModelVersions::V0_178::Base
-
new_struct Presto::Client::ModelVersions::V0_173::Base
-
new_struct Presto::Client::ModelVersions::V0_153::Base
-
new_struct Presto::Client::ModelVersions::V0_149::Base
-
new_struct Presto::Client::ModelVersions::V316::Base
-
new_struct Presto::Client::ModelVersions::V303::Base
-
#next_uri Presto::Client::Query
-
#query Presto::Client::StatementClient
-
#query Presto::Client::Client
-
#query_failed? Presto::Client::StatementClient
-
#query_id Presto::Client::ModelVersions::V0_205::TaskId
-
#query_id Presto::Client::ModelVersions::V0_205::StageId
-
#query_id Presto::Client::ModelVersions::V0_178::StageId
-
#query_id Presto::Client::ModelVersions::V0_178::TaskId
-
#query_id Presto::Client::ModelVersions::V0_173::StageId
-
#query_id Presto::Client::ModelVersions::V0_173::TaskId
-
#query_id Presto::Client::ModelVersions::V0_153::TaskId
-
#query_id Presto::Client::ModelVersions::V0_153::StageId
-
#query_id Presto::Client::ModelVersions::V0_149::TaskId
-
#query_id Presto::Client::ModelVersions::V0_149::StageId
-
#query_id Presto::Client::ModelVersions::V316::TaskId
-
#query_id Presto::Client::ModelVersions::V316::StageId
-
#query_id Presto::Client::ModelVersions::V303::StageId
-
#query_id Presto::Client::ModelVersions::V303::TaskId
-
#query_id Presto::Client::StatementClient
-
#query_info Presto::Client::StatementClient
-
#query_info Presto::Client::Query
-
#query_succeeded? Presto::Client::StatementClient
-
#raise_if_failed Presto::Client::Query
-
#raise_if_timeout! Presto::Client::StatementClient
-
#raise_timeout_error! Presto::Client::StatementClient
-
resume Presto::Client::Query
-
#resume_query Presto::Client::Client
-
#rows Presto::Client::Query
-
#run Presto::Client::Client
-
#run_with_names Presto::Client::Client
-
#running? Presto::Client::StatementClient
-
#stage_id Presto::Client::ModelVersions::V0_205::TaskId
-
#stage_id Presto::Client::ModelVersions::V0_178::TaskId
-
#stage_id Presto::Client::ModelVersions::V0_173::TaskId
-
#stage_id Presto::Client::ModelVersions::V0_153::TaskId
-
#stage_id Presto::Client::ModelVersions::V0_149::TaskId
-
#stage_id Presto::Client::ModelVersions::V316::TaskId
-
#stage_id Presto::Client::ModelVersions::V303::TaskId
-
start Presto::Client::Query
-
#status Presto::Client::PrestoHttpError