package org.opendaylight.controller.cluster.datastore.node.utils.stream;
-import com.google.common.base.Preconditions;
import java.io.DataOutput;
-import java.io.DataOutputStream;
import java.io.IOException;
-import java.io.OutputStream;
import java.util.HashMap;
import java.util.Map;
import org.opendaylight.yangtools.yang.common.QName;
+import org.opendaylight.yangtools.yang.common.Revision;
/**
* NormalizedNodeOutputStreamWriter will be used by distributed datastore to send normalized node in
* {@link #leafNode(org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier.NodeIdentifier, Object)} twice
* and then, {@link #endNode()} to end container node.
*
- * Based on the each node, the node type is also written to the stream, that helps in reconstructing the object,
+ * <p>Based on the each node, the node type is also written to the stream, that helps in reconstructing the object,
* while reading.
*/
-public class NormalizedNodeOutputStreamWriter extends AbstractNormalizedNodeDataOutput {
+final class NormalizedNodeOutputStreamWriter extends AbstractNormalizedNodeDataOutput {
private final Map<String, Integer> stringCodeMap = new HashMap<>();
- /**
- * @deprecated Use {@link #NormalizedNodeOutputStreamWriter(DataOutput)} instead.
- */
- @Deprecated
- public NormalizedNodeOutputStreamWriter(final OutputStream stream) throws IOException {
- this((DataOutput) new DataOutputStream(Preconditions.checkNotNull(stream)));
- }
-
- /**
- * @deprecated Use {@link NormalizedNodeInputOutput#newDataOutput(DataOutput)} instead.
- */
- @Deprecated
- public NormalizedNodeOutputStreamWriter(final DataOutput output) {
+ NormalizedNodeOutputStreamWriter(final DataOutput output) {
super(output);
}
@Override
- protected final short streamVersion() {
+ protected short streamVersion() {
return TokenTypes.LITHIUM_VERSION;
}
protected void writeQName(final QName qname) throws IOException {
writeString(qname.getLocalName());
writeString(qname.getNamespace().toString());
- writeString(qname.getFormattedRevision());
+ writeString(qname.getRevision().map(Revision::toString).orElse(null));
}
@Override