Yeah. I think we might also consider supporting RowKeyFormat with a hash
prefix, if that's still supported.


On Thu, May 2, 2013 at 5:32 PM, Jeff Kolesky <notifications@github.com>wrote:

> In
> kiji-mapreduce/src/main/java/org/kiji/mapreduce/framework/SmartKijiTableInputFormat.java:
>
> > +        throw new IOException(String.format("Invalid value [%s] for configuration propert [%s]: "
> > +                                            + "post hash start key must be incrementable",
> > +                                            postHashStartKeyEncoded, KIJI_POST_HASH_START_KEY));
> > +      }
> > +
> > +      // In cases were the end key does not equal the postHashStartKey, we'll want to use
> > +      // the said prefix + 1.
> > +      byte[] postHashEndKey = postHashStartKey.clone();
> > +      incrementKey(postHashEndKey, 1);
> > +
> > +      final KijiURI inputTableURI = KijiURI.newBuilder(
> > +                                      conf.get(KijiConfKeys.KIJI_
> INPUT_TABLE_URI)).build();
> > +      final Kiji kiji = Kiji.Factory.open(inputTableURI, conf);
> > +      try {
> > +        final KijiTable table = kiji.openTable(inputTableURI.getTable());
> > +        RowKeyFormat2 rowKeyFormat2 = (RowKeyFormat2) table.getLayout().getDesc().getKeysFormat();
>
> Perhaps check for the format being RowKeyFormat2 and explicitly throw an
> exception if the check fails. Also document this as a requirement.
>
> —
> Reply to this email directly or view it on GitHub<https://github.com/opower/kiji-mapreduce/pull/4/files#r4067302>
> .
>