[jira] [Work logged] (BEAM-3097) Allow BigQuerySource to take a ValueProvider as a table input.

2020-04-07 Thread ASF GitHub Bot (Jira)


 [ 
https://issues.apache.org/jira/browse/BEAM-3097?focusedWorklogId=417854&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-417854
 ]

ASF GitHub Bot logged work on BEAM-3097:


Author: ASF GitHub Bot
Created on: 07/Apr/20 17:58
Start Date: 07/Apr/20 17:58
Worklog Time Spent: 10m 
  Work Description: pabloem commented on pull request #11244: [BEAM-3097] 
_ReadFromBigQuery supports valueprovider for table
URL: https://github.com/apache/beam/pull/11244
 
 
   
 

This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 417854)
Time Spent: 3h 50m  (was: 3h 40m)

> Allow BigQuerySource to take a ValueProvider as a table input.
> --
>
> Key: BEAM-3097
> URL: https://issues.apache.org/jira/browse/BEAM-3097
> Project: Beam
>  Issue Type: Improvement
>  Components: sdk-py-core
>Reporter: Ed Mothershaw
>Priority: Minor
>   Original Estimate: 2h
>  Time Spent: 3h 50m
>  Remaining Estimate: 0h
>
> In file sdks/python/apache_beam/io/gcp/bigquery.py, class BigQuery, line 389. 
> When a ValueProvider is input as table the script will fail.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Work logged] (BEAM-3097) Allow BigQuerySource to take a ValueProvider as a table input.

2020-04-07 Thread ASF GitHub Bot (Jira)


 [ 
https://issues.apache.org/jira/browse/BEAM-3097?focusedWorklogId=417697&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-417697
 ]

ASF GitHub Bot logged work on BEAM-3097:


Author: ASF GitHub Bot
Created on: 07/Apr/20 14:06
Start Date: 07/Apr/20 14:06
Worklog Time Spent: 10m 
  Work Description: chamikaramj commented on issue #11244: [BEAM-3097] 
_ReadFromBigQuery supports valueprovider for table
URL: https://github.com/apache/beam/pull/11244#issuecomment-610407671
 
 
   LGTM. Thanks.
 

This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 417697)
Time Spent: 3h 40m  (was: 3.5h)

> Allow BigQuerySource to take a ValueProvider as a table input.
> --
>
> Key: BEAM-3097
> URL: https://issues.apache.org/jira/browse/BEAM-3097
> Project: Beam
>  Issue Type: Improvement
>  Components: sdk-py-core
>Reporter: Ed Mothershaw
>Priority: Minor
>   Original Estimate: 2h
>  Time Spent: 3h 40m
>  Remaining Estimate: 0h
>
> In file sdks/python/apache_beam/io/gcp/bigquery.py, class BigQuery, line 389. 
> When a ValueProvider is input as table the script will fail.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Work logged] (BEAM-3097) Allow BigQuerySource to take a ValueProvider as a table input.

2020-04-06 Thread ASF GitHub Bot (Jira)


 [ 
https://issues.apache.org/jira/browse/BEAM-3097?focusedWorklogId=417136&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-417136
 ]

ASF GitHub Bot logged work on BEAM-3097:


Author: ASF GitHub Bot
Created on: 06/Apr/20 21:20
Start Date: 06/Apr/20 21:20
Worklog Time Spent: 10m 
  Work Description: pabloem commented on issue #11244: [BEAM-3097] 
_ReadFromBigQuery supports valueprovider for table
URL: https://github.com/apache/beam/pull/11244#issuecomment-610042807
 
 
   @chamikaramj any other comments? I might merge as Kamil has approved and 
your ocmments have been addressed
 

This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 417136)
Time Spent: 3.5h  (was: 3h 20m)

> Allow BigQuerySource to take a ValueProvider as a table input.
> --
>
> Key: BEAM-3097
> URL: https://issues.apache.org/jira/browse/BEAM-3097
> Project: Beam
>  Issue Type: Improvement
>  Components: sdk-py-core
>Reporter: Ed Mothershaw
>Priority: Minor
>   Original Estimate: 2h
>  Time Spent: 3.5h
>  Remaining Estimate: 0h
>
> In file sdks/python/apache_beam/io/gcp/bigquery.py, class BigQuery, line 389. 
> When a ValueProvider is input as table the script will fail.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Work logged] (BEAM-3097) Allow BigQuerySource to take a ValueProvider as a table input.

2020-04-06 Thread ASF GitHub Bot (Jira)


 [ 
https://issues.apache.org/jira/browse/BEAM-3097?focusedWorklogId=417135&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-417135
 ]

ASF GitHub Bot logged work on BEAM-3097:


Author: ASF GitHub Bot
Created on: 06/Apr/20 21:19
Start Date: 06/Apr/20 21:19
Worklog Time Spent: 10m 
  Work Description: pabloem commented on issue #11244: [BEAM-3097] 
_ReadFromBigQuery supports valueprovider for table
URL: https://github.com/apache/beam/pull/11244#issuecomment-610042507
 
 
   Failure is HDFS integration test. unrelated to this.
 

This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 417135)
Time Spent: 3h 20m  (was: 3h 10m)

> Allow BigQuerySource to take a ValueProvider as a table input.
> --
>
> Key: BEAM-3097
> URL: https://issues.apache.org/jira/browse/BEAM-3097
> Project: Beam
>  Issue Type: Improvement
>  Components: sdk-py-core
>Reporter: Ed Mothershaw
>Priority: Minor
>   Original Estimate: 2h
>  Time Spent: 3h 20m
>  Remaining Estimate: 0h
>
> In file sdks/python/apache_beam/io/gcp/bigquery.py, class BigQuery, line 389. 
> When a ValueProvider is input as table the script will fail.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Work logged] (BEAM-3097) Allow BigQuerySource to take a ValueProvider as a table input.

