本文整理了Java中org.apache.tephra.Transaction.isCurrentWrite()
方法的一些代码示例,展示了Transaction.isCurrentWrite()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Transaction.isCurrentWrite()
方法的具体详情如下:
包路径:org.apache.tephra.Transaction
类名称:Transaction
方法名:isCurrentWrite
[英]Returns whether the given version was written by the current transaction.
[中]
代码示例来源:origin: org.apache.tephra/tephra-api
/**
* Returns whether or not the given version should be visible to the current transaction. A version will be visible
* if it was successfully committed prior to the current transaction starting, or was written by the current
* transaction (using either the current write pointer or the write pointer from a prior checkpoint).
*
* @param version the data version to check for visibility
* @return true if the version is visible, false if it should be hidden (filtered)
*
* @see #setVisibility(VisibilityLevel) to control whether the current write pointer is visible.
*/
public boolean isVisible(long version) {
// either it was committed before or the change belongs to current tx
return (version <= getReadPointer() && !isExcluded(version)) ||
(isCurrentWrite(version) &&
(visibilityLevel != VisibilityLevel.SNAPSHOT_EXCLUDE_CURRENT || writePointer != version));
}
代码示例来源:origin: org.apache.tephra/tephra-hbase-compat-0.96
} else if (tx.isVisible(kvTimestamp)) {
if (tx.getVisibilityLevel() == Transaction.VisibilityLevel.SNAPSHOT_ALL && tx.isCurrentWrite(kvTimestamp)) {
代码示例来源:origin: org.apache.tephra/tephra-hbase-compat-0.98
} else if (tx.isVisible(kvTimestamp)) {
if (tx.getVisibilityLevel() == Transaction.VisibilityLevel.SNAPSHOT_ALL && tx.isCurrentWrite(kvTimestamp)) {
代码示例来源:origin: org.apache.tephra/tephra-hbase-compat-1.0
} else if (tx.isVisible(kvTimestamp)) {
if (tx.getVisibilityLevel() == Transaction.VisibilityLevel.SNAPSHOT_ALL && tx.isCurrentWrite(kvTimestamp)) {
代码示例来源:origin: org.apache.tephra/tephra-hbase-compat-1.1
} else if (tx.isVisible(kvTimestamp)) {
if (tx.getVisibilityLevel() == Transaction.VisibilityLevel.SNAPSHOT_ALL && tx.isCurrentWrite(kvTimestamp)) {
代码示例来源:origin: org.apache.tephra/tephra-hbase-compat-1.0-cdh
} else if (tx.isVisible(kvTimestamp)) {
if (tx.getVisibilityLevel() == Transaction.VisibilityLevel.SNAPSHOT_ALL && tx.isCurrentWrite(kvTimestamp)) {
内容来源于网络,如有侵权,请联系作者删除!