[
https://issues.apache.org/jira/browse/BEAM-3749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390399#comment-16390399
]
Kenneth Knowles commented on BEAM-3749:
---
I added the test here:
[
https://issues.apache.org/jira/browse/BEAM-3749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390324#comment-16390324
]
Xu Mingmin commented on BEAM-3749:
--
Do you run a test to verify that?
> support customized
[
https://issues.apache.org/jira/browse/BEAM-3749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390311#comment-16390311
]
Kenneth Knowles commented on BEAM-3749:
---
I think this link will clarify:
[
https://issues.apache.org/jira/browse/BEAM-3749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390271#comment-16390271
]
Xu Mingmin commented on BEAM-3749:
--
I get your point, below code doesn't use the trigger set in
[
https://issues.apache.org/jira/browse/BEAM-3749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390129#comment-16390129
]
Kenneth Knowles commented on BEAM-3749:
---
What I mean is that the windowing itself is set up in the
[
https://issues.apache.org/jira/browse/BEAM-3749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390124#comment-16390124
]
Xu Mingmin commented on BEAM-3749:
--
It doesn't, with {{Window.configure()}} the code is
{code}
input
[
https://issues.apache.org/jira/browse/BEAM-3749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16387279#comment-16387279
]
Kenneth Knowles commented on BEAM-3749:
---
It turns out that the needed feature exists and is this:
[
https://issues.apache.org/jira/browse/BEAM-3749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16381653#comment-16381653
]
Xu Mingmin commented on BEAM-3749:
--
Sink-based trigger has a limitation that it cannot handle the case
[
https://issues.apache.org/jira/browse/BEAM-3749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16381530#comment-16381530
]
Robert Bradshaw commented on BEAM-3749:
---
I wonder if sink-based triggers would be a better fit here
[
https://issues.apache.org/jira/browse/BEAM-3749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16380953#comment-16380953
]
Xu Mingmin commented on BEAM-3749:
--
[
https://issues.apache.org/jira/browse/BEAM-3749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16380811#comment-16380811
]
Kenneth Knowles commented on BEAM-3749:
---
I realize a problem though - you do need to add the trigger
[
https://issues.apache.org/jira/browse/BEAM-3749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16380809#comment-16380809
]
Kenneth Knowles commented on BEAM-3749:
---
Hmm, the first bit seems like a bug. You should be able to
[
https://issues.apache.org/jira/browse/BEAM-3749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16377844#comment-16377844
]
Kenneth Knowles commented on BEAM-3749:
---
What about this?
{code}
PCollectionTuple inputTables = ...;
13 matches
Mail list logo