2020-04-06 Thread ASF GitHub Bot (Jira)


 [ 
https://issues.apache.org/jira/browse/BEAM-3097?focusedWorklogId=416508&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-416508
 ]

ASF GitHub Bot logged work on BEAM-3097:


Author: ASF GitHub Bot
Created on: 06/Apr/20 10:57
Start Date: 06/Apr/20 10:57
Worklog Time Spent: 10m 
  Work Description: kamilwu commented on issue #11244: [BEAM-3097] 
_ReadFromBigQuery supports valueprovider for table
URL: https://github.com/apache/beam/pull/11244#issuecomment-609723986
 
 
   Run Python 3.7 PostCommit
 

This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 416508)
Time Spent: 3h 10m  (was: 3h)

> Allow BigQuerySource to take a ValueProvider as a table input.
> --
>
> Key: BEAM-3097
> URL: https://issues.apache.org/jira/browse/BEAM-3097
> Project: Beam
>  Issue Type: Improvement
>  Components: sdk-py-core
>Reporter: Ed Mothershaw
>Priority: Minor
>   Original Estimate: 2h
>  Time Spent: 3h 10m
>  Remaining Estimate: 0h
>
> In file sdks/python/apache_beam/io/gcp/bigquery.py, class BigQuery, line 389. 
> When a ValueProvider is input as table the script will fail.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Work logged] (BEAM-3097) Allow BigQuerySource to take a ValueProvider as a table input.

2020-04-06 Thread ASF GitHub Bot (Jira)


 [ 
https://issues.apache.org/jira/browse/BEAM-3097?focusedWorklogId=416507&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-416507
 ]

ASF GitHub Bot logged work on BEAM-3097:


Author: ASF GitHub Bot
Created on: 06/Apr/20 10:56
Start Date: 06/Apr/20 10:56
Worklog Time Spent: 10m 
  Work Description: kamilwu commented on issue #11244: [BEAM-3097] 
_ReadFromBigQuery supports valueprovider for table
URL: https://github.com/apache/beam/pull/11244#issuecomment-609723916
 
 
   This time it failed because of `docker-credential-gcloud not installed or 
not available in PATH`. This is a known issue, we have a ticket for that: 
https://issues.apache.org/jira/browse/BEAM-8409
 

This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 416507)
Time Spent: 3h  (was: 2h 50m)

> Allow BigQuerySource to take a ValueProvider as a table input.
> --
>
> Key: BEAM-3097
> URL: https://issues.apache.org/jira/browse/BEAM-3097
> Project: Beam
>  Issue Type: Improvement
>  Components: sdk-py-core
>Reporter: Ed Mothershaw
>Priority: Minor
>   Original Estimate: 2h
>  Time Spent: 3h
>  Remaining Estimate: 0h
>
> In file sdks/python/apache_beam/io/gcp/bigquery.py, class BigQuery, line 389. 
> When a ValueProvider is input as table the script will fail.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Work logged] (BEAM-3097) Allow BigQuerySource to take a ValueProvider as a table input.

2020-04-03 Thread ASF GitHub Bot (Jira)


 [ 
https://issues.apache.org/jira/browse/BEAM-3097?focusedWorklogId=415808&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-415808
 ]

ASF GitHub Bot logged work on BEAM-3097:


Author: ASF GitHub Bot
Created on: 03/Apr/20 22:58
Start Date: 03/Apr/20 22:58
Worklog Time Spent: 10m 
  Work Description: pabloem commented on issue #11244: [BEAM-3097] 
_ReadFromBigQuery supports valueprovider for table
URL: https://github.com/apache/beam/pull/11244#issuecomment-608768810
 
 
   Run Python 3.7 PostCommit
 

This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 415808)
Time Spent: 2h 50m  (was: 2h 40m)

> Allow BigQuerySource to take a ValueProvider as a table input.
> --
>
> Key: BEAM-3097
> URL: https://issues.apache.org/jira/browse/BEAM-3097
> Project: Beam
>  Issue Type: Improvement
>  Components: sdk-py-core
>Reporter: Ed Mothershaw
>Priority: Minor
>   Original Estimate: 2h
>  Time Spent: 2h 50m
>  Remaining Estimate: 0h
>
> In file sdks/python/apache_beam/io/gcp/bigquery.py, class BigQuery, line 389. 
> When a ValueProvider is input as table the script will fail.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Work logged] (BEAM-3097) Allow BigQuerySource to take a ValueProvider as a table input.

2020-04-03 Thread ASF GitHub Bot (Jira)


 [ 
https://issues.apache.org/jira/browse/BEAM-3097?focusedWorklogId=415758&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-415758
 ]

ASF GitHub Bot logged work on BEAM-3097:


Author: ASF GitHub Bot
Created on: 03/Apr/20 21:43
Start Date: 03/Apr/20 21:43
Worklog Time Spent: 10m 
  Work Description: pabloem commented on pull request #11244: [BEAM-3097] 
_ReadFromBigQuery supports valueprovider for table
URL: https://github.com/apache/beam/pull/11244#discussion_r403350713
 
 

 ##
 File path: sdks/python/apache_beam/io/gcp/bigquery.py
 ##
 @@ -657,6 +664,10 @@ def estimate_size(self):
   kms_key=self.kms_key)
   size = int(job.statistics.totalBytesProcessed)
   return size
+else:
+  # Size estimation is best effort. We return 0 as we have no
+  # access to the query that we're running.
+  return 0
 
 Review comment:
   Done
 

This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 415758)
Time Spent: 2h 40m  (was: 2.5h)

