This is an automated email from the ASF dual-hosted git repository.
aljoscha pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 4ec4644952c05167f52ae0937e043140d26059ae
Author: Aljoscha Krettek <aljoscha.kret...@gmail.com>
AuthorDate: Thu Feb 8 13:01:22 2018 +0100
Make ProcessFnRunner constructor public
We need this to be able to instantiate with the constructor in the Flink
Runner.
---
.../src/main/java/org/apache/beam/runners/core/ProcessFnRunner.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/runners/core-java/src/main/java/org/apache/beam/runners/core/ProcessFnRunner.java
b/runners/core-java/src/main/java/org/apache/beam/runners/core/ProcessFnRunner.java
index 88275d6..e4dfd13 100644
---
a/runners/core-java/src/main/java/org/apache/beam/runners/core/ProcessFnRunner.java
+++
b/runners/core-java/src/main/java/org/apache/beam/runners/core/ProcessFnRunner.java
@@ -43,7 +43,7 @@ public class ProcessFnRunner<InputT, OutputT, RestrictionT>
private final Collection<PCollectionView<?>> views;
private final ReadyCheckingSideInputReader sideInputReader;
- ProcessFnRunner(
+ public ProcessFnRunner(
DoFnRunner<KeyedWorkItem<String, KV<InputT, RestrictionT>>, OutputT>
underlying,
Collection<PCollectionView<?>> views,
ReadyCheckingSideInputReader sideInputReader) {
--
To stop receiving notification emails like this one, please contact
aljos...@apache.org.
