org.apache.ignite.internal.util.typedef.F.eq()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(6.0k)|赞(0)|评价(0)|浏览(103)

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

F.eq介绍

暂无

代码示例

代码示例来源:origin: apache/ignite

/** {@inheritDoc} */
@Override public boolean equals(Object o) {
  if (this == o)
    return true;
  if (!(o instanceof StatefulValue))
    return false;
  StatefulValue other = (StatefulValue)o;
  return F.eq(val, other.val) && F.eq(valStatus, other.valStatus);
}

代码示例来源:origin: apache/ignite

/** {@inheritDoc} */
@Override public boolean equals(Object obj) {
  if (obj != null && obj instanceof ClientListenerProtocolVersion) {
    ClientListenerProtocolVersion other = (ClientListenerProtocolVersion)obj;
    return F.eq(major, other.major) && F.eq(minor, other.minor) && F.eq(maintenance, other.maintenance);
  }
  return false;
}

代码示例来源:origin: apache/ignite

/** {@inheritDoc} */
@Override public boolean equals(Object o) {
  if (this == o)
    return true;
  if (!(o instanceof GridTuple3))
    return false;
  GridTuple3<?, ?, ?> t = (GridTuple3<?, ?, ?>)o;
  return F.eq(val1, t.val1) && F.eq(val2, t.val2) && F.eq(val3, t.val3);
}

代码示例来源:origin: apache/ignite

/**
 * @return {@code True} if need perform binary memory recovery. Only records {@link PageDeltaRecord}
 * and {@link PageSnapshot} needs to be applyed from {@link #cpStartId}.
 */
public boolean needRestoreMemory() {
  return !F.eq(cpStartId, cpEndId) && !F.eq(NULL_UUID, cpStartId);
}

代码示例来源:origin: apache/ignite

/** {@inheritDoc} */
@Override public boolean equals(Object o) {
  if (this == o)
    return true;
  if (!(o instanceof GridTuple5))
    return false;
  GridTuple5<?, ?, ?, ?, ?> t = (GridTuple5<?, ?, ?, ?, ?>)o;
  return F.eq(v1, t.v1) && F.eq(v2, t.v2) && F.eq(v3, t.v3) && F.eq(v4, t.v4) && F.eq(v5, t.v5);
}

代码示例来源:origin: apache/ignite

/** {@inheritDoc} */
@Override public boolean equals(Object o) {
  if (this == o)
    return true;
  if (o == null || getClass() != o.getClass())
    return false;
  JdbcIndexMeta meta = (JdbcIndexMeta)o;
  return F.eq(schemaName, meta.schemaName) && F.eq(tblName, meta.tblName) && F.eq(idxName, meta.idxName);
}

代码示例来源:origin: apache/ignite

/** {@inheritDoc} */
@Override public boolean equals(Object o) {
  if (this == o)
    return true;
  if (o == null || getClass() != o.getClass())
    return false;
  JdbcPrimaryKeyMeta meta = (JdbcPrimaryKeyMeta)o;
  return F.eq(schemaName, meta.schemaName) && F.eq(tblName, meta.tblName) && F.eq(name, meta.name);
}

代码示例来源:origin: apache/ignite

/** {@inheritDoc} */
@Override public boolean equals(Object o) {
  if (this == o)
    return true;
  if (o == null || getClass() != o.getClass())
    return false;
  QueryIndexKey other = (QueryIndexKey)o;
  return F.eq(name, other.name) && F.eq(schemaName, other.schemaName);
}

代码示例来源:origin: apache/ignite

/** {@inheritDoc} */
@Override public boolean equals(Object o) {
  if (this == o)
    return true;
  if (o == null || getClass() != o.getClass())
    return false;
  QueryIndex index = (QueryIndex)o;
  return inlineSize == index.inlineSize &&
    F.eq(name, index.name) &&
    F.eq(fields, index.fields) &&
    type == index.type;
}

代码示例来源:origin: apache/ignite

/** {@inheritDoc} */
  @Override public boolean equals(Object o) {
    if (this == o)
      return true;

    if (o == null || getClass() != o.getClass())
      return false;

    GridCacheQueryDetailMetricsKey other = (GridCacheQueryDetailMetricsKey)o;

    return qryType == other.qryType && F.eq(qry, other.qry);
  }
}

