com.attivio.sdk.client.streaming

Interface StreamingQueryResponse

All Superinterfaces:

AutoCloseable, Closeable

public interface StreamingQueryResponse
extends Closeable

An interface that allows the developer to retrieve results from a streaming search query. Use the SearchClient.search(StreamingQueryRequest) to issues streaming queries.

IMPORTANT:Results must be retrieved in the following order and result retrieval is NOT thread safe. Attempting to retrieve a response type that was not requested may throw an exception.

• documents - via getDocumentIds() or getDocuments() depending on the value of the requested StreamingQueryRequest.DocumentStreamingMode
• facets - via getFacets() - you must call StreamingQueryRequest.setStreamFacets(boolean) to include facet results
• query response - via getQueryResponse()

See Also:

SearchClient, StreamingQueryRequest

Method Summary

Modifier and Type	Method and Description
void	cancel() Force disconnect the client connection.
void	close() Closes the streaming connection.
Iterable<String>	getDocumentIds() Get the response document ids.
Iterable<SearchDocument>	getDocuments() Get the response documents.
Iterable<StreamingFacetResponse>	getFacets() Get the facets.
QueryResponse	getQueryResponse() Get the QueryResponse for the query.

Method Detail

getDocuments

Iterable<SearchDocument> getDocuments()
                               throws IOException

Get the response documents.

This method will throw an exception if documents are not yet available, or were not requested.

Throws:

IOException

getDocumentIds

Iterable<String> getDocumentIds()
                         throws IOException

Get the response document ids.

This method will throw an exception if document ids are not yet available, or were not requested.

Throws:

IOException

getFacets

Iterable<StreamingFacetResponse> getFacets()
                                    throws IOException

Get the facets.

This method will throw an exception if facets are not yet available, or were not requested.

Throws:

IOException

getQueryResponse

QueryResponse getQueryResponse()
                        throws IOException,
                               AttivioException

Get the QueryResponse for the query.

This method will throw an exception if the query response is not yet available, or if the query execution resulted in an exception.

NOTE: this method may return null if stream was closed prematurely.

Throws:

IOException

AttivioException

close

void close()
    throws IOException

Closes the streaming connection.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

cancel

void cancel()
     throws IOException

Force disconnect the client connection. Ignores thread guards on purpose.

Throws:

IOException