> Allow BigQuerySource to take a ValueProvider as a table input.
> --
>
> Key: BEAM-3097
> URL: https://issues.apache.org/jira/browse/BEAM-3097
> Project: Beam
>  Issue Type: Improvement
>  Components: sdk-py-core
>Reporter: Ed Mothershaw
>Priority: Minor
>   Original Estimate: 2h
>  Time Spent: 2h 40m
>  Remaining Estimate: 0h
>
> In file sdks/python/apache_beam/io/gcp/bigquery.py, class BigQuery, line 389. 
> When a ValueProvider is input as table the script will fail.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Work logged] (BEAM-3097) Allow BigQuerySource to take a ValueProvider as a table input.

2020-04-03 Thread ASF GitHub Bot (Jira)


 [ 
https://issues.apache.org/jira/browse/BEAM-3097?focusedWorklogId=415756&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-415756
 ]

ASF GitHub Bot logged work on BEAM-3097:


Author: ASF GitHub Bot
Created on: 03/Apr/20 21:42
Start Date: 03/Apr/20 21:42
Worklog Time Spent: 10m 
  Work Description: pabloem commented on pull request #11244: [BEAM-3097] 
_ReadFromBigQuery supports valueprovider for table
URL: https://github.com/apache/beam/pull/11244#discussion_r403350549
 
 

 ##
 File path: sdks/python/apache_beam/io/gcp/bigquery.py
 ##
 @@ -641,12 +641,19 @@ def __init__(
   def estimate_size(self):
 bq = bigquery_tools.BigQueryWrapper()
 if self.table_reference is not None:
+  table_ref = self.table_reference
+  if (isinstance(self.table_reference, vp.ValueProvider) and
+  self.table_reference.is_accessible()):
+table_ref = bigquery_tools.parse_table_reference(
+self.table_reference.get(), self.dataset, self.project)
+  elif isinstance(self.table_reference, vp.ValueProvider):
+# Size estimation is best effort. We return 0 as we have no
+# access to the table that we're querying.
+return 0
   table = bq.get_table(
-  self.table_reference.projectId,
-  self.table_reference.datasetId,
-  self.table_reference.tableId)
+  table_ref.projectId, table_ref.datasetId, table_ref.tableId)
   return int(table.numBytes)
-else:
+elif self.query is not None and self.query.is_accessible():
   job = bq._start_query_job(
 
 Review comment:
   if you look at line 663, it is a dry run : )
 

This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 415756)
Time Spent: 2h 20m  (was: 2h 10m)

> Allow BigQuerySource to take a ValueProvider as a table input.
> --
>
> Key: BEAM-3097
> URL: https://issues.apache.org/jira/browse/BEAM-3097
> Project: Beam
>  Issue Type: Improvement
>  Components: sdk-py-core
>Reporter: Ed Mothershaw
>Priority: Minor
>   Original Estimate: 2h
>  Time Spent: 2h 20m
>  Remaining Estimate: 0h
>
> In file sdks/python/apache_beam/io/gcp/bigquery.py, class BigQuery, line 389. 
> When a ValueProvider is input as table the script will fail.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Work logged] (BEAM-3097) Allow BigQuerySource to take a ValueProvider as a table input.

2020-04-03 Thread ASF GitHub Bot (Jira)


 [ 
https://issues.apache.org/jira/browse/BEAM-3097?focusedWorklogId=415757&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-415757
 ]

ASF GitHub Bot logged work on BEAM-3097:


Author: ASF GitHub Bot
Created on: 03/Apr/20 21:42
Start Date: 03/Apr/20 21:42
Worklog Time Spent: 10m 
  Work Description: pabloem commented on pull request #11244: [BEAM-3097] 
_ReadFromBigQuery supports valueprovider for table
URL: https://github.com/apache/beam/pull/11244#discussion_r403350683
 
 

 ##
 File path: sdks/python/apache_beam/io/gcp/bigquery.py
 ##
 @@ -641,12 +641,19 @@ def __init__(
   def estimate_size(self):
 bq = bigquery_tools.BigQueryWrapper()
 if self.table_reference is not None:
+  table_ref = self.table_reference
+  if (isinstance(self.table_reference, vp.ValueProvider) and
+  self.table_reference.is_accessible()):
+table_ref = bigquery_tools.parse_table_reference(
+self.table_reference.get(), self.dataset, self.project)
+  elif isinstance(self.table_reference, vp.ValueProvider):
+# Size estimation is best effort. We return 0 as we have no
+# access to the table that we're querying.
+return 0
 
 Review comment:
   Done
 

This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 415757)
Time Spent: 2.5h  (was: 2h 20m)

> Allow BigQuerySource to take a ValueProvider as a table input.
> --
>
> Key: BEAM-3097
> URL: https://issues.apache.org/jira/browse/BEAM-3097
> Project: Beam
>  Issue Type: Improvement
>  Components: sdk-py-core
>Reporter: Ed Mothershaw
>Priority: Minor
>   Original Estimate: 2h
>  Time Spent: 2.5h
>  Remaining Estimate: 0h
>
> In file sdks/python/apache_beam/io/gcp/bigquery.py, class BigQuery, line 389. 
> When a ValueProvider is input as table the script will fail.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Work logged] (BEAM-3097) Allow BigQuerySource to take a ValueProvider as a table input.

2020-04-03 Thread ASF GitHub Bot (Jira)


 [ 
https://issues.apache.org/jira/browse/BEAM-3097?focusedWorklogId=415755&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-415755
 ]

ASF GitHub Bot logged work on BEAM-3097:


Author: ASF GitHub Bot
Created on: 03/Apr/20 21:42
Start Date: 03/Apr/20 21:42
Worklog Time Spent: 10m 
  Work Description: pabloem commented on pull request #11244: [BEAM-3097] 
