Skip to content

Commit

Permalink
Moves OldDoFn to runners-core
Browse files Browse the repository at this point in the history
  • Loading branch information
@jkff
jkff committed Jan 20, 2017
1 parent 77c7505 commit 5f8b8c5
Show file tree
Hide file tree
Showing 34 changed files with 53 additions and 49 deletions.
2 changes: 1 addition & 1 deletion ...rs/apex/src/main/java/org/apache/beam/runners/apex/translation/WindowBoundTranslator.java
View file
Expand Up @@ -23,8 +23,8 @@
import org.apache.beam.runners.apex.translation.operators.ApexParDoOperator;
import org.apache.beam.runners.core.AssignWindowsDoFn;
import org.apache.beam.runners.core.DoFnAdapters;
import org.apache.beam.runners.core.OldDoFn;
import org.apache.beam.sdk.transforms.DoFn;
import org.apache.beam.sdk.transforms.OldDoFn;
import org.apache.beam.sdk.transforms.windowing.BoundedWindow;
import org.apache.beam.sdk.transforms.windowing.Window;
import org.apache.beam.sdk.util.WindowedValue;
Expand Down
2 changes: 1 addition & 1 deletion .../main/java/org/apache/beam/runners/apex/translation/operators/ApexGroupByKeyOperator.java
View file
Expand Up @@ -44,6 +44,7 @@
import org.apache.beam.runners.core.GroupAlsoByWindowViaWindowSetDoFn;
import org.apache.beam.runners.core.KeyedWorkItem;
import org.apache.beam.runners.core.KeyedWorkItems;
import org.apache.beam.runners.core.OldDoFn;
import org.apache.beam.runners.core.SystemReduceFn;
import org.apache.beam.sdk.coders.Coder;
import org.apache.beam.sdk.coders.CoderException;
Expand All @@ -52,7 +53,6 @@
import org.apache.beam.sdk.transforms.Aggregator;
import org.apache.beam.sdk.transforms.Combine;
import org.apache.beam.sdk.transforms.GroupByKey;
import org.apache.beam.sdk.transforms.OldDoFn;
import org.apache.beam.sdk.transforms.windowing.BoundedWindow;
import org.apache.beam.sdk.transforms.windowing.PaneInfo;
import org.apache.beam.sdk.util.CoderUtils;
Expand Down
2 changes: 1 addition & 1 deletion ...x/src/main/java/org/apache/beam/runners/apex/translation/operators/ApexParDoOperator.java
View file
Expand Up @@ -43,14 +43,14 @@
import org.apache.beam.runners.core.DoFnRunners;
import org.apache.beam.runners.core.DoFnRunners.OutputManager;
import org.apache.beam.runners.core.ExecutionContext;
import org.apache.beam.runners.core.OldDoFn;
import org.apache.beam.runners.core.PushbackSideInputDoFnRunner;
import org.apache.beam.runners.core.SideInputHandler;
import org.apache.beam.sdk.coders.Coder;
import org.apache.beam.sdk.coders.ListCoder;
import org.apache.beam.sdk.transforms.Aggregator;
import org.apache.beam.sdk.transforms.Combine.CombineFn;
import org.apache.beam.sdk.transforms.DoFn;
import org.apache.beam.sdk.transforms.OldDoFn;
import org.apache.beam.sdk.util.NullSideInputReader;
import org.apache.beam.sdk.util.SideInputReader;
import org.apache.beam.sdk.util.UserCodeException;
Expand Down
3 changes: 1 addition & 2 deletions runners/core-java/src/main/java/org/apache/beam/runners/core/AssignWindowsDoFn.java
View file
Expand Up @@ -21,8 +21,7 @@

