Skip to content

Instantly share code, notes, and snippets.

@charles-tan

charles-tan/ds_state_processor_blog_4.java

Created March 4, 2024 20:44
Show Gist options
  • Save charles-tan/12726358ee98158c399d31e10804f043 to your computer and use it in GitHub Desktop.
Save charles-tan/12726358ee98158c399d31e10804f043 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
ds_state_processor_blog_4.java
@Override
public void initializeState(StateInitializationContext context) throws Exception {
super.initializeState(context);
final ListState<byte[]> rawState =
context.getOperatorStateStore().getListState(SPLITS_STATE_DESC);
readerState = new SimpleVersionedListState<>(rawState, splitSerializer);
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment