[streaming] OperatorState and StateCheckpoint classes and implementations added for state checkpointing and rebalancing