import com.google.common.collect.Iterables;
import java.util.Collection;
import org.apache.beam.sdk.transforms.OldDoFn;
import org.apache.beam.sdk.transforms.OldDoFn.RequiresWindowAccess;
import org.apache.beam.runners.core.OldDoFn.RequiresWindowAccess;
import org.apache.beam.sdk.transforms.windowing.BoundedWindow;
import org.apache.beam.sdk.transforms.windowing.PaneInfo;
import org.apache.beam.sdk.transforms.windowing.WindowFn;
Expand Down
1 change: 0 additions & 1 deletion runners/core-java/src/main/java/org/apache/beam/runners/core/DoFnAdapters.java
View file
Expand Up @@ -26,7 +26,6 @@
import org.apache.beam.sdk.transforms.DoFn.Context;
import org.apache.beam.sdk.transforms.DoFn.OnTimerContext;
import org.apache.beam.sdk.transforms.DoFn.ProcessContext;
import org.apache.beam.sdk.transforms.OldDoFn;
import org.apache.beam.sdk.transforms.display.DisplayData;
import org.apache.beam.sdk.transforms.reflect.DoFnInvoker;
import org.apache.beam.sdk.transforms.reflect.DoFnInvokers;
Expand Down
1 change: 0 additions & 1 deletion runners/core-java/src/main/java/org/apache/beam/runners/core/DoFnRunner.java
View file
Expand Up @@ -19,7 +19,6 @@

import org.apache.beam.sdk.transforms.Aggregator;
import org.apache.beam.sdk.transforms.DoFn;
import org.apache.beam.sdk.transforms.OldDoFn;
import org.apache.beam.sdk.transforms.windowing.BoundedWindow;
import org.apache.beam.sdk.util.TimeDomain;
import org.apache.beam.sdk.util.WindowedValue;
Expand Down
1 change: 0 additions & 1 deletion runners/core-java/src/main/java/org/apache/beam/runners/core/DoFnRunners.java
View file
Expand Up @@ -22,7 +22,6 @@
import org.apache.beam.sdk.options.PipelineOptions;
import org.apache.beam.sdk.transforms.Aggregator;
import org.apache.beam.sdk.transforms.DoFn;
import org.apache.beam.sdk.transforms.OldDoFn;
import org.apache.beam.sdk.transforms.windowing.BoundedWindow;
import org.apache.beam.sdk.util.SideInputReader;
import org.apache.beam.sdk.util.WindowedValue;
Expand Down
1 change: 0 additions & 1 deletion ...re-java/src/main/java/org/apache/beam/runners/core/GroupAlsoByWindowViaWindowSetDoFn.java
View file
Expand Up @@ -21,7 +21,6 @@
import org.apache.beam.runners.core.triggers.ExecutableTriggerStateMachine;
import org.apache.beam.runners.core.triggers.TriggerStateMachines;
import org.apache.beam.sdk.transforms.Aggregator;
import org.apache.beam.sdk.transforms.OldDoFn;
import org.apache.beam.sdk.transforms.Sum;
import org.apache.beam.sdk.transforms.windowing.BoundedWindow;
import org.apache.beam.sdk.util.SystemDoFnInternal;
Expand Down
1 change: 0 additions & 1 deletion runners/core-java/src/main/java/org/apache/beam/runners/core/GroupAlsoByWindowsDoFn.java
View file
Expand Up @@ -18,7 +18,6 @@
package org.apache.beam.runners.core;

import org.apache.beam.sdk.transforms.Aggregator;
import org.apache.beam.sdk.transforms.OldDoFn;
import org.apache.beam.sdk.transforms.Sum;
import org.apache.beam.sdk.transforms.windowing.BoundedWindow;
import org.apache.beam.sdk.util.SystemDoFnInternal;
Expand Down
1 change: 0 additions & 1 deletion runners/core-java/src/main/java/org/apache/beam/runners/core/LateDataDroppingDoFnRunner.java
View file
Expand Up @@ -22,7 +22,6 @@
import com.google.common.base.Predicate;
import com.google.common.collect.Iterables;
import org.apache.beam.sdk.transforms.Aggregator;
import org.apache.beam.sdk.transforms.OldDoFn;
import org.apache.beam.sdk.transforms.windowing.BoundedWindow;
import org.apache.beam.sdk.util.TimeDomain;
import org.apache.beam.sdk.util.TimerInternals;
Expand Down
9 changes: 8 additions & 1 deletion ...g/apache/beam/sdk/transforms/OldDoFn.java → ...org/apache/beam/runners/core/OldDoFn.java
View file
Expand Up @@ -15,7 +15,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.beam.sdk.transforms;
package org.apache.beam.runners.core;

