org.apache.flink.table.client.gateway

Class StatementResult

java.lang.Object

org.apache.flink.table.client.gateway.StatementResult

All Implemented Interfaces:

AutoCloseable, Iterator<RowData>, CloseableIterator<RowData>

public class StatementResult
extends Object
implements CloseableIterator<RowData>

Wrapped results for the FetchResultsResponseBody.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.util.CloseableIterator

CloseableIterator.IteratorAdapter<E>

Field Summary

Fields inherited from interface org.apache.flink.util.CloseableIterator

EMPTY_INSTANCE

Constructor Summary

Constructors

Constructor and Description
StatementResult(ResolvedSchema resultSchema, CloseableIterator<RowData> resultProvider, boolean isQueryResult, ResultKind resultKind, JobID jobID)
StatementResult(ResolvedSchema resultSchema, CloseableIterator<RowData> resultProvider, boolean isQueryResult, ResultKind resultKind, JobID jobID, RowDataToStringConverter toStringConverter)

Method Summary

Modifier and Type	Method and Description
void	close()
JobID	getJobId()
ResultKind	getResultKind()
ResolvedSchema	getResultSchema()
RowDataToStringConverter	getRowDataToStringConverter()
boolean	hasNext()
boolean	isQueryResult()
RowData	next()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.util.CloseableIterator

adapterForIterator, adapterForIterator, empty, flatten, fromList, ofElement, ofElements

Methods inherited from interface java.util.Iterator

forEachRemaining, remove

Constructor Detail

StatementResult

public StatementResult(ResolvedSchema resultSchema,
                       CloseableIterator<RowData> resultProvider,
                       boolean isQueryResult,
                       ResultKind resultKind,
                       @Nullable
                       JobID jobID)

StatementResult

@VisibleForTesting
public StatementResult(ResolvedSchema resultSchema,
                                          CloseableIterator<RowData> resultProvider,
                                          boolean isQueryResult,
                                          ResultKind resultKind,
                                          @Nullable
                                          JobID jobID,
                                          RowDataToStringConverter toStringConverter)

Method Detail

getResultSchema

public ResolvedSchema getResultSchema()

isQueryResult

public boolean isQueryResult()

getJobId

@Nullable
public JobID getJobId()

getResultKind

public ResultKind getResultKind()

getRowDataToStringConverter

public RowDataToStringConverter getRowDataToStringConverter()

close

public void close()

Specified by:

close in interface AutoCloseable

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<RowData>

next

public RowData next()

Specified by:

next in interface Iterator<RowData>