public class BroadcastOutputFactory extends Object
BroadcastOutput
from the Output
.Constructor and Description |
---|
BroadcastOutputFactory() |
Modifier and Type | Method and Description |
---|---|
static <OUT> BroadcastOutput<OUT> |
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 . |
public static <OUT> BroadcastOutput<OUT> createBroadcastOutput(org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<OUT>> output, org.apache.flink.metrics.Counter numRecordsOut)
output
.output
- the original output.numRecordsOut
- the counter for the number of output record.Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.