import static com.google.common.base.Preconditions.checkArgument;
import static com.google.common.base.Preconditions.checkNotNull;
Expand All @@ -30,7 +30,14 @@
import org.apache.beam.sdk.annotations.Experimental.Kind;
import org.apache.beam.sdk.options.PipelineOptions;
import org.apache.beam.sdk.runners.PipelineRunner;
import org.apache.beam.sdk.transforms.Aggregator;
import org.apache.beam.sdk.transforms.Combine;
import org.apache.beam.sdk.transforms.Combine.CombineFn;
import org.apache.beam.sdk.transforms.DelegatingAggregator;
import org.apache.beam.sdk.transforms.DoFn;
import org.apache.beam.sdk.transforms.DoFnTester;
import org.apache.beam.sdk.transforms.ParDo;
import org.apache.beam.sdk.transforms.SerializableFunction;
import org.apache.beam.sdk.transforms.display.DisplayData;
import org.apache.beam.sdk.transforms.display.HasDisplayData;
import org.apache.beam.sdk.transforms.windowing.BoundedWindow;
Expand Down
3 changes: 1 addition & 2 deletions runners/core-java/src/main/java/org/apache/beam/runners/core/SimpleOldDoFnRunner.java
View file
Expand Up @@ -27,11 +27,10 @@
import java.util.Set;
import org.apache.beam.runners.core.DoFnRunners.OutputManager;
import org.apache.beam.runners.core.ExecutionContext.StepContext;
import org.apache.beam.runners.core.OldDoFn.RequiresWindowAccess;
import org.apache.beam.sdk.options.PipelineOptions;
import org.apache.beam.sdk.transforms.Aggregator;
import org.apache.beam.sdk.transforms.Combine.CombineFn;
import org.apache.beam.sdk.transforms.OldDoFn;
import org.apache.beam.sdk.transforms.OldDoFn.RequiresWindowAccess;
import org.apache.beam.sdk.transforms.windowing.BoundedWindow;
import org.apache.beam.sdk.transforms.windowing.GlobalWindow;
import org.apache.beam.sdk.transforms.windowing.GlobalWindows;
Expand Down
4 changes: 3 additions & 1 deletion ...nsforms/DoFnDelegatingAggregatorTest.java → ...rs/core/DoFnDelegatingAggregatorTest.java
View file
Expand Up @@ -15,15 +15,17 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.beam.sdk.transforms;
package org.apache.beam.runners.core;

import static org.junit.Assert.assertEquals;
import static org.mockito.Matchers.anyLong;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.never;
import static org.mockito.Mockito.verify;

import org.apache.beam.sdk.transforms.Aggregator;
import org.apache.beam.sdk.transforms.Combine.CombineFn;
import org.apache.beam.sdk.transforms.DelegatingAggregator;
import org.junit.Before;
import org.junit.Rule;
import org.junit.Test;
Expand Down
3 changes: 2 additions & 1 deletion ...ache/beam/sdk/transforms/NoOpOldDoFn.java → ...apache/beam/runners/core/NoOpOldDoFn.java
View file
Expand Up @@ -15,9 +15,10 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.beam.sdk.transforms;
package org.apache.beam.runners.core;

import org.apache.beam.sdk.options.PipelineOptions;
import org.apache.beam.sdk.transforms.Aggregator;
import org.apache.beam.sdk.transforms.Combine.CombineFn;
import org.apache.beam.sdk.values.TupleTag;
import org.joda.time.Instant;
Expand Down
5 changes: 4 additions & 1 deletion ...am/sdk/transforms/OldDoFnContextTest.java → ...beam/runners/core/OldDoFnContextTest.java
View file
Expand Up @@ -15,12 +15,15 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.beam.sdk.transforms;
package org.apache.beam.runners.core;

import static org.mockito.Mockito.spy;
import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.when;

import org.apache.beam.sdk.transforms.Aggregator;
import org.apache.beam.sdk.transforms.Combine;
import org.apache.beam.sdk.transforms.Sum;
import org.junit.Before;
import org.junit.Test;
import org.junit.runner.RunWith;
Expand Down
7 changes: 6 additions & 1 deletion ...ache/beam/sdk/transforms/OldDoFnTest.java → ...apache/beam/runners/core/OldDoFnTest.java
View file
Expand Up @@ -15,7 +15,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.beam.sdk.transforms;
package org.apache.beam.runners.core;

import static org.hamcrest.Matchers.empty;
import static org.hamcrest.Matchers.isA;
Expand All @@ -25,7 +25,12 @@

