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

Metadata.triggerOnAggregateChanged介绍

暂无

代码示例

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

private void updateAggregates(
  Metadata metadata,
  Map<String, AggregateMetadata> oldAggregates,
  Map<String, AggregateMetadata> newAggregates,
  String aggregateToRebuild) {
 Iterator<AggregateMetadata> it = oldAggregates.values().iterator();
 while (it.hasNext()) {
  AggregateMetadata oldAggregate = it.next();
  String oldAggregateName =
    Metadata.fullFunctionName(oldAggregate.getSimpleName(), oldAggregate.getArgumentTypes());
  if ((aggregateToRebuild == null || aggregateToRebuild.equals(oldAggregateName))
    && !newAggregates.containsKey(oldAggregateName)) {
   it.remove();
   metadata.triggerOnAggregateRemoved(oldAggregate);
  }
 }
 for (AggregateMetadata newAggregate : newAggregates.values()) {
  String newAggregateName =
    Metadata.fullFunctionName(newAggregate.getSimpleName(), newAggregate.getArgumentTypes());
  AggregateMetadata oldAggregate = oldAggregates.put(newAggregateName, newAggregate);
  if (oldAggregate == null) {
   metadata.triggerOnAggregateAdded(newAggregate);
  } else if (!newAggregate.equals(oldAggregate)) {
   metadata.triggerOnAggregateChanged(newAggregate, oldAggregate);
  }
 }
}

代码示例来源：origin: com.facebook.presto.cassandra/cassandra-driver

private void updateAggregates(Metadata metadata, Map<String, AggregateMetadata> oldAggregates, Map<String, AggregateMetadata> newAggregates, String aggregateToRebuild) {
  Iterator<AggregateMetadata> it = oldAggregates.values().iterator();
  while (it.hasNext()) {
    AggregateMetadata oldAggregate = it.next();
    String oldAggregateName = Metadata.fullFunctionName(oldAggregate.getSimpleName(), oldAggregate.getArgumentTypes());
    if ((aggregateToRebuild == null || aggregateToRebuild.equals(oldAggregateName)) && !newAggregates.containsKey(oldAggregateName)) {
      it.remove();
      metadata.triggerOnAggregateRemoved(oldAggregate);
    }
  }
  for (AggregateMetadata newAggregate : newAggregates.values()) {
    String newAggregateName = Metadata.fullFunctionName(newAggregate.getSimpleName(), newAggregate.getArgumentTypes());
    AggregateMetadata oldAggregate = oldAggregates.put(newAggregateName, newAggregate);
    if (oldAggregate == null) {
      metadata.triggerOnAggregateAdded(newAggregate);
    } else if (!newAggregate.equals(oldAggregate)) {
      metadata.triggerOnAggregateChanged(newAggregate, oldAggregate);
    }
  }
}

代码示例来源：origin: io.prestosql.cassandra/cassandra-driver

private void updateAggregates(Metadata metadata, Map<String, AggregateMetadata> oldAggregates, Map<String, AggregateMetadata> newAggregates, String aggregateToRebuild) {
  Iterator<AggregateMetadata> it = oldAggregates.values().iterator();
  while (it.hasNext()) {
    AggregateMetadata oldAggregate = it.next();
    String oldAggregateName = Metadata.fullFunctionName(oldAggregate.getSimpleName(), oldAggregate.getArgumentTypes());
    if ((aggregateToRebuild == null || aggregateToRebuild.equals(oldAggregateName)) && !newAggregates.containsKey(oldAggregateName)) {
      it.remove();
      metadata.triggerOnAggregateRemoved(oldAggregate);
    }
  }
  for (AggregateMetadata newAggregate : newAggregates.values()) {
    String newAggregateName = Metadata.fullFunctionName(newAggregate.getSimpleName(), newAggregate.getArgumentTypes());
    AggregateMetadata oldAggregate = oldAggregates.put(newAggregateName, newAggregate);
    if (oldAggregate == null) {
      metadata.triggerOnAggregateAdded(newAggregate);
    } else if (!newAggregate.equals(oldAggregate)) {
      metadata.triggerOnAggregateChanged(newAggregate, oldAggregate);
    }
  }
}

代码示例来源：origin: com.yugabyte/cassandra-driver-core

private void updateAggregates(Metadata metadata, Map<String, AggregateMetadata> oldAggregates, Map<String, AggregateMetadata> newAggregates, String aggregateToRebuild) {
  Iterator<AggregateMetadata> it = oldAggregates.values().iterator();
  while (it.hasNext()) {
    AggregateMetadata oldAggregate = it.next();
    String oldAggregateName = Metadata.fullFunctionName(oldAggregate.getSimpleName(), oldAggregate.getArgumentTypes());
    if ((aggregateToRebuild == null || aggregateToRebuild.equals(oldAggregateName)) && !newAggregates.containsKey(oldAggregateName)) {
      it.remove();
      metadata.triggerOnAggregateRemoved(oldAggregate);
    }
  }
  for (AggregateMetadata newAggregate : newAggregates.values()) {
    String newAggregateName = Metadata.fullFunctionName(newAggregate.getSimpleName(), newAggregate.getArgumentTypes());
    AggregateMetadata oldAggregate = oldAggregates.put(newAggregateName, newAggregate);
    if (oldAggregate == null) {
      metadata.triggerOnAggregateAdded(newAggregate);
    } else if (!newAggregate.equals(oldAggregate)) {
      metadata.triggerOnAggregateChanged(newAggregate, oldAggregate);
    }
  }
}