_ReadFromBigQuery supports valueprovider for table
URL: https://github.com/apache/beam/pull/11244#discussion_r403350428
 
 

 ##
 File path: sdks/python/apache_beam/io/gcp/bigquery.py
 ##
 @@ -641,12 +641,19 @@ def __init__(
   def estimate_size(self):
 bq = bigquery_tools.BigQueryWrapper()
 if self.table_reference is not None:
+  table_ref = self.table_reference
+  if (isinstance(self.table_reference, vp.ValueProvider) and
+  self.table_reference.is_accessible()):
+table_ref = bigquery_tools.parse_table_reference(
+self.table_reference.get(), self.dataset, self.project)
+  elif isinstance(self.table_reference, vp.ValueProvider):
+# Size estimation is best effort. We return 0 as we have no
+# access to the table that we're querying.
+return 0
   table = bq.get_table(
-  self.table_reference.projectId,
-  self.table_reference.datasetId,
-  self.table_reference.tableId)
+  table_ref.projectId, table_ref.datasetId, table_ref.tableId)
   return int(table.numBytes)
-else:
+elif self.query is not None and self.query.is_accessible():
 
 Review comment:
   It is supported now. In this case, the `self.query` parameter is wrapped by 
a ValueProvider already. This does not work for `self.table` because it may be 
a non-string.
 

This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 415755)
Time Spent: 2h 10m  (was: 2h)

> Allow BigQuerySource to take a ValueProvider as a table input.
> --
>
> Key: BEAM-3097
> URL: https://issues.apache.org/jira/browse/BEAM-3097
> Project: Beam
>  Issue Type: Improvement
>  Components: sdk-py-core
>Reporter: Ed Mothershaw
>Priority: Minor
>   Original Estimate: 2h
>  Time Spent: 2h 10m
>  Remaining Estimate: 0h
>
> In file sdks/python/apache_beam/io/gcp/bigquery.py, class BigQuery, line 389. 
> When a ValueProvider is input as table the script will fail.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Work logged] (BEAM-3097) Allow BigQuerySource to take a ValueProvider as a table input.

2020-04-03 Thread ASF GitHub Bot (Jira)


 [ 
https://issues.apache.org/jira/browse/BEAM-3097?focusedWorklogId=415705&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-415705
 ]

ASF GitHub Bot logged work on BEAM-3097:


Author: ASF GitHub Bot
Created on: 03/Apr/20 20:06
Start Date: 03/Apr/20 20:06
Worklog Time Spent: 10m 
  Work Description: pabloem commented on issue #11244: [BEAM-3097] 
_ReadFromBigQuery supports valueprovider for table
URL: https://github.com/apache/beam/pull/11244#issuecomment-608634124
 
 
   i dont understand why it's failing on permission issues now..
 

This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 415705)
Remaining Estimate: 0h  (was: 10m)
Time Spent: 2h  (was: 1h 50m)

> Allow BigQuerySource to take a ValueProvider as a table input.
> --
>
> Key: BEAM-3097
> URL: https://issues.apache.org/jira/browse/BEAM-3097
> Project: Beam
>  Issue Type: Improvement
>  Components: sdk-py-core
>Reporter: Ed Mothershaw
>Priority: Minor
>   Original Estimate: 2h
>  Time Spent: 2h
>  Remaining Estimate: 0h
>
> In file sdks/python/apache_beam/io/gcp/bigquery.py, class BigQuery, line 389. 
> When a ValueProvider is input as table the script will fail.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Work logged] (BEAM-3097) Allow BigQuerySource to take a ValueProvider as a table input.

2020-04-02 Thread ASF GitHub Bot (Jira)


 [ 
https://issues.apache.org/jira/browse/BEAM-3097?focusedWorklogId=415206&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-415206
 ]

ASF GitHub Bot logged work on BEAM-3097:


Author: ASF GitHub Bot
Created on: 03/Apr/20 00:24
Start Date: 03/Apr/20 00:24
Worklog Time Spent: 10m 
  Work Description: chamikaramj commented on pull request #11244: 
[BEAM-3097] _ReadFromBigQuery supports valueprovider for table
URL: https://github.com/apache/beam/pull/11244#discussion_r402668065
 
 

 ##
 File path: sdks/python/apache_beam/io/gcp/bigquery.py
 ##
 @@ -641,12 +641,19 @@ def __init__(
   def estimate_size(self):
 bq = bigquery_tools.BigQueryWrapper()
 if self.table_reference is not None:
+  table_ref = self.table_reference
+  if (isinstance(self.table_reference, vp.ValueProvider) and
+  self.table_reference.is_accessible()):
+table_ref = bigquery_tools.parse_table_reference(
+self.table_reference.get(), self.dataset, self.project)
+  elif isinstance(self.table_reference, vp.ValueProvider):
+# Size estimation is best effort. We return 0 as we have no
+# access to the table that we're querying.
+return 0
   table = bq.get_table(
-  self.table_reference.projectId,
-  self.table_reference.datasetId,
-  self.table_reference.tableId)
+  table_ref.projectId, table_ref.datasetId, table_ref.tableId)
   return int(table.numBytes)
-else:
+elif self.query is not None and self.query.is_accessible():
   job = bq._start_query_job(
 
 Review comment:
   Not from this PR but shouldn't this be a dry run ?
 

This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 415206)
Remaining Estimate: 10m  (was: 20m)
Time Spent: 1h 50m  (was: 1h 40m)

> Allow BigQuerySource to take a ValueProvider as a table input.
> --
>
> Key: BEAM-3097
> URL: https://issues.apache.org/jira/browse/BEAM-3097
> Project: Beam
>  Issue Type: Improvement
>  Components: sdk-py-core
>Reporter: Ed Mothershaw
>Priority: Minor
>   Original Estimate: 2h
>  Time Spent: 1h 50m
>  Remaining Estimate: 10m
>
> In file sdks/python/apache_beam/io/gcp/bigquery.py, class BigQuery, line 389. 
> When a ValueProvider is input as table the script will fail.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Work logged] (BEAM-3097) Allow BigQuerySource to take a ValueProvider as a table input.

