Skip to content

Commit

Permalink
fix style
Browse files Browse the repository at this point in the history
  • Loading branch information
ModRyanFu committed Jan 16, 2025
1 parent b1dc144 commit 27ae7a9
Showing 1 changed file with 1 addition and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -76,8 +76,7 @@
})
public class DoFnOp<InT, FnOutT, OutT> implements Op<InT, OutT, Void> {
private static final Logger LOG = LoggerFactory.getLogger(DoFnOp.class);
public static final String TIMER_BATCH_LIMIT_CONFIG =
"beam.samza.dofnop.timerBatchLimit";
public static final String TIMER_BATCH_LIMIT_CONFIG = "beam.samza.dofnop.timerBatchLimit";

private final TupleTag<FnOutT> mainOutputTag;
private final DoFn<InT, FnOutT> doFn;
Expand Down

0 comments on commit 27ae7a9

Please sign in to comment.