Repository: incubator-rya Updated Branches: refs/heads/develop 787c43050 -> 8168b85a7
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/4a73be7a Tree: http://git-wip-us.apache.org/repos/asf/incubator-rya/tree/4a73be7a Diff: http://git-wip-us.apache.org/repos/asf/incubator-rya/diff/4a73be7a Branch: refs/heads/develop Commit: 4a73be7ab8afe24faf9b871f5e11c9c3ca5f034a Parents: 19e2e43 Author: craighahnparsons <[email protected]> Authored: Thu Mar 17 14:31:36 2016 -0400 Committer: craighahnparsons <[email protected]> Committed: Thu Mar 17 14:31:36 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/4a73be7a/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) {
