Class NotReadyResult
- java.lang.Object
-
- org.apache.flink.table.gateway.service.result.NotReadyResult
-
- All Implemented Interfaces:
org.apache.flink.table.gateway.api.results.ResultSet
public class NotReadyResult extends Object implements org.apache.flink.table.gateway.api.results.ResultSet
To represent that the execution result is not ready to fetch.
-
-
Field Summary
Fields Modifier and Type Field Description static NotReadyResultINSTANCE
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description List<org.apache.flink.table.data.RowData>getData()org.apache.flink.api.common.JobIDgetJobID()LonggetNextToken()org.apache.flink.table.api.ResultKindgetResultKind()org.apache.flink.table.catalog.ResolvedSchemagetResultSchema()org.apache.flink.table.gateway.api.results.ResultSet.ResultTypegetResultType()booleanisQueryResult()
-
-
-
Field Detail
-
INSTANCE
public static final NotReadyResult INSTANCE
-
-
Method Detail
-
getResultType
public org.apache.flink.table.gateway.api.results.ResultSet.ResultType getResultType()
- Specified by:
getResultTypein interfaceorg.apache.flink.table.gateway.api.results.ResultSet
-
getNextToken
public Long getNextToken()
- Specified by:
getNextTokenin interfaceorg.apache.flink.table.gateway.api.results.ResultSet
-
getResultSchema
public org.apache.flink.table.catalog.ResolvedSchema getResultSchema()
- Specified by:
getResultSchemain interfaceorg.apache.flink.table.gateway.api.results.ResultSet
-
getData
public List<org.apache.flink.table.data.RowData> getData()
- Specified by:
getDatain interfaceorg.apache.flink.table.gateway.api.results.ResultSet
-
isQueryResult
public boolean isQueryResult()
- Specified by:
isQueryResultin interfaceorg.apache.flink.table.gateway.api.results.ResultSet
-
getJobID
public org.apache.flink.api.common.JobID getJobID()
- Specified by:
getJobIDin interfaceorg.apache.flink.table.gateway.api.results.ResultSet
-
getResultKind
public org.apache.flink.table.api.ResultKind getResultKind()
- Specified by:
getResultKindin interfaceorg.apache.flink.table.gateway.api.results.ResultSet
-
-