Class ZooKeeperSharedValue
- java.lang.Object
-
- org.apache.flink.runtime.zookeeper.ZooKeeperSharedValue
-
public class ZooKeeperSharedValue extends Object
Wrapper class for aSharedValue
so that we don't expose a curator dependency in our internal APIs. Such an exposure is problematic due to the relocation of curator.
-
-
Constructor Summary
Constructors Constructor Description ZooKeeperSharedValue(org.apache.flink.shaded.curator5.org.apache.curator.framework.recipes.shared.SharedValue sharedValue)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
byte[]
getValue()
void
setValue(byte[] newValue)
void
start()
-
-
-
Method Detail
-
close
public void close() throws IOException
- Throws:
IOException
-
getValue
public byte[] getValue()
-
-