本文整理了Java中org.apache.rya.api.domain.RyaStatement.setContext
方法的一些代码示例,展示了RyaStatement.setContext
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RyaStatement.setContext
方法的具体详情如下:
包路径:org.apache.rya.api.domain.RyaStatement
类名称: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()));
内容来源于网络,如有侵权,请联系作者删除!