| commit | af06318f3bd7ad8e8425c20808409152391026f3 | [log] [tgz] |
|---|---|---|
| author | madhusudancs@gmail.com <madhusudancs@gmail.com@123451ca-8445-de46-9d55-352943316053> | Thu Feb 07 02:31:53 2013 +0000 |
| committer | madhusudancs@gmail.com <madhusudancs@gmail.com@123451ca-8445-de46-9d55-352943316053> | Thu Feb 07 02:31:53 2013 +0000 |
| tree | 85ba6e620c4fe712aa9349e20b593d15a7faebb5 | |
| parent | e9b89569785f1bc5a94cc2b83de00692710b21bb [diff] |
The dataset API only gets the serialized descriptor. git-svn-id: https://hyracks.googlecode.com/svn/branches/fullstack_hyracks_result_distribution@2853 123451ca-8445-de46-9d55-352943316053
diff --git a/hyracks/hyracks-examples/hyracks-integration-tests/src/test/java/edu/uci/ics/hyracks/tests/integration/AbstractIntegrationTest.java b/hyracks/hyracks-examples/hyracks-integration-tests/src/test/java/edu/uci/ics/hyracks/tests/integration/AbstractIntegrationTest.java index c1e0578..c6a0510 100644 --- a/hyracks/hyracks-examples/hyracks-integration-tests/src/test/java/edu/uci/ics/hyracks/tests/integration/AbstractIntegrationTest.java +++ b/hyracks/hyracks-examples/hyracks-integration-tests/src/test/java/edu/uci/ics/hyracks/tests/integration/AbstractIntegrationTest.java
@@ -133,8 +133,8 @@ IHyracksDataset hyracksDataset = new HyracksDataset(hcc, datasetClientCtx, nReaders); hyracksDataset.open(jobId, spec.getResultSetIds().get(0)); - RecordDescriptor recordDescriptor = hyracksDataset.getRecordDescriptor(); - FrameTupleAccessor frameTupleAccessor = new FrameTupleAccessor(datasetClientCtx.getFrameSize(), + byte[] serializedRecordDescriptor = hyracksDataset.getSerializedRecordDescriptor(); +/* FrameTupleAccessor frameTupleAccessor = new FrameTupleAccessor(datasetClientCtx.getFrameSize(), recordDescriptor); ByteBuffer readBuffer = datasetClientCtx.allocateFrame(); @@ -170,7 +170,7 @@ } } // End of my code - +*/ hcc.waitForCompletion(jobId); dumpOutputFiles(); }