scwhittle commented on a change in pull request #13318:
URL: https://github.com/apache/beam/pull/13318#discussion_r534115800
##########
File path:
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query3.java
##########
@@ -164,21 +165,19 @@ public void processElement(ProcessContext c) {
@StateId(PERSON)
private static final StateSpec<ValueState<Person>> personSpec =
StateSpecs.value(Person.CODER);
- private static final String PERSON_STATE_EXPIRING = "personStateExpiring";
+ private static final String STATE_EXPIRING = "stateExpiring";
@StateId(AUCTIONS)
- private final StateSpec<ValueState<List<Auction>>> auctionsSpec =
- StateSpecs.value(ListCoder.of(Auction.CODER));
+ private final StateSpec<BagState<Auction>> auctionsSpec =
StateSpecs.bag(Auction.CODER);
- @TimerId(PERSON_STATE_EXPIRING)
- private final TimerSpec timerSpec =
TimerSpecs.timer(TimeDomain.EVENT_TIME);
+ @TimerId(STATE_EXPIRING)
Review comment:
Changed back to event time timer.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
