Class List

Classes Methods Files

Search:

Top Level Namespace
PrestoTop Level Namespace
- ClientPresto
  - Client < ObjectPresto::Client
  - ModelsPresto::Client
    AggregationNode=Base.new(:id,:source,:group_by,:aggregations,:functions,:masks,:step,:sample_weight,:confidence) < ObjectPresto::Client::Models
    Base < StructPresto::Client::Models
    BufferInfo=Base.new(:buffer_id,:finished,:buffered_pages,:pages_sent) < ObjectPresto::Client::Models
    Column=Base.new(:name,:type) < ObjectPresto::Client::Models
    ColumnHandle=Base.new(:connector_id,:connector_handle) < ObjectPresto::Client::Models
    ConnectorSession < HashPresto::Client::Models
    DistinctLimitNode=Base.new(:id,:source,:limit) < ObjectPresto::Client::Models
    DistributionSnapshot=Base.new(:max_error,:count,:total,:p01,:p05,:p10,:p25,:p50,:p75,:p90,:p95,:p99,:min,:max) < ObjectPresto::Client::Models
    DriverStats=Base.new(:create_time,:start_time,:end_time,:queued_time,:elapsed_time,:memory_reservation,:total_scheduled_time,:total_cpu_time,:total_user_time,:total_blocked_time,: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) < ObjectPresto::Client::Models
    EquiJoinClause=Base.new(:left,:right) < ObjectPresto::Client::Models
    ErrorCode=Base.new(:code,:name) < ObjectPresto::Client::Models
    ErrorLocation=Base.new(:line_number,:column_number) < ObjectPresto::Client::Models
    ExchangeNode=Base.new(:id,:source_fragment_ids,:outputs) < ObjectPresto::Client::Models
    ExecutionFailureInfo=Base.new(:type,:message,:cause,:suppressed,:stack,:error_location,:error_code) < ObjectPresto::Client::Models
    FailureInfo=Base.new(:type,:message,:cause,:suppressed,:stack,:error_location) < ObjectPresto::Client::Models
    FilterNode=Base.new(:id,:source,:predicate) < ObjectPresto::Client::Models
    IndexHandle=Base.new(:connector_id,:connector_handle) < ObjectPresto::Client::Models
    IndexJoinNode=Base.new(:id,:type,:probe_source,:index_source,:criteria) < ObjectPresto::Client::Models
    IndexSourceNode=Base.new(:id,:index_handle,:table_handle,:lookup_symbols,:output_symbols,:assignments,:effective_tuple_domain) < ObjectPresto::Client::Models
    Input=Base.new(:connector_id,:schema,:table,:columns) < ObjectPresto::Client::Models
    JoinNode=Base.new(:id,:type,:left,:right,:criteria) < ObjectPresto::Client::Models
    LimitNode=Base.new(:id,:source,:count,:sample_weight) < ObjectPresto::Client::Models
    MarkDistinctNode=Base.new(:id,:source,:marker_symbol,:distinct_symbols,:sample_weight_symbol) < ObjectPresto::Client::Models
    MaterializeSampleNode=Base.new(:id,:source,:sample_weight_symbol) < ObjectPresto::Client::Models
    OperatorStats=Base.new(:operator_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,:info) < ObjectPresto::Client::Models
    OutputNode=Base.new(:id,:source,:columns,:outputs) < ObjectPresto::Client::Models
    OutputTableHandle=Base.new(:connector_id,:connector_handle) < ObjectPresto::Client::Models
    PipelineStats=Base.new(:input_pipeline,:output_pipeline,:total_drivers,:queued_drivers,:running_drivers,:completed_drivers,:memory_reservation,:queued_time,:elapsed_time,:total_scheduled_time,:total_cpu_time,:total_user_time,:total_blocked_time,:raw_input_data_size,:raw_input_positions,:processed_input_data_size,:processed_input_positions,:output_data_size,:output_positions,:operator_summaries,:drivers) < ObjectPresto::Client::Models
    PlanFragment=Base.new(:id,:root,:symbols,:distribution,:partitioned_source,:output_partitioning,:partition_by) < ObjectPresto::Client::Models
    PlanFragmentId < StringPresto::Client::Models
    PlanNodePresto::Client::Models
    PlanNodeId < StringPresto::Client::Models
    ProjectNode=Base.new(:id,:source,:assignments) < ObjectPresto::Client::Models
    QueryError=Base.new(:message,:sql_state,:error_code,:error_location,:failure_info) < ObjectPresto::Client::Models
    QueryId < StringPresto::Client::Models
    QueryInfo=Base.new(:query_id,:session,:state,:self,:field_names,:query,:query_stats,:output_stage,:failure_info,:error_code,:inputs) < ObjectPresto::Client::Models
    QueryResults=Base.new(:id,:info_uri,:partial_cancel_uri,:next_uri,:columns,:data,:stats,:error) < ObjectPresto::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,:total_tasks,:running_tasks,:completed_tasks,:total_drivers,:queued_drivers,:running_drivers,:completed_drivers,:total_memory_reservation,:total_scheduled_time,:total_cpu_time,:total_user_time,:total_blocked_time,:raw_input_data_size,:raw_input_positions,:processed_input_data_size,:processed_input_positions,:output_data_size,:output_positions) < ObjectPresto::Client::Models
    SampleNode=Base.new(:id,:source,:sample_ratio,:sample_type,:rescaled,:sample_weight_symbol) < ObjectPresto::Client::Models
    SemiJoinNode=Base.new(:id,:source,:filtering_source,:source_join_symbol,:filtering_source_join_symbol,:semi_join_output) < ObjectPresto::Client::Models
    SharedBufferInfo=Base.new(:state,:master_sequence_id,:pages_added,:buffers) < ObjectPresto::Client::Models
    Signature=Base.new(:name,:return_type,:argument_types,:approximate) < ObjectPresto::Client::Models
    SinkNode=Base.new(:id,:source,:output_symbols) < ObjectPresto::Client::Models
    SortNode=Base.new(:id,:source,:order_by,:orderings) < ObjectPresto::Client::Models
    StageId < StringPresto::Client::Models
    StageInfo=Base.new(:stage_id,:state,:self,:plan,:types,:stage_stats,:tasks,:sub_stages,:failures) < ObjectPresto::Client::Models
    StageStats=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) < ObjectPresto::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) < ObjectPresto::Client::Models
    TableCommitNode=Base.new(:id,:source,:target,:outputs) < ObjectPresto::Client::Models
    TableHandle=Base.new(:connector_id,:connector_handle) < ObjectPresto::Client::Models
    TableScanNode=Base.new(:id,:table,:output_symbols,:assignments,:original_constraint) < ObjectPresto::Client::Models
    TableWriterNode=Base.new(:id,:source,:target,:columns,:column_names,:outputs,:sample_weight_symbol) < ObjectPresto::Client::Models
    TaskId < StringPresto::Client::Models
    TaskInfo=Base.new(:task_id,:version,:state,:self,:last_heartbeat,:output_buffers,:no_more_splits,:stats,:failures) < ObjectPresto::Client::Models
    TaskStats=Base.new(:create_time,:first_start_time,:last_start_time,:end_time,:elapsed_time,:queued_time,:total_drivers,:queued_drivers,:running_drivers,:completed_drivers,:memory_reservation,:total_scheduled_time,:total_cpu_time,:total_user_time,:total_blocked_time,:raw_input_data_size,:raw_input_positions,:processed_input_data_size,:processed_input_positions,:output_data_size,:output_positions,:pipelines) < ObjectPresto::Client::Models
    TopNNode=Base.new(:id,:source,:count,:order_by,:orderings,:partial,:sample_weight) < ObjectPresto::Client::Models
    ValuesNode=Base.new(:id,:output_symbols,:rows) < ObjectPresto::Client::Models
    WindowNode=Base.new(:id,:source,:partition_by,:order_by,:orderings,:window_functions,:signatures) < ObjectPresto::Client::Models
  - PrestoClientError < PrestoErrorPresto::Client
  - PrestoError < StandardErrorPresto::Client
  - PrestoHeadersPresto::Client
  - PrestoHttpError < PrestoErrorPresto::Client
  - PrestoQueryError < PrestoErrorPresto::Client
  - Query < ObjectPresto::Client
  - StatementClient < ObjectPresto::Client