Uses of Interface
org.apache.flink.table.runtime.context.ExecutionContext
-
-
Uses of ExecutionContext in org.apache.flink.table.runtime.context
Classes in org.apache.flink.table.runtime.context that implement ExecutionContext Modifier and Type Class Description class
ExecutionContextImpl
Implementation of ExecutionContext. -
Uses of ExecutionContext in org.apache.flink.table.runtime.operators.aggregate
Methods in org.apache.flink.table.runtime.operators.aggregate with parameters of type ExecutionContext Modifier and Type Method Description void
MiniBatchGlobalGroupAggFunction. open(ExecutionContext ctx)
void
MiniBatchGroupAggFunction. open(ExecutionContext ctx)
void
MiniBatchIncrementalGroupAggFunction. open(ExecutionContext ctx)
void
MiniBatchLocalGroupAggFunction. open(ExecutionContext ctx)
-
Uses of ExecutionContext in org.apache.flink.table.runtime.operators.bundle
Fields in org.apache.flink.table.runtime.operators.bundle declared as ExecutionContext Modifier and Type Field Description protected ExecutionContext
MapBundleFunction. ctx
Methods in org.apache.flink.table.runtime.operators.bundle with parameters of type ExecutionContext Modifier and Type Method Description void
MapBundleFunction. open(ExecutionContext ctx)
-
Uses of ExecutionContext in org.apache.flink.table.runtime.operators.deduplicate
Methods in org.apache.flink.table.runtime.operators.deduplicate with parameters of type ExecutionContext Modifier and Type Method Description void
ProcTimeMiniBatchDeduplicateKeepLastRowFunction. open(ExecutionContext ctx)
-
Uses of ExecutionContext in org.apache.flink.table.runtime.operators.over.frame
Methods in org.apache.flink.table.runtime.operators.over.frame with parameters of type ExecutionContext Modifier and Type Method Description void
InsensitiveOverFrame. open(ExecutionContext ctx)
void
OffsetOverFrame. open(ExecutionContext ctx)
void
OverWindowFrame. open(ExecutionContext ctx)
Open to init withExecutionContext
.void
RangeSlidingOverFrame. open(ExecutionContext ctx)
void
RangeUnboundedFollowingOverFrame. open(ExecutionContext ctx)
void
RangeUnboundedPrecedingOverFrame. open(ExecutionContext ctx)
void
SlidingOverFrame. open(ExecutionContext ctx)
void
UnboundedFollowingOverFrame. open(ExecutionContext ctx)
void
UnboundedOverWindowFrame. open(ExecutionContext ctx)
void
UnboundedPrecedingOverFrame. open(ExecutionContext ctx)
-