-
#advance
PrestoLegacy::Client::StatementClient
-
-
#cancel
PrestoLegacy::Client::Query
-
-
#close
PrestoLegacy::Client::StatementClient
-
#close
PrestoLegacy::Client::Query
-
#closed?
PrestoLegacy::Client::StatementClient
-
-
-
-
#debug?
PrestoLegacy::Client::StatementClient
-
decode
PrestoLegacy::Client::Models::TypeParameterRequirement=Base.new(:name,:comparable_required,:orderable_required,:variadic_bound)
-
decode
PrestoLegacy::Client::Models::PageBufferInfo=Base.new(:partition,:buffered_pages,:queued_pages,:buffered_bytes,:pages_added)
-
decode
PrestoLegacy::Client::Models::TopNNode=Base.new(:id,:source,:count,:order_by,:orderings,:partial)
-
decode
PrestoLegacy::Client::Models::WindowNode=Base.new(:id,:source,:partition_by,:order_by,:orderings,:frame,:window_functions,:signatures,:hash_symbol,:pre_partitioned_inputs,:pre_sorted_order_prefix)
-
decode
PrestoLegacy::Client::Models::MetadataDeleteNode=Base.new(:id,:target,:output,:table_layout)
-
decode
PrestoLegacy::Client::Models::TopNRowNumberNode=Base.new(:id,:source,:partition_by,:order_by,:orderings,:row_number_symbol,:max_row_count_per_partition,:partial,:hash_symbol)
-
decode
PrestoLegacy::Client::Models::TableHandle=Base.new(:connector_id,:connector_handle)
-
decode
PrestoLegacy::Client::Models::TableLayoutHandle=Base.new(:connector_id,:transaction_handle,:connector_handle)
-
decode
PrestoLegacy::Client::Models::StatementStats=Base.new(:state,: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
PrestoLegacy::Client::Models::StageInfo=Base.new(:stage_id,:state,:self,:plan,:types,:stage_stats,:tasks,:sub_stages,:failure_cause)
-
decode
PrestoLegacy::Client::Models::UnionNode=Base.new(:id,:sources,:symbol_mapping)
-
decode
PrestoLegacy::Client::Models::TableFinishNode=Base.new(:id,:source,:target,:outputs)
-
decode
PrestoLegacy::Client::Models::Signature=Base.new(:name,:kind,:type_parameter_requirements,:return_type,:argument_types,:variable_arity)
-
decode
PrestoLegacy::Client::Models::SortNode=Base.new(:id,:source,:order_by,:orderings)
-
decode
PrestoLegacy::Client::Models::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)
-
decode
PrestoLegacy::Client::Models::SharedBufferInfo=Base.new(:state,:can_add_buffers,:can_add_pages,:total_buffered_bytes,:total_buffered_pages,:total_queued_pages,:total_pages_sent,:buffers)
-
decode
PrestoLegacy::Client::Models::DeleteHandle=Base.new(:handle)
-
decode
PrestoLegacy::Client::Models::ValuesNode=Base.new(:id,:output_symbols,:rows)
-
decode
PrestoLegacy::Client::Models::UnnestNode=Base.new(:id,:source,:replicate_symbols,:unnest_symbols,:ordinality_symbol)
-
decode
PrestoLegacy::Client::Models::TaskInfo=Base.new(:task_id,:task_instance_id,:version,:state,:self,:last_heartbeat,:output_buffers,:no_more_splits,:stats,:failures)
-
decode
PrestoLegacy::Client::Models::TableScanNode=Base.new(:id,:table,:output_symbols,:assignments,:layout,:current_constraint,:original_constraint)
-
decode
PrestoLegacy::Client::Models::TableWriterNode=Base.new(:id,:source,:target,:columns,:column_names,:outputs,:sample_weight_symbol)
-
decode
PrestoLegacy::Client::Models::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
PrestoLegacy::Client::Models::DistributionSnapshot=Base.new(:max_error,:count,:total,:p01,:p05,:p10,:p25,:p50,:p75,:p90,:p95,:p99,:min,:max)
-
decode
PrestoLegacy::Client::Models::PlanNode
-
decode
PrestoLegacy::Client::Models::WriterTarget=Base.new(:type,:handle)
-
decode
PrestoLegacy::Client::Models::EquiJoinClause=Base.new(:left,:right,:probe,:index)
-
decode
PrestoLegacy::Client::Models::TaskStats=Base.new(:create_time,:first_start_time,:last_start_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
PrestoLegacy::Client::Models::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,: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
PrestoLegacy::Client::Models::QueryInfo=Base.new(:query_id,:session,:state,:memory_pool,:scheduled,:self,:field_names,:query,:query_stats,:set_session_properties,:reset_session_properties,:started_transaction_id,:clear_transaction_id,:update_type,:output_stage,:failure_info,:error_code,:inputs)
-
decode
PrestoLegacy::Client::Models::AggregationNode=Base.new(:id,:source,:group_by,:aggregations,:functions,:masks,:step,:sample_weight,:confidence,:hash_symbol)
-
decode
PrestoLegacy::Client::Models::BufferInfo=Base.new(:buffer_id,:finished,:buffered_pages,:pages_sent,:page_buffer_info)
-
decode
PrestoLegacy::Client::Models::ClientColumn=Base.new(:name,:type,:type_signature)
-
decode
PrestoLegacy::Client::Models::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
PrestoLegacy::Client::Models::ClientTypeSignature=Base.new(:raw_type,:type_arguments,:literal_arguments,:arguments)
-
decode
PrestoLegacy::Client::Models::ClientTypeSignatureParameter=Base.new(:kind,:value)
-
decode
PrestoLegacy::Client::Models::Column=Base.new(:name,:type)
-
decode
PrestoLegacy::Client::Models::DeleteNode=Base.new(:id,:source,:target,:row_id,:outputs)
-
decode
PrestoLegacy::Client::Models::DistinctLimitNode=Base.new(:id,:source,:limit,:hash_symbol)
-
decode
PrestoLegacy::Client::Models::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
PrestoLegacy::Client::Models::EnforceSingleRowNode=Base.new(:id,:source)
-
decode
PrestoLegacy::Client::Models::ErrorCode=Base.new(:code,:name)
-
decode
PrestoLegacy::Client::Models::ErrorLocation=Base.new(:line_number,:column_number)
-
decode
PrestoLegacy::Client::Models::ExchangeNode=Base.new(:id,:type,:partition_function,:sources,:outputs,:inputs)
-
decode
PrestoLegacy::Client::Models::ExecutionFailureInfo=Base.new(:type,:message,:cause,:suppressed,:stack,:error_location,:error_code)
-
decode
PrestoLegacy::Client::Models::FailureInfo=Base.new(:type,:message,:cause,:suppressed,:stack,:error_location)
-
decode
PrestoLegacy::Client::Models::FilterNode=Base.new(:id,:source,:predicate)
-
decode
PrestoLegacy::Client::Models::IndexHandle=Base.new(:connector_id,:transaction_handle,:connector_handle)
-
decode
PrestoLegacy::Client::Models::IndexJoinNode=Base.new(:id,:type,:probe_source,:index_source,:criteria,:probe_hash_symbol,:index_hash_symbol)
-
decode
PrestoLegacy::Client::Models::IndexSourceNode=Base.new(:id,:index_handle,:table_handle,:lookup_symbols,:output_symbols,:assignments,:effective_tuple_domain)
-
decode
PrestoLegacy::Client::Models::Input=Base.new(:connector_id,:schema,:table,:columns)
-
decode
PrestoLegacy::Client::Models::InsertTableHandle=Base.new(:connector_id,:transaction_handle,:connector_handle)
-
decode
PrestoLegacy::Client::Models::JoinNode=Base.new(:id,:type,:left,:right,:criteria,:left_hash_symbol,:right_hash_symbol)
-
decode
PrestoLegacy::Client::Models::LimitNode=Base.new(:id,:source,:count)
-
decode
PrestoLegacy::Client::Models::MarkDistinctNode=Base.new(:id,:source,:marker_symbol,:distinct_symbols,:hash_symbol)
-
decode
PrestoLegacy::Client::Models::SampleNode=Base.new(:id,:source,:sample_ratio,:sample_type,:rescaled,:sample_weight_symbol)
-
decode
PrestoLegacy::Client::Models::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
PrestoLegacy::Client::Models::OutputNode=Base.new(:id,:source,:columns,:outputs)
-
decode
PrestoLegacy::Client::Models::OutputTableHandle=Base.new(:connector_id,:transaction_handle,:connector_handle)
-
decode
PrestoLegacy::Client::Models::PartitionFunctionBinding=Base.new(:function_handle,:partitioning_columns,:hash_column,:replicate_nulls,:partition_count)
-
decode
PrestoLegacy::Client::Models::PipelineStats=Base.new(: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
PrestoLegacy::Client::Models::PlanFragment=Base.new(:id,:root,:symbols,:output_layout,:distribution,:partitioned_source,:partition_function)
-
decode
PrestoLegacy::Client::Models::ProjectNode=Base.new(:id,:source,:assignments)
-
decode
PrestoLegacy::Client::Models::QueryError=Base.new(:message,:sql_state,:error_code,:error_name,:error_type,:error_location,:failure_info)
-
decode
PrestoLegacy::Client::Models::RemoteSourceNode=Base.new(:id,:source_fragment_ids,:outputs)
-
decode
PrestoLegacy::Client::Models::QueryResults=Base.new(:id,:info_uri,:partial_cancel_uri,:next_uri,:columns,:data,:stats,:error,:update_type,:update_count)
-
decode
PrestoLegacy::Client::Models::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
PrestoLegacy::Client::Models::RowNumberNode=Base.new(:id,:source,:partition_by,:row_number_symbol,:max_row_count_per_partition,:hash_symbol)
-
-
-
-
-
-
-
-
-
-
#id
PrestoLegacy::Client::Models::TaskId
-
#id
PrestoLegacy::Client::Models::StageId
-
#initialize
PrestoLegacy::Client::Models::ConnectorSession
-
-
-
-
-
-
-
-
new
PrestoLegacy::Client::Models::Base
-
-
-
-
#query
PrestoLegacy::Client::StatementClient
-
#query
PrestoLegacy::Client::Client
-
-
#query_id
PrestoLegacy::Client::Models::TaskId
-
#query_id
PrestoLegacy::Client::Models::StageId
-
-
-
-
-
resume
PrestoLegacy::Client::Query
-
-
#rows
PrestoLegacy::Client::Query
-
#run
PrestoLegacy::Client::Client
-
-
#stage_id
PrestoLegacy::Client::Models::TaskId
-
start
PrestoLegacy::Client::Query
-
#status
PrestoLegacy::Client::PrestoHttpError