代码示例来源:origin: apache/ignite

/** {@inheritDoc} */
@Nullable @Override public V remove(Object key) {
  if (F.eq(key, k3)) {
    V res = v3;
    v3 = null;
    k3 = null;
    return res;
  }
  return super.remove(key);
}

代码示例来源:origin: apache/ignite

/** {@inheritDoc} */
@Override public boolean hasChild(String name, IgniteUuid expId) {
  if (listing != null) {
    IgfsListingEntry entry = listing.get(name);
    if (entry != null)
      return F.eq(expId, entry.fileId());
  }
  return false;
}

代码示例来源:origin: apache/ignite

/** {@inheritDoc} */
@Override public boolean equals(Object o) {
  if (o == this)
    return true;
  if (o == null || o.getClass() != getClass())
    return false;
  IgfsBlockKey that = (IgfsBlockKey)o;
  return blockId == that.blockId && fileId.equals(that.fileId) && F.eq(affKey, that.affKey) &&
    evictExclude == that.evictExclude;
}

代码示例来源:origin: apache/ignite

/** */
  @Override public boolean equals(Object o) {
    if (this == o)
      return true;
    if (!(o instanceof Person))
      return false;
    Person other = (Person)o;
    return F.eq(other.name, name) && other.age == age;
  }
}

代码示例来源:origin: apache/ignite

/**
 * @param n Node to check.
 * @param part Partition.
 * @param topVer Topology version.
 * @return {@code True} if checked node is primary for given partition.
 */
public boolean primaryByPartition(ClusterNode n, int part, AffinityTopologyVersion topVer) {
  return F.eq(primaryByPartition(part, topVer), n);
}

代码示例来源:origin: apache/ignite

/**
 * @param ctx Callback invoked when cache is stopped.
 */
public void onCacheStop(GridCacheContext ctx) {
  Iterator<Map.Entry<UUID, RemoteRoutineInfo>> it = rmtInfos.entrySet().iterator();
  while (it.hasNext()) {
    Map.Entry<UUID, RemoteRoutineInfo> entry = it.next();
    GridContinuousHandler hnd = entry.getValue().hnd;
    if (hnd.isQuery() && F.eq(ctx.name(), hnd.cacheName()))
      it.remove();
  }
}

代码示例来源:origin: apache/ignite

/** {@inheritDoc} */
@SuppressWarnings("unchecked")
@Nullable @Override public <T> T attribute(String name) {
  if (F.eq(name, IgniteNodeAttributes.ATTR_MACS))
    return (T)macs;
  throwUnsupported();
  return null;
}

代码示例来源:origin: apache/ignite

/** {@inheritDoc} */
  @Override public boolean equals(Object obj) {
    if (obj == null)
      return false;

    if (obj.getClass() != getClass())
      return false;

    PartitionSingleNode other = (PartitionSingleNode)obj;

    return F.eq(constant(), other.constant()) && F.eq(value(), other.value()) &&
      F.eq(tbl.alias(), other.tbl.alias());
  }
}

代码示例来源:origin: apache/ignite

/** {@inheritDoc} */
  @Override public boolean apply(ClusterNode node) {
    String igniteInstanceName = node.attribute(IgniteNodeAttributes.ATTR_IGNITE_INSTANCE_NAME);
    for (String attr : attrs) {
      if (F.eq(attr, igniteInstanceName))
        return true;
    }
    return false;
  }
}

代码示例来源:origin: apache/ignite

@Override public boolean apply(Event evt) {
    assert evt.type() == EventType.EVT_CACHE_REBALANCE_PART_DATA_LOST;
    CacheRebalancingEvent cacheEvt = (CacheRebalancingEvent)evt;
    if (cacheEvt.partition() == part0 && F.eq(cacheName, cacheEvt.cacheName())) {
      latch.countDown();
      // Auto-unsubscribe.
      return false;
    }
    return true;
  }
}, EventType.EVT_CACHE_REBALANCE_PART_DATA_LOST);

相关文章