Skip to content

Instantly share code, notes, and snippets.

@charles-tan

charles-tan/ds_state_processor_blog_3.java

Created March 4, 2024 20:44
Show Gist options
  • Save charles-tan/93efa459571ef35528bdfcb48f51b4e3 to your computer and use it in GitHub Desktop.
Save charles-tan/93efa459571ef35528bdfcb48f51b4e3 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
ds_state_processor_blog_3.java
static final ListStateDescriptor<byte[]> SPLITS_STATE_DESC =
new ListStateDescriptor<>("SourceReaderState", BytePrimitiveArraySerializer.INSTANCE);
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment