A B C D E F G H I J K L M N O P Q R S T U V W

A

AbstractEmbeddedSchedulerWorkflowHeaders - Class in org.apache.flink.table.gateway.rest.header.materializedtable.scheduler

Abstract modify and delete workflow related message headers.

AbstractEmbeddedSchedulerWorkflowHeaders() - Constructor for class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.AbstractEmbeddedSchedulerWorkflowHeaders

AbstractOperationHandler - Class in org.apache.flink.table.gateway.rest.handler.operation

Abstract operation handler.

AbstractOperationHandler(SqlGatewayService, Map<String, String>, MessageHeaders<EmptyRequestBody, OperationStatusResponseBody, OperationMessageParameters>) - Constructor for class org.apache.flink.table.gateway.rest.handler.operation.AbstractOperationHandler

AbstractOperationHeaders - Class in org.apache.flink.table.gateway.rest.header.operation

Abstract operation related message headers.

AbstractOperationHeaders() - Constructor for class org.apache.flink.table.gateway.rest.header.operation.AbstractOperationHeaders

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> - Class in org.apache.flink.table.gateway.rest.handler

Super class for sql gateway handlers that work with RequestBodys and ResponseBodys.

AbstractSqlGatewayRestHandler(SqlGatewayService, Map<String, String>, MessageHeaders<R, P, M>) - Constructor for class org.apache.flink.table.gateway.rest.handler.AbstractSqlGatewayRestHandler

addOperationRelatedHandlers(List<Tuple2<RestHandlerSpecification, ChannelInboundHandler>>) - Method in class org.apache.flink.table.gateway.rest.SqlGatewayRestEndpoint

ADDRESS - Static variable in class org.apache.flink.table.gateway.rest.util.SqlGatewayRestOptions

The address that should be used by clients to connect to the sql gateway server.

addStatementSetOperation(ModifyOperation) - Method in class org.apache.flink.table.gateway.service.context.SessionContext

addUtilRelatedHandlers(List<Tuple2<RestHandlerSpecification, ChannelInboundHandler>>) - Method in class org.apache.flink.table.gateway.rest.SqlGatewayRestEndpoint

asSummaryString() - Method in class org.apache.flink.table.gateway.workflow.EmbeddedRefreshHandler

awaitOperationTermination(OperationHandle) - Method in class org.apache.flink.table.gateway.service.operation.OperationManager

awaitTermination() - Method in class org.apache.flink.table.gateway.service.operation.OperationManager.Operation

B

BIND_ADDRESS - Static variable in class org.apache.flink.table.gateway.rest.util.SqlGatewayRestOptions

The address that the sql gateway server binds itself to.

BIND_PORT - Static variable in class org.apache.flink.table.gateway.rest.util.SqlGatewayRestOptions

The port range that the sql gateway server could bind itself to.

buildNextUri(SqlGatewayRestAPIVersion, String, String, Long, RowFormat) - Static method in class org.apache.flink.table.gateway.rest.header.statement.FetchResultsHeaders

C

callDescribeJobOperation(TableEnvironmentInternal, OperationHandle, DescribeJobOperation) - Method in class org.apache.flink.table.gateway.service.operation.OperationExecutor

callExecutableOperation(OperationHandle, ExecutableOperation) - Method in class org.apache.flink.table.gateway.service.operation.OperationExecutor

callMaterializedTableOperation(OperationExecutor, OperationHandle, MaterializedTableOperation, String) - Method in class org.apache.flink.table.gateway.service.materializedtable.MaterializedTableManager

callRemoveJar(OperationHandle, String) - Method in class org.apache.flink.table.gateway.service.operation.OperationExecutor

callShowJobsOperation(TableEnvironmentInternal, OperationHandle, ShowJobsOperation) - Method in class org.apache.flink.table.gateway.service.operation.OperationExecutor

callStopJobOperation(TableEnvironmentInternal, OperationHandle, StopJobOperation) - Method in class org.apache.flink.table.gateway.service.operation.OperationExecutor

cancel() - Method in class org.apache.flink.table.gateway.service.operation.OperationManager.Operation

cancelOperation(OperationHandle) - Method in class org.apache.flink.table.gateway.service.operation.OperationManager

Cancel the execution of the operation.

cancelOperation(SessionHandle, OperationHandle) - Method in class org.apache.flink.table.gateway.service.SqlGatewayServiceImpl

CancelOperationHandler - Class in org.apache.flink.table.gateway.rest.handler.operation

Handler to cancel operation.

CancelOperationHandler(SqlGatewayService, Map<String, String>, MessageHeaders<EmptyRequestBody, OperationStatusResponseBody, OperationMessageParameters>) - Constructor for class org.apache.flink.table.gateway.rest.handler.operation.CancelOperationHandler

CancelOperationHeaders - Class in org.apache.flink.table.gateway.rest.header.operation

Message headers for canceling operation.

CancelOperationHeaders() - Constructor for class org.apache.flink.table.gateway.rest.header.operation.CancelOperationHeaders

catalogManager - Variable in class org.apache.flink.table.gateway.service.context.SessionContext.SessionState

close() - Method in class org.apache.flink.table.gateway.service.context.SessionContext

Close resources, e.g. catalogs.

close() - Method in class org.apache.flink.table.gateway.service.materializedtable.MaterializedTableManager

close() - Method in class org.apache.flink.table.gateway.service.operation.OperationManager

Closes the OperationManager and all operations.

close() - Method in class org.apache.flink.table.gateway.service.operation.OperationManager.Operation

close() - Method in class org.apache.flink.table.gateway.service.result.ResultFetcher

close() - Method in class org.apache.flink.table.gateway.service.result.ResultStore

close() - Method in class org.apache.flink.table.gateway.service.session.Session

close() - Method in class org.apache.flink.table.gateway.workflow.EmbeddedWorkflowScheduler

CLOSE_MESSAGE - Static variable in class org.apache.flink.table.gateway.rest.handler.session.CloseSessionHandler

closeOperation(OperationHandle) - Method in class org.apache.flink.table.gateway.service.operation.OperationManager

Close the operation and release all resources used by the OperationManager.Operation.

closeOperation(SessionHandle, OperationHandle) - Method in class org.apache.flink.table.gateway.service.SqlGatewayServiceImpl

CloseOperationHandler - Class in org.apache.flink.table.gateway.rest.handler.operation

Handler to close operation.

CloseOperationHandler(SqlGatewayService, Map<String, String>, MessageHeaders<EmptyRequestBody, OperationStatusResponseBody, OperationMessageParameters>) - Constructor for class org.apache.flink.table.gateway.rest.handler.operation.CloseOperationHandler

CloseOperationHeaders - Class in org.apache.flink.table.gateway.rest.header.operation

Message headers for closing operation.

CloseOperationHeaders() - Constructor for class org.apache.flink.table.gateway.rest.header.operation.CloseOperationHeaders

closeSession(SessionHandle) - Method in interface org.apache.flink.table.gateway.service.session.SessionManager

Close the session with the specified identifier and releases the resources used by the session.

closeSession(SessionHandle) - Method in class org.apache.flink.table.gateway.service.session.SessionManagerImpl

closeSession(SessionHandle) - Method in class org.apache.flink.table.gateway.service.SqlGatewayServiceImpl

CloseSessionHandler - Class in org.apache.flink.table.gateway.rest.handler.session

Handler to close session.

CloseSessionHandler(SqlGatewayService, Map<String, String>, MessageHeaders<EmptyRequestBody, CloseSessionResponseBody, SessionMessageParameters>) - Constructor for class org.apache.flink.table.gateway.rest.handler.session.CloseSessionHandler

CloseSessionHeaders - Class in org.apache.flink.table.gateway.rest.header.session

Message headers for closing a session.

CloseSessionResponseBody - Class in org.apache.flink.table.gateway.rest.message.session

ResponseBody for closing a session.

CloseSessionResponseBody(String) - Constructor for class org.apache.flink.table.gateway.rest.message.session.CloseSessionResponseBody

CLUSTER_INFO - Static variable in class org.apache.flink.table.gateway.service.utils.Constants

ColumnInfo - Class in org.apache.flink.table.gateway.rest.serde

A column info represents a table column's structure with column name, column type.

ColumnInfo(String, LogicalType, String) - Constructor for class org.apache.flink.table.gateway.rest.serde.ColumnInfo

completeStatement(SessionHandle, String, int) - Method in class org.apache.flink.table.gateway.service.SqlGatewayServiceImpl

CompleteStatementHandler - Class in org.apache.flink.table.gateway.rest.handler.statement

Handler to complete a statement.

CompleteStatementHandler(SqlGatewayService, Map<String, String>, MessageHeaders<CompleteStatementRequestBody, CompleteStatementResponseBody, SessionMessageParameters>) - Constructor for class org.apache.flink.table.gateway.rest.handler.statement.CompleteStatementHandler

CompleteStatementHeaders - Class in org.apache.flink.table.gateway.rest.header.statement

Message headers for completing a statement.

CompleteStatementHeaders() - Constructor for class org.apache.flink.table.gateway.rest.header.statement.CompleteStatementHeaders

CompleteStatementRequestBody - Class in org.apache.flink.table.gateway.rest.message.statement

RequestBody for completing a statement.

CompleteStatementRequestBody(String, int) - Constructor for class org.apache.flink.table.gateway.rest.message.statement.CompleteStatementRequestBody

CompleteStatementResponseBody - Class in org.apache.flink.table.gateway.rest.message.statement

ResponseBody for completing a statement.

CompleteStatementResponseBody(List<String>) - Constructor for class org.apache.flink.table.gateway.rest.message.statement.CompleteStatementResponseBody

COMPLETION_CANDIDATES - Static variable in class org.apache.flink.table.gateway.service.utils.Constants

configureSession(OperationHandle, String) - Method in class org.apache.flink.table.gateway.service.operation.OperationExecutor

configureSession(SessionHandle, String, long) - Method in class org.apache.flink.table.gateway.service.SqlGatewayServiceImpl

ConfigureSessionHandler - Class in org.apache.flink.table.gateway.rest.handler.session

Handler to configure a session with statement.

ConfigureSessionHandler(SqlGatewayService, Map<String, String>, MessageHeaders<ConfigureSessionRequestBody, EmptyResponseBody, SessionMessageParameters>) - Constructor for class org.apache.flink.table.gateway.rest.handler.session.ConfigureSessionHandler

ConfigureSessionHeaders - Class in org.apache.flink.table.gateway.rest.header.session

Message headers for configuring a session.

ConfigureSessionHeaders() - Constructor for class org.apache.flink.table.gateway.rest.header.session.ConfigureSessionHeaders

ConfigureSessionRequestBody - Class in org.apache.flink.table.gateway.rest.message.session

RequestBody for configuring a session.

ConfigureSessionRequestBody(String) - Constructor for class org.apache.flink.table.gateway.rest.message.session.ConfigureSessionRequestBody

ConfigureSessionRequestBody(String, Long) - Constructor for class org.apache.flink.table.gateway.rest.message.session.ConfigureSessionRequestBody

Constants - Class in org.apache.flink.table.gateway.service.utils

Constants used in the SqlGatewayService.

Constants() - Constructor for class org.apache.flink.table.gateway.service.utils.Constants

convertFromString(String) - Method in class org.apache.flink.table.gateway.rest.message.materializedtable.MaterializedTableIdentifierPathParameter

convertFromString(String) - Method in class org.apache.flink.table.gateway.rest.message.operation.OperationHandleIdPathParameter

convertFromString(String) - Method in class org.apache.flink.table.gateway.rest.message.session.SessionHandleIdPathParameter

convertFromString(String) - Method in class org.apache.flink.table.gateway.rest.message.statement.FetchResultsTokenPathParameter

convertStringToValue(String) - Method in class org.apache.flink.table.gateway.rest.message.statement.FetchResultsRowFormatQueryParameter

convertTimeZoneRowData(RowData) - Method in class org.apache.flink.table.gateway.rest.util.RowDataLocalTimeZoneConverter

convertToString(String) - Method in class org.apache.flink.table.gateway.rest.message.materializedtable.MaterializedTableIdentifierPathParameter

convertToString(OperationHandle) - Method in class org.apache.flink.table.gateway.rest.message.operation.OperationHandleIdPathParameter

convertToString(SessionHandle) - Method in class org.apache.flink.table.gateway.rest.message.session.SessionHandleIdPathParameter

convertToString(Long) - Method in class org.apache.flink.table.gateway.rest.message.statement.FetchResultsTokenPathParameter

convertValueToString(RowFormat) - Method in class org.apache.flink.table.gateway.rest.message.statement.FetchResultsRowFormatQueryParameter

create(DefaultContext, SessionHandle, SessionEnvironment, ExecutorService) - Static method in class org.apache.flink.table.gateway.service.context.SessionContext

create(DefaultContext) - Static method in interface org.apache.flink.table.gateway.service.session.SessionManager

Create the SessionManager with the default configuration.

CreateEmbeddedSchedulerWorkflowHandler - Class in org.apache.flink.table.gateway.rest.handler.materializedtable.scheduler

Handler to create workflow in embedded scheduler.

CreateEmbeddedSchedulerWorkflowHandler(SqlGatewayService, EmbeddedQuartzScheduler, Map<String, String>, MessageHeaders<CreateEmbeddedSchedulerWorkflowRequestBody, CreateEmbeddedSchedulerWorkflowResponseBody, EmptyMessageParameters>) - Constructor for class org.apache.flink.table.gateway.rest.handler.materializedtable.scheduler.CreateEmbeddedSchedulerWorkflowHandler

CreateEmbeddedSchedulerWorkflowHeaders - Class in org.apache.flink.table.gateway.rest.header.materializedtable.scheduler

Message headers for create workflow in embedded scheduler.

CreateEmbeddedSchedulerWorkflowHeaders() - Constructor for class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.CreateEmbeddedSchedulerWorkflowHeaders

