title: Executing a sql query inside a dataflow using python on PCollection
body: <p>I am trying to implement one sql query as a transform in dataflow. I loaded a table from bigquery as PCollection. I want to aggregate my data like below query.</p>
  
  <p><code>SELECT
    name,
    user_id,
    place,
    SUM(amount) as some_amount ,
    SUM(cost) as sum_cost 
  FROM
    [project:test.day_0_test]
  GROUP BY 1,2,3
  </code>
  How I can implement it easily. I heard that Data flow with Java support running sql kind query on P Collection, but correctly python is not supporting. Can any one help me to solve this</p>
  
  <p>Note:</p>
  
  <p>I want to implement this query on a P Collection .. Not to read from bigquery directly</p>