This is an automated email from the ASF dual-hosted git repository. echauchot pushed a commit to branch spark-runner_structured-streaming in repository https://gitbox.apache.org/repos/asf/beam.git
commit 878ff4e9fc66c5377031995d1ba67a548863c7c9 Author: Etienne Chauchot <[email protected]> AuthorDate: Thu Jan 3 15:56:11 2019 +0100 Add missing 0-arg public constructor --- .../spark/structuredstreaming/translation/batch/DatasetSourceBatch.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/runners/spark-structured-streaming/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/DatasetSourceBatch.java b/runners/spark-structured-streaming/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/DatasetSourceBatch.java index e19bbdb..496b95a 100644 --- a/runners/spark-structured-streaming/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/DatasetSourceBatch.java +++ b/runners/spark-structured-streaming/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/DatasetSourceBatch.java @@ -50,6 +50,8 @@ public class DatasetSourceBatch<T> implements DataSourceV2, ReadSupport { static final String DEFAULT_PARALLELISM = "default-parallelism"; static final String PIPELINE_OPTIONS = "pipeline-options"; + public DatasetSourceBatch() { + } @SuppressWarnings("unchecked") @Override