CreateEmbeddedSchedulerWorkflowRequestBody - Class in org.apache.flink.table.gateway.rest.message.materializedtable.scheduler

RequestBody for create workflow in embedded scheduler.

CreateEmbeddedSchedulerWorkflowRequestBody(String, String, Map<String, String>, Map<String, String>, String) - Constructor for class org.apache.flink.table.gateway.rest.message.materializedtable.scheduler.CreateEmbeddedSchedulerWorkflowRequestBody

CreateEmbeddedSchedulerWorkflowResponseBody - Class in org.apache.flink.table.gateway.rest.message.materializedtable.scheduler

ResponseBody for create workflow in embedded scheduler.

CreateEmbeddedSchedulerWorkflowResponseBody(String, String) - Constructor for class org.apache.flink.table.gateway.rest.message.materializedtable.scheduler.CreateEmbeddedSchedulerWorkflowResponseBody

createExecutor() - Method in class org.apache.flink.table.gateway.service.session.Session

createExecutor(Configuration) - Method in class org.apache.flink.table.gateway.service.session.Session

createOperationExecutor(Configuration) - Method in class org.apache.flink.table.gateway.service.context.SessionContext

createRefreshWorkflow(CreateRefreshWorkflow) - Method in class org.apache.flink.table.gateway.workflow.EmbeddedWorkflowScheduler

createResultInfo(ResultSet, RowFormat, RowDataLocalTimeZoneConverter) - Static method in class org.apache.flink.table.gateway.rest.serde.ResultInfo

createScheduleWorkflow(WorkflowInfo, String) - Method in class org.apache.flink.table.gateway.workflow.scheduler.EmbeddedQuartzScheduler

createSqlGatewayEndpoint(SqlGatewayEndpointFactory.Context) - Method in class org.apache.flink.table.gateway.rest.SqlGatewayRestEndpointFactory

createWorkflowScheduler(WorkflowSchedulerFactory.Context) - Method in class org.apache.flink.table.gateway.workflow.EmbeddedWorkflowSchedulerFactory

currentSessionCount() - Method in class org.apache.flink.table.gateway.service.session.SessionManagerImpl

D

dateToString(Date) - Static method in class org.apache.flink.table.gateway.workflow.scheduler.QuartzSchedulerUtils

DEFAULT_DATETIME_FORMATTER - Static variable in class org.apache.flink.table.gateway.workflow.scheduler.QuartzSchedulerUtils

DefaultContext - Class in org.apache.flink.table.gateway.service.context

The context memorized initial configuration.

DefaultContext(Map<String, String>, List<URL>) - Constructor for class org.apache.flink.table.gateway.service.context.DefaultContext

DefaultContext(Configuration, List<URL>) - Constructor for class org.apache.flink.table.gateway.service.context.DefaultContext

DeleteEmbeddedSchedulerWorkflowHandler - Class in org.apache.flink.table.gateway.rest.handler.materializedtable.scheduler

Handler to delete workflow in embedded scheduler.

DeleteEmbeddedSchedulerWorkflowHandler(SqlGatewayService, EmbeddedQuartzScheduler, Map<String, String>, MessageHeaders<EmbeddedSchedulerWorkflowRequestBody, EmptyResponseBody, EmptyMessageParameters>) - Constructor for class org.apache.flink.table.gateway.rest.handler.materializedtable.scheduler.DeleteEmbeddedSchedulerWorkflowHandler

DeleteEmbeddedSchedulerWorkflowHeaders - Class in org.apache.flink.table.gateway.rest.header.materializedtable.scheduler

Message headers for delete workflow in embedded scheduler.

DeleteEmbeddedSchedulerWorkflowHeaders() - Constructor for class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.DeleteEmbeddedSchedulerWorkflowHeaders

deleteRefreshWorkflow(DeleteRefreshWorkflow<EmbeddedRefreshHandler>) - Method in class org.apache.flink.table.gateway.workflow.EmbeddedWorkflowScheduler

deleteScheduleWorkflow(String, String) - Method in class org.apache.flink.table.gateway.workflow.scheduler.EmbeddedQuartzScheduler

deserialize(JsonParser, DeserializationContext) - Method in class org.apache.flink.table.gateway.rest.serde.FetchResultResponseBodyDeserializer

deserialize(JsonParser, DeserializationContext) - Method in class org.apache.flink.table.gateway.rest.serde.LogicalTypeJsonDeserializer

deserialize(JsonParser, DeserializationContext) - Method in class org.apache.flink.table.gateway.rest.serde.ResultInfoDeserializer

deserialize(byte[], ClassLoader) - Method in class org.apache.flink.table.gateway.workflow.EmbeddedRefreshHandlerSerializer

disableStatementSet() - Method in class org.apache.flink.table.gateway.service.context.SessionContext

DUMMY_RESULT_STORE - Static variable in class org.apache.flink.table.gateway.service.result.ResultStore

DYNAMIC_PROPERTY_OPTION - Static variable in class org.apache.flink.table.gateway.cli.SqlGatewayOptionsParser

E

EmbeddedQuartzScheduler - Class in org.apache.flink.table.gateway.workflow.scheduler

An embedded workflow scheduler based on quartz Scheduler that store all workflow in memory, it does not have high availability.

EmbeddedQuartzScheduler() - Constructor for class org.apache.flink.table.gateway.workflow.scheduler.EmbeddedQuartzScheduler

EmbeddedQuartzScheduler.EmbeddedSchedulerJob - Class in org.apache.flink.table.gateway.workflow.scheduler

The Job implementation for embedded quartz scheduler.

EmbeddedRefreshHandler - Class in org.apache.flink.table.gateway.workflow

A RefreshHandler instance for embedded workflow scheduler.

EmbeddedRefreshHandler(String, String) - Constructor for class org.apache.flink.table.gateway.workflow.EmbeddedRefreshHandler

EmbeddedRefreshHandlerSerializer - Class in org.apache.flink.table.gateway.workflow

RefreshHandlerSerializer for EmbeddedRefreshHandler.

EmbeddedRefreshHandlerSerializer() - Constructor for class org.apache.flink.table.gateway.workflow.EmbeddedRefreshHandlerSerializer

EmbeddedSchedulerJob() - Constructor for class org.apache.flink.table.gateway.workflow.scheduler.EmbeddedQuartzScheduler.EmbeddedSchedulerJob

EmbeddedSchedulerWorkflowRequestBody - Class in org.apache.flink.table.gateway.rest.message.materializedtable.scheduler

RequestBody for suspend, resume, delete workflow in embedded scheduler.

EmbeddedSchedulerWorkflowRequestBody(String, String) - Constructor for class org.apache.flink.table.gateway.rest.message.materializedtable.scheduler.EmbeddedSchedulerWorkflowRequestBody

EmbeddedWorkflowScheduler - Class in org.apache.flink.table.gateway.workflow

A workflow scheduler plugin implementation for EmbeddedQuartzScheduler.

EmbeddedWorkflowScheduler(Configuration) - Constructor for class org.apache.flink.table.gateway.workflow.EmbeddedWorkflowScheduler

EmbeddedWorkflowSchedulerFactory - Class in org.apache.flink.table.gateway.workflow

The WorkflowSchedulerFactory to create the EmbeddedWorkflowScheduler.

EmbeddedWorkflowSchedulerFactory() - Constructor for class org.apache.flink.table.gateway.workflow.EmbeddedWorkflowSchedulerFactory

enableStatementSet() - Method in class org.apache.flink.table.gateway.service.context.SessionContext

equals(Object) - Method in class org.apache.flink.table.gateway.rest.serde.ColumnInfo

equals(Object) - Method in class org.apache.flink.table.gateway.rest.serde.ResultInfo

equals(Object) - Method in class org.apache.flink.table.gateway.workflow.EmbeddedRefreshHandler

equals(Object) - Method in class org.apache.flink.table.gateway.workflow.WorkflowInfo

execute(SessionHandle, OperationHandle) - Method in class org.apache.flink.table.gateway.rest.handler.operation.AbstractOperationHandler

execute(SessionHandle, OperationHandle) - Method in class org.apache.flink.table.gateway.rest.handler.operation.CancelOperationHandler

execute(SessionHandle, OperationHandle) - Method in class org.apache.flink.table.gateway.rest.handler.operation.CloseOperationHandler

execute(JobExecutionContext) - Method in class org.apache.flink.table.gateway.workflow.scheduler.EmbeddedQuartzScheduler.EmbeddedSchedulerJob

executeStatement(OperationHandle, String) - Method in class org.apache.flink.table.gateway.service.operation.OperationExecutor

executeStatement(OperationHandle, Configuration, String) - Method in class org.apache.flink.table.gateway.service.operation.OperationExecutor

executeStatement(SessionHandle, String, long, Configuration) - Method in class org.apache.flink.table.gateway.service.SqlGatewayServiceImpl

ExecuteStatementHandler - Class in org.apache.flink.table.gateway.rest.handler.statement

Handler to execute a statement.

ExecuteStatementHandler(SqlGatewayService, Map<String, String>, MessageHeaders<ExecuteStatementRequestBody, ExecuteStatementResponseBody, SessionMessageParameters>) - Constructor for class org.apache.flink.table.gateway.rest.handler.statement.ExecuteStatementHandler

ExecuteStatementHeaders - Class in org.apache.flink.table.gateway.rest.header.statement

Message headers for executing a statement.

ExecuteStatementHeaders() - Constructor for class org.apache.flink.table.gateway.rest.header.statement.ExecuteStatementHeaders

ExecuteStatementRequestBody - Class in org.apache.flink.table.gateway.rest.message.statement

RequestBody for executing a statement.

ExecuteStatementRequestBody(String) - Constructor for class org.apache.flink.table.gateway.rest.message.statement.ExecuteStatementRequestBody

ExecuteStatementRequestBody(String, Long, Map<String, String>) - Constructor for class org.apache.flink.table.gateway.rest.message.statement.ExecuteStatementRequestBody

ExecuteStatementResponseBody - Class in org.apache.flink.table.gateway.rest.message.statement

ResponseBody for executing a statement.

ExecuteStatementResponseBody(String) - Constructor for class org.apache.flink.table.gateway.rest.message.statement.ExecuteStatementResponseBody

F

factoryIdentifier() - Method in class org.apache.flink.table.gateway.rest.SqlGatewayRestEndpointFactory

factoryIdentifier() - Method in class org.apache.flink.table.gateway.workflow.EmbeddedWorkflowSchedulerFactory

FetchResultResponseBodyDeserializer - Class in org.apache.flink.table.gateway.rest.serde

Deserializer to deserialize FetchResultsResponseBody.

FetchResultResponseBodyDeserializer() - Constructor for class org.apache.flink.table.gateway.rest.serde.FetchResultResponseBodyDeserializer

FetchResultResponseBodyImpl - Class in org.apache.flink.table.gateway.rest.message.statement

The implementation of the FetchResultsResponseBody with ready results.

FetchResultResponseBodyImpl(ResultSet.ResultType, boolean, JobID, ResultKind, ResultInfo, String) - Constructor for class org.apache.flink.table.gateway.rest.message.statement.FetchResultResponseBodyImpl

fetchResults(OperationHandle, long, int) - Method in class org.apache.flink.table.gateway.service.operation.OperationManager

Get the results of the operation.

fetchResults(OperationHandle, FetchOrientation, int) - Method in class org.apache.flink.table.gateway.service.operation.OperationManager

fetchResults(long, int) - Method in class org.apache.flink.table.gateway.service.operation.OperationManager.Operation

fetchResults(FetchOrientation, int) - Method in class org.apache.flink.table.gateway.service.operation.OperationManager.Operation

fetchResults(FetchOrientation, int) - Method in class org.apache.flink.table.gateway.service.result.ResultFetcher

fetchResults(long, int) - Method in class org.apache.flink.table.gateway.service.result.ResultFetcher

Fetch results from the result store.

fetchResults(SessionHandle, OperationHandle, long, int) - Method in class org.apache.flink.table.gateway.service.SqlGatewayServiceImpl

fetchResults(SessionHandle, OperationHandle, FetchOrientation, int) - Method in class org.apache.flink.table.gateway.service.SqlGatewayServiceImpl

FetchResultsHandler - Class in org.apache.flink.table.gateway.rest.handler.statement

Handler to fetch results.

FetchResultsHandler(SqlGatewayService, Map<String, String>, MessageHeaders<EmptyRequestBody, FetchResultsResponseBody, FetchResultsMessageParameters>) - Constructor for class org.apache.flink.table.gateway.rest.handler.statement.FetchResultsHandler

FetchResultsHeaders - Class in org.apache.flink.table.gateway.rest.header.statement

Message headers for fetching results.

FetchResultsMessageParameters - Class in org.apache.flink.table.gateway.rest.message.statement

MessageParameters for fetching results.

FetchResultsMessageParameters(SqlGatewayRestAPIVersion) - Constructor for class org.apache.flink.table.gateway.rest.message.statement.FetchResultsMessageParameters

FetchResultsMessageParameters(SessionHandle, OperationHandle, Long, RowFormat) - Constructor for class org.apache.flink.table.gateway.rest.message.statement.FetchResultsMessageParameters

FetchResultsResponseBody - Interface in org.apache.flink.table.gateway.rest.message.statement

ResponseBody for executing a statement.

FetchResultsResponseBodySerializer - Class in org.apache.flink.table.gateway.rest.serde

Serializer to serialize FetchResultsResponseBody.

FetchResultsResponseBodySerializer() - Constructor for class org.apache.flink.table.gateway.rest.serde.FetchResultsResponseBodySerializer

FetchResultsRowFormatQueryParameter - Class in org.apache.flink.table.gateway.rest.message.statement

A MessageQueryParameter that parses the 'rowFormat' query parameter for fetching results.

FetchResultsRowFormatQueryParameter() - Constructor for class org.apache.flink.table.gateway.rest.message.statement.FetchResultsRowFormatQueryParameter