2020-04-02 Thread ASF GitHub Bot (Jira)


 [ 
https://issues.apache.org/jira/browse/BEAM-3097?focusedWorklogId=415202&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-415202
 ]

ASF GitHub Bot logged work on BEAM-3097:


Author: ASF GitHub Bot
Created on: 03/Apr/20 00:23
Start Date: 03/Apr/20 00:23
Worklog Time Spent: 10m 
  Work Description: chamikaramj commented on pull request #11244: 
[BEAM-3097] _ReadFromBigQuery supports valueprovider for table
URL: https://github.com/apache/beam/pull/11244#discussion_r402668065
 
 

 ##
 File path: sdks/python/apache_beam/io/gcp/bigquery.py
 ##
 @@ -641,12 +641,19 @@ def __init__(
   def estimate_size(self):
 bq = bigquery_tools.BigQueryWrapper()
 if self.table_reference is not None:
+  table_ref = self.table_reference
+  if (isinstance(self.table_reference, vp.ValueProvider) and
+  self.table_reference.is_accessible()):
+table_ref = bigquery_tools.parse_table_reference(
+self.table_reference.get(), self.dataset, self.project)
+  elif isinstance(self.table_reference, vp.ValueProvider):
+# Size estimation is best effort. We return 0 as we have no
+# access to the table that we're querying.
+return 0
   table = bq.get_table(
-  self.table_reference.projectId,
-  self.table_reference.datasetId,
-  self.table_reference.tableId)
+  table_ref.projectId, table_ref.datasetId, table_ref.tableId)
   return int(table.numBytes)
-else:
+elif self.query is not None and self.query.is_accessible():
   job = bq._start_query_job(
 
 Review comment:
   For from this PR but shouldn't this be a dry run ?
 

This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 415202)
Remaining Estimate: 0.5h  (was: 40m)
Time Spent: 1.5h  (was: 1h 20m)

> Allow BigQuerySource to take a ValueProvider as a table input.
> --
>
> Key: BEAM-3097
> URL: https://issues.apache.org/jira/browse/BEAM-3097
> Project: Beam
>  Issue Type: Improvement
>  Components: sdk-py-core
>Reporter: Ed Mothershaw
>Priority: Minor
>   Original Estimate: 2h
>  Time Spent: 1.5h
>  Remaining Estimate: 0.5h
>
> In file sdks/python/apache_beam/io/gcp/bigquery.py, class BigQuery, line 389. 
> When a ValueProvider is input as table the script will fail.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Work logged] (BEAM-3097) Allow BigQuerySource to take a ValueProvider as a table input.

2020-04-02 Thread ASF GitHub Bot (Jira)


 [ 
https://issues.apache.org/jira/browse/BEAM-3097?focusedWorklogId=415205&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-415205
 ]

ASF GitHub Bot logged work on BEAM-3097:


Author: ASF GitHub Bot
Created on: 03/Apr/20 00:23
Start Date: 03/Apr/20 00:23
Worklog Time Spent: 10m 
  Work Description: chamikaramj commented on pull request #11244: 
[BEAM-3097] _ReadFromBigQuery supports valueprovider for table
URL: https://github.com/apache/beam/pull/11244#discussion_r402669567
 
 

 ##
 File path: sdks/python/apache_beam/io/gcp/bigquery.py
 ##
 @@ -641,12 +641,19 @@ def __init__(
   def estimate_size(self):
 bq = bigquery_tools.BigQueryWrapper()
 if self.table_reference is not None:
+  table_ref = self.table_reference
+  if (isinstance(self.table_reference, vp.ValueProvider) and
+  self.table_reference.is_accessible()):
+table_ref = bigquery_tools.parse_table_reference(
+self.table_reference.get(), self.dataset, self.project)
+  elif isinstance(self.table_reference, vp.ValueProvider):
+# Size estimation is best effort. We return 0 as we have no
+# access to the table that we're querying.
+return 0
 
 Review comment:
   We have to return None if size cannot be determined. See spec here: 
https://github.com/apache/beam/blob/master/sdks/python/apache_beam/io/iobase.py#L157
 

This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 415205)
Remaining Estimate: 20m  (was: 0.5h)
Time Spent: 1h 40m  (was: 1.5h)

> Allow BigQuerySource to take a ValueProvider as a table input.
> --
>
> Key: BEAM-3097
> URL: https://issues.apache.org/jira/browse/BEAM-3097
> Project: Beam
>  Issue Type: Improvement
>  Components: sdk-py-core
>Reporter: Ed Mothershaw
>Priority: Minor
>   Original Estimate: 2h
>  Time Spent: 1h 40m
>  Remaining Estimate: 20m
>
> In file sdks/python/apache_beam/io/gcp/bigquery.py, class BigQuery, line 389. 
> When a ValueProvider is input as table the script will fail.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Work logged] (BEAM-3097) Allow BigQuerySource to take a ValueProvider as a table input.

2020-04-02 Thread ASF GitHub Bot (Jira)


 [ 
https://issues.apache.org/jira/browse/BEAM-3097?focusedWorklogId=415204&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-415204
 ]

ASF GitHub Bot logged work on BEAM-3097:


Author: ASF GitHub Bot
Created on: 03/Apr/20 00:23
Start Date: 03/Apr/20 00:23
Worklog Time Spent: 10m 
  Work Description: chamikaramj commented on pull request #11244: 
[BEAM-3097] _ReadFromBigQuery supports valueprovider for table
URL: https://github.com/apache/beam/pull/11244#discussion_r402669596
 
 

 ##
 File path: sdks/python/apache_beam/io/gcp/bigquery.py
 ##
 @@ -657,6 +664,10 @@ def estimate_size(self):
   kms_key=self.kms_key)
   size = int(job.statistics.totalBytesProcessed)
   return size
