Consider this function there.
@Test(timeout = TestConstants.ITEST_TIMEOUT)
public void test() throws Exception {
ArrayList<ColumnDescriptor> columns = new ArrayList<ColumnDescriptor>();
ColumnDescriptor cd = new ColumnDescriptor();
cd.name = FAMILY1;
columns.add(cd);
cd = new ColumnDescriptor();
cd.name = FAMILY2;
columns.add(cd);
Hbase.Client client = controller.getThriftClient();
client.createTable(TABLE, columns);
ArrayList<Mutation> mutations = new ArrayList<Mutation>();
mutations.add(new Mutation(false, COLUMN, VALUE));
client.mutateRow(TABLE, ROW, mutations);
int scan1 = client.scannerOpen(TABLE, FIRST,
Lists.newArrayList(FAMILY1));
List<TRowResult> rows = client.scannerGet(scan1);
assertThat(rows.size(), is(1));
assertThat(Bytes.toString(rows.get(0).getRow()), is("testRow"));
assertTrue("No more rows", client.scannerGet(scan1).isEmpty());
client.scannerClose(scan1);
int scan2 = client.scannerOpen(TABLE, FIRST,
Lists.newArrayList(FAMILY2));
assertTrue("No more rows", client.scannerGet(scan2).isEmpty());
client.scannerClose(scan2);
}
The name attribute in a ColumnDescriptor is of type byte buffer whereas
FAMILY1 is a byte[] array. In eclipse the red marks say, "Type mismatch:
cannot convert from byte[] to ByteBuffer"
--
thanks and regards,
Apurv Verma
B. Tech.(CSE)
IIT- Ropar
On Wed, Mar 21, 2012 at 8:46 PM, Andrei Savu <[email protected]> wrote:
> What kind of problems?
>
> On Wed, Mar 21, 2012 at 5:14 PM, Apurv Verma <[email protected]> wrote:
>
>> Hi,
>> I pulled the latest whirr-trunk and imported it into eclipse. The
>> class CdhHBaseServiceTest in whirr-cdh is having problems.
>>
>>
>> --
>> thanks and regards,
>>
>> Apurv Verma
>> B. Tech.(CSE)
>> IIT- Ropar
>>
>>
>>
>>
>>
>