FetchResultsTokenPathParameter - Class in org.apache.flink.table.gateway.rest.message.statement

MessagePathParameter that parses the token string.

FetchResultsTokenPathParameter() - Constructor for class org.apache.flink.table.gateway.rest.message.statement.FetchResultsTokenPathParameter

FIELD_IS_QUERY_RESULT - Static variable in class org.apache.flink.table.gateway.rest.serde.FetchResultsResponseBodySerializer

FIELD_JOB_ID - Static variable in class org.apache.flink.table.gateway.rest.serde.FetchResultsResponseBodySerializer

FIELD_NAME_CLASS - Static variable in class org.apache.flink.table.gateway.rest.serde.LogicalTypeJsonSerializer

FIELD_NAME_COLUMN_INFOS - Static variable in class org.apache.flink.table.gateway.rest.serde.ResultInfoSerializer

FIELD_NAME_DATA - Static variable in class org.apache.flink.table.gateway.rest.serde.ResultInfoSerializer

FIELD_NAME_ELEMENT_TYPE - Static variable in class org.apache.flink.table.gateway.rest.serde.LogicalTypeJsonSerializer

FIELD_NAME_FIELD_NAME - Static variable in class org.apache.flink.table.gateway.rest.serde.LogicalTypeJsonSerializer

FIELD_NAME_FIELD_TYPE - Static variable in class org.apache.flink.table.gateway.rest.serde.LogicalTypeJsonSerializer

FIELD_NAME_FIELDS - Static variable in class org.apache.flink.table.gateway.rest.serde.LogicalTypeJsonSerializer

FIELD_NAME_FIELDS - Static variable in class org.apache.flink.table.gateway.rest.serde.ResultInfoSerializer

FIELD_NAME_FILED_DESCRIPTION - Static variable in class org.apache.flink.table.gateway.rest.serde.LogicalTypeJsonSerializer

FIELD_NAME_FRACTIONAL_PRECISION - Static variable in class org.apache.flink.table.gateway.rest.serde.LogicalTypeJsonSerializer

FIELD_NAME_KEY_TYPE - Static variable in class org.apache.flink.table.gateway.rest.serde.LogicalTypeJsonSerializer

FIELD_NAME_KIND - Static variable in class org.apache.flink.table.gateway.rest.serde.ResultInfoSerializer

FIELD_NAME_LENGTH - Static variable in class org.apache.flink.table.gateway.rest.serde.LogicalTypeJsonSerializer

FIELD_NAME_NULLABLE - Static variable in class org.apache.flink.table.gateway.rest.serde.LogicalTypeJsonSerializer

FIELD_NAME_PRECISION - Static variable in class org.apache.flink.table.gateway.rest.serde.LogicalTypeJsonSerializer

FIELD_NAME_RESOLUTION - Static variable in class org.apache.flink.table.gateway.rest.serde.LogicalTypeJsonSerializer

FIELD_NAME_ROW_FORMAT - Static variable in class org.apache.flink.table.gateway.rest.serde.ResultInfoSerializer

FIELD_NAME_SCALE - Static variable in class org.apache.flink.table.gateway.rest.serde.LogicalTypeJsonSerializer

FIELD_NAME_SERIALIZER - Static variable in class org.apache.flink.table.gateway.rest.serde.LogicalTypeJsonSerializer

FIELD_NAME_TYPE_NAME - Static variable in class org.apache.flink.table.gateway.rest.serde.LogicalTypeJsonSerializer

FIELD_NAME_VALUE_TYPE - Static variable in class org.apache.flink.table.gateway.rest.serde.LogicalTypeJsonSerializer

FIELD_NEXT_RESULT_URI - Static variable in class org.apache.flink.table.gateway.rest.serde.FetchResultsResponseBodySerializer

FIELD_RESULT_KIND - Static variable in class org.apache.flink.table.gateway.rest.serde.FetchResultsResponseBodySerializer

FIELD_RESULT_TYPE - Static variable in class org.apache.flink.table.gateway.rest.serde.FetchResultsResponseBodySerializer

FIELD_RESULTS - Static variable in class org.apache.flink.table.gateway.rest.serde.FetchResultsResponseBodySerializer

fromJson(String, Class<T>) - Static method in class org.apache.flink.table.gateway.workflow.scheduler.QuartzSchedulerUtils

fromResults(OperationHandle, ResolvedSchema, List<RowData>) - Static method in class org.apache.flink.table.gateway.service.result.ResultFetcher

fromResults(OperationHandle, ResolvedSchema, List<RowData>, JobID, ResultKind) - Static method in class org.apache.flink.table.gateway.service.result.ResultFetcher

fromTableResult(OperationHandle, TableResultInternal, boolean) - Static method in class org.apache.flink.table.gateway.service.result.ResultFetcher

fromURIToVersion(String) - Static method in enum org.apache.flink.table.gateway.rest.util.SqlGatewayRestAPIVersion

Convert uri to SqlGatewayRestAPIVersion.

functionCatalog - Variable in class org.apache.flink.table.gateway.service.context.SessionContext.SessionState

G

GetApiVersionHandler - Class in org.apache.flink.table.gateway.rest.handler.util

Handler to get rest api version.

GetApiVersionHandler(SqlGatewayService, Map<String, String>, MessageHeaders<EmptyRequestBody, GetApiVersionResponseBody, EmptyMessageParameters>) - Constructor for class org.apache.flink.table.gateway.rest.handler.util.GetApiVersionHandler

GetApiVersionHandler(SqlGatewayService, Map<String, String>, MessageHeaders<EmptyRequestBody, GetApiVersionResponseBody, EmptyMessageParameters>, List<SqlGatewayRestAPIVersion>) - Constructor for class org.apache.flink.table.gateway.rest.handler.util.GetApiVersionHandler

GetApiVersionHeaders - Class in org.apache.flink.table.gateway.rest.header.util

Message headers for getting rest api version.

GetApiVersionResponseBody - Class in org.apache.flink.table.gateway.rest.message.util

ResponseBody for getting rest api version.

GetApiVersionResponseBody(List<String>) - Constructor for class org.apache.flink.table.gateway.rest.message.util.GetApiVersionResponseBody

getBufferedRecordSize() - Method in class org.apache.flink.table.gateway.service.result.ResultStore

getCandidates() - Method in class org.apache.flink.table.gateway.rest.message.statement.CompleteStatementResponseBody

getColumnInfos() - Method in class org.apache.flink.table.gateway.rest.serde.ResultInfo

Get the column info of the data.

getComment() - Method in class org.apache.flink.table.gateway.rest.serde.ColumnInfo

getCompletionHints(OperationHandle, String, int) - Method in class org.apache.flink.table.gateway.service.operation.OperationExecutor

getCronExpression() - Method in class org.apache.flink.table.gateway.rest.message.materializedtable.scheduler.CreateEmbeddedSchedulerWorkflowRequestBody

getCurrentCatalog() - Method in class org.apache.flink.table.gateway.service.operation.OperationExecutor

getCurrentCatalog(SessionHandle) - Method in class org.apache.flink.table.gateway.service.SqlGatewayServiceImpl

getData() - Method in class org.apache.flink.table.gateway.rest.serde.ResultInfo

Get the data.

getData() - Method in class org.apache.flink.table.gateway.service.result.NotReadyResult

getDefaultContext() - Method in class org.apache.flink.table.gateway.service.context.SessionContext

getDefaultInstance() - Static method in class org.apache.flink.table.gateway.rest.header.statement.FetchResultsHeaders

getDefaultVersion() - Static method in enum org.apache.flink.table.gateway.rest.util.SqlGatewayRestAPIVersion

Returns the default version.

getDependencies() - Method in class org.apache.flink.table.gateway.service.context.DefaultContext

getDescription() - Method in class org.apache.flink.table.gateway.rest.header.materializedtable.RefreshMaterializedTableHeaders

getDescription() - Method in class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.CreateEmbeddedSchedulerWorkflowHeaders

getDescription() - Method in class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.DeleteEmbeddedSchedulerWorkflowHeaders

getDescription() - Method in class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.ResumeEmbeddedSchedulerWorkflowHeaders

getDescription() - Method in class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.SuspendEmbeddedSchedulerWorkflowHeaders

getDescription() - Method in class org.apache.flink.table.gateway.rest.header.operation.CancelOperationHeaders

getDescription() - Method in class org.apache.flink.table.gateway.rest.header.operation.CloseOperationHeaders

getDescription() - Method in class org.apache.flink.table.gateway.rest.header.operation.GetOperationStatusHeaders

getDescription() - Method in class org.apache.flink.table.gateway.rest.header.session.CloseSessionHeaders

getDescription() - Method in class org.apache.flink.table.gateway.rest.header.session.ConfigureSessionHeaders

getDescription() - Method in class org.apache.flink.table.gateway.rest.header.session.GetSessionConfigHeaders

getDescription() - Method in class org.apache.flink.table.gateway.rest.header.session.OpenSessionHeaders

getDescription() - Method in class org.apache.flink.table.gateway.rest.header.session.TriggerSessionHeartbeatHeaders

getDescription() - Method in class org.apache.flink.table.gateway.rest.header.statement.CompleteStatementHeaders

getDescription() - Method in class org.apache.flink.table.gateway.rest.header.statement.ExecuteStatementHeaders

getDescription() - Method in class org.apache.flink.table.gateway.rest.header.statement.FetchResultsHeaders

getDescription() - Method in class org.apache.flink.table.gateway.rest.header.util.GetApiVersionHeaders

getDescription() - Method in class org.apache.flink.table.gateway.rest.header.util.GetInfoHeaders

getDescription() - Method in class org.apache.flink.table.gateway.rest.message.materializedtable.MaterializedTableIdentifierPathParameter

getDescription() - Method in class org.apache.flink.table.gateway.rest.message.operation.OperationHandleIdPathParameter

getDescription() - Method in class org.apache.flink.table.gateway.rest.message.session.SessionHandleIdPathParameter

getDescription() - Method in class org.apache.flink.table.gateway.rest.message.statement.FetchResultsRowFormatQueryParameter

getDescription() - Method in class org.apache.flink.table.gateway.rest.message.statement.FetchResultsTokenPathParameter

getDynamicConfigs() - Method in class org.apache.flink.table.gateway.cli.SqlGatewayOptions

getDynamicOptions() - Method in class org.apache.flink.table.gateway.rest.message.materializedtable.RefreshMaterializedTableRequestBody

getDynamicOptions() - Method in class org.apache.flink.table.gateway.rest.message.materializedtable.scheduler.ResumeEmbeddedSchedulerWorkflowRequestBody

getDynamicOptions() - Method in class org.apache.flink.table.gateway.workflow.WorkflowInfo

getEndpointVersion() - Method in class org.apache.flink.table.gateway.service.context.SessionContext

getEndpointVersion() - Method in class org.apache.flink.table.gateway.service.session.Session

getExecutionConfig() - Method in class org.apache.flink.table.gateway.rest.message.materializedtable.RefreshMaterializedTableRequestBody

getExecutionConfig() - Method in class org.apache.flink.table.gateway.rest.message.materializedtable.scheduler.CreateEmbeddedSchedulerWorkflowRequestBody

getExecutionConfig() - Method in class org.apache.flink.table.gateway.rest.message.statement.ExecuteStatementRequestBody

getExecutionConfig() - Method in class org.apache.flink.table.gateway.workflow.WorkflowInfo

getFieldGetters() - Method in class org.apache.flink.table.gateway.rest.serde.ResultInfo

Create the RowData.FieldGetter to get column value in the results.

getFlinkConfig() - Method in class org.apache.flink.table.gateway.service.context.DefaultContext

getFunctionDefinition(UnresolvedIdentifier) - Method in class org.apache.flink.table.gateway.service.operation.OperationExecutor

getFunctionDefinition(SessionHandle, UnresolvedIdentifier) - Method in class org.apache.flink.table.gateway.service.SqlGatewayServiceImpl

getGatewayInfo() - Method in class org.apache.flink.table.gateway.service.SqlGatewayServiceImpl

getHttpMethod() - Method in class org.apache.flink.table.gateway.rest.header.materializedtable.RefreshMaterializedTableHeaders

getHttpMethod() - Method in class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.CreateEmbeddedSchedulerWorkflowHeaders

getHttpMethod() - Method in class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.DeleteEmbeddedSchedulerWorkflowHeaders

getHttpMethod() - Method in class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.ResumeEmbeddedSchedulerWorkflowHeaders

getHttpMethod() - Method in class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.SuspendEmbeddedSchedulerWorkflowHeaders

getHttpMethod() - Method in class org.apache.flink.table.gateway.rest.header.operation.CancelOperationHeaders

getHttpMethod() - Method in class org.apache.flink.table.gateway.rest.header.operation.CloseOperationHeaders

getHttpMethod() - Method in class org.apache.flink.table.gateway.rest.header.operation.GetOperationStatusHeaders

getHttpMethod() - Method in class org.apache.flink.table.gateway.rest.header.session.CloseSessionHeaders

getHttpMethod() - Method in class org.apache.flink.table.gateway.rest.header.session.ConfigureSessionHeaders

getHttpMethod() - Method in class org.apache.flink.table.gateway.rest.header.session.GetSessionConfigHeaders

getHttpMethod() - Method in class org.apache.flink.table.gateway.rest.header.session.OpenSessionHeaders

getHttpMethod() - Method in class org.apache.flink.table.gateway.rest.header.session.TriggerSessionHeartbeatHeaders

getHttpMethod() - Method in class org.apache.flink.table.gateway.rest.header.statement.CompleteStatementHeaders

getHttpMethod() - Method in class org.apache.flink.table.gateway.rest.header.statement.ExecuteStatementHeaders

getHttpMethod() - Method in class org.apache.flink.table.gateway.rest.header.statement.FetchResultsHeaders

