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

Transaction.setVisibility介绍

[英]Sets the visibility level for read operations.
[中]设置读取操作的可见性级别。

代码示例

代码示例来源：origin: apache/phoenix

@Override
public void setVisibilityLevel(PhoenixVisibilityLevel visibilityLevel) {
  VisibilityLevel tephraVisibilityLevel = null;
  switch (visibilityLevel) {
  case SNAPSHOT:
    tephraVisibilityLevel = VisibilityLevel.SNAPSHOT;
    break;
  case SNAPSHOT_EXCLUDE_CURRENT:
    tephraVisibilityLevel = VisibilityLevel.SNAPSHOT_EXCLUDE_CURRENT;
    break;
  case SNAPSHOT_ALL:
    tephraVisibilityLevel = VisibilityLevel.SNAPSHOT_ALL;
    break;
  default:
    assert (false);
  }
  Transaction tx = getCurrentTransaction();
  assert(tx != null);
  tx.setVisibility(tephraVisibilityLevel);
}

代码示例来源：origin: apache/phoenix

@Override
public void checkpoint(boolean hasUncommittedData) throws SQLException {
  if (hasUncommittedData) {
    try {
      if (txContext == null) {
        tx = txServiceClient.checkpoint(tx);
      } else {
        assert (txContext != null);
        txContext.checkpoint();
        tx = txContext.getCurrentTransaction();
      }
    } catch (TransactionFailureException e) {
      throw new SQLException(e);
    }
  }
  // Since we're querying our own table while mutating it, we must exclude
  // see our current mutations, otherwise we can get erroneous results
  // (for DELETE)
  // or get into an infinite loop (for UPSERT SELECT).
  if (txContext == null) {
    tx.setVisibility(VisibilityLevel.SNAPSHOT_EXCLUDE_CURRENT);
  } else {
    assert (txContext != null);
    txContext.getCurrentTransaction().setVisibility(
        VisibilityLevel.SNAPSHOT_EXCLUDE_CURRENT);
  }
}

代码示例来源：origin: com.aliyun.phoenix/ali-phoenix-core

@Override
public void setVisibilityLevel(PhoenixVisibilityLevel visibilityLevel) {
  VisibilityLevel tephraVisibilityLevel = null;
  switch (visibilityLevel) {
  case SNAPSHOT:
    tephraVisibilityLevel = VisibilityLevel.SNAPSHOT;
    break;
  case SNAPSHOT_EXCLUDE_CURRENT:
    tephraVisibilityLevel = VisibilityLevel.SNAPSHOT_EXCLUDE_CURRENT;
    break;
  case SNAPSHOT_ALL:
    tephraVisibilityLevel = VisibilityLevel.SNAPSHOT_ALL;
    break;
  default:
    assert (false);
  }
  Transaction tx = getCurrentTransaction();
  assert(tx != null);
  tx.setVisibility(tephraVisibilityLevel);
}

代码示例来源：origin: org.apache.phoenix/phoenix-core

@Override
public void setVisibilityLevel(PhoenixVisibilityLevel visibilityLevel) {
  VisibilityLevel tephraVisibilityLevel = null;
  switch (visibilityLevel) {
  case SNAPSHOT:
    tephraVisibilityLevel = VisibilityLevel.SNAPSHOT;
    break;
  case SNAPSHOT_EXCLUDE_CURRENT:
    tephraVisibilityLevel = VisibilityLevel.SNAPSHOT_EXCLUDE_CURRENT;
    break;
  case SNAPSHOT_ALL:
    tephraVisibilityLevel = VisibilityLevel.SNAPSHOT_ALL;
    break;
  default:
    assert (false);
  }
  Transaction tx = getCurrentTransaction();
  assert(tx != null);
  tx.setVisibility(tephraVisibilityLevel);
}

代码示例来源：origin: com.aliyun.phoenix/ali-phoenix-core

@Override
public void checkpoint(boolean hasUncommittedData) throws SQLException {
  if (hasUncommittedData) {
    try {
      if (txContext == null) {
        tx = txServiceClient.checkpoint(tx);
      } else {
        assert (txContext != null);
        txContext.checkpoint();
        tx = txContext.getCurrentTransaction();
      }
    } catch (TransactionFailureException e) {
      throw new SQLException(e);
    }
  }
  // Since we're querying our own table while mutating it, we must exclude
  // see our current mutations, otherwise we can get erroneous results
  // (for DELETE)
  // or get into an infinite loop (for UPSERT SELECT).
  if (txContext == null) {
    tx.setVisibility(VisibilityLevel.SNAPSHOT_EXCLUDE_CURRENT);
  } else {
    assert (txContext != null);
    txContext.getCurrentTransaction().setVisibility(
        VisibilityLevel.SNAPSHOT_EXCLUDE_CURRENT);
  }
}

代码示例来源：origin: org.apache.phoenix/phoenix-core

@Override
public void checkpoint(boolean hasUncommittedData) throws SQLException {
  if (hasUncommittedData) {
    try {
      if (txContext == null) {
        tx = txServiceClient.checkpoint(tx);
      } else {
        assert (txContext != null);
        txContext.checkpoint();
        tx = txContext.getCurrentTransaction();
      }
    } catch (TransactionFailureException e) {
      throw new SQLException(e);
    }
  }
  // Since we're querying our own table while mutating it, we must exclude
  // see our current mutations, otherwise we can get erroneous results
  // (for DELETE)
  // or get into an infinite loop (for UPSERT SELECT).
  if (txContext == null) {
    tx.setVisibility(VisibilityLevel.SNAPSHOT_EXCLUDE_CURRENT);
  } else {
    assert (txContext != null);
    txContext.getCurrentTransaction().setVisibility(
        VisibilityLevel.SNAPSHOT_EXCLUDE_CURRENT);
  }
}