本文整理了Java中org.apache.fluo.api.data.Bytes.equals()
方法的一些代码示例,展示了Bytes.equals()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Bytes.equals()
方法的具体详情如下:
包路径:org.apache.fluo.api.data.Bytes
类名称:Bytes
方法名:equals
[英]Returns true if this Bytes object equals another.
[中]如果此字节对象等于另一个字节对象,则返回true。
代码示例来源:origin: org.apache.fluo/fluo-recipes-core
@Override
public boolean equals(Object o) {
if (o instanceof RowRange) {
RowRange or = (RowRange) o;
return start.equals(or.start) && end.equals(or.end);
}
return false;
}
代码示例来源:origin: org.apache.fluo/fluo-recipes-core
@Override
public boolean equals(Object o) {
if (o instanceof LogEntry) {
LogEntry other = (LogEntry) o;
return ((op == other.op) && row.equals(other.row) && col.equals(other.col)
&& value.equals(other.value));
}
return false;
}
代码示例来源:origin: org.apache.fluo/fluo-api
@Override
public boolean equals(Object o) {
if (o == this) {
return true;
}
if (o instanceof RowColumnValue) {
RowColumnValue orcv = (RowColumnValue) o;
return row.equals(orcv.row) && col.equals(orcv.col) && val.equals(orcv.val);
}
return false;
}
代码示例来源:origin: apache/fluo
@Override
public boolean equals(Object o) {
if (o == this) {
return true;
}
if (o instanceof RowColumnValue) {
RowColumnValue orcv = (RowColumnValue) o;
return row.equals(orcv.row) && col.equals(orcv.col) && val.equals(orcv.val);
}
return false;
}
代码示例来源:origin: apache/fluo
@Override
public boolean equals(Object o) {
if (o instanceof PrimaryRowColumn) {
PrimaryRowColumn ock = (PrimaryRowColumn) o;
return prow.equals(ock.prow) && pcol.equals(ock.pcol) && startTs == ock.startTs;
}
return false;
}
代码示例来源:origin: apache/fluo
@Override
public boolean equals(Object o) {
if (this == o) {
return true;
}
if (o instanceof ColumnValue) {
ColumnValue ocv = (ColumnValue) o;
return column.equals(ocv.column) && val.equals(ocv.val);
}
return false;
}
代码示例来源:origin: apache/fluo
@Override
public boolean equals(Object o) {
if (this == o) {
return true;
}
if (o instanceof RowColumn) {
RowColumn other = (RowColumn) o;
return row.equals(other.row) && col.equals(other.col);
}
return false;
}
代码示例来源:origin: org.apache.fluo/fluo-api
@Override
public boolean equals(Object o) {
if (this == o) {
return true;
}
if (o instanceof ColumnValue) {
ColumnValue ocv = (ColumnValue) o;
return column.equals(ocv.column) && val.equals(ocv.val);
}
return false;
}
代码示例来源:origin: org.apache.fluo/fluo-api
@Override
public boolean equals(Object o) {
if (this == o) {
return true;
}
if (o instanceof Column) {
Column oc = (Column) o;
return family.equals(oc.getFamily()) && qualifier.equals(oc.getQualifier())
&& visibility.equals(oc.getVisibility());
}
return false;
}
}
代码示例来源:origin: org.apache.fluo/fluo-api
@Override
public boolean equals(Object o) {
if (this == o) {
return true;
}
if (o instanceof RowColumn) {
RowColumn other = (RowColumn) o;
return row.equals(other.row) && col.equals(other.col);
}
return false;
}
代码示例来源:origin: org.apache.fluo/fluo-core
@Override
public boolean equals(Object o) {
if (o instanceof PrimaryRowColumn) {
PrimaryRowColumn ock = (PrimaryRowColumn) o;
return prow.equals(ock.prow) && pcol.equals(ock.pcol) && startTs == ock.startTs;
}
return false;
}
代码示例来源:origin: apache/fluo
@Override
public boolean equals(Object o) {
if (this == o) {
return true;
}
if (o instanceof Column) {
Column oc = (Column) o;
return family.equals(oc.getFamily()) && qualifier.equals(oc.getQualifier())
&& visibility.equals(oc.getVisibility());
}
return false;
}
}
代码示例来源:origin: org.apache.fluo/fluo-recipes-test
private static boolean diff(String dataType, Bytes expected, Bytes actual) {
if (!expected.equals(actual)) {
log.error("Difference found in {} - expected {} actual {}", dataType,
Hex.encNonAscii(expected), Hex.encNonAscii(actual));
return true;
}
return false;
}
代码示例来源:origin: apache/fluo
private static RowColumn buildRowColumn(KeyBuilder key) {
if (key.infinite || key.row.equals(Bytes.EMPTY)) {
return RowColumn.EMPTY;
} else if (key.cf.equals(Bytes.EMPTY)) {
return new RowColumn(key.row);
} else if (key.cq.equals(Bytes.EMPTY)) {
return new RowColumn(key.row, new Column(key.cf));
} else if (key.cv.equals(Bytes.EMPTY)) {
return new RowColumn(key.row, new Column(key.cf, key.cq));
}
return new RowColumn(key.row, new Column(key.cf, key.cq, key.cv));
}
代码示例来源:origin: org.apache.fluo/fluo-api
private static RowColumn buildRowColumn(KeyBuilder key) {
if (key.infinite || key.row.equals(Bytes.EMPTY)) {
return RowColumn.EMPTY;
} else if (key.cf.equals(Bytes.EMPTY)) {
return new RowColumn(key.row);
} else if (key.cq.equals(Bytes.EMPTY)) {
return new RowColumn(key.row, new Column(key.cf));
} else if (key.cv.equals(Bytes.EMPTY)) {
return new RowColumn(key.row, new Column(key.cf, key.cq));
}
return new RowColumn(key.row, new Column(key.cf, key.cq, key.cv));
}
代码示例来源:origin: apache/fluo
void setReadLock(Bytes row, Column col) {
checkIfOpen();
Objects.requireNonNull(row);
Objects.requireNonNull(col);
if (col.getFamily().equals(ColumnConstants.NOTIFY_CF)) {
throw new IllegalArgumentException(ColumnConstants.NOTIFY_CF + " is a reserved family");
}
env.getSharedResources().getVisCache().validate(col);
Map<Column, Bytes> colUpdates = updates.computeIfAbsent(row, k -> new HashMap<>());
Bytes curVal = colUpdates.get(col);
if (curVal != null && (isWrite(curVal) || isDelete(curVal))) {
throw new AlreadySetException("Attemped read lock after write lock " + row + " " + col);
}
colUpdates.put(col, RLOCK_VAL);
}
代码示例来源:origin: org.apache.fluo/fluo-recipes-core
/**
* @return Returns input with prefix and hash stripped from beginning.
*/
public Bytes removeHash(Bytes row) {
Preconditions.checkArgument(row.length() >= prefixBytes.length() + 5,
"Row is shorter than expected " + row);
Preconditions.checkArgument(row.subSequence(0, prefixBytes.length()).equals(prefixBytes),
"Row does not have expected prefix " + row);
Preconditions.checkArgument(hasHash(row), "Row does not have expected hash " + row);
return row.subSequence(prefixBytes.length() + 5, row.length());
}
代码示例来源:origin: org.apache.fluo/fluo-recipes-core
@Override
public boolean equals(Object o) {
if (o instanceof Value) {
Value ov = (Value) o;
if (getBytes() == null) {
return ov.getBytes() == null;
} else {
return getBytes().equals(ov.getBytes());
}
}
return false;
}
}
代码示例来源:origin: org.apache.fluo/fluo-core
private static boolean isPrimary(PrimaryRowColumn prc, Key k) {
return prc.prow.equals(ByteUtil.toBytes(k.getRowData()))
&& prc.pcol.equals(SpanUtil.toRowColumn(k).getColumn());
}
代码示例来源:origin: apache/fluo
private static boolean isPrimary(PrimaryRowColumn prc, Key k) {
return prc.prow.equals(ByteUtil.toBytes(k.getRowData()))
&& prc.pcol.equals(SpanUtil.toRowColumn(k).getColumn());
}
内容来源于网络,如有侵权,请联系作者删除!