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 authored and tgroh committed Dec 13, 2016
1 parent 59f1fb2 commit db7b7cf
Showing 1 changed file with 6 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -118,7 +118,12 @@ public void populateDisplayData(DisplayData.Builder builder) {
public static class BoundedToUnboundedSourceAdapter<T>
extends UnboundedSource<T, BoundedToUnboundedSourceAdapter.Checkpoint<T>> {

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

private final BoundedSource<T> boundedSource;

public BoundedToUnboundedSourceAdapter(BoundedSource<T> boundedSource) {
this.boundedSource = boundedSource;
Expand Down

0 comments on commit db7b7cf

Please sign in to comment.