All Classes

Class	Description
AbstractOperationHandler	Abstract operation handler.
AbstractOperationHeaders	Abstract operation related message headers.
AbstractSqlGatewayRestHandler<R extends org.apache.flink.runtime.rest.messages.RequestBody,P extends org.apache.flink.runtime.rest.messages.ResponseBody,M extends org.apache.flink.runtime.rest.messages.MessageParameters>	Super class for sql gateway handlers that work with RequestBodys and ResponseBodys.
CancelOperationHandler	Handler to cancel operation.
CancelOperationHeaders	Message headers for canceling operation.
CloseOperationHandler	Handler to close operation.
CloseOperationHeaders	Message headers for closing operation.
CloseSessionHandler	Handler to close session.
CloseSessionHeaders	Message headers for closing a session.
CloseSessionResponseBody	ResponseBody for closing a session.
ColumnInfo	A column info represents a table column's structure with column name, column type.
CompleteStatementHandler	Handler to complete a statement.
CompleteStatementHeaders	Message headers for completing a statement.
CompleteStatementRequestBody	RequestBody for completing a statement.
CompleteStatementResponseBody	ResponseBody for completing a statement.
ConfigureSessionHandler	Handler to configure a session with statement.
ConfigureSessionHeaders	Message headers for configuring a session.
ConfigureSessionRequestBody	RequestBody for configuring a session.
Constants	Constants used in the SqlGatewayService.
DefaultContext	The context memorized initial configuration.
ExecuteStatementHandler	Handler to execute a statement.
ExecuteStatementHeaders	Message headers for executing a statement.
ExecuteStatementRequestBody	RequestBody for executing a statement.
ExecuteStatementResponseBody	ResponseBody for executing a statement.
FetchResultResponseBodyDeserializer	Deserializer to deserialize FetchResultsResponseBody.
FetchResultResponseBodyImpl	The implementation of the FetchResultsResponseBody with ready results.
FetchResultsHandler	Handler to fetch results.
FetchResultsHeaders	Message headers for fetching results.
FetchResultsMessageParameters	MessageParameters for fetching results.
FetchResultsResponseBody	ResponseBody for executing a statement.
FetchResultsResponseBodySerializer	Serializer to serialize FetchResultsResponseBody.
FetchResultsRowFormatQueryParameter	A MessageQueryParameter that parses the 'rowFormat' query parameter for fetching results.
FetchResultsTokenPathParameter	MessagePathParameter that parses the token string.
GetApiVersionHandler	Handler to get rest api version.
GetApiVersionHeaders	Message headers for getting rest api version.
GetApiVersionResponseBody	ResponseBody for getting rest api version.
GetInfoHandler	Handler to get cluster information.
GetInfoHeaders	Message headers for getting cluster information.
GetInfoResponseBody	ResponseBody for getting cluster information.
GetOperationStatusHandler	Handler to get the status of operation.
GetOperationStatusHeaders	Message headers for getting the status of operation.
GetSessionConfigHandler	Handler to get the session configuration.
GetSessionConfigHeaders	Message headers for getting session configuration.
GetSessionConfigResponseBody	ResponseBody for get session configuration.
LogicalTypeJsonDeserializer	JSON deserializer for LogicalType.
LogicalTypeJsonSerializer	Json serializer for LogicalType.
NotReadyFetchResultResponse	The FetchResultsResponseBody indicates the results is not ready.
NotReadyResult	To represent that the execution result is not ready to fetch.
OpenSessionHandler	Handler to open session.
OpenSessionHeaders	Message headers for opening a session.
OpenSessionRequestBody	RequestBody for opening a session.
OpenSessionResponseBody	ResponseBody for opening a session.
OperationExecutor	An executor to execute the Operation.
OperationHandleIdPathParameter	MessagePathParameter that parses the OperationHandle.
OperationManager	Manager for the OperationManager.Operation.
OperationMessageParameters	MessageParameters for operation.
OperationStatusResponseBody	ResponseBody for getting the status of operation.
ResultFetcher	A fetcher to fetch result from submitted statement.
ResultInfo	A ResultInfo contains information of a ResultSet.
ResultInfoDeserializer	Deserializer for ResultInfo.
ResultInfoSerializer	Serializer for ResultInfo.
ResultStore	A result store which stores and buffers results.
RowFormat	Describes the serialization format of RowData in the ResultSet.
Session	Similar to HTTP Session, which could maintain user identity and store user-specific data during multiple request/response interactions between a client and the gateway server.
SessionContext	Context describing a session, it's mainly used for user to open a new session in the backend.
SessionContext.SessionState	session state.
SessionHandleIdPathParameter	MessagePathParameter that parse the SessionHandle.
SessionManager	Mange the lifecycle of the Session.
SessionManagerImpl	The implementation of the SessionManager that manage the lifecycle of the Session.
SessionMessageParameters	MessagePathParameter for session handle.
SqlCancelException	Thrown to trigger a canceling of the executing operation.
SqlExecutionException	Exception thrown during the execution.
SqlGateway	Main entry point for the SQL Gateway.
SqlGatewayMessageHeaders<R extends org.apache.flink.runtime.rest.messages.RequestBody,P extends org.apache.flink.runtime.rest.messages.ResponseBody,M extends org.apache.flink.runtime.rest.messages.MessageParameters>	This class links RequestBodys to ResponseBodys types and contains meta-data required for their http headers in runtime module.
SqlGatewayOptions	Options to configure the SqlGateway.
SqlGatewayOptionsParser	Parser to parse the command line options.
SqlGatewayRestAPIVersion	An enum for all versions of the Sql Gateway REST API.
SqlGatewayRestEndpoint	The rest endpoint for sql gateway.
SqlGatewayRestEndpointFactory	The factory for sql gateway.
SqlGatewayRestEndpointUtils	Utils for the SqlGatewayRestEndpoint.
SqlGatewayRestOptions	Options to configure SqlGatewayRestEndpoint.
SqlGatewayServiceImpl	The implementation of the SqlGatewayService interface.
SqlGatewayStreamExecutionEnvironment	The SqlGatewayStreamExecutionEnvironment is a StreamExecutionEnvironment that runs the program with SQL gateway.
TriggerSessionHeartbeatHandler	Handler to touch the session.
TriggerSessionHeartbeatHeaders	Message headers for touching the session.
UrlPrefixDecorator<R extends org.apache.flink.runtime.rest.messages.RequestBody,P extends org.apache.flink.runtime.rest.messages.ResponseBody,M extends org.apache.flink.runtime.rest.messages.MessageParameters>	This class decorates the URL of the original message headers by adding a prefix.