| Package | Description |
|---|---|
| org.apache.flink.table.gateway.workflow |
| Modifier and Type | Method and Description |
|---|---|
EmbeddedRefreshHandler |
EmbeddedWorkflowScheduler.createRefreshWorkflow(org.apache.flink.table.workflow.CreateRefreshWorkflow createRefreshWorkflow) |
EmbeddedRefreshHandler |
EmbeddedRefreshHandlerSerializer.deserialize(byte[] serializedBytes,
ClassLoader cl) |
| Modifier and Type | Method and Description |
|---|---|
byte[] |
EmbeddedRefreshHandlerSerializer.serialize(EmbeddedRefreshHandler refreshHandler) |
| Modifier and Type | Method and Description |
|---|---|
void |
EmbeddedWorkflowScheduler.deleteRefreshWorkflow(org.apache.flink.table.workflow.DeleteRefreshWorkflow<EmbeddedRefreshHandler> deleteRefreshWorkflow) |
void |
EmbeddedWorkflowScheduler.modifyRefreshWorkflow(org.apache.flink.table.workflow.ModifyRefreshWorkflow<EmbeddedRefreshHandler> modifyRefreshWorkflow) |
Copyright © 2014–2025 The Apache Software Foundation. All rights reserved.