Modifier and Type | Method and Description |
---|---|
SlotSharingGroup |
SlotSharingGroup.Builder.build()
Build the SlotSharingGroup.
|
Modifier and Type | Method and Description |
---|---|
static ResourceSpec |
SlotSharingGroupUtils.extractResourceSpec(SlotSharingGroup slotSharingGroup) |
Modifier and Type | Method and Description |
---|---|
Optional<SlotSharingGroup> |
Transformation.getSlotSharingGroup()
Returns the slot sharing group of this transformation if present.
|
Modifier and Type | Method and Description |
---|---|
void |
Transformation.setSlotSharingGroup(SlotSharingGroup slotSharingGroup)
Sets the slot sharing group of this transformation.
|
Modifier and Type | Method and Description |
---|---|
DataStreamSink<T> |
DataStreamSink.slotSharingGroup(SlotSharingGroup slotSharingGroup)
Sets the slot sharing group of this operation.
|
SingleOutputStreamOperator<T> |
SingleOutputStreamOperator.slotSharingGroup(SlotSharingGroup slotSharingGroup)
Sets the slot sharing group of this operation.
|
Modifier and Type | Method and Description |
---|---|
StreamExecutionEnvironment |
StreamExecutionEnvironment.registerSlotSharingGroup(SlotSharingGroup slotSharingGroup)
Register a slot sharing group with its resource spec.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.