All Classes

Class	Description
AbstractEmbeddedSchedulerWorkflowHeaders	Abstract modify and delete workflow related message headers.
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.
CreateEmbeddedSchedulerWorkflowHandler	Handler to create workflow in embedded scheduler.
CreateEmbeddedSchedulerWorkflowHeaders	Message headers for create workflow in embedded scheduler.
CreateEmbeddedSchedulerWorkflowRequestBody	RequestBody for create workflow in embedded scheduler.
CreateEmbeddedSchedulerWorkflowResponseBody	ResponseBody for create workflow in embedded scheduler.
DefaultContext	The context memorized initial configuration.
DeleteEmbeddedSchedulerWorkflowHandler	Handler to delete workflow in embedded scheduler.
DeleteEmbeddedSchedulerWorkflowHeaders	Message headers for delete workflow in embedded scheduler.
DeployScriptHandler	Handler to deploy the script in application mode.
DeployScriptHeaders	Message headers for run the script in application mode.
DeployScriptRequestBody	Request to deploy a script in application mode.
DeployScriptResponseBody	Response about the cluster that runs the application.
EmbeddedQuartzScheduler	An embedded workflow scheduler based on quartz Scheduler that store all workflow in memory, it does not have high availability.
EmbeddedQuartzScheduler.EmbeddedSchedulerJob	The Job implementation for embedded quartz scheduler.
EmbeddedRefreshHandler	A RefreshHandler instance for embedded workflow scheduler.
EmbeddedRefreshHandlerSerializer	RefreshHandlerSerializer for EmbeddedRefreshHandler.
EmbeddedSchedulerWorkflowRequestBody	RequestBody for suspend, resume, delete workflow in embedded scheduler.
EmbeddedWorkflowScheduler	A workflow scheduler plugin implementation for EmbeddedQuartzScheduler.
EmbeddedWorkflowSchedulerFactory	The WorkflowSchedulerFactory to create the EmbeddedWorkflowScheduler.
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.
MaterializedTableIdentifierPathParameter	MessagePathParameter that parses the materialized table identifier.
MaterializedTableManager	Manager is responsible for execute the MaterializedTableOperation.
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.
Printer	Printer to print the statement results in application mode.
Printer.RowDataIterator
QuartzSchedulerUtils	Utility class for quartz scheduler.
RefreshMaterializedTableHandler	Handler to execute materialized table refresh operation.
RefreshMaterializedTableHeaders	Message headers for executing a materialized table refresh operation.
RefreshMaterializedTableParameters	MessageParameters for execute materialized table refresh operation.
RefreshMaterializedTableRequestBody	RequestBody for executing materialized table refresh operation.
RefreshMaterializedTableResponseBody	ResponseBody for executing a materialized table refresh 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.
ResumeEmbeddedSchedulerWorkflowHandler	Handler to resume workflow in embedded scheduler.
ResumeEmbeddedSchedulerWorkflowHeaders	Message headers for resume workflow in embedded scheduler.
ResumeEmbeddedSchedulerWorkflowRequestBody	RequestBody for resume workflow in embedded scheduler.
RowDataLocalTimeZoneConverter	Convert LocalZonedTimestampType data in RowData to TimestampData based on the local time zone.
RowFormat	Describes the serialization format of RowData in the ResultSet.
SchedulerException	General exception for workflow scheduler related errors.
ScriptExecutor	Executor to execute the statements.
ScriptRunner	Runner to run the script.
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.
SuspendEmbeddedSchedulerWorkflowHandler	Handler to suspend workflow in embedded scheduler.
SuspendEmbeddedSchedulerWorkflowHeaders	Message headers for suspend workflow in embedded scheduler.
TriggerSessionHeartbeatHandler	Handler to touch the session.
TriggerSessionHeartbeatHeaders	Message headers for touching the session.
WorkflowInfo	The WorkflowInfo represents the required information of one materialized table background workflow.