repeatedSample.addSampleSize(sampleSize);
repeatedSample.addSampleRepeat(sampleRepeat);
repeatedSample.connectDataInput(tupleFactory.getDataOutput());
pipeline.add(repeatedSample);
TupleToWebRowSetCharArrays tupleToWebRowSet =
new TupleToWebRowSetCharArrays();
tupleToWebRowSet.connectDataInput(repeatedSample.getResultOutput());
pipeline.add(tupleToWebRowSet);
WriteToDataSource writeToDataSource =
new WriteToDataSource();
writeToDataSource.setResourceID(dataSource.getResourceID());
writeToDataSource.connectInput(tupleToWebRowSet.getResultOutput());
pipeline.add(writeToDataSource);
tupleToWebRowSet.getResultOutput().setDataSourceResource(dataSource);
// send it to the server
RequestResource request =
drer.execute(pipeline, RequestExecutionType.ASYNCHRONOUS);
request.pollUntilRequestStarted(1000);
// Get the result data and display it
int count = 0;
while(tupleToWebRowSet.hasNextResult())
{
System.out.println("******************************************************");
System.out.println("******************************************************");
System.out.println("Have new result set, number " + count);
System.out.println("******************************************************");
System.out.println("******************************************************");
ResultSet rs = tupleToWebRowSet.nextResultAsResultSet();
printResultSet(rs);
count++;
if (count == numRuns)