+else:
+  # Size estimation is best effort. We return 0 as we have no
+  # access to the query that we're running.
+  return 0
 
 Review comment:
   Ditto.
 

This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 415204)
Remaining Estimate: 0.5h  (was: 40m)
Time Spent: 1.5h  (was: 1h 20m)

> Allow BigQuerySource to take a ValueProvider as a table input.
> --
>
> Key: BEAM-3097
> URL: https://issues.apache.org/jira/browse/BEAM-3097
> Project: Beam
>  Issue Type: Improvement
>  Components: sdk-py-core
>Reporter: Ed Mothershaw
>Priority: Minor
>   Original Estimate: 2h
>  Time Spent: 1.5h
>  Remaining Estimate: 0.5h
>
> In file sdks/python/apache_beam/io/gcp/bigquery.py, class BigQuery, line 389. 
> When a ValueProvider is input as table the script will fail.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Work logged] (BEAM-3097) Allow BigQuerySource to take a ValueProvider as a table input.

2020-04-02 Thread ASF GitHub Bot (Jira)


 [ 
https://issues.apache.org/jira/browse/BEAM-3097?focusedWorklogId=415203&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-415203
 ]

ASF GitHub Bot logged work on BEAM-3097:


Author: ASF GitHub Bot
Created on: 03/Apr/20 00:23
Start Date: 03/Apr/20 00:23
Worklog Time Spent: 10m 
  Work Description: chamikaramj commented on pull request #11244: 
[BEAM-3097] _ReadFromBigQuery supports valueprovider for table
URL: https://github.com/apache/beam/pull/11244#discussion_r402668608
 
 

 ##
 File path: sdks/python/apache_beam/io/gcp/bigquery.py
 ##
 @@ -641,12 +641,19 @@ def __init__(
   def estimate_size(self):
 bq = bigquery_tools.BigQueryWrapper()
 if self.table_reference is not None:
+  table_ref = self.table_reference
+  if (isinstance(self.table_reference, vp.ValueProvider) and
+  self.table_reference.is_accessible()):
+table_ref = bigquery_tools.parse_table_reference(
+self.table_reference.get(), self.dataset, self.project)
+  elif isinstance(self.table_reference, vp.ValueProvider):
+# Size estimation is best effort. We return 0 as we have no
+# access to the table that we're querying.
+return 0
   table = bq.get_table(
-  self.table_reference.projectId,
-  self.table_reference.datasetId,
-  self.table_reference.tableId)
+  table_ref.projectId, table_ref.datasetId, table_ref.tableId)
   return int(table.numBytes)
-else:
+elif self.query is not None and self.query.is_accessible():
 
 Review comment:
   Shouldn't we support ValueProvider for queries as well ?
 

This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 415203)
Remaining Estimate: 0.5h  (was: 40m)
Time Spent: 1.5h  (was: 1h 20m)

> Allow BigQuerySource to take a ValueProvider as a table input.
> --
>
> Key: BEAM-3097
> URL: https://issues.apache.org/jira/browse/BEAM-3097
> Project: Beam
>  Issue Type: Improvement
>  Components: sdk-py-core
>Reporter: Ed Mothershaw
>Priority: Minor
>   Original Estimate: 2h
>  Time Spent: 1.5h
>  Remaining Estimate: 0.5h
>
> In file sdks/python/apache_beam/io/gcp/bigquery.py, class BigQuery, line 389. 
> When a ValueProvider is input as table the script will fail.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Work logged] (BEAM-3097) Allow BigQuerySource to take a ValueProvider as a table input.

2020-04-01 Thread ASF GitHub Bot (Jira)


 [ 
https://issues.apache.org/jira/browse/BEAM-3097?focusedWorklogId=414309&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-414309
 ]

ASF GitHub Bot logged work on BEAM-3097:


Author: ASF GitHub Bot
Created on: 01/Apr/20 21:58
Start Date: 01/Apr/20 21:58
Worklog Time Spent: 10m 
  Work Description: pabloem commented on issue #11244: [BEAM-3097] 
_ReadFromBigQuery supports valueprovider for table
URL: https://github.com/apache/beam/pull/11244#issuecomment-607510701
 
 
   Run Python 3.7 PostCommit
 

This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 414309)
Remaining Estimate: 40m  (was: 50m)
Time Spent: 1h 20m  (was: 1h 10m)

> Allow BigQuerySource to take a ValueProvider as a table input.
> --
>
> Key: BEAM-3097
> URL: https://issues.apache.org/jira/browse/BEAM-3097
> Project: Beam
>  Issue Type: Improvement
>  Components: sdk-py-core
>Reporter: Ed Mothershaw
>Priority: Minor
>   Original Estimate: 2h
>  Time Spent: 1h 20m
>  Remaining Estimate: 40m
>
> In file sdks/python/apache_beam/io/gcp/bigquery.py, class BigQuery, line 389. 
> When a ValueProvider is input as table the script will fail.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Work logged] (BEAM-3097) Allow BigQuerySource to take a ValueProvider as a table input.

2020-04-01 Thread ASF GitHub Bot (Jira)


 [ 
https://issues.apache.org/jira/browse/BEAM-3097?focusedWorklogId=414210&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-414210
 ]

ASF GitHub Bot logged work on BEAM-3097:


Author: ASF GitHub Bot
Created on: 01/Apr/20 18:34
Start Date: 01/Apr/20 18:34
Worklog Time Spent: 10m 
  Work Description: pabloem commented on issue #11244: [BEAM-3097] 
_ReadFromBigQuery supports valueprovider for table
URL: https://github.com/apache/beam/pull/11244#issuecomment-607421085
 
 
   Run Python PreCommit
 

This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 414210)
Remaining Estimate: 50m  (was: 1h)
Time Spent: 1h 10m  (was: 1h)

