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

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

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

RyaStatement.setContext介绍

暂无

代码示例

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

public RyaStatementBuilder setContext(final RyaURI ryaURI) {
  ryaStatement.setContext(ryaURI);
  return this;
}

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

public RyaStatementBuilder setContext(final RyaIRI ryaIRI) {
  ryaStatement.setContext(ryaIRI);
  return this;
}

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

/**
 * Writes a (key,value) pair to Rya. Adds the statement to a buffer, and
 * flushes the statement buffer to the database if full.
 * @param   key     Arbitrary Writable, not used.
 * @param   value   Contains statement to insert to Rya.
 * @throws  IOException if writing to Accumulo fails.
 */
@Override
public void write(final Writable key, final RyaStatementWritable value) throws IOException {
  final RyaStatement ryaStatement = value.getRyaStatement();
  if (ryaStatement.getColumnVisibility() == null) {
    ryaStatement.setColumnVisibility(cv);
  }
  if (ryaStatement.getContext() == null) {
    ryaStatement.setContext(defaultContext);
  }
  buffer.add(ryaStatement);
  bufferCurrentSize += statementSize(ryaStatement);
  if (bufferCurrentSize >= bufferSizeLimit) {
    flushBuffer();
  }
}

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

/**
 * Writes a (key,value) pair to Rya. Adds the statement to a buffer, and
 * flushes the statement buffer to the database if full.
 * @param   key     Arbitrary Writable, not used.
 * @param   value   Contains statement to insert to Rya.
 * @throws  IOException if writing to Accumulo fails.
 */
@Override
public void write(final Writable key, final RyaStatementWritable value) throws IOException {
  final RyaStatement ryaStatement = value.getRyaStatement();
  if (ryaStatement.getColumnVisibility() == null) {
    ryaStatement.setColumnVisibility(cv);
  }
  if (ryaStatement.getContext() == null) {
    ryaStatement.setContext(defaultContext);
  }
  buffer.add(ryaStatement);
  bufferCurrentSize += statementSize(ryaStatement);
  if (bufferCurrentSize >= bufferSizeLimit) {
    flushBuffer();
  }
}

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

boolean hasNextValue = input.readBoolean();
if (hasNextValue){
  statement.setContext(new RyaIRI(input.readString()));

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

boolean hasNextValue = input.readBoolean();
if (hasNextValue){
  statement.setContext(new RyaURI(input.readString()));

相关文章