Repository: incubator-rya Updated Branches: refs/heads/develop 30ca57ede -> c8249adb4
Added data type in tuple creation Project: http://git-wip-us.apache.org/repos/asf/incubator-rya/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-rya/commit/c8249adb Tree: http://git-wip-us.apache.org/repos/asf/incubator-rya/tree/c8249adb Diff: http://git-wip-us.apache.org/repos/asf/incubator-rya/diff/c8249adb Branch: refs/heads/develop Commit: c8249adb47674c4e0a0802e1745baa060a6ea23b Parents: 30ca57e Author: craighahnparsons <[email protected]> Authored: Thu Mar 17 14:31:36 2016 -0400 Committer: pujav65 <[email protected]> Committed: Thu Apr 7 09:06:06 2016 -0400 ---------------------------------------------------------------------- .../main/java/mvm/rya/accumulo/pig/StatementPatternStorage.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/c8249adb/pig/accumulo.pig/src/main/java/mvm/rya/accumulo/pig/StatementPatternStorage.java ---------------------------------------------------------------------- diff --git a/pig/accumulo.pig/src/main/java/mvm/rya/accumulo/pig/StatementPatternStorage.java b/pig/accumulo.pig/src/main/java/mvm/rya/accumulo/pig/StatementPatternStorage.java index 9ec9d45..6e67f29 100644 --- a/pig/accumulo.pig/src/main/java/mvm/rya/accumulo/pig/StatementPatternStorage.java +++ b/pig/accumulo.pig/src/main/java/mvm/rya/accumulo/pig/StatementPatternStorage.java @@ -289,11 +289,14 @@ public class StatementPatternStorage extends AccumuloStorage { RyaStatement ryaStatement = ryaContext.deserializeTriple(layout, new TripleRow(key.getRow().getBytes(), key.getColumnFamily().getBytes(), key.getColumnQualifier().getBytes())); - Tuple tuple = TupleFactory.getInstance().newTuple(4); + Tuple tuple = TupleFactory.getInstance().newTuple(7); tuple.set(0, ryaStatement.getSubject().getData()); tuple.set(1, ryaStatement.getPredicate().getData()); tuple.set(2, ryaStatement.getObject().getData()); tuple.set(3, (ryaStatement.getContext() != null) ? (ryaStatement.getContext().getData()) : (null)); + tuple.set(4, ryaStatement.getSubject().getDataType()); + tuple.set(5, ryaStatement.getPredicate().getDataType()); + tuple.set(6, ryaStatement.getObject().getDataType()); return tuple; } } catch (Exception e) {