> Allow BigQuerySource to take a ValueProvider as a table input.
> --
>
> Key: BEAM-3097
> URL: https://issues.apache.org/jira/browse/BEAM-3097
> Project: Beam
>  Issue Type: Improvement
>  Components: sdk-py-core
>Reporter: Ed Mothershaw
>Priority: Minor
>   Original Estimate: 2h
>  Time Spent: 1h 10m
>  Remaining Estimate: 50m
>
> In file sdks/python/apache_beam/io/gcp/bigquery.py, class BigQuery, line 389. 
> When a ValueProvider is input as table the script will fail.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Work logged] (BEAM-3097) Allow BigQuerySource to take a ValueProvider as a table input.

2020-04-01 Thread ASF GitHub Bot (Jira)


 [ 
https://issues.apache.org/jira/browse/BEAM-3097?focusedWorklogId=413945&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-413945
 ]

ASF GitHub Bot logged work on BEAM-3097:


Author: ASF GitHub Bot
Created on: 01/Apr/20 10:07
Start Date: 01/Apr/20 10:07
Worklog Time Spent: 10m 
  Work Description: kamilwu commented on issue #11244: [BEAM-3097] 
_ReadFromBigQuery supports valueprovider for table
URL: https://github.com/apache/beam/pull/11244#issuecomment-607159015
 
 
   This looks great! Thank you @pabloem, I have nothing to add
 

This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 413945)
Remaining Estimate: 1h  (was: 1h 10m)
Time Spent: 1h  (was: 50m)

> Allow BigQuerySource to take a ValueProvider as a table input.
> --
>
> Key: BEAM-3097
> URL: https://issues.apache.org/jira/browse/BEAM-3097
> Project: Beam
>  Issue Type: Improvement
>  Components: sdk-py-core
>Reporter: Ed Mothershaw
>Priority: Minor
>   Original Estimate: 2h
>  Time Spent: 1h
>  Remaining Estimate: 1h
>
> In file sdks/python/apache_beam/io/gcp/bigquery.py, class BigQuery, line 389. 
> When a ValueProvider is input as table the script will fail.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Work logged] (BEAM-3097) Allow BigQuerySource to take a ValueProvider as a table input.

2020-03-31 Thread ASF GitHub Bot (Jira)


 [ 
https://issues.apache.org/jira/browse/BEAM-3097?focusedWorklogId=413593&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-413593
 ]

ASF GitHub Bot logged work on BEAM-3097:


Author: ASF GitHub Bot
Created on: 31/Mar/20 22:50
Start Date: 31/Mar/20 22:50
Worklog Time Spent: 10m 
  Work Description: pabloem commented on issue #11244: [BEAM-3097] 
_ReadFromBigQuery supports valueprovider for table
URL: https://github.com/apache/beam/pull/11244#issuecomment-606925872
 
 
   r: @chamikaramj 
 

This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 413593)
Remaining Estimate: 1h 10m  (was: 1h 20m)
Time Spent: 50m  (was: 40m)

> Allow BigQuerySource to take a ValueProvider as a table input.
> --
>
> Key: BEAM-3097
> URL: https://issues.apache.org/jira/browse/BEAM-3097
> Project: Beam
>  Issue Type: Improvement
>  Components: sdk-py-core
>Reporter: Ed Mothershaw
>Priority: Minor
>   Original Estimate: 2h
>  Time Spent: 50m
>  Remaining Estimate: 1h 10m
>
> In file sdks/python/apache_beam/io/gcp/bigquery.py, class BigQuery, line 389. 
> When a ValueProvider is input as table the script will fail.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Work logged] (BEAM-3097) Allow BigQuerySource to take a ValueProvider as a table input.

2020-03-28 Thread ASF GitHub Bot (Jira)


 [ 
https://issues.apache.org/jira/browse/BEAM-3097?focusedWorklogId=411785&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-411785
 ]

ASF GitHub Bot logged work on BEAM-3097:


Author: ASF GitHub Bot
Created on: 28/Mar/20 19:53
Start Date: 28/Mar/20 19:53
Worklog Time Spent: 10m 
  Work Description: pabloem commented on issue #11244: [BEAM-3097] 
_ReadFromBigQuery supports valueprovider for table
URL: https://github.com/apache/beam/pull/11244#issuecomment-605510718
 
 
   passing pc before formatting: 
https://builds.apache.org/job/beam_PostCommit_Python37_PR/122/
 

This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 411785)
Remaining Estimate: 1h 20m  (was: 1.5h)
Time Spent: 40m  (was: 0.5h)

> Allow BigQuerySource to take a ValueProvider as a table input.
> --
>
> Key: BEAM-3097
> URL: https://issues.apache.org/jira/browse/BEAM-3097
> Project: Beam
>  Issue Type: Improvement
>  Components: sdk-py-core
>Reporter: Ed Mothershaw
>Priority: Minor
>   Original Estimate: 2h
>  Time Spent: 40m
>  Remaining Estimate: 1h 20m
>
> In file sdks/python/apache_beam/io/gcp/bigquery.py, class BigQuery, line 389. 
> When a ValueProvider is input as table the script will fail.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Work logged] (BEAM-3097) Allow BigQuerySource to take a ValueProvider as a table input.

2020-03-27 Thread ASF GitHub Bot (Jira)


 [ 
https://issues.apache.org/jira/browse/BEAM-3097?focusedWorklogId=411244&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-411244
 ]

ASF GitHub Bot logged work on BEAM-3097:


Author: ASF GitHub Bot
Created on: 27/Mar/20 18:11
Start Date: 27/Mar/20 18:11
Worklog Time Spent: 10m 
  Work Description: pabloem commented on issue #11244: [BEAM-3097] 
