843844845846847848849850851852853
// write the records RecordSink sink = recordSinkProvider.getRecordSink(outputHandle); sink.beginRecord(8); sink.appendLong(2); sink.finishRecord(); sink.beginRecord(5); sink.appendLong(3); sink.finishRecord();
847848849850851852853854855856857
sink.beginRecord(8); sink.appendLong(2); sink.finishRecord(); sink.beginRecord(5); sink.appendLong(3); sink.finishRecord(); sink.beginRecord(7); sink.appendLong(4); sink.finishRecord();
851852853854855856857858859860861
sink.beginRecord(5); sink.appendLong(3); sink.finishRecord(); sink.beginRecord(7); sink.appendLong(4); sink.finishRecord(); String fragment = sink.commit(); // commit the table
921922923924925926927928929930931
// write the records RecordSink sink = recordSinkProvider.getRecordSink(outputHandle); sink.beginRecord(1); sink.appendLong(1); sink.appendString("hello".getBytes(UTF_8)); sink.appendLong(123); sink.appendDouble(43.5); sink.appendBoolean(true); sink.finishRecord();
164165166167168169170171172173174
// write the records RecordSink sink = client.getRecordSink(outputHandle); sink.beginRecord(1); sink.appendLong(1); sink.finishRecord(); sink.beginRecord(1); sink.appendLong(3); sink.finishRecord();
168169170171172173174175176177178
sink.beginRecord(1); sink.appendLong(1); sink.finishRecord(); sink.beginRecord(1); sink.appendLong(3); sink.finishRecord(); sink.beginRecord(1); sink.appendLong(2); sink.finishRecord();
172173174175176177178179180181182
sink.beginRecord(1); sink.appendLong(3); sink.finishRecord(); sink.beginRecord(1); sink.appendLong(2); sink.finishRecord(); String fragment = sink.commit(); // commit the table
859860861862863864865866867868869
863864865866867868869870871872873
867868869870871872873874875876877