This is an automated email from the ASF dual-hosted git repository.
pabloem pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new 2527f02 Populate source data from SDF
new 1d3e3ef Merge pull request #11302 from [BEAM-9607] Populate source
data from SDF
2527f02 is described below
commit 2527f02950a09bfb6317130f12afa4c2156f65db
Author: Boyuan Zhang <[email protected]>
AuthorDate: Thu Apr 2 22:11:20 2020 -0700
Populate source data from SDF
---
sdks/python/apache_beam/io/iobase.py | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
diff --git a/sdks/python/apache_beam/io/iobase.py
b/sdks/python/apache_beam/io/iobase.py
index 22ad3b4..13c5ea0 100644
--- a/sdks/python/apache_beam/io/iobase.py
+++ b/sdks/python/apache_beam/io/iobase.py
@@ -1491,7 +1491,11 @@ class _SDFBoundedSourceWrapper(ptransform.PTransform):
self.source = read_source
def display_data(self):
- return {'source': self.source, 'source_type': str(type(self.source))}
+ return {
+ 'source': DisplayDataItem(
+ self.source.__class__, label='Read Source'),
+ 'source_dd': self.source
+ }
def process(
self,