_ReadFromBigQuery supports valueprovider for table
URL: https://github.com/apache/beam/pull/11244#issuecomment-605181366
 
 
   Run Python 3.7 PostCommit
 

This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 411244)
Remaining Estimate: 1.5h  (was: 1h 40m)
Time Spent: 0.5h  (was: 20m)

> Allow BigQuerySource to take a ValueProvider as a table input.
> --
>
> Key: BEAM-3097
> URL: https://issues.apache.org/jira/browse/BEAM-3097
> Project: Beam
>  Issue Type: Improvement
>  Components: sdk-py-core
>Reporter: Ed Mothershaw
>Priority: Minor
>   Original Estimate: 2h
>  Time Spent: 0.5h
>  Remaining Estimate: 1.5h
>
> In file sdks/python/apache_beam/io/gcp/bigquery.py, class BigQuery, line 389. 
> When a ValueProvider is input as table the script will fail.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Work logged] (BEAM-3097) Allow BigQuerySource to take a ValueProvider as a table input.

2020-03-26 Thread ASF GitHub Bot (Jira)


 [ 
https://issues.apache.org/jira/browse/BEAM-3097?focusedWorklogId=410744&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-410744
 ]

ASF GitHub Bot logged work on BEAM-3097:


Author: ASF GitHub Bot
Created on: 27/Mar/20 00:50
Start Date: 27/Mar/20 00:50
Worklog Time Spent: 10m 
  Work Description: pabloem commented on pull request #11244: [BEAM-3097] 
_ReadFromBigQuery supports valueprovider for table
URL: https://github.com/apache/beam/pull/11244
 
 
   **Please** add a meaningful description for your change here
   
   
   
   Thank you for your contribution! Follow this checklist to help us 
incorporate your contribution quickly and easily:
   
- [ ] [**Choose 
reviewer(s)**](https://beam.apache.org/contribute/#make-your-change) and 
mention them in a comment (`R: @username`).
- [ ] Format the pull request title like `[BEAM-XXX] Fixes bug in 
ApproximateQuantiles`, where you replace `BEAM-XXX` with the appropriate JIRA 
issue, if applicable. This will automatically link the pull request to the 
issue.
- [ ] Update `CHANGES.md` with noteworthy changes.
- [ ] If this contribution is large, please file an Apache [Individual 
Contributor License Agreement](https://www.apache.org/licenses/icla.pdf).
   
   See the [Contributor Guide](https://beam.apache.org/contribute) for more 
tips on [how to make review process 
smoother](https://beam.apache.org/contribute/#make-reviewers-job-easier).
   
   Post-Commit Tests Status (on master branch)
   

   
   Lang | SDK | Apex | Dataflow | Flink | Gearpump | Samza | Spark
   --- | --- | --- | --- | --- | --- | --- | ---
   Go | [![Build 
Status](https://builds.apache.org/job/beam_PostCommit_Go/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Go/lastCompletedBuild/)
 | --- | --- | [![Build 
Status](https://builds.apache.org/job/beam_PostCommit_Go_VR_Flink/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Go_VR_Flink/lastCompletedBuild/)
 | --- | --- | [![Build 
Status](https://builds.apache.org/job/beam_PostCommit_Go_VR_Spark/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Go_VR_Spark/lastCompletedBuild/)
   Java | [![Build 
Status](https://builds.apache.org/job/beam_PostCommit_Java/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Java/lastCompletedBuild/)
 | [![Build 
Status](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Apex/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Apex/lastCompletedBuild/)
 | [![Build 
Status](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow/lastCompletedBuild/)[![Build
 
Status](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow_Java11/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow_Java11/lastCompletedBuild/)
 | [![Build 
Status](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink/lastCompletedBuild/)[![Build
 
Status](https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Batch/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Batch/lastCompletedBuild/)[![Build
 
Status](https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/lastCompletedBuild/)
 | [![Build 
Status](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump/lastCompletedBuild/)
 | [![Build 
Status](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Samza/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Samza/lastCompletedBuild/)
 | [![Build 
Status](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Spark/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Spark/lastCompletedBuild/)[![Build
 
Status](https://builds.apache.org/job/beam_PostCommit_Java_PVR_Spark_Batch/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Java_PVR_Spark_Batch/lastCompletedBuild/)[![Build
 
Status](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_SparkStructuredStreaming/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Java_Vali

[jira] [Work logged] (BEAM-3097) Allow BigQuerySource to take a ValueProvider as a table input.

2020-03-26 Thread ASF GitHub Bot (Jira)


 [ 
https://issues.apache.org/jira/browse/BEAM-3097?focusedWorklogId=410745&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-410745
 ]

ASF GitHub Bot logged work on BEAM-3097:


Author: ASF GitHub Bot
Created on: 27/Mar/20 00:50
Start Date: 27/Mar/20 00:50
Worklog Time Spent: 10m 
  Work Description: pabloem commented on issue #11244: [BEAM-3097] 
_ReadFromBigQuery supports valueprovider for table
URL: https://github.com/apache/beam/pull/11244#issuecomment-604759269
 
 
   Run Python 3.7 PostCommit
 

This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 410745)
Remaining Estimate: 1h 40m  (was: 1h 50m)
Time Spent: 20m  (was: 10m)

> Allow BigQuerySource to take a ValueProvider as a table input.
> --
>
> Key: BEAM-3097
> URL: https://issues.apache.org/jira/browse/BEAM-3097
> Project: Beam
>  Issue Type: Improvement
>  Components: sdk-py-core
>Reporter: Ed Mothershaw
>Priority: Minor
>   Original Estimate: 2h
>  Time Spent: 20m
>  Remaining Estimate: 1h 40m
>
> In file sdks/python/apache_beam/io/gcp/bigquery.py, class BigQuery, line 389. 
> When a ValueProvider is input as table the script will fail.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)