Repository: incubator-rya Updated Branches: refs/heads/develop c8249adb4 -> 787c43050
fix to add timestamp, column visibility and value to statement Project: http://git-wip-us.apache.org/repos/asf/incubator-rya/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-rya/commit/0bdc86fd Tree: http://git-wip-us.apache.org/repos/asf/incubator-rya/tree/0bdc86fd Diff: http://git-wip-us.apache.org/repos/asf/incubator-rya/diff/0bdc86fd Branch: refs/heads/develop Commit: 0bdc86fd792c7037c60ee151cd0e377102be7793 Parents: c8249ad Author: jej2003 <[email protected]> Authored: Tue Mar 22 14:33:19 2016 -0400 Committer: pujav65 <[email protected]> Committed: Thu May 12 11:46:14 2016 -0400 ---------------------------------------------------------------------- .../src/main/java/mvm/rya/accumulo/mr/RyaStatementInputFormat.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/0bdc86fd/dao/accumulo.rya/src/main/java/mvm/rya/accumulo/mr/RyaStatementInputFormat.java ---------------------------------------------------------------------- diff --git a/dao/accumulo.rya/src/main/java/mvm/rya/accumulo/mr/RyaStatementInputFormat.java b/dao/accumulo.rya/src/main/java/mvm/rya/accumulo/mr/RyaStatementInputFormat.java index c6f12be..3399166 100644 --- a/dao/accumulo.rya/src/main/java/mvm/rya/accumulo/mr/RyaStatementInputFormat.java +++ b/dao/accumulo.rya/src/main/java/mvm/rya/accumulo/mr/RyaStatementInputFormat.java @@ -79,7 +79,7 @@ public class RyaStatementInputFormat extends AbstractInputFormat<Text, RyaStatem try { currentK = currentKey.getRow(); - RyaStatement stmt = this.ryaContext.deserializeTriple(this.tableLayout, new TripleRow(entry.getKey().getRow().getBytes(), entry.getKey().getColumnFamily().getBytes(), entry.getKey().getColumnQualifier().getBytes())); + RyaStatement stmt = this.ryaContext.deserializeTriple(this.tableLayout, new TripleRow(entry.getKey().getRow().getBytes(), entry.getKey().getColumnFamily().getBytes(), entry.getKey().getColumnQualifier().getBytes(), entry.getKey().getTimestamp(), entry.getKey().getColumnVisibility().getBytes(), entry.getValue().get())); RyaStatementWritable writable = new RyaStatementWritable(); writable.setRyaStatement(stmt); currentV = writable;
