Class FetchResultResponseBodyImpl
- java.lang.Object
-
- org.apache.flink.table.gateway.rest.message.statement.FetchResultResponseBodyImpl
-
- All Implemented Interfaces:
org.apache.flink.runtime.rest.messages.ResponseBody,FetchResultsResponseBody
public class FetchResultResponseBodyImpl extends Object implements FetchResultsResponseBody
The implementation of theFetchResultsResponseBodywith ready results.
-
-
Constructor Summary
Constructors Constructor Description FetchResultResponseBodyImpl(org.apache.flink.table.gateway.api.results.ResultSet.ResultType resultType, boolean isQueryResult, org.apache.flink.api.common.JobID jobID, org.apache.flink.table.api.ResultKind resultKind, ResultInfo results, String nextResultUri)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.flink.api.common.JobIDgetJobID()StringgetNextResultUri()org.apache.flink.table.api.ResultKindgetResultKind()ResultInfogetResults()org.apache.flink.table.gateway.api.results.ResultSet.ResultTypegetResultType()booleanisQueryResult()
-
-
-
Constructor Detail
-
FetchResultResponseBodyImpl
public FetchResultResponseBodyImpl(org.apache.flink.table.gateway.api.results.ResultSet.ResultType resultType, boolean isQueryResult, @Nullable org.apache.flink.api.common.JobID jobID, org.apache.flink.table.api.ResultKind resultKind, ResultInfo results, @Nullable String nextResultUri)
-
-
Method Detail
-
getResults
public ResultInfo getResults()
- Specified by:
getResultsin interfaceFetchResultsResponseBody
-
getResultType
public org.apache.flink.table.gateway.api.results.ResultSet.ResultType getResultType()
- Specified by:
getResultTypein interfaceFetchResultsResponseBody
-
getNextResultUri
@Nullable public String getNextResultUri()
- Specified by:
getNextResultUriin interfaceFetchResultsResponseBody
-
isQueryResult
public boolean isQueryResult()
- Specified by:
isQueryResultin interfaceFetchResultsResponseBody
-
getJobID
@Nullable public org.apache.flink.api.common.JobID getJobID()
- Specified by:
getJobIDin interfaceFetchResultsResponseBody
-
getResultKind
public org.apache.flink.table.api.ResultKind getResultKind()
- Specified by:
getResultKindin interfaceFetchResultsResponseBody
-
-