import java.io.Serializable;
import org.apache.beam.sdk.options.PipelineOptions;
import org.apache.beam.sdk.transforms.Aggregator;
import org.apache.beam.sdk.transforms.Combine;
import org.apache.beam.sdk.transforms.Combine.CombineFn;
import org.apache.beam.sdk.transforms.Max;
import org.apache.beam.sdk.transforms.SerializableFunction;
import org.apache.beam.sdk.transforms.Sum;
import org.apache.beam.sdk.transforms.display.DisplayData;
import org.apache.beam.sdk.values.TupleTag;
import org.joda.time.Instant;
Expand Down
2 changes: 1 addition & 1 deletion runners/core-java/src/test/java/org/apache/beam/runners/core/SimpleOldDoFnRunnerTest.java
View file
Expand Up @@ -23,7 +23,7 @@
import java.util.Arrays;
import java.util.List;
import org.apache.beam.runners.core.BaseExecutionContext.StepContext;
import org.apache.beam.sdk.transforms.OldDoFn;

import org.apache.beam.sdk.util.SystemDoFnInternal;
import org.apache.beam.sdk.util.UserCodeException;
import org.apache.beam.sdk.util.WindowedValue;
Expand Down
2 changes: 1 addition & 1 deletion ...rs/flink/runner/src/main/java/org/apache/beam/runners/flink/OldPerKeyCombineFnRunner.java
View file
Expand Up @@ -18,8 +18,8 @@
package org.apache.beam.runners.flink;

import java.io.Serializable;
import org.apache.beam.runners.core.OldDoFn;
import org.apache.beam.sdk.transforms.CombineFnBase.PerKeyCombineFn;
import org.apache.beam.sdk.transforms.OldDoFn;

/**
* An interface that runs a {@link PerKeyCombineFn} with unified APIs using
Expand Down
2 changes: 1 addition & 1 deletion ...s/flink/runner/src/main/java/org/apache/beam/runners/flink/OldPerKeyCombineFnRunners.java
View file
Expand Up @@ -17,13 +17,13 @@
*/
package org.apache.beam.runners.flink;

import org.apache.beam.runners.core.OldDoFn;
import org.apache.beam.runners.core.PerKeyCombineFnRunner;
import org.apache.beam.sdk.options.PipelineOptions;
import org.apache.beam.sdk.transforms.Combine.KeyedCombineFn;
import org.apache.beam.sdk.transforms.CombineFnBase.PerKeyCombineFn;
import org.apache.beam.sdk.transforms.CombineWithContext;
import org.apache.beam.sdk.transforms.CombineWithContext.KeyedCombineFnWithContext;
import org.apache.beam.sdk.transforms.OldDoFn;
import org.apache.beam.sdk.values.PCollectionView;

/**
Expand Down
2 changes: 1 addition & 1 deletion .../src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkDoFnFunction.java
View file
Expand Up @@ -19,10 +19,10 @@

import java.util.Map;
import org.apache.beam.runners.core.DoFnAdapters;
import org.apache.beam.runners.core.OldDoFn;
import org.apache.beam.runners.flink.translation.utils.SerializedPipelineOptions;
import org.apache.beam.sdk.options.PipelineOptions;
import org.apache.beam.sdk.transforms.DoFn;
import org.apache.beam.sdk.transforms.OldDoFn;
import org.apache.beam.sdk.transforms.reflect.DoFnSignatures;
import org.apache.beam.sdk.util.WindowedValue;
import org.apache.beam.sdk.util.WindowingStrategy;
Expand Down
2 changes: 1 addition & 1 deletion ...apache/beam/runners/flink/translation/functions/FlinkMergingNonShuffleReduceFunction.java
View file
Expand Up @@ -24,12 +24,12 @@
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import org.apache.beam.runners.core.OldDoFn;
import org.apache.beam.runners.flink.OldPerKeyCombineFnRunner;
import org.apache.beam.runners.flink.OldPerKeyCombineFnRunners;
import org.apache.beam.runners.flink.translation.utils.SerializedPipelineOptions;
import org.apache.beam.sdk.options.PipelineOptions;
import org.apache.beam.sdk.transforms.CombineFnBase;
import org.apache.beam.sdk.transforms.OldDoFn;
import org.apache.beam.sdk.transforms.windowing.BoundedWindow;
import org.apache.beam.sdk.transforms.windowing.IntervalWindow;
import org.apache.beam.sdk.transforms.windowing.OutputTimeFn;
Expand Down
2 changes: 1 addition & 1 deletion ...ava/org/apache/beam/runners/flink/translation/functions/FlinkMultiOutputDoFnFunction.java
View file
Expand Up @@ -19,10 +19,10 @@

import java.util.Map;
import org.apache.beam.runners.core.DoFnAdapters;
import org.apache.beam.runners.core.OldDoFn;
import org.apache.beam.runners.flink.translation.utils.SerializedPipelineOptions;
import org.apache.beam.sdk.options.PipelineOptions;
import org.apache.beam.sdk.transforms.DoFn;
import org.apache.beam.sdk.transforms.OldDoFn;
import org.apache.beam.sdk.transforms.join.RawUnionValue;
import org.apache.beam.sdk.transforms.reflect.DoFnSignatures;
import org.apache.beam.sdk.util.WindowedValue;
Expand Down
2 changes: 1 addition & 1 deletion ...a/org/apache/beam/runners/flink/translation/functions/FlinkMultiOutputProcessContext.java
View file
Expand Up @@ -19,8 +19,8 @@

import java.util.Collection;
import java.util.Map;
import org.apache.beam.runners.core.OldDoFn;
import org.apache.beam.sdk.options.PipelineOptions;
import org.apache.beam.sdk.transforms.OldDoFn;
import org.apache.beam.sdk.transforms.join.RawUnionValue;
import org.apache.beam.sdk.transforms.windowing.BoundedWindow;
import org.apache.beam.sdk.transforms.windowing.PaneInfo;
Expand Down
2 changes: 1 addition & 1 deletion ...java/org/apache/beam/runners/flink/translation/functions/FlinkNoElementAssignContext.java
View file
Expand Up @@ -17,7 +17,7 @@
*/
package org.apache.beam.runners.flink.translation.functions;

