public static class StoreSinkWriteState.StateValue extends Object
StoreSinkWrite
. All state values should be given a partition and a
bucket so that they can be redistributed once the sink parallelism is changed.Constructor and Description |
---|
StateValue(BinaryRow partition,
int bucket,
byte[] value) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.