getHttpMethod() - Method in class org.apache.flink.table.gateway.rest.header.util.GetApiVersionHeaders

getHttpMethod() - Method in class org.apache.flink.table.gateway.rest.header.util.GetInfoHeaders

GetInfoHandler - Class in org.apache.flink.table.gateway.rest.handler.util

Handler to get cluster information.

GetInfoHandler(SqlGatewayService, Map<String, String>, MessageHeaders<EmptyRequestBody, GetInfoResponseBody, EmptyMessageParameters>) - Constructor for class org.apache.flink.table.gateway.rest.handler.util.GetInfoHandler

GetInfoHeaders - Class in org.apache.flink.table.gateway.rest.header.util

Message headers for getting cluster information.

GetInfoResponseBody - Class in org.apache.flink.table.gateway.rest.message.util

ResponseBody for getting cluster information.

GetInfoResponseBody(String, String) - Constructor for class org.apache.flink.table.gateway.rest.message.util.GetInfoResponseBody

getInitConfig() - Method in class org.apache.flink.table.gateway.rest.message.materializedtable.scheduler.CreateEmbeddedSchedulerWorkflowRequestBody

getInitConfig() - Method in class org.apache.flink.table.gateway.workflow.WorkflowInfo

getInsertStatement(ObjectIdentifier, String, Map<String, String>) - Static method in class org.apache.flink.table.gateway.service.materializedtable.MaterializedTableManager

Generate insert statement for materialized table.

getInstance() - Static method in class org.apache.flink.table.gateway.rest.header.materializedtable.RefreshMaterializedTableHeaders

getInstance() - Static method in class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.CreateEmbeddedSchedulerWorkflowHeaders

getInstance() - Static method in class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.DeleteEmbeddedSchedulerWorkflowHeaders

getInstance() - Static method in class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.ResumeEmbeddedSchedulerWorkflowHeaders

getInstance() - Static method in class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.SuspendEmbeddedSchedulerWorkflowHeaders

getInstance() - Static method in class org.apache.flink.table.gateway.rest.header.operation.CancelOperationHeaders

getInstance() - Static method in class org.apache.flink.table.gateway.rest.header.operation.CloseOperationHeaders

getInstance() - Static method in class org.apache.flink.table.gateway.rest.header.operation.GetOperationStatusHeaders

getInstance() - Static method in class org.apache.flink.table.gateway.rest.header.session.CloseSessionHeaders

getInstance() - Static method in class org.apache.flink.table.gateway.rest.header.session.ConfigureSessionHeaders

getInstance() - Static method in class org.apache.flink.table.gateway.rest.header.session.GetSessionConfigHeaders

getInstance() - Static method in class org.apache.flink.table.gateway.rest.header.session.OpenSessionHeaders

getInstance() - Static method in class org.apache.flink.table.gateway.rest.header.session.TriggerSessionHeartbeatHeaders

getInstance() - Static method in class org.apache.flink.table.gateway.rest.header.statement.CompleteStatementHeaders

getInstance() - Static method in class org.apache.flink.table.gateway.rest.header.statement.ExecuteStatementHeaders

getInstance() - Static method in class org.apache.flink.table.gateway.rest.header.util.GetApiVersionHeaders

getInstance() - Static method in class org.apache.flink.table.gateway.rest.header.util.GetInfoHeaders

getInstanceV1() - Static method in class org.apache.flink.table.gateway.rest.header.statement.FetchResultsHeaders

getJobID() - Method in class org.apache.flink.table.gateway.rest.message.statement.FetchResultResponseBodyImpl

getJobID() - Method in interface org.apache.flink.table.gateway.rest.message.statement.FetchResultsResponseBody

getJobID() - Method in class org.apache.flink.table.gateway.rest.message.statement.NotReadyFetchResultResponse

getJobID() - Method in class org.apache.flink.table.gateway.service.result.NotReadyResult

getJobKey(String) - Static method in class org.apache.flink.table.gateway.workflow.scheduler.QuartzSchedulerUtils

getLastAccessTime() - Method in class org.apache.flink.table.gateway.service.session.Session

getLogicalType() - Method in class org.apache.flink.table.gateway.rest.serde.ColumnInfo

getMaterializedTableIdentifier() - Method in class org.apache.flink.table.gateway.rest.message.materializedtable.scheduler.CreateEmbeddedSchedulerWorkflowRequestBody

getMaterializedTableIdentifier() - Method in class org.apache.flink.table.gateway.workflow.WorkflowInfo

getName() - Method in class org.apache.flink.table.gateway.rest.serde.ColumnInfo

getNextResultUri() - Method in class org.apache.flink.table.gateway.rest.message.statement.FetchResultResponseBodyImpl

getNextResultUri() - Method in interface org.apache.flink.table.gateway.rest.message.statement.FetchResultsResponseBody

getNextResultUri() - Method in class org.apache.flink.table.gateway.rest.message.statement.NotReadyFetchResultResponse

getNextToken() - Method in class org.apache.flink.table.gateway.service.result.NotReadyResult

getOperation(OperationHandle) - Method in class org.apache.flink.table.gateway.service.operation.OperationManager

getOperationCount() - Method in class org.apache.flink.table.gateway.service.operation.OperationManager

getOperationCount(SessionHandle) - Method in class org.apache.flink.table.gateway.service.session.SessionManagerImpl

getOperationHandle() - Method in class org.apache.flink.table.gateway.rest.message.materializedtable.RefreshMaterializedTableResponseBody

getOperationHandle() - Method in class org.apache.flink.table.gateway.rest.message.statement.ExecuteStatementResponseBody

getOperationInfo(OperationHandle) - Method in class org.apache.flink.table.gateway.service.operation.OperationManager

Get the OperationInfo of the operation.

getOperationInfo() - Method in class org.apache.flink.table.gateway.service.operation.OperationManager.Operation

getOperationInfo(SessionHandle, OperationHandle) - Method in class org.apache.flink.table.gateway.service.SqlGatewayServiceImpl

getOperationManager() - Method in class org.apache.flink.table.gateway.service.context.SessionContext

getOperationManager() - Method in class org.apache.flink.table.gateway.service.session.Session

getOperationResultSchema(OperationHandle) - Method in class org.apache.flink.table.gateway.service.operation.OperationManager

Get the ResolvedSchema of the operation.

getOperationResultSchema(SessionHandle, OperationHandle) - Method in class org.apache.flink.table.gateway.service.SqlGatewayServiceImpl

GetOperationStatusHandler - Class in org.apache.flink.table.gateway.rest.handler.operation

Handler to get the status of operation.

GetOperationStatusHandler(SqlGatewayService, Map<String, String>, MessageHeaders<EmptyRequestBody, OperationStatusResponseBody, OperationMessageParameters>) - Constructor for class org.apache.flink.table.gateway.rest.handler.operation.GetOperationStatusHandler

GetOperationStatusHeaders - Class in org.apache.flink.table.gateway.rest.header.operation

Message headers for getting the status of operation.

GetOperationStatusHeaders() - Constructor for class org.apache.flink.table.gateway.rest.header.operation.GetOperationStatusHeaders

getPathParameters() - Method in class org.apache.flink.table.gateway.rest.message.materializedtable.RefreshMaterializedTableParameters

getPathParameters() - Method in class org.apache.flink.table.gateway.rest.message.operation.OperationMessageParameters

getPathParameters() - Method in class org.apache.flink.table.gateway.rest.message.session.SessionMessageParameters

getPathParameters() - Method in class org.apache.flink.table.gateway.rest.message.statement.FetchResultsMessageParameters

getPlanCacheManager() - Method in class org.apache.flink.table.gateway.service.context.SessionContext

getPlanCacheManager() - Method in class org.apache.flink.table.gateway.service.session.Session

getPosition() - Method in class org.apache.flink.table.gateway.rest.message.statement.CompleteStatementRequestBody

getProductName() - Method in class org.apache.flink.table.gateway.rest.message.util.GetInfoResponseBody

getProductVersion() - Method in class org.apache.flink.table.gateway.rest.message.util.GetInfoResponseBody

getProperties() - Method in class org.apache.flink.table.gateway.rest.message.session.GetSessionConfigResponseBody

getProperties() - Method in class org.apache.flink.table.gateway.rest.message.session.OpenSessionRequestBody

getQuartzScheduler() - Method in class org.apache.flink.table.gateway.rest.SqlGatewayRestEndpoint

getQuartzScheduler() - Method in class org.apache.flink.table.gateway.workflow.scheduler.EmbeddedQuartzScheduler

getQueryParameters() - Method in class org.apache.flink.table.gateway.rest.message.materializedtable.RefreshMaterializedTableParameters

getQueryParameters() - Method in class org.apache.flink.table.gateway.rest.message.operation.OperationMessageParameters

getQueryParameters() - Method in class org.apache.flink.table.gateway.rest.message.session.SessionMessageParameters

getQueryParameters() - Method in class org.apache.flink.table.gateway.rest.message.statement.FetchResultsMessageParameters

getRefreshHandlerSerializer() - Method in class org.apache.flink.table.gateway.workflow.EmbeddedWorkflowScheduler

getRefreshStatement(ObjectIdentifier, String, Map<String, String>, Map<String, String>) - Static method in class org.apache.flink.table.gateway.service.materializedtable.MaterializedTableManager

getRequestClass() - Method in class org.apache.flink.table.gateway.rest.header.materializedtable.RefreshMaterializedTableHeaders

getRequestClass() - Method in class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.AbstractEmbeddedSchedulerWorkflowHeaders

getRequestClass() - Method in class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.CreateEmbeddedSchedulerWorkflowHeaders

getRequestClass() - Method in class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.ResumeEmbeddedSchedulerWorkflowHeaders

getRequestClass() - Method in class org.apache.flink.table.gateway.rest.header.operation.AbstractOperationHeaders

getRequestClass() - Method in class org.apache.flink.table.gateway.rest.header.session.CloseSessionHeaders

getRequestClass() - Method in class org.apache.flink.table.gateway.rest.header.session.ConfigureSessionHeaders

getRequestClass() - Method in class org.apache.flink.table.gateway.rest.header.session.GetSessionConfigHeaders

getRequestClass() - Method in class org.apache.flink.table.gateway.rest.header.session.OpenSessionHeaders

getRequestClass() - Method in class org.apache.flink.table.gateway.rest.header.session.TriggerSessionHeartbeatHeaders

getRequestClass() - Method in class org.apache.flink.table.gateway.rest.header.statement.CompleteStatementHeaders

getRequestClass() - Method in class org.apache.flink.table.gateway.rest.header.statement.ExecuteStatementHeaders

getRequestClass() - Method in class org.apache.flink.table.gateway.rest.header.statement.FetchResultsHeaders

getRequestClass() - Method in class org.apache.flink.table.gateway.rest.header.util.GetApiVersionHeaders

getRequestClass() - Method in class org.apache.flink.table.gateway.rest.header.util.GetInfoHeaders

getResponseClass() - Method in class org.apache.flink.table.gateway.rest.header.materializedtable.RefreshMaterializedTableHeaders

getResponseClass() - Method in class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.AbstractEmbeddedSchedulerWorkflowHeaders

getResponseClass() - Method in class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.CreateEmbeddedSchedulerWorkflowHeaders

getResponseClass() - Method in class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.ResumeEmbeddedSchedulerWorkflowHeaders

getResponseClass() - Method in class org.apache.flink.table.gateway.rest.header.operation.AbstractOperationHeaders

getResponseClass() - Method in class org.apache.flink.table.gateway.rest.header.session.CloseSessionHeaders

getResponseClass() - Method in class org.apache.flink.table.gateway.rest.header.session.ConfigureSessionHeaders

getResponseClass() - Method in class org.apache.flink.table.gateway.rest.header.session.GetSessionConfigHeaders

getResponseClass() - Method in class org.apache.flink.table.gateway.rest.header.session.OpenSessionHeaders

getResponseClass() - Method in class org.apache.flink.table.gateway.rest.header.session.TriggerSessionHeartbeatHeaders

getResponseClass() - Method in class org.apache.flink.table.gateway.rest.header.statement.CompleteStatementHeaders

getResponseClass() - Method in class org.apache.flink.table.gateway.rest.header.statement.ExecuteStatementHeaders

getResponseClass() - Method in class org.apache.flink.table.gateway.rest.header.statement.FetchResultsHeaders

getResponseClass() - Method in class org.apache.flink.table.gateway.rest.header.util.GetApiVersionHeaders

getResponseClass() - Method in class org.apache.flink.table.gateway.rest.header.util.GetInfoHeaders

getResponseStatusCode() - Method in class org.apache.flink.table.gateway.rest.header.materializedtable.RefreshMaterializedTableHeaders

getResponseStatusCode() - Method in class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.AbstractEmbeddedSchedulerWorkflowHeaders

getResponseStatusCode() - Method in class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.CreateEmbeddedSchedulerWorkflowHeaders

getResponseStatusCode() - Method in class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.ResumeEmbeddedSchedulerWorkflowHeaders

getResponseStatusCode() - Method in class org.apache.flink.table.gateway.rest.header.operation.AbstractOperationHeaders

getResponseStatusCode() - Method in class org.apache.flink.table.gateway.rest.header.session.CloseSessionHeaders

getResponseStatusCode() - Method in class org.apache.flink.table.gateway.rest.header.session.ConfigureSessionHeaders

getResponseStatusCode() - Method in class org.apache.flink.table.gateway.rest.header.session.GetSessionConfigHeaders

getResponseStatusCode() - Method in class org.apache.flink.table.gateway.rest.header.session.OpenSessionHeaders

getResponseStatusCode() - Method in class org.apache.flink.table.gateway.rest.header.session.TriggerSessionHeartbeatHeaders

getResponseStatusCode() - Method in class org.apache.flink.table.gateway.rest.header.statement.CompleteStatementHeaders

