本文整理了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
暂无
代码示例来源: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);
内容来源于网络,如有侵权,请联系作者删除!