Skip to content

Instantly share code, notes, and snippets.

@Aitozi

Aitozi/ContinuousEventTimeTrigger.java

Created April 1, 2018 15:16
Show Gist options
  • Save Aitozi/55ee919f1d473202f70e0f282b390462 to your computer and use it in GitHub Desktop.
Save Aitozi/55ee919f1d473202f70e0f282b390462 to your computer and use it in GitHub Desktop.
Download ZIP
ReducingState usage in ContinuousEventTimeTrigger.java
Raw
ContinuousEventTimeTrigger.java
private final ReducingStateDescriptor<Long> stateDesc =
new ReducingStateDescriptor<>("fire-time", new Min(), LongSerializer.INSTANCE);
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment