org.elasticsearch.cluster.metadata.MetaData.readDiffFrom()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(2.6k)|赞(0)|评价(0)|浏览(88)

本文整理了Java中org.elasticsearch.cluster.metadata.MetaData.readDiffFrom()方法的一些代码示例,展示了MetaData.readDiffFrom()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。MetaData.readDiffFrom()方法的具体详情如下:
包路径:org.elasticsearch.cluster.metadata.MetaData
类名称:MetaData
方法名:readDiffFrom

MetaData.readDiffFrom介绍

暂无

代码示例

代码示例来源:origin: org.elasticsearch/elasticsearch

ClusterStateDiff(StreamInput in, DiscoveryNode localNode) throws IOException {
  clusterName = new ClusterName(in);
  fromUuid = in.readString();
  toUuid = in.readString();
  toVersion = in.readLong();
  routingTable = RoutingTable.readDiffFrom(in);
  nodes = DiscoveryNodes.readDiffFrom(in, localNode);
  metaData = MetaData.readDiffFrom(in);
  blocks = ClusterBlocks.readDiffFrom(in);
  customs = DiffableUtils.readImmutableOpenMapDiff(in, DiffableUtils.getStringKeySerializer(), CUSTOM_VALUE_SERIALIZER);
}

代码示例来源:origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.elasticsearch

ClusterStateDiff(StreamInput in, DiscoveryNode localNode) throws IOException {
  clusterName = new ClusterName(in);
  fromUuid = in.readString();
  toUuid = in.readString();
  toVersion = in.readLong();
  routingTable = RoutingTable.readDiffFrom(in);
  nodes = DiscoveryNodes.readDiffFrom(in, localNode);
  metaData = MetaData.readDiffFrom(in);
  blocks = ClusterBlocks.readDiffFrom(in);
  customs = DiffableUtils.readImmutableOpenMapDiff(in, DiffableUtils.getStringKeySerializer(), CUSTOM_VALUE_SERIALIZER);
}

代码示例来源:origin: com.strapdata.elasticsearch/elasticsearch

ClusterStateDiff(StreamInput in, DiscoveryNode localNode) throws IOException {
  clusterName = new ClusterName(in);
  fromUuid = in.readString();
  toUuid = in.readString();
  toVersion = in.readLong();
  routingTable = RoutingTable.readDiffFrom(in);
  nodes = DiscoveryNodes.readDiffFrom(in, localNode);
  metaData = MetaData.readDiffFrom(in);
  blocks = ClusterBlocks.readDiffFrom(in);
  customs = DiffableUtils.readImmutableOpenMapDiff(in, DiffableUtils.getStringKeySerializer(), CUSTOM_VALUE_SERIALIZER);
}

代码示例来源:origin: harbby/presto-connectors

public ClusterStateDiff(StreamInput in, ClusterState proto) throws IOException {
  clusterName = ClusterName.readClusterName(in);
  fromUuid = in.readString();
  toUuid = in.readString();
  toVersion = in.readLong();
  routingTable = proto.routingTable.readDiffFrom(in);
  nodes = proto.nodes.readDiffFrom(in);
  metaData = proto.metaData.readDiffFrom(in);
  blocks = proto.blocks.readDiffFrom(in);
  customs = DiffableUtils.readImmutableOpenMapDiff(in, new KeyedReader<Custom>() {
    @Override
    public Custom readFrom(StreamInput in, String key) throws IOException {
      return lookupPrototypeSafe(key).readFrom(in);
    }
    @Override
    public Diff<Custom> readDiffFrom(StreamInput in, String key) throws IOException {
      return lookupPrototypeSafe(key).readDiffFrom(in);
    }
  });
}

相关文章

微信公众号

最新文章

更多