public class OutputReflectionContext extends Object
Constructor and Description |
---|
OutputReflectionContext() |
Modifier and Type | Method and Description |
---|---|
<OUT> org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<OUT>>[] |
getBroadcastingInternalOutputs(Object output) |
org.apache.flink.util.OutputTag<?> |
getChainingOutputTag(Object output) |
<OUT> org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<OUT>> |
getCountingInternalOutput(Object output) |
org.apache.flink.runtime.io.network.api.writer.RecordWriter<org.apache.flink.runtime.plugable.SerializationDelegate<org.apache.flink.streaming.runtime.streamrecord.StreamElement>> |
getRecordWriter(Object output) |
org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.streaming.runtime.streamrecord.StreamElement> |
getRecordWriterTypeSerializer(Object output) |
boolean |
isBroadcastingOutput(org.apache.flink.streaming.api.operators.Output<?> rawOutput) |
boolean |
isChainingOutput(org.apache.flink.streaming.api.operators.Output<?> rawOutput) |
boolean |
isCountingOutput(org.apache.flink.streaming.api.operators.Output<?> rawOutput) |
boolean |
isRecordWriterOutput(org.apache.flink.streaming.api.operators.Output<?> rawOutput) |
public boolean isBroadcastingOutput(org.apache.flink.streaming.api.operators.Output<?> rawOutput)
public boolean isChainingOutput(org.apache.flink.streaming.api.operators.Output<?> rawOutput)
public boolean isRecordWriterOutput(org.apache.flink.streaming.api.operators.Output<?> rawOutput)
public boolean isCountingOutput(org.apache.flink.streaming.api.operators.Output<?> rawOutput)
public <OUT> org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<OUT>>[] getBroadcastingInternalOutputs(Object output)
public <OUT> org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<OUT>> getCountingInternalOutput(Object output)
public org.apache.flink.util.OutputTag<?> getChainingOutputTag(Object output)
public org.apache.flink.runtime.io.network.api.writer.RecordWriter<org.apache.flink.runtime.plugable.SerializationDelegate<org.apache.flink.streaming.runtime.streamrecord.StreamElement>> getRecordWriter(Object output)
public org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.streaming.runtime.streamrecord.StreamElement> getRecordWriterTypeSerializer(Object output)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.