import org.apache.beam.sdk.transforms.OldDoFn;
import org.apache.beam.runners.core.OldDoFn;
import org.apache.beam.sdk.transforms.windowing.BoundedWindow;
import org.apache.beam.sdk.transforms.windowing.WindowFn;
import org.joda.time.Instant;
Expand Down
2 changes: 1 addition & 1 deletion .../java/org/apache/beam/runners/flink/translation/functions/FlinkPartialReduceFunction.java
View file
Expand Up @@ -24,12 +24,12 @@
import java.util.Comparator;
import java.util.Iterator;
import java.util.Map;
import org.apache.beam.runners.core.OldDoFn;
import org.apache.beam.runners.flink.OldPerKeyCombineFnRunner;
import org.apache.beam.runners.flink.OldPerKeyCombineFnRunners;
import org.apache.beam.runners.flink.translation.utils.SerializedPipelineOptions;
import org.apache.beam.sdk.options.PipelineOptions;
import org.apache.beam.sdk.transforms.CombineFnBase;
import org.apache.beam.sdk.transforms.OldDoFn;
import org.apache.beam.sdk.transforms.windowing.BoundedWindow;
import org.apache.beam.sdk.transforms.windowing.OutputTimeFn;
import org.apache.beam.sdk.transforms.windowing.PaneInfo;
Expand Down
2 changes: 1 addition & 1 deletion ...ain/java/org/apache/beam/runners/flink/translation/functions/FlinkProcessContextBase.java
View file
Expand Up @@ -24,11 +24,11 @@
import java.util.Collections;
import java.util.Iterator;
import java.util.Map;
import org.apache.beam.runners.core.OldDoFn;
import org.apache.beam.runners.flink.translation.wrappers.SerializableFnAggregatorWrapper;
import org.apache.beam.sdk.options.PipelineOptions;
import org.apache.beam.sdk.transforms.Aggregator;
import org.apache.beam.sdk.transforms.Combine;
import org.apache.beam.sdk.transforms.OldDoFn;
import org.apache.beam.sdk.transforms.windowing.BoundedWindow;
import org.apache.beam.sdk.transforms.windowing.PaneInfo;
import org.apache.beam.sdk.util.TimerInternals;
Expand Down
2 changes: 1 addition & 1 deletion ...rc/main/java/org/apache/beam/runners/flink/translation/functions/FlinkReduceFunction.java
View file
Expand Up @@ -26,12 +26,12 @@
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import org.apache.beam.runners.core.OldDoFn;
import org.apache.beam.runners.flink.OldPerKeyCombineFnRunner;
import org.apache.beam.runners.flink.OldPerKeyCombineFnRunners;
import org.apache.beam.runners.flink.translation.utils.SerializedPipelineOptions;
import org.apache.beam.sdk.options.PipelineOptions;
import org.apache.beam.sdk.transforms.CombineFnBase;
import org.apache.beam.sdk.transforms.OldDoFn;
import org.apache.beam.sdk.transforms.windowing.BoundedWindow;
import org.apache.beam.sdk.transforms.windowing.OutputTimeFn;
import org.apache.beam.sdk.transforms.windowing.PaneInfo;
Expand Down
2 changes: 1 addition & 1 deletion .../org/apache/beam/runners/flink/translation/functions/FlinkSingleOutputProcessContext.java
View file
Expand Up @@ -19,8 +19,8 @@

