@ Override public Record read ( Key key , ReadConsistency consistency ) { checkNotNull ( key , "key" ) ; checkNotNull ( consistency , "consistency" ) ; AstyanaxTable table = ( AstyanaxTable ) key . getTable ( ) ; AstyanaxStorage storage = table . getReadStorage ( ) ; DeltaPlacement placement = ( DeltaPlacement ) storage . getPlacement ( ) ; ByteBuffer rowKey = storage . getRowKey ( key . getKey ( ) ) ; return read ( key , rowKey , consistency , placement ) ; }
This CQL based read method works for a row with 64 deltas of 3 MB each . The same read with the AstyanaxDataReaderDAO would give Thrift frame errors .