org.apache.rya.api.domain.RyaStatement.getSubject()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(8.1k)|赞(0)|评价(0)|浏览(106)

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

RyaStatement.getSubject介绍

暂无

代码示例

代码示例来源：origin: org.apache.rya/rya.api

@Override
  protected RyaURI convert(RyaStatement statement) throws RyaDAOException {
    return statement.getSubject();
  }
}, entry);

代码示例来源：origin: apache/incubator-rya

@Override
  protected RyaIRI convert(RyaStatement statement) throws RyaDAOException {
    return statement.getSubject();
  }
}, entry);

代码示例来源：origin: org.apache.rya/rya.api

@Override
public RyaURI next() throws RyaDAOException {
  if (query == null || !query.hasNext()) {
    if (!batchNext()) return null;
  }
  if (query != null && query.hasNext()) {
    return query.next().getKey().getSubject();
  } else {
    return null;
  }
}

代码示例来源：origin: apache/incubator-rya

@Override
public RyaIRI next() throws RyaDAOException {
  if (query == null || !query.hasNext()) {
    if (!batchNext()) return null;
  }
  if (query != null && query.hasNext()) {
    return query.next().getKey().getSubject();
  } else {
    return null;
  }
}

代码示例来源：origin: org.apache.rya/rya.mapreduce

private int statementSize(final RyaStatement ryaStatement) {
  final RyaURI subject = ryaStatement.getSubject();
  final RyaURI predicate = ryaStatement.getPredicate();
  final RyaType object = ryaStatement.getObject();
  final RyaURI context = ryaStatement.getContext();
  int size = 3 + subject.getData().length() + predicate.getData().length() + object.getData().length();
  if (!XMLSchema.ANYURI.equals(object.getDataType())) {
    size += 2 + object.getDataType().toString().length();
  }
  if (context != null) {
    size += context.getData().length();
  }
  return size;
}

代码示例来源：origin: apache/incubator-rya

private int statementSize(final RyaStatement ryaStatement) {
  final RyaIRI subject = ryaStatement.getSubject();
  final RyaIRI predicate = ryaStatement.getPredicate();
  final RyaType object = ryaStatement.getObject();
  final RyaIRI context = ryaStatement.getContext();
  int size = 3 + subject.getData().length() + predicate.getData().length() + object.getData().length();
  if (!XMLSchema.ANYURI.equals(object.getDataType())) {
    size += 2 + object.getDataType().toString().length();
  }
  if (context != null) {
    size += context.getData().length();
  }
  return size;
}

代码示例来源：origin: org.apache.rya/rya.api

public TriplePatternStrategy retrieveStrategy(final RyaStatement stmt) {
  return retrieveStrategy(stmt.getSubject(), stmt.getPredicate(), stmt.getObject(), stmt.getContext());
}

代码示例来源：origin: apache/incubator-rya

public TriplePatternStrategy retrieveStrategy(final RyaStatement stmt) {
  return retrieveStrategy(stmt.getSubject(), stmt.getPredicate(), stmt.getObject(), stmt.getContext());
}

代码示例来源：origin: org.apache.rya/mongodb.rya

private static boolean isResultForQuery(final RyaStatement query, final RyaStatement result) {
  return isResult(query.getSubject(), result.getSubject()) &&
      isResult(query.getPredicate(), result.getPredicate()) &&
      isResult(query.getObject(), result.getObject()) &&
      isResult(query.getContext(), result.getContext());
}

代码示例来源：origin: apache/incubator-rya

private static String prettyFormat(final RyaStatement statement) {
  final RyaIRI s = statement.getSubject();
  final RyaIRI p = statement.getPredicate();
  final RyaType o = statement.getObject();
  return "<" + s.getData() + "> <"+ p.getData() + "> <" + o.getData() + ">";
}

代码示例来源：origin: apache/incubator-rya

private static boolean isResultForQuery(final RyaStatement query, final RyaStatement result) {
  return isResult(query.getSubject(), result.getSubject()) &&
      isResult(query.getPredicate(), result.getPredicate()) &&
      isResult(query.getObject(), result.getObject()) &&
      isResult(query.getContext(), result.getContext());
}

代码示例来源：origin: org.apache.rya/rya.api

private boolean batchNext() throws RyaDAOException {
  if (!iteration.hasNext()) {
    return false;
  }
  Collection<Map.Entry<RyaStatement, BindingSet>> batchedResults = new ArrayList<Map.Entry<RyaStatement, BindingSet>>();
  for (int i = 0; i < batch && iteration.hasNext(); i++) {
    RyaStatement next = iteration.next();
    batchedResults.add(new RdfCloudTripleStoreUtils.CustomEntry<RyaStatement, BindingSet>(
        new RyaStatement(next.getSubject(), pred, next.getObject()), null));
  }
  query = ryaQueryEngine.queryWithBindingSet(batchedResults, null);
  return query.hasNext();
}

代码示例来源：origin: apache/incubator-rya

