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

RyaStatement.setValue介绍

暂无

代码示例

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

@Deprecated
public RyaStatementBuilder setValue(final byte[] value) {
  ryaStatement.setValue(value);
  return this;
}

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

@Deprecated
public RyaStatementBuilder setValue(final byte[] value) {
  ryaStatement.setValue(value);
  return this;
}

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

public RyaStatementBuilder setMetadata(final StatementMetadata metadata) {
  ryaStatement.setValue(metadata.toBytes());
  return this;
}

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

public RyaStatementBuilder setMetadata(final StatementMetadata metadata) {
  ryaStatement.setValue(metadata.toBytes());
  return this;
}

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

key.getTimestamp(), key.getColumnVisibilityData().toArray(), next.getValue().get()));
if (next.getValue() != null) {
  statement.setValue(next.getValue().get());

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

key.getTimestamp(), key.getColumnVisibilityData().toArray(), next.getValue().get()));
if (next.getValue() != null) {
  statement.setValue(next.getValue().get());

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

/**
   * Loads a RyaStatementWritable by reading data from an input stream.
   * Creates a new RyaStatement and assigns it to this RyaStatementWritable.
   * @param   dataInput   An stream containing serialized statement data.
   */
  @Override
  public void readFields(DataInput dataInput) throws IOException {
    byte[] row = read(dataInput);
    byte[] columnFamily = read(dataInput);
    byte[] columnQualifier = read(dataInput);
    byte[] columnVisibility = read(dataInput);
    byte[] value = read(dataInput);
    boolean b = dataInput.readBoolean();
    Long timestamp = null;
    if (b) {
      timestamp = dataInput.readLong();
    }
    try {
      ryaStatement = ryaContext.deserializeTriple(RdfCloudTripleStoreConstants.TABLE_LAYOUT.SPO,
          new TripleRow(row, columnFamily, columnQualifier));
      ryaStatement.setColumnVisibility(columnVisibility);
      ryaStatement.setValue(value);
      ryaStatement.setTimestamp(timestamp);
    } catch (TripleRowResolverException e) {
      throw new IOException(e);
    }
  }
}

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

/**
   * Loads a RyaStatementWritable by reading data from an input stream.
   * Creates a new RyaStatement and assigns it to this RyaStatementWritable.
   * @param   dataInput   An stream containing serialized statement data.
   */
  @Override
  public void readFields(DataInput dataInput) throws IOException {
    byte[] row = read(dataInput);
    byte[] columnFamily = read(dataInput);
    byte[] columnQualifier = read(dataInput);
    byte[] columnVisibility = read(dataInput);
    byte[] value = read(dataInput);
    boolean b = dataInput.readBoolean();
    Long timestamp = null;
    if (b) {
      timestamp = dataInput.readLong();
    }
    try {
      ryaStatement = ryaContext.deserializeTriple(RdfCloudTripleStoreConstants.TABLE_LAYOUT.SPO,
          new TripleRow(row, columnFamily, columnQualifier));
      ryaStatement.setColumnVisibility(columnVisibility);
      ryaStatement.setValue(value);
      ryaStatement.setTimestamp(timestamp);
    } catch (TripleRowResolverException e) {
      throw new IOException(e);
    }
  }
}

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

@Override
public RyaStatement next() throws RyaDAOException {
  if (!hasNext()) {
    return null;
  }
  try {
    Map.Entry<Key, Value> next = dataIterator.next();
    Key key = next.getKey();
    RyaStatement statement = context.deserializeTriple(tableLayout,
        new TripleRow(key.getRowData().toArray(), key.getColumnFamilyData().toArray(), key.getColumnQualifierData().toArray(),
            key.getTimestamp(), key.getColumnVisibilityData().toArray(), next.getValue().get()));
    if (next.getValue() != null) {
      statement.setValue(next.getValue().get());
    }
    maxResults--;
    return statement;
  } catch (TripleRowResolverException e) {
    throw new RyaDAOException(e);
  }
}

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

@Override
public RyaStatement next() throws RyaDAOException {
  if (!hasNext()) {
    return null;
  }
  try {
    Map.Entry<Key, Value> next = dataIterator.next();
    Key key = next.getKey();
    RyaStatement statement = context.deserializeTriple(tableLayout,
        new TripleRow(key.getRowData().toArray(), key.getColumnFamilyData().toArray(), key.getColumnQualifierData().toArray(),
            key.getTimestamp(), key.getColumnVisibilityData().toArray(), next.getValue().get()));
    if (next.getValue() != null) {
      statement.setValue(next.getValue().get());
    }
    maxResults--;
    return statement;
  } catch (TripleRowResolverException e) {
    throw new RyaDAOException(e);
  }
}

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

if (hasNextValue){
  length = input.readInt();
  statement.setValue(input.readBytes(length));

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

if (hasNextValue){
  length = input.readInt();
  statement.setValue(input.readBytes(length));