com.qubole.qds.sdk.java.client

Class ResultStreamer

java.lang.Object

com.qubole.qds.sdk.java.client.ResultStreamer

All Implemented Interfaces:

Closeable, AutoCloseable

public class ResultStreamer
extends Object
implements Closeable

Streamer for large results

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	ResultStreamer.S3Client

Constructor Summary

Constructors

Constructor and Description
ResultStreamer(QdsClient client)

Method Summary

Modifier and Type	Method and Description
void	close()
protected Account	getAccount()
protected AccountCredentials	getAccountCredentials()
Reader	getResults(ResultValue resultValue) Return a stream over the given results.
protected ResultStreamer.S3Client	newS3Client()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ResultStreamer

public ResultStreamer(QdsClient client)

Parameters:

client - qds client

Method Detail

getResults

public Reader getResults(ResultValue resultValue)
                  throws Exception

Return a stream over the given results. If the results are not inline, the results will come from S3

Parameters:

resultValue - result

Returns:

stream

Throws:

Exception - errors

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

getAccount

protected Account getAccount()
                      throws Exception

Throws:

Exception

getAccountCredentials

protected AccountCredentials getAccountCredentials()
                                            throws Exception

Throws:

Exception

newS3Client

protected ResultStreamer.S3Client newS3Client()
                                       throws Exception

Throws:

Exception