getResponseStatusCode() - Method in class org.apache.flink.table.gateway.rest.header.statement.ExecuteStatementHeaders

getResponseStatusCode() - Method in class org.apache.flink.table.gateway.rest.header.statement.FetchResultsHeaders

getResponseStatusCode() - Method in class org.apache.flink.table.gateway.rest.header.util.GetApiVersionHeaders

getResponseStatusCode() - Method in class org.apache.flink.table.gateway.rest.header.util.GetInfoHeaders

getRestEndpointUrl() - Method in class org.apache.flink.table.gateway.rest.message.materializedtable.scheduler.CreateEmbeddedSchedulerWorkflowRequestBody

getRestEndpointUrl() - Method in class org.apache.flink.table.gateway.workflow.WorkflowInfo

getResultKind() - Method in class org.apache.flink.table.gateway.rest.message.statement.FetchResultResponseBodyImpl

getResultKind() - Method in interface org.apache.flink.table.gateway.rest.message.statement.FetchResultsResponseBody

getResultKind() - Method in class org.apache.flink.table.gateway.rest.message.statement.NotReadyFetchResultResponse

getResultKind() - Method in class org.apache.flink.table.gateway.service.result.NotReadyResult

getResults() - Method in class org.apache.flink.table.gateway.rest.message.statement.FetchResultResponseBodyImpl

getResults() - Method in interface org.apache.flink.table.gateway.rest.message.statement.FetchResultsResponseBody

getResults() - Method in class org.apache.flink.table.gateway.rest.message.statement.NotReadyFetchResultResponse

getResultSchema() - Method in class org.apache.flink.table.gateway.rest.serde.ResultInfo

Get the schemas of the results.

getResultSchema() - Method in class org.apache.flink.table.gateway.service.operation.OperationManager.Operation

getResultSchema() - Method in class org.apache.flink.table.gateway.service.result.NotReadyResult

getResultSchema() - Method in class org.apache.flink.table.gateway.service.result.ResultFetcher

getResultStore() - Method in class org.apache.flink.table.gateway.service.result.ResultFetcher

getResultType() - Method in class org.apache.flink.table.gateway.rest.message.statement.FetchResultResponseBodyImpl

getResultType() - Method in interface org.apache.flink.table.gateway.rest.message.statement.FetchResultsResponseBody

getResultType() - Method in class org.apache.flink.table.gateway.rest.message.statement.NotReadyFetchResultResponse

getResultType() - Method in class org.apache.flink.table.gateway.service.result.NotReadyResult

getRowFormat() - Method in class org.apache.flink.table.gateway.rest.serde.ResultInfo

Get the row format about the data.

getScheduleTime() - Method in class org.apache.flink.table.gateway.rest.message.materializedtable.RefreshMaterializedTableRequestBody

getSession(SessionHandle) - Method in interface org.apache.flink.table.gateway.service.session.SessionManager

Get the Session with the identifier.

getSession(SessionHandle) - Method in class org.apache.flink.table.gateway.service.session.SessionManagerImpl

getSession(SessionHandle) - Method in class org.apache.flink.table.gateway.service.SqlGatewayServiceImpl

getSessionConf() - Method in class org.apache.flink.table.gateway.service.context.SessionContext

getSessionConfig() - Method in class org.apache.flink.table.gateway.service.session.Session

getSessionConfig(SessionHandle) - Method in class org.apache.flink.table.gateway.service.SqlGatewayServiceImpl

GetSessionConfigHandler - Class in org.apache.flink.table.gateway.rest.handler.session

Handler to get the session configuration.

GetSessionConfigHandler(SqlGatewayService, Map<String, String>, MessageHeaders<EmptyRequestBody, GetSessionConfigResponseBody, SessionMessageParameters>) - Constructor for class org.apache.flink.table.gateway.rest.handler.session.GetSessionConfigHandler

GetSessionConfigHeaders - Class in org.apache.flink.table.gateway.rest.header.session

Message headers for getting session configuration.

GetSessionConfigResponseBody - Class in org.apache.flink.table.gateway.rest.message.session

ResponseBody for get session configuration.

GetSessionConfigResponseBody(Map<String, String>) - Constructor for class org.apache.flink.table.gateway.rest.message.session.GetSessionConfigResponseBody

getSessionContext() - Method in class org.apache.flink.table.gateway.service.operation.OperationExecutor

getSessionEndpointVersion(SessionHandle) - Method in class org.apache.flink.table.gateway.service.SqlGatewayServiceImpl

getSessionHandle() - Method in class org.apache.flink.table.gateway.rest.message.session.OpenSessionResponseBody

getSessionHandle() - Method in class org.apache.flink.table.gateway.service.session.Session

getSessionId() - Method in class org.apache.flink.table.gateway.service.context.SessionContext

getSessionName() - Method in class org.apache.flink.table.gateway.rest.message.session.OpenSessionRequestBody

getSessionState() - Method in class org.apache.flink.table.gateway.service.context.SessionContext

getStableVersions() - Static method in enum org.apache.flink.table.gateway.rest.util.SqlGatewayRestAPIVersion

Returns the supported stable versions.

getStatement() - Method in class org.apache.flink.table.gateway.rest.message.session.ConfigureSessionRequestBody

getStatement() - Method in class org.apache.flink.table.gateway.rest.message.statement.CompleteStatementRequestBody

getStatement() - Method in class org.apache.flink.table.gateway.rest.message.statement.ExecuteStatementRequestBody

getStatementSetOperations() - Method in class org.apache.flink.table.gateway.service.context.SessionContext

getStaticPartitions() - Method in class org.apache.flink.table.gateway.rest.message.materializedtable.RefreshMaterializedTableRequestBody

getStatus(SessionHandle, OperationHandle) - Method in class org.apache.flink.table.gateway.rest.handler.operation.AbstractOperationHandler

getStatus(SessionHandle, OperationHandle) - Method in class org.apache.flink.table.gateway.rest.handler.operation.CloseOperationHandler

getStatus() - Method in class org.apache.flink.table.gateway.rest.message.operation.OperationStatusResponseBody

getStatus() - Method in class org.apache.flink.table.gateway.rest.message.session.CloseSessionResponseBody

getSupportedAPIVersions() - Method in class org.apache.flink.table.gateway.rest.header.materializedtable.RefreshMaterializedTableHeaders

getSupportedAPIVersions() - Method in class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.AbstractEmbeddedSchedulerWorkflowHeaders

getSupportedAPIVersions() - Method in class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.CreateEmbeddedSchedulerWorkflowHeaders

getSupportedAPIVersions() - Method in class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.ResumeEmbeddedSchedulerWorkflowHeaders

getSupportedAPIVersions() - Method in class org.apache.flink.table.gateway.rest.header.session.ConfigureSessionHeaders

getSupportedAPIVersions() - Method in interface org.apache.flink.table.gateway.rest.header.SqlGatewayMessageHeaders

getSupportedAPIVersions() - Method in class org.apache.flink.table.gateway.rest.header.statement.CompleteStatementHeaders

getSupportedAPIVersions() - Method in class org.apache.flink.table.gateway.rest.header.statement.FetchResultsHeaders

getTable(ObjectIdentifier) - Method in class org.apache.flink.table.gateway.service.operation.OperationExecutor

getTable(SessionHandle, ObjectIdentifier) - Method in class org.apache.flink.table.gateway.service.SqlGatewayServiceImpl

getTableEnvironment() - Method in class org.apache.flink.table.gateway.service.operation.OperationExecutor

getTableEnvironment(ResourceManager, Configuration) - Method in class org.apache.flink.table.gateway.service.operation.OperationExecutor

getTargetRestEndpointURL() - Method in class org.apache.flink.table.gateway.rest.header.materializedtable.RefreshMaterializedTableHeaders

getTargetRestEndpointURL() - Method in class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.CreateEmbeddedSchedulerWorkflowHeaders

getTargetRestEndpointURL() - Method in class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.DeleteEmbeddedSchedulerWorkflowHeaders

getTargetRestEndpointURL() - Method in class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.ResumeEmbeddedSchedulerWorkflowHeaders

getTargetRestEndpointURL() - Method in class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.SuspendEmbeddedSchedulerWorkflowHeaders

getTargetRestEndpointURL() - Method in class org.apache.flink.table.gateway.rest.header.operation.CancelOperationHeaders

getTargetRestEndpointURL() - Method in class org.apache.flink.table.gateway.rest.header.operation.CloseOperationHeaders

getTargetRestEndpointURL() - Method in class org.apache.flink.table.gateway.rest.header.operation.GetOperationStatusHeaders

getTargetRestEndpointURL() - Method in class org.apache.flink.table.gateway.rest.header.session.CloseSessionHeaders

getTargetRestEndpointURL() - Method in class org.apache.flink.table.gateway.rest.header.session.ConfigureSessionHeaders

getTargetRestEndpointURL() - Method in class org.apache.flink.table.gateway.rest.header.session.GetSessionConfigHeaders

getTargetRestEndpointURL() - Method in class org.apache.flink.table.gateway.rest.header.session.OpenSessionHeaders

getTargetRestEndpointURL() - Method in class org.apache.flink.table.gateway.rest.header.session.TriggerSessionHeartbeatHeaders

getTargetRestEndpointURL() - Method in class org.apache.flink.table.gateway.rest.header.statement.CompleteStatementHeaders

getTargetRestEndpointURL() - Method in class org.apache.flink.table.gateway.rest.header.statement.ExecuteStatementHeaders

getTargetRestEndpointURL() - Method in class org.apache.flink.table.gateway.rest.header.statement.FetchResultsHeaders

getTargetRestEndpointURL() - Method in class org.apache.flink.table.gateway.rest.header.util.GetApiVersionHeaders

getTargetRestEndpointURL() - Method in class org.apache.flink.table.gateway.rest.header.util.GetInfoHeaders

getTimeout() - Method in class org.apache.flink.table.gateway.rest.message.session.ConfigureSessionRequestBody

getTimeout() - Method in class org.apache.flink.table.gateway.rest.message.statement.ExecuteStatementRequestBody

getUnresolvedMessageParameters() - Method in class org.apache.flink.table.gateway.rest.header.materializedtable.RefreshMaterializedTableHeaders

getUnresolvedMessageParameters() - Method in class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.AbstractEmbeddedSchedulerWorkflowHeaders

getUnresolvedMessageParameters() - Method in class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.CreateEmbeddedSchedulerWorkflowHeaders

getUnresolvedMessageParameters() - Method in class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.ResumeEmbeddedSchedulerWorkflowHeaders

getUnresolvedMessageParameters() - Method in class org.apache.flink.table.gateway.rest.header.operation.AbstractOperationHeaders

getUnresolvedMessageParameters() - Method in class org.apache.flink.table.gateway.rest.header.session.CloseSessionHeaders

getUnresolvedMessageParameters() - Method in class org.apache.flink.table.gateway.rest.header.session.ConfigureSessionHeaders

getUnresolvedMessageParameters() - Method in class org.apache.flink.table.gateway.rest.header.session.GetSessionConfigHeaders

getUnresolvedMessageParameters() - Method in class org.apache.flink.table.gateway.rest.header.session.OpenSessionHeaders

getUnresolvedMessageParameters() - Method in class org.apache.flink.table.gateway.rest.header.session.TriggerSessionHeartbeatHeaders

getUnresolvedMessageParameters() - Method in class org.apache.flink.table.gateway.rest.header.statement.CompleteStatementHeaders

getUnresolvedMessageParameters() - Method in class org.apache.flink.table.gateway.rest.header.statement.ExecuteStatementHeaders

getUnresolvedMessageParameters() - Method in class org.apache.flink.table.gateway.rest.header.statement.FetchResultsHeaders

getUnresolvedMessageParameters() - Method in class org.apache.flink.table.gateway.rest.header.util.GetApiVersionHeaders

getUnresolvedMessageParameters() - Method in class org.apache.flink.table.gateway.rest.header.util.GetInfoHeaders

getURLVersionPrefix() - Method in enum org.apache.flink.table.gateway.rest.util.SqlGatewayRestAPIVersion

