Skip to content

Commit

Permalink
Add no-arg constructor for UnboundedReadFromBoundedSource
Browse files Browse the repository at this point in the history
This allows Kryo to work with the type, currently required by
the Apex runner.
  • Loading branch information
kennknowles committed Dec 12, 2016
1 parent 59f1fb2 commit 4124f9b
Showing 1 changed file with 5 additions and 0 deletions.
Expand Up @@ -118,6 +118,11 @@ public void populateDisplayData(DisplayData.Builder builder) {
public static class BoundedToUnboundedSourceAdapter<T>
extends UnboundedSource<T, BoundedToUnboundedSourceAdapter.Checkpoint<T>> {

@SuppressWarnings("unused") // for Kryo
private BoundedToUnboundedSourceAdapter() {
this.boundedSource = null;
}

private BoundedSource<T> boundedSource;

public BoundedToUnboundedSourceAdapter(BoundedSource<T> boundedSource) {
Expand Down

0 comments on commit 4124f9b

Please sign in to comment.