private boolean batchNext() throws RyaDAOException {
  if (!iteration.hasNext()) {
    return false;
  }
  Collection<Map.Entry<RyaStatement, BindingSet>> batchedResults = new ArrayList<Map.Entry<RyaStatement, BindingSet>>();
  for (int i = 0; i < batch && iteration.hasNext(); i++) {
    RyaStatement next = iteration.next();
    batchedResults.add(new RdfCloudTripleStoreUtils.CustomEntry<RyaStatement, BindingSet>(
        new RyaStatement(next.getSubject(), pred, next.getObject()), null));
  }
  query = ryaQueryEngine.queryWithBindingSet(batchedResults, null);
  return query.hasNext();
}

代码示例来源：origin: apache/incubator-rya

public static String getTripleString(final RyaStatement rs) {
  checkNotNull(rs);
  final String subj = rs.getSubject().getData() + TYPE_DELIM + URI_TYPE;
  final String pred = rs.getPredicate().getData() + TYPE_DELIM + URI_TYPE;
  final String objData = rs.getObject().getData();
  final String objDataType = rs.getObject().getDataType().stringValue();
  return subj + DELIM + pred + DELIM + objData + TYPE_DELIM + objDataType;
}

代码示例来源：origin: org.apache.rya/rya.pcj.fluo.app

public static String getTripleString(final RyaStatement rs) {
  checkNotNull(rs);
  final String subj = rs.getSubject().getData() + TYPE_DELIM + URI_TYPE;
  final String pred = rs.getPredicate().getData() + TYPE_DELIM + URI_TYPE;
  final String objData = rs.getObject().getData();
  final String objDataType = rs.getObject().getDataType().stringValue();
  return subj + DELIM + pred + DELIM + objData + TYPE_DELIM + objDataType;
}

代码示例来源：origin: apache/incubator-rya

public static void ryaStatementsEqualIgnoresBlankNode(Set<RyaStatement> statements1, Set<RyaStatement> statements2) {
  Map<String, RyaIRI> bNodeMap = new HashMap<>();
  statements1.forEach(x-> bNodeMap.put(x.getPredicate().getData(), x.getSubject()));
  statements2.forEach(x -> x.setSubject(bNodeMap.get(x.getPredicate().getData())));
  ryaStatementSetsEqualIgnoresTimestamp(statements1, statements2);
}

代码示例来源：origin: apache/incubator-rya

public static void ryaStatementsEqualIgnoresBlankNode(Set<RyaStatement> statements1, Set<RyaStatement> statements2) {
  Map<String, RyaIRI> bNodeMap = new HashMap<>();
  statements1.forEach(x-> bNodeMap.put(x.getPredicate().getData(), x.getSubject()));
  statements2.forEach(x -> x.setSubject(bNodeMap.get(x.getPredicate().getData())));
  ryaStatementSetsEqualIgnoresTimestamp(statements1, statements2);
}

代码示例来源：origin: org.apache.rya/rya.api

public static Statement convertStatement(RyaStatement statement) {
  assert statement != null;
  if (statement.getContext() != null) {
    return new ContextStatementImpl(convertURI(statement.getSubject()),
        convertURI(statement.getPredicate()),
        convertValue(statement.getObject()),
        convertURI(statement.getContext()));
  } else {
    return new StatementImpl(convertURI(statement.getSubject()),
        convertURI(statement.getPredicate()),
        convertValue(statement.getObject()));
  }
}

代码示例来源：origin: apache/incubator-rya

private static RyaStatement updateRyaStatementColumnVisibility(final RyaStatement ryaStatement, final ColumnVisibility newCv) {
  final RyaStatement newCvRyaStatement = new RyaStatement(ryaStatement.getSubject(), ryaStatement.getPredicate(), ryaStatement.getObject(), ryaStatement.getContext(), ryaStatement.getQualifer(), newCv.getExpression(), ryaStatement.getValue(), ryaStatement.getTimestamp());
  return newCvRyaStatement;
}

代码示例来源：origin: apache/incubator-rya

/**
 * Turn a single StatementPattern into a Range.
 * @param conf
 * @throws IOException if the range can't be resolved
 */
private Map.Entry<TABLE_LAYOUT, ByteRange> getRange(final StatementPattern sp) throws IOException {
  final Var context = sp.getContextVar();
  final Statement stmt = new NullableStatementImpl((Resource) sp.getSubjectVar().getValue(),
      (IRI) sp.getPredicateVar().getValue(), sp.getObjectVar().getValue(),
      context == null ? null : (Resource) context.getValue());
  final RyaStatement rs = RdfToRyaConversions.convertStatement(stmt);
  final TriplePatternStrategy strategy = ryaContext.retrieveStrategy(rs);
  final Map.Entry<TABLE_LAYOUT, ByteRange> entry =
      strategy.defineRange(rs.getSubject(), rs.getPredicate(), rs.getObject(), rs.getContext(), conf);
  return entry;
}

内容来源于网络，如有侵权，请联系作者删除！

RyaStatement

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com