Package | Description |
---|---|
org.apache.flink.iteration.broadcast | |
org.apache.flink.iteration.operator |
Modifier and Type | Class and Description |
---|---|
class |
ChainingBroadcastOutput<OUT>
The broadcast output corresponding to a chained output.
|
class |
CountingBroadcastOutput<OUT>
The intermediate broadcast output that wrappers a list of internal outputs.
|
class |
RecordWriterBroadcastOutput<OUT>
The broadcast output corresponding to a record writer output.
|
Modifier and Type | Method and Description |
---|---|
static <OUT> BroadcastOutput<OUT> |
BroadcastOutputFactory.createBroadcastOutput(org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<OUT>> output,
org.apache.flink.metrics.Counter numRecordsOut)
Creates the wrapper broadcast output from
output . |
Constructor and Description |
---|
CountingBroadcastOutput(org.apache.flink.metrics.Counter numRecordsOut,
List<BroadcastOutput<OUT>> internalOutputs) |
Modifier and Type | Field and Description |
---|---|
protected BroadcastOutput<IterationRecord<T>> |
AbstractWrapperOperator.eventBroadcastOutput |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.