[ 
https://issues.apache.org/jira/browse/DRILL-4258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15241694#comment-15241694
 ] 

ASF GitHub Bot commented on DRILL-4258:
---------------------------------------

GitHub user StevenMPhillips opened a pull request:

    https://github.com/apache/drill/pull/479

    DRILL-4258: Add threads, fragments, and queries system tables

    Here are the pojos that represent the data for the new system tables:
    
    ```java
      public static class FragmentInfo {
        public String hostname;
        public String queryId;
        public int majorFragmentId;
        public int minorFragmentId;
        public Long memoryUsage;
        /**
         * The maximum number of input records across all Operators in fragment
         */
        public Long rowsProcessed;
        public Timestamp startTime;
      }
    ```
    
    ```java
      public static class ThreadSummary {
        /**
         * The Drillbit hostname
         */
        public String hostname;
    
        /**
         * The Drillbit user port
         */
        public long user_port;
        public String threadName;
        public long threadId;
        public boolean inNative;
        public boolean suspended;
        public String threadState;
        /**
         * Thread cpu time during last second. Between 0 and 100
         */
        public Integer cpuTime;
        /**
         * Thread user cpu time during last second. Between 0 and 100
         */
        public Integer userTime;
        public String stackTrace;
      }
    ```
    
    ```java
      public static class QueryInfo {
        /**
         * The host where foreman is running
         */
        public String foreman;
        /**
         * User who submitted query
         */
        public String user;
        public String queryId;
        /**
         * Query sql string
         */
        public String query;
        public Timestamp startTime;
      }
    ```
    
    I did not include data in the query table which can be obtained from the 
fragments table and doing a join on the queryId.

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/StevenMPhillips/drill drill-4258

Alternatively you can review and apply these changes as the patch at:

    https://github.com/apache/drill/pull/479.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #479
    
----
commit c99fffd5f091bcea17d8a0248c22094ed90ca86d
Author: Steven Phillips <[email protected]>
Date:   2016-04-14T18:27:46Z

    DRILL-4258: Add threads, fragments, and queries system tables

----


> Create New SYS tables: cpu, queries, fragments, threads, threadtraces, 
> connections
> ----------------------------------------------------------------------------------
>
>                 Key: DRILL-4258
>                 URL: https://issues.apache.org/jira/browse/DRILL-4258
>             Project: Apache Drill
>          Issue Type: New Feature
>          Components: Execution - Monitoring
>            Reporter: Jacques Nadeau
>            Assignee: Jacques Nadeau
>
> cpu: Drillbit, # Cores, CPU consumption (with different windows?)
> queries: Foreman, QueryId, User, SQL, Start Time, rows processed, query plan, 
> # nodes involved, number of running fragments, memory consumed
> fragments: Drillbit, queryid, major fragmentid, minorfragmentid, coordinate, 
> memory usage, rows processed, start time
> threads: name, priority, state, id, thread-level cpu stats
> threadtraces: threads, stack trace
> connections: client, server, type, establishedDate, messagesSent, bytesSent



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to