org.apache.fluo.api.data.Bytes.equals()方法的使用及代码示例

x33g5p2x  于2022-01-17 转载在 其他  
字(6.3k)|赞(0)|评价(0)|浏览(62)

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

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());
}

相关文章