import java.util.Collection;
import java.util.Map;
import org.apache.beam.runners.core.OldDoFn;
import org.apache.beam.sdk.options.PipelineOptions;
import org.apache.beam.sdk.transforms.OldDoFn;
import org.apache.beam.sdk.transforms.windowing.BoundedWindow;
import org.apache.beam.sdk.transforms.windowing.PaneInfo;
import org.apache.beam.sdk.util.WindowedValue;
Expand Down
2 changes: 1 addition & 1 deletion .../main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java
View file
Expand Up @@ -33,6 +33,7 @@
import org.apache.beam.runners.core.DoFnRunner;
import org.apache.beam.runners.core.DoFnRunners;
import org.apache.beam.runners.core.ExecutionContext;
import org.apache.beam.runners.core.OldDoFn;
import org.apache.beam.runners.core.PushbackSideInputDoFnRunner;
import org.apache.beam.runners.core.SideInputHandler;
import org.apache.beam.runners.flink.translation.utils.SerializedPipelineOptions;
Expand All @@ -43,7 +44,6 @@
import org.apache.beam.sdk.transforms.Aggregator;
import org.apache.beam.sdk.transforms.Combine;
import org.apache.beam.sdk.transforms.DoFn;
import org.apache.beam.sdk.transforms.OldDoFn;
import org.apache.beam.sdk.transforms.join.RawUnionValue;
import org.apache.beam.sdk.transforms.windowing.BoundedWindow;
import org.apache.beam.sdk.util.CoderUtils;
Expand Down
2 changes: 1 addition & 1 deletion ...java/org/apache/beam/runners/flink/translation/wrappers/streaming/WindowDoFnOperator.java
View file
Expand Up @@ -42,12 +42,12 @@
import org.apache.beam.runners.core.GroupAlsoByWindowViaWindowSetDoFn;
import org.apache.beam.runners.core.KeyedWorkItem;
import org.apache.beam.runners.core.KeyedWorkItems;
import org.apache.beam.runners.core.OldDoFn;
import org.apache.beam.runners.core.SystemReduceFn;
import org.apache.beam.runners.flink.translation.wrappers.DataInputViewWrapper;
import org.apache.beam.sdk.coders.Coder;
import org.apache.beam.sdk.options.PipelineOptions;
import org.apache.beam.sdk.transforms.DoFn;
import org.apache.beam.sdk.transforms.OldDoFn;
import org.apache.beam.sdk.transforms.windowing.BoundedWindow;
import org.apache.beam.sdk.util.TimeDomain;
import org.apache.beam.sdk.util.TimerInternals;
Expand Down
4 changes: 1 addition & 3 deletions ...gle-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/DoFnInfo.java
View file
Expand Up @@ -21,7 +21,6 @@
import java.util.Map;
import org.apache.beam.sdk.coders.Coder;
import org.apache.beam.sdk.transforms.DoFn;
import org.apache.beam.sdk.transforms.OldDoFn;
import org.apache.beam.sdk.util.WindowingStrategy;
import org.apache.beam.sdk.values.PCollectionView;
import org.apache.beam.sdk.values.TupleTag;
Expand All @@ -41,8 +40,7 @@ public class DoFnInfo<InputT, OutputT> implements Serializable {
private final Map<Long, TupleTag<?>> outputMap;

/**
* Creates a {@link DoFnInfo} for the given {@link Serializable} object, which is expected to be a
* {@link DoFn} or {@link OldDoFn} or other context-appropriate UDF blob.
* Creates a {@link DoFnInfo} for the given {@link DoFn}.
*/
public static <InputT, OutputT> DoFnInfo<InputT, OutputT> forFn(
DoFn<InputT, OutputT> doFn,
Expand Down

0 comments on commit 5f8b8c5

Please sign in to comment.