docs: void initializeState(final ListState<byte[]> bucketStates, final ListState<Long> partCounterState) throws Exception {
  
  		initializePartCounter(partCounterState);
  
  		LOG.info("Subtask {} initializing its state (max part counter={}).", subtaskIndex, maxPartCounter);
  
  		initializeActiveBuckets(bucketStates);
  	}