We don't support supercolumns in CFIF yet.
Peng Guo added this in his patchset at
http://files.cnblogs.com/gpcuster/CassandraInputFormat.rar but it's
mixed in with a ton of other changes. Honestly it's probably easier
to start fresh, but it might be useful to look at his code for
inspiration.
On Wed, Jun 2, 2010 at 2:41 PM, Torsten Curdt <tcu...@vafer.org> wrote:
> I have a super column along he lines of
>
> <time> => { <long> => { att: value }}
>
> Now I would like to process a set of rows [from_time..until_time] with Hadoop.
> I've setup the hadoop job like this
>
> job.setInputFormatClass(ColumnFamilyInputFormat.class);
> ConfigHelper.setColumnFamily(job.getConfiguration(), "family",
> "events");
>
> SlicePredicate predicate = new SlicePredicate();
> predicate.setSlice_range(new SliceRange(new byte[0], new
> byte[0],
> false, 1000));
>
> ConfigHelper.setSlicePredicate(job.getConfiguration(),
> predicate);
>
> but I don't see how I could say what rows the job should process.
> Any pointers?
>
> cheers
> --
> Torsten
>
--
Jonathan Ellis
Project Chair, Apache Cassandra
co-founder of Riptano, the source for professional Cassandra support
http://riptano.com