Returns the URL version prefix (e.g.

getUserClassloader() - Method in class org.apache.flink.table.gateway.service.context.SessionContext

getVersions() - Method in class org.apache.flink.table.gateway.rest.message.util.GetApiVersionResponseBody

getWorkflowGroup() - Method in class org.apache.flink.table.gateway.rest.message.materializedtable.scheduler.CreateEmbeddedSchedulerWorkflowResponseBody

getWorkflowGroup() - Method in class org.apache.flink.table.gateway.rest.message.materializedtable.scheduler.EmbeddedSchedulerWorkflowRequestBody

getWorkflowGroup() - Method in class org.apache.flink.table.gateway.rest.message.materializedtable.scheduler.ResumeEmbeddedSchedulerWorkflowRequestBody

getWorkflowGroup() - Method in class org.apache.flink.table.gateway.workflow.EmbeddedRefreshHandler

getWorkflowName() - Method in class org.apache.flink.table.gateway.rest.message.materializedtable.scheduler.CreateEmbeddedSchedulerWorkflowResponseBody

getWorkflowName() - Method in class org.apache.flink.table.gateway.rest.message.materializedtable.scheduler.EmbeddedSchedulerWorkflowRequestBody

getWorkflowName() - Method in class org.apache.flink.table.gateway.rest.message.materializedtable.scheduler.ResumeEmbeddedSchedulerWorkflowRequestBody

getWorkflowName() - Method in class org.apache.flink.table.gateway.workflow.EmbeddedRefreshHandler

H

handleRequest(SqlGatewayRestAPIVersion, HandlerRequest<R>) - Method in class org.apache.flink.table.gateway.rest.handler.AbstractSqlGatewayRestHandler

This method is called for every incoming request and returns a CompletableFuture containing a the response.

handleRequest(SqlGatewayRestAPIVersion, HandlerRequest<RefreshMaterializedTableRequestBody>) - Method in class org.apache.flink.table.gateway.rest.handler.materializedtable.RefreshMaterializedTableHandler

handleRequest(SqlGatewayRestAPIVersion, HandlerRequest<CreateEmbeddedSchedulerWorkflowRequestBody>) - Method in class org.apache.flink.table.gateway.rest.handler.materializedtable.scheduler.CreateEmbeddedSchedulerWorkflowHandler

handleRequest(SqlGatewayRestAPIVersion, HandlerRequest<EmbeddedSchedulerWorkflowRequestBody>) - Method in class org.apache.flink.table.gateway.rest.handler.materializedtable.scheduler.DeleteEmbeddedSchedulerWorkflowHandler

handleRequest(SqlGatewayRestAPIVersion, HandlerRequest<ResumeEmbeddedSchedulerWorkflowRequestBody>) - Method in class org.apache.flink.table.gateway.rest.handler.materializedtable.scheduler.ResumeEmbeddedSchedulerWorkflowHandler

handleRequest(SqlGatewayRestAPIVersion, HandlerRequest<EmbeddedSchedulerWorkflowRequestBody>) - Method in class org.apache.flink.table.gateway.rest.handler.materializedtable.scheduler.SuspendEmbeddedSchedulerWorkflowHandler

handleRequest(SqlGatewayRestAPIVersion, HandlerRequest<EmptyRequestBody>) - Method in class org.apache.flink.table.gateway.rest.handler.operation.AbstractOperationHandler

handleRequest(SqlGatewayRestAPIVersion, HandlerRequest<EmptyRequestBody>) - Method in class org.apache.flink.table.gateway.rest.handler.session.CloseSessionHandler

handleRequest(SqlGatewayRestAPIVersion, HandlerRequest<ConfigureSessionRequestBody>) - Method in class org.apache.flink.table.gateway.rest.handler.session.ConfigureSessionHandler

handleRequest(SqlGatewayRestAPIVersion, HandlerRequest<EmptyRequestBody>) - Method in class org.apache.flink.table.gateway.rest.handler.session.GetSessionConfigHandler

handleRequest(SqlGatewayRestAPIVersion, HandlerRequest<OpenSessionRequestBody>) - Method in class org.apache.flink.table.gateway.rest.handler.session.OpenSessionHandler

handleRequest(SqlGatewayRestAPIVersion, HandlerRequest<EmptyRequestBody>) - Method in class org.apache.flink.table.gateway.rest.handler.session.TriggerSessionHeartbeatHandler

handleRequest(SqlGatewayRestAPIVersion, HandlerRequest<CompleteStatementRequestBody>) - Method in class org.apache.flink.table.gateway.rest.handler.statement.CompleteStatementHandler

handleRequest(SqlGatewayRestAPIVersion, HandlerRequest<ExecuteStatementRequestBody>) - Method in class org.apache.flink.table.gateway.rest.handler.statement.ExecuteStatementHandler

handleRequest(SqlGatewayRestAPIVersion, HandlerRequest<EmptyRequestBody>) - Method in class org.apache.flink.table.gateway.rest.handler.statement.FetchResultsHandler

handleRequest(SqlGatewayRestAPIVersion, HandlerRequest<EmptyRequestBody>) - Method in class org.apache.flink.table.gateway.rest.handler.util.GetApiVersionHandler

handleRequest(SqlGatewayRestAPIVersion, HandlerRequest<EmptyRequestBody>) - Method in class org.apache.flink.table.gateway.rest.handler.util.GetInfoHandler

hashCode() - Method in class org.apache.flink.table.gateway.rest.serde.ColumnInfo

hashCode() - Method in class org.apache.flink.table.gateway.rest.serde.ResultInfo

hashCode() - Method in class org.apache.flink.table.gateway.workflow.EmbeddedRefreshHandler

hashCode() - Method in class org.apache.flink.table.gateway.workflow.WorkflowInfo

hasTimeZoneData() - Method in class org.apache.flink.table.gateway.rest.util.RowDataLocalTimeZoneConverter

I

IDENTIFIER - Static variable in class org.apache.flink.table.gateway.rest.SqlGatewayRestEndpointFactory

The identifier string for SqlGatewayRestEndpointFactory.

IDENTIFIER - Static variable in class org.apache.flink.table.gateway.workflow.EmbeddedWorkflowSchedulerFactory

initializeConfiguration(DefaultContext, SessionEnvironment, SessionHandle) - Static method in class org.apache.flink.table.gateway.service.context.SessionContext

initializeHandlers(CompletableFuture<String>) - Method in class org.apache.flink.table.gateway.rest.SqlGatewayRestEndpoint

initializeQuartzSchedulerConfig() - Static method in class org.apache.flink.table.gateway.workflow.scheduler.QuartzSchedulerUtils

This method is used for initializing the quartz scheduler config, the related options copy from quartz.properties, but we override the option org.quartz.threadPool.threadCount to 1 for minimizing the thread impact to SqlGateway.

initializeSessionState(SessionEnvironment, Configuration, ResourceManager) - Static method in class org.apache.flink.table.gateway.service.context.SessionContext

INSTANCE - Static variable in class org.apache.flink.table.gateway.service.result.NotReadyResult

INSTANCE - Static variable in class org.apache.flink.table.gateway.workflow.EmbeddedRefreshHandlerSerializer

isDefaultVersion() - Method in enum org.apache.flink.table.gateway.rest.util.SqlGatewayRestAPIVersion

Returns whether this version is the default REST API version.

isPeriodic() - Method in class org.apache.flink.table.gateway.rest.message.materializedtable.RefreshMaterializedTableRequestBody

isPrintHelp() - Method in class org.apache.flink.table.gateway.cli.SqlGatewayOptions

isQueryResult() - Method in class org.apache.flink.table.gateway.rest.message.statement.FetchResultResponseBodyImpl

isQueryResult() - Method in interface org.apache.flink.table.gateway.rest.message.statement.FetchResultsResponseBody

isQueryResult() - Method in class org.apache.flink.table.gateway.rest.message.statement.NotReadyFetchResultResponse

isQueryResult() - Method in class org.apache.flink.table.gateway.service.result.NotReadyResult

isRetrieving() - Method in class org.apache.flink.table.gateway.service.result.ResultStore

isSessionAlive(SessionHandle) - Method in class org.apache.flink.table.gateway.service.session.SessionManagerImpl

isStableVersion() - Method in enum org.apache.flink.table.gateway.rest.util.SqlGatewayRestAPIVersion

Returns whether this version is considered stable.

isStatementSetState() - Method in class org.apache.flink.table.gateway.service.context.SessionContext

J

JOB_ID - Static variable in class org.apache.flink.table.gateway.service.utils.Constants

JOB_NAME - Static variable in class org.apache.flink.table.gateway.service.utils.Constants

K

KEY - Static variable in class org.apache.flink.table.gateway.rest.message.materializedtable.MaterializedTableIdentifierPathParameter

KEY - Static variable in class org.apache.flink.table.gateway.rest.message.operation.OperationHandleIdPathParameter

KEY - Static variable in class org.apache.flink.table.gateway.rest.message.session.SessionHandleIdPathParameter

KEY - Static variable in class org.apache.flink.table.gateway.rest.message.statement.FetchResultsRowFormatQueryParameter

KEY - Static variable in class org.apache.flink.table.gateway.rest.message.statement.FetchResultsTokenPathParameter

L

listCatalogs() - Method in class org.apache.flink.table.gateway.service.operation.OperationExecutor

listCatalogs(SessionHandle) - Method in class org.apache.flink.table.gateway.service.SqlGatewayServiceImpl

listDatabases(String) - Method in class org.apache.flink.table.gateway.service.operation.OperationExecutor

listDatabases(SessionHandle, String) - Method in class org.apache.flink.table.gateway.service.SqlGatewayServiceImpl

listSystemFunctions() - Method in class org.apache.flink.table.gateway.service.operation.OperationExecutor

listSystemFunctions(SessionHandle) - Method in class org.apache.flink.table.gateway.service.SqlGatewayServiceImpl

listTables(String, String, Set<CatalogBaseTable.TableKind>) - Method in class org.apache.flink.table.gateway.service.operation.OperationExecutor

listTables(SessionHandle, String, String, Set<CatalogBaseTable.TableKind>) - Method in class org.apache.flink.table.gateway.service.SqlGatewayServiceImpl

listUserDefinedFunctions(String, String) - Method in class org.apache.flink.table.gateway.service.operation.OperationExecutor

listUserDefinedFunctions(SessionHandle, String, String) - Method in class org.apache.flink.table.gateway.service.SqlGatewayServiceImpl

load(Configuration, List<URL>, boolean) - Static method in class org.apache.flink.table.gateway.service.context.DefaultContext

Build the DefaultContext from config.yaml, dynamic configuration and users specified jars.

LogicalTypeJsonDeserializer - Class in org.apache.flink.table.gateway.rest.serde

JSON deserializer for LogicalType.

LogicalTypeJsonSerializer - Class in org.apache.flink.table.gateway.rest.serde

Json serializer for LogicalType.

LogicalTypeJsonSerializer() - Constructor for class org.apache.flink.table.gateway.rest.serde.LogicalTypeJsonSerializer

M

main(String[]) - Static method in class org.apache.flink.table.gateway.SqlGateway

MaterializedTableIdentifierPathParameter - Class in org.apache.flink.table.gateway.rest.message.materializedtable

MessagePathParameter that parses the materialized table identifier.

MaterializedTableIdentifierPathParameter() - Constructor for class org.apache.flink.table.gateway.rest.message.materializedtable.MaterializedTableIdentifierPathParameter

materializedTableManager - Variable in class org.apache.flink.table.gateway.service.context.SessionContext.SessionState

MaterializedTableManager - Class in org.apache.flink.table.gateway.service.materializedtable

Manager is responsible for execute the MaterializedTableOperation.

MaterializedTableManager(Configuration, URLClassLoader) - Constructor for class org.apache.flink.table.gateway.service.materializedtable.MaterializedTableManager

modifyRefreshWorkflow(ModifyRefreshWorkflow<EmbeddedRefreshHandler>) - Method in class org.apache.flink.table.gateway.workflow.EmbeddedWorkflowScheduler

moduleManager - Variable in class org.apache.flink.table.gateway.service.context.SessionContext.SessionState

N

NotReadyFetchResultResponse - Class in org.apache.flink.table.gateway.rest.message.statement

The FetchResultsResponseBody indicates the results is not ready.

NotReadyFetchResultResponse(String) - Constructor for class org.apache.flink.table.gateway.rest.message.statement.NotReadyFetchResultResponse

NotReadyResult - Class in org.apache.flink.table.gateway.service.result

To represent that the execution result is not ready to fetch.

O

open() - Method in class org.apache.flink.table.gateway.service.context.SessionContext

open() - Method in class org.apache.flink.table.gateway.service.materializedtable.MaterializedTableManager

open() - Method in class org.apache.flink.table.gateway.service.session.Session

open() - Method in class org.apache.flink.table.gateway.workflow.EmbeddedWorkflowScheduler

openSession(SessionEnvironment) - Method in interface org.apache.flink.table.gateway.service.session.SessionManager

Register a new Session.

openSession(SessionEnvironment) - Method in class org.apache.flink.table.gateway.service.session.SessionManagerImpl

openSession(SessionEnvironment) - Method in class org.apache.flink.table.gateway.service.SqlGatewayServiceImpl

OpenSessionHandler - Class in org.apache.flink.table.gateway.rest.handler.session

Handler to open session.

OpenSessionHandler(SqlGatewayService, Map<String, String>, MessageHeaders<OpenSessionRequestBody, OpenSessionResponseBody, EmptyMessageParameters>) - Constructor for class org.apache.flink.table.gateway.rest.handler.session.OpenSessionHandler

OpenSessionHeaders - Class in org.apache.flink.table.gateway.rest.header.session

Message headers for opening a session.

OpenSessionRequestBody - Class in org.apache.flink.table.gateway.rest.message.session

RequestBody for opening a session.

OpenSessionRequestBody(String, Map<String, String>) - Constructor for class org.apache.flink.table.gateway.rest.message.session.OpenSessionRequestBody

OpenSessionResponseBody - Class in org.apache.flink.table.gateway.rest.message.session

ResponseBody for opening a session.

OpenSessionResponseBody(String) - Constructor for class org.apache.flink.table.gateway.rest.message.session.OpenSessionResponseBody

Operation(OperationHandle, Callable<ResultFetcher>) - Constructor for class org.apache.flink.table.gateway.service.operation.OperationManager.Operation

OperationExecutor - Class in org.apache.flink.table.gateway.service.operation

An executor to execute the Operation.

OperationExecutor(SessionContext, Configuration) - Constructor for class org.apache.flink.table.gateway.service.operation.OperationExecutor

OperationHandleIdPathParameter - Class in org.apache.flink.table.gateway.rest.message.operation

MessagePathParameter that parses the OperationHandle.

OperationHandleIdPathParameter() - Constructor for class org.apache.flink.table.gateway.rest.message.operation.OperationHandleIdPathParameter

operationId() - Method in class org.apache.flink.table.gateway.rest.header.materializedtable.RefreshMaterializedTableHeaders

operationId() - Method in class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.CreateEmbeddedSchedulerWorkflowHeaders

operationId() - Method in class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.DeleteEmbeddedSchedulerWorkflowHeaders

operationId() - Method in class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.ResumeEmbeddedSchedulerWorkflowHeaders

operationId() - Method in class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.SuspendEmbeddedSchedulerWorkflowHeaders

operationId() - Method in class org.apache.flink.table.gateway.rest.header.operation.CancelOperationHeaders

operationId() - Method in class org.apache.flink.table.gateway.rest.header.operation.CloseOperationHeaders

operationId() - Method in class org.apache.flink.table.gateway.rest.header.operation.GetOperationStatusHeaders

operationId() - Method in class org.apache.flink.table.gateway.rest.header.session.CloseSessionHeaders

operationId() - Method in class org.apache.flink.table.gateway.rest.header.session.ConfigureSessionHeaders

operationId() - Method in class org.apache.flink.table.gateway.rest.header.session.GetSessionConfigHeaders

operationId() - Method in class org.apache.flink.table.gateway.rest.header.session.OpenSessionHeaders

operationId() - Method in class org.apache.flink.table.gateway.rest.header.session.TriggerSessionHeartbeatHeaders

operationId() - Method in class org.apache.flink.table.gateway.rest.header.statement.CompleteStatementHeaders

operationId() - Method in class org.apache.flink.table.gateway.rest.header.statement.ExecuteStatementHeaders

operationId() - Method in class org.apache.flink.table.gateway.rest.header.statement.FetchResultsHeaders

operationId() - Method in class org.apache.flink.table.gateway.rest.header.util.GetApiVersionHeaders

operationId() - Method in class org.apache.flink.table.gateway.rest.header.util.GetInfoHeaders

OperationManager - Class in org.apache.flink.table.gateway.service.operation

Manager for the OperationManager.Operation.

OperationManager(ExecutorService) - Constructor for class org.apache.flink.table.gateway.service.operation.OperationManager

OperationManager.Operation - Class in org.apache.flink.table.gateway.service.operation

Operation to manage the execution, results and so on.

OperationMessageParameters - Class in org.apache.flink.table.gateway.rest.message.operation

MessageParameters for operation.

OperationMessageParameters() - Constructor for class org.apache.flink.table.gateway.rest.message.operation.OperationMessageParameters

OperationMessageParameters(SessionHandle, OperationHandle) - Constructor for class org.apache.flink.table.gateway.rest.message.operation.OperationMessageParameters

OperationStatusResponseBody - Class in org.apache.flink.table.gateway.rest.message.operation

ResponseBody for getting the status of operation.

OperationStatusResponseBody(String) - Constructor for class org.apache.flink.table.gateway.rest.message.operation.OperationStatusResponseBody

OPTION_HELP - Static variable in class org.apache.flink.table.gateway.cli.SqlGatewayOptionsParser

optionalOptions() - Method in class org.apache.flink.table.gateway.rest.SqlGatewayRestEndpointFactory

optionalOptions() - Method in class org.apache.flink.table.gateway.workflow.EmbeddedWorkflowSchedulerFactory

org.apache.flink.table.gateway - package org.apache.flink.table.gateway

org.apache.flink.table.gateway.cli - package org.apache.flink.table.gateway.cli

org.apache.flink.table.gateway.environment - package org.apache.flink.table.gateway.environment

org.apache.flink.table.gateway.rest - package org.apache.flink.table.gateway.rest

org.apache.flink.table.gateway.rest.handler - package org.apache.flink.table.gateway.rest.handler

org.apache.flink.table.gateway.rest.handler.materializedtable - package org.apache.flink.table.gateway.rest.handler.materializedtable

org.apache.flink.table.gateway.rest.handler.materializedtable.scheduler - package org.apache.flink.table.gateway.rest.handler.materializedtable.scheduler

org.apache.flink.table.gateway.rest.handler.operation - package org.apache.flink.table.gateway.rest.handler.operation

org.apache.flink.table.gateway.rest.handler.session - package org.apache.flink.table.gateway.rest.handler.session

org.apache.flink.table.gateway.rest.handler.statement - package org.apache.flink.table.gateway.rest.handler.statement

org.apache.flink.table.gateway.rest.handler.util - package org.apache.flink.table.gateway.rest.handler.util

org.apache.flink.table.gateway.rest.header - package org.apache.flink.table.gateway.rest.header

org.apache.flink.table.gateway.rest.header.materializedtable - package org.apache.flink.table.gateway.rest.header.materializedtable

org.apache.flink.table.gateway.rest.header.materializedtable.scheduler - package org.apache.flink.table.gateway.rest.header.materializedtable.scheduler

org.apache.flink.table.gateway.rest.header.operation - package org.apache.flink.table.gateway.rest.header.operation

org.apache.flink.table.gateway.rest.header.session - package org.apache.flink.table.gateway.rest.header.session

org.apache.flink.table.gateway.rest.header.statement - package org.apache.flink.table.gateway.rest.header.statement

org.apache.flink.table.gateway.rest.header.util - package org.apache.flink.table.gateway.rest.header.util

org.apache.flink.table.gateway.rest.message.materializedtable - package org.apache.flink.table.gateway.rest.message.materializedtable

org.apache.flink.table.gateway.rest.message.materializedtable.scheduler - package org.apache.flink.table.gateway.rest.message.materializedtable.scheduler

org.apache.flink.table.gateway.rest.message.operation - package org.apache.flink.table.gateway.rest.message.operation

org.apache.flink.table.gateway.rest.message.session - package org.apache.flink.table.gateway.rest.message.session

org.apache.flink.table.gateway.rest.message.statement - package org.apache.flink.table.gateway.rest.message.statement

org.apache.flink.table.gateway.rest.message.util - package org.apache.flink.table.gateway.rest.message.util

org.apache.flink.table.gateway.rest.serde - package org.apache.flink.table.gateway.rest.serde

org.apache.flink.table.gateway.rest.util - package org.apache.flink.table.gateway.rest.util

org.apache.flink.table.gateway.service - package org.apache.flink.table.gateway.service

org.apache.flink.table.gateway.service.context - package org.apache.flink.table.gateway.service.context

org.apache.flink.table.gateway.service.materializedtable - package org.apache.flink.table.gateway.service.materializedtable

org.apache.flink.table.gateway.service.operation - package org.apache.flink.table.gateway.service.operation

org.apache.flink.table.gateway.service.result - package org.apache.flink.table.gateway.service.result

org.apache.flink.table.gateway.service.session - package org.apache.flink.table.gateway.service.session

org.apache.flink.table.gateway.service.utils - package org.apache.flink.table.gateway.service.utils

org.apache.flink.table.gateway.workflow - package org.apache.flink.table.gateway.workflow

org.apache.flink.table.gateway.workflow.scheduler - package org.apache.flink.table.gateway.workflow.scheduler

P

parseSqlGatewayOptions(String[]) - Static method in class org.apache.flink.table.gateway.cli.SqlGatewayOptionsParser

parseToken(String) - Static method in class org.apache.flink.table.gateway.rest.util.SqlGatewayRestEndpointUtils

Parse token from the result uri.

PORT - Static variable in class org.apache.flink.table.gateway.rest.util.SqlGatewayRestOptions

The port that the client connects to.

printHelpSqlGateway(PrintStream) - Static method in class org.apache.flink.table.gateway.cli.SqlGatewayOptionsParser

Prints the help for the client.

PRODUCT_NAME - Static variable in class org.apache.flink.table.gateway.rest.handler.util.GetInfoHandler

Q

QUARTZ_JOB_GROUP - Static variable in class org.apache.flink.table.gateway.workflow.scheduler.QuartzSchedulerUtils

QUARTZ_JOB_PREFIX - Static variable in class org.apache.flink.table.gateway.workflow.scheduler.QuartzSchedulerUtils

QuartzSchedulerUtils - Class in org.apache.flink.table.gateway.workflow.scheduler

Utility class for quartz scheduler.

QuartzSchedulerUtils() - Constructor for class org.apache.flink.table.gateway.workflow.scheduler.QuartzSchedulerUtils

R

rebuildRestEndpointOptions(Map<String, String>, Map<String, String>) - Static method in class org.apache.flink.table.gateway.rest.SqlGatewayRestEndpointFactory

refreshMaterializedTable(OperationExecutor, OperationHandle, ObjectIdentifier, Map<String, String>, Map<String, String>, boolean, String) - Method in class org.apache.flink.table.gateway.service.materializedtable.MaterializedTableManager

refreshMaterializedTable(OperationHandle, String, boolean, String, Map<String, String>, Map<String, String>) - Method in class org.apache.flink.table.gateway.service.operation.OperationExecutor

refreshMaterializedTable(SessionHandle, String, boolean, String, Map<String, String>, Map<String, String>, Map<String, String>) - Method in class org.apache.flink.table.gateway.service.SqlGatewayServiceImpl

RefreshMaterializedTableHandler - Class in org.apache.flink.table.gateway.rest.handler.materializedtable

Handler to execute materialized table refresh operation.

RefreshMaterializedTableHandler(SqlGatewayService, Map<String, String>, MessageHeaders<RefreshMaterializedTableRequestBody, RefreshMaterializedTableResponseBody, RefreshMaterializedTableParameters>) - Constructor for class org.apache.flink.table.gateway.rest.handler.materializedtable.RefreshMaterializedTableHandler

RefreshMaterializedTableHeaders - Class in org.apache.flink.table.gateway.rest.header.materializedtable

Message headers for executing a materialized table refresh operation.

RefreshMaterializedTableHeaders() - Constructor for class org.apache.flink.table.gateway.rest.header.materializedtable.RefreshMaterializedTableHeaders

RefreshMaterializedTableParameters - Class in org.apache.flink.table.gateway.rest.message.materializedtable

MessageParameters for execute materialized table refresh operation.

RefreshMaterializedTableParameters() - Constructor for class org.apache.flink.table.gateway.rest.message.materializedtable.RefreshMaterializedTableParameters

RefreshMaterializedTableParameters(SessionHandle, String) - Constructor for class org.apache.flink.table.gateway.rest.message.materializedtable.RefreshMaterializedTableParameters

RefreshMaterializedTableRequestBody - Class in org.apache.flink.table.gateway.rest.message.materializedtable

RequestBody for executing materialized table refresh operation.

RefreshMaterializedTableRequestBody(boolean, String, Map<String, String>, Map<String, String>, Map<String, String>) - Constructor for class org.apache.flink.table.gateway.rest.message.materializedtable.RefreshMaterializedTableRequestBody

RefreshMaterializedTableResponseBody - Class in org.apache.flink.table.gateway.rest.message.materializedtable

ResponseBody for executing a materialized table refresh operation.

RefreshMaterializedTableResponseBody(String) - Constructor for class org.apache.flink.table.gateway.rest.message.materializedtable.RefreshMaterializedTableResponseBody

requiredOptions() - Method in class org.apache.flink.table.gateway.rest.SqlGatewayRestEndpointFactory

requiredOptions() - Method in class org.apache.flink.table.gateway.workflow.EmbeddedWorkflowSchedulerFactory

reset(String) - Method in class org.apache.flink.table.gateway.service.context.SessionContext

reset() - Method in class org.apache.flink.table.gateway.service.context.SessionContext

resourceManager - Variable in class org.apache.flink.table.gateway.service.context.SessionContext.SessionState

respondToRequest(ChannelHandlerContext, HttpRequest, HandlerRequest<R>, NonLeaderRetrievalRestfulGateway) - Method in class org.apache.flink.table.gateway.rest.handler.AbstractSqlGatewayRestHandler

ResultFetcher - Class in org.apache.flink.table.gateway.service.result

A fetcher to fetch result from submitted statement.

ResultInfo - Class in org.apache.flink.table.gateway.rest.serde

A ResultInfo contains information of a ResultSet.

ResultInfoDeserializer - Class in org.apache.flink.table.gateway.rest.serde

Deserializer for ResultInfo.

ResultInfoDeserializer() - Constructor for class org.apache.flink.table.gateway.rest.serde.ResultInfoDeserializer

ResultInfoSerializer - Class in org.apache.flink.table.gateway.rest.serde

Serializer for ResultInfo.

ResultInfoSerializer() - Constructor for class org.apache.flink.table.gateway.rest.serde.ResultInfoSerializer

ResultStore - Class in org.apache.flink.table.gateway.service.result

A result store which stores and buffers results.

ResultStore(CloseableIterator<RowData>, int) - Constructor for class org.apache.flink.table.gateway.service.result.ResultStore

ResumeEmbeddedSchedulerWorkflowHandler - Class in org.apache.flink.table.gateway.rest.handler.materializedtable.scheduler

Handler to resume workflow in embedded scheduler.

ResumeEmbeddedSchedulerWorkflowHandler(SqlGatewayService, EmbeddedQuartzScheduler, Map<String, String>, MessageHeaders<ResumeEmbeddedSchedulerWorkflowRequestBody, EmptyResponseBody, EmptyMessageParameters>) - Constructor for class org.apache.flink.table.gateway.rest.handler.materializedtable.scheduler.ResumeEmbeddedSchedulerWorkflowHandler

ResumeEmbeddedSchedulerWorkflowHeaders - Class in org.apache.flink.table.gateway.rest.header.materializedtable.scheduler

Message headers for resume workflow in embedded scheduler.

ResumeEmbeddedSchedulerWorkflowHeaders() - Constructor for class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.ResumeEmbeddedSchedulerWorkflowHeaders

ResumeEmbeddedSchedulerWorkflowRequestBody - Class in org.apache.flink.table.gateway.rest.message.materializedtable.scheduler

RequestBody for resume workflow in embedded scheduler.

ResumeEmbeddedSchedulerWorkflowRequestBody(String, String, Map<String, String>) - Constructor for class org.apache.flink.table.gateway.rest.message.materializedtable.scheduler.ResumeEmbeddedSchedulerWorkflowRequestBody

resumeScheduleWorkflow(String, String, Map<String, String>) - Method in class org.apache.flink.table.gateway.workflow.scheduler.EmbeddedQuartzScheduler

Resume a quartz schedule job with new dynamic options.

retrieveRecords() - Method in class org.apache.flink.table.gateway.service.result.ResultStore

RowDataLocalTimeZoneConverter - Class in org.apache.flink.table.gateway.rest.util

Convert LocalZonedTimestampType data in RowData to TimestampData based on the local time zone.

RowDataLocalTimeZoneConverter(List<LogicalType>, ReadableConfig) - Constructor for class org.apache.flink.table.gateway.rest.util.RowDataLocalTimeZoneConverter

RowDataLocalTimeZoneConverter(List<LogicalType>, TimeZone) - Constructor for class org.apache.flink.table.gateway.rest.util.RowDataLocalTimeZoneConverter

RowFormat - Enum in org.apache.flink.table.gateway.rest.util

Describes the serialization format of RowData in the ResultSet.

run() - Method in class org.apache.flink.table.gateway.service.operation.OperationManager.Operation

S

SAVEPOINT_PATH - Static variable in class org.apache.flink.table.gateway.service.utils.Constants

SCHEDULE_TIME_FORMAT - Static variable in class org.apache.flink.table.gateway.workflow.scheduler.QuartzSchedulerUtils

SchedulerException - Exception in org.apache.flink.table.gateway.workflow.scheduler

General exception for workflow scheduler related errors.

SchedulerException(String) - Constructor for exception org.apache.flink.table.gateway.workflow.scheduler.SchedulerException

SchedulerException(String, Throwable) - Constructor for exception org.apache.flink.table.gateway.workflow.scheduler.SchedulerException

serialize(FetchResultsResponseBody, JsonGenerator, SerializerProvider) - Method in class org.apache.flink.table.gateway.rest.serde.FetchResultsResponseBodySerializer

serialize(LogicalType, JsonGenerator, SerializerProvider) - Method in class org.apache.flink.table.gateway.rest.serde.LogicalTypeJsonSerializer

serialize(ResultInfo, JsonGenerator, SerializerProvider) - Method in class org.apache.flink.table.gateway.rest.serde.ResultInfoSerializer

serialize(EmbeddedRefreshHandler) - Method in class org.apache.flink.table.gateway.workflow.EmbeddedRefreshHandlerSerializer

service - Variable in class org.apache.flink.table.gateway.rest.handler.AbstractSqlGatewayRestHandler

service - Variable in class org.apache.flink.table.gateway.rest.SqlGatewayRestEndpoint

Session - Class in org.apache.flink.table.gateway.service.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.

Session(SessionContext) - Constructor for class org.apache.flink.table.gateway.service.session.Session

SessionContext - Class in org.apache.flink.table.gateway.service.context

Context describing a session, it's mainly used for user to open a new session in the backend.

SessionContext(DefaultContext, SessionHandle, EndpointVersion, Configuration, URLClassLoader, SessionContext.SessionState, OperationManager) - Constructor for class org.apache.flink.table.gateway.service.context.SessionContext

sessionContext - Variable in class org.apache.flink.table.gateway.service.operation.OperationExecutor

SessionContext.SessionState - Class in org.apache.flink.table.gateway.service.context

session state.

SessionHandleIdPathParameter - Class in org.apache.flink.table.gateway.rest.message.session

MessagePathParameter that parse the SessionHandle.

SessionHandleIdPathParameter() - Constructor for class org.apache.flink.table.gateway.rest.message.session.SessionHandleIdPathParameter

SessionManager - Interface in org.apache.flink.table.gateway.service.session

Mange the lifecycle of the Session.

SessionManagerImpl - Class in org.apache.flink.table.gateway.service.session

The implementation of the SessionManager that manage the lifecycle of the Session.

SessionManagerImpl(DefaultContext) - Constructor for class org.apache.flink.table.gateway.service.session.SessionManagerImpl

SessionMessageParameters - Class in org.apache.flink.table.gateway.rest.message.session

MessagePathParameter for session handle.

SessionMessageParameters() - Constructor for class org.apache.flink.table.gateway.rest.message.session.SessionMessageParameters

SessionMessageParameters(SessionHandle) - Constructor for class org.apache.flink.table.gateway.rest.message.session.SessionMessageParameters

SessionState(CatalogManager, ModuleManager, ResourceManager, FunctionCatalog, MaterializedTableManager) - Constructor for class org.apache.flink.table.gateway.service.context.SessionContext.SessionState

set(String, String) - Method in class org.apache.flink.table.gateway.service.context.SessionContext

SET_KEY - Static variable in class org.apache.flink.table.gateway.service.utils.Constants

SET_VALUE - Static variable in class org.apache.flink.table.gateway.service.utils.Constants

setAsContext(ClassLoader) - Static method in class org.apache.flink.table.gateway.environment.SqlGatewayStreamExecutionEnvironment

SqlCancelException - Exception in org.apache.flink.table.gateway.service.utils

Thrown to trigger a canceling of the executing operation.

SqlCancelException(String) - Constructor for exception org.apache.flink.table.gateway.service.utils.SqlCancelException

SqlExecutionException - Exception in org.apache.flink.table.gateway.service.utils

Exception thrown during the execution.

SqlExecutionException(String) - Constructor for exception org.apache.flink.table.gateway.service.utils.SqlExecutionException

SqlExecutionException(String, Throwable) - Constructor for exception org.apache.flink.table.gateway.service.utils.SqlExecutionException

SqlGateway - Class in org.apache.flink.table.gateway

Main entry point for the SQL Gateway.

SqlGateway(Configuration, SessionManager) - Constructor for class org.apache.flink.table.gateway.SqlGateway

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> - Interface in org.apache.flink.table.gateway.rest.header

This class links RequestBodys to ResponseBodys types and contains meta-data required for their http headers in runtime module.

SqlGatewayOptions - Class in org.apache.flink.table.gateway.cli

Options to configure the SqlGateway.

SqlGatewayOptions(boolean, Properties) - Constructor for class org.apache.flink.table.gateway.cli.SqlGatewayOptions

SqlGatewayOptionsParser - Class in org.apache.flink.table.gateway.cli

Parser to parse the command line options.

SqlGatewayOptionsParser() - Constructor for class org.apache.flink.table.gateway.cli.SqlGatewayOptionsParser

SqlGatewayRestAPIVersion - Enum in org.apache.flink.table.gateway.rest.util

An enum for all versions of the Sql Gateway REST API.

SqlGatewayRestEndpoint - Class in org.apache.flink.table.gateway.rest

The rest endpoint for sql gateway.

SqlGatewayRestEndpoint(Configuration, SqlGatewayService) - Constructor for class org.apache.flink.table.gateway.rest.SqlGatewayRestEndpoint

SqlGatewayRestEndpointFactory - Class in org.apache.flink.table.gateway.rest

The factory for sql gateway.

SqlGatewayRestEndpointFactory() - Constructor for class org.apache.flink.table.gateway.rest.SqlGatewayRestEndpointFactory

SqlGatewayRestEndpointUtils - Class in org.apache.flink.table.gateway.rest.util

Utils for the SqlGatewayRestEndpoint.

SqlGatewayRestEndpointUtils() - Constructor for class org.apache.flink.table.gateway.rest.util.SqlGatewayRestEndpointUtils

SqlGatewayRestOptions - Class in org.apache.flink.table.gateway.rest.util

Options to configure SqlGatewayRestEndpoint.

SqlGatewayRestOptions() - Constructor for class org.apache.flink.table.gateway.rest.util.SqlGatewayRestOptions

SqlGatewayServiceImpl - Class in org.apache.flink.table.gateway.service

The implementation of the SqlGatewayService interface.

SqlGatewayServiceImpl(SessionManager) - Constructor for class org.apache.flink.table.gateway.service.SqlGatewayServiceImpl

SqlGatewayStreamExecutionEnvironment - Class in org.apache.flink.table.gateway.environment

The SqlGatewayStreamExecutionEnvironment is a StreamExecutionEnvironment that runs the program with SQL gateway.

SqlGatewayStreamExecutionEnvironment() - Constructor for class org.apache.flink.table.gateway.environment.SqlGatewayStreamExecutionEnvironment

start() - Method in interface org.apache.flink.table.gateway.service.session.SessionManager

Start the SessionManager and do the required initialization.

start() - Method in class org.apache.flink.table.gateway.service.session.SessionManagerImpl

start() - Method in class org.apache.flink.table.gateway.SqlGateway

start() - Method in class org.apache.flink.table.gateway.workflow.scheduler.EmbeddedQuartzScheduler

START_TIME - Static variable in class org.apache.flink.table.gateway.service.utils.Constants

startInternal() - Method in class org.apache.flink.table.gateway.rest.SqlGatewayRestEndpoint

STATUS - Static variable in class org.apache.flink.table.gateway.service.utils.Constants

stop() - Method in class org.apache.flink.table.gateway.rest.SqlGatewayRestEndpoint

stop() - Method in interface org.apache.flink.table.gateway.service.session.SessionManager

Destroy the SessionManager and releases used resources.

stop() - Method in class org.apache.flink.table.gateway.service.session.SessionManagerImpl

stop() - Method in class org.apache.flink.table.gateway.SqlGateway

stop() - Method in class org.apache.flink.table.gateway.workflow.scheduler.EmbeddedQuartzScheduler

submitOperation(Callable<ResultSet>) - Method in class org.apache.flink.table.gateway.service.operation.OperationManager

Submit the operation to the OperationManager.

submitOperation(Function<OperationHandle, ResultFetcher>) - Method in class org.apache.flink.table.gateway.service.operation.OperationManager

Submit the operation to the OperationManager.

submitOperation(SessionHandle, Callable<ResultSet>) - Method in class org.apache.flink.table.gateway.service.SqlGatewayServiceImpl

SuspendEmbeddedSchedulerWorkflowHandler - Class in org.apache.flink.table.gateway.rest.handler.materializedtable.scheduler

Handler to suspend workflow in embedded scheduler.

SuspendEmbeddedSchedulerWorkflowHandler(SqlGatewayService, EmbeddedQuartzScheduler, Map<String, String>, MessageHeaders<EmbeddedSchedulerWorkflowRequestBody, EmptyResponseBody, EmptyMessageParameters>) - Constructor for class org.apache.flink.table.gateway.rest.handler.materializedtable.scheduler.SuspendEmbeddedSchedulerWorkflowHandler

SuspendEmbeddedSchedulerWorkflowHeaders - Class in org.apache.flink.table.gateway.rest.header.materializedtable.scheduler

Message headers for suspend workflow in embedded scheduler.

SuspendEmbeddedSchedulerWorkflowHeaders() - Constructor for class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.SuspendEmbeddedSchedulerWorkflowHeaders

suspendScheduleWorkflow(String, String) - Method in class org.apache.flink.table.gateway.workflow.scheduler.EmbeddedQuartzScheduler

T

tableExists(ObjectIdentifier) - Method in class org.apache.flink.table.gateway.service.operation.OperationExecutor

toColumn() - Method in class org.apache.flink.table.gateway.rest.serde.ColumnInfo

toColumnInfo(Column) - Static method in class org.apache.flink.table.gateway.rest.serde.ColumnInfo

toJson(T) - Static method in class org.apache.flink.table.gateway.workflow.scheduler.QuartzSchedulerUtils

toString() - Method in class org.apache.flink.table.gateway.rest.serde.ColumnInfo

toString() - Method in class org.apache.flink.table.gateway.rest.serde.ResultInfo

toString() - Method in class org.apache.flink.table.gateway.workflow.EmbeddedRefreshHandler

toString() - Method in class org.apache.flink.table.gateway.workflow.WorkflowInfo

touch() - Method in class org.apache.flink.table.gateway.service.session.Session

TriggerSessionHeartbeatHandler - Class in org.apache.flink.table.gateway.rest.handler.session

Handler to touch the session.

TriggerSessionHeartbeatHandler(SqlGatewayService, Map<String, String>, MessageHeaders<EmptyRequestBody, EmptyResponseBody, SessionMessageParameters>) - Constructor for class org.apache.flink.table.gateway.rest.handler.session.TriggerSessionHeartbeatHandler

TriggerSessionHeartbeatHeaders - Class in org.apache.flink.table.gateway.rest.header.session

Message headers for touching the session.

TriggerSessionHeartbeatHeaders() - Constructor for class org.apache.flink.table.gateway.rest.header.session.TriggerSessionHeartbeatHeaders

U

UNDERLINE - Static variable in class org.apache.flink.table.gateway.workflow.scheduler.QuartzSchedulerUtils

unsetAsContext() - Static method in class org.apache.flink.table.gateway.environment.SqlGatewayStreamExecutionEnvironment

URL - Static variable in class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.CreateEmbeddedSchedulerWorkflowHeaders

URL - Static variable in class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.DeleteEmbeddedSchedulerWorkflowHeaders

URL - Static variable in class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.ResumeEmbeddedSchedulerWorkflowHeaders

URL - Static variable in class org.apache.flink.table.gateway.rest.header.materializedtable.scheduler.SuspendEmbeddedSchedulerWorkflowHeaders

URL - Static variable in class org.apache.flink.table.gateway.rest.header.statement.FetchResultsHeaders

V

valueOf(String) - Static method in enum org.apache.flink.table.gateway.rest.util.RowFormat

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.table.gateway.rest.util.SqlGatewayRestAPIVersion

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.apache.flink.table.gateway.rest.util.RowFormat

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flink.table.gateway.rest.util.SqlGatewayRestAPIVersion

Returns an array containing the constants of this enum type, in the order they are declared.

W

waitUntilHasData() - Method in class org.apache.flink.table.gateway.service.result.ResultStore

waitUntilStop() - Method in class org.apache.flink.table.gateway.SqlGateway

withResourceManager(ResourceManager) - Method in class org.apache.flink.table.gateway.service.result.ResultFetcher

WORKFLOW_INFO - Static variable in class org.apache.flink.table.gateway.workflow.scheduler.QuartzSchedulerUtils

WorkflowInfo - Class in org.apache.flink.table.gateway.workflow

The WorkflowInfo represents the required information of one materialized table background workflow.

WorkflowInfo(String, Map<String, String>, Map<String, String>, Map<String, String>, String) - Constructor for class org.apache.flink.table.gateway.workflow.WorkflowInfo

A B C D E F G H I J K L M N O P Q R S T U V W