All Methods Instance Methods Concrete Methods Deprecated Methods
Modifier and Type |
Method and Description |
List<StreamEdge> |
getChainedOutputs(ClassLoader cl) |
int |
getChainIndex() |
CheckpointingMode |
getCheckpointMode() |
Configuration |
getConfiguration() |
List<StreamEdge> |
getInPhysicalEdges(ClassLoader cl) |
String |
getIterationId() |
long |
getIterationWaitTime() |
double |
getManagedMemoryFraction() |
List<StreamEdge> |
getNonChainedOutputs(ClassLoader cl) |
int |
getNumberOfInputs() |
int |
getNumberOfOutputs() |
OperatorID |
getOperatorID() |
String |
getOperatorName() |
List<StreamEdge> |
getOutEdgesInOrder(ClassLoader cl) |
<T> List<OutputSelector<T>> |
getOutputSelectors(ClassLoader userCodeClassloader) |
byte[] |
getSerializedStateBackend() |
StateBackend |
getStateBackend(ClassLoader cl) |
<K> TypeSerializer<K> |
getStateKeySerializer(ClassLoader cl) |
KeySelector<?,Serializable> |
getStatePartitioner(int input,
ClassLoader cl) |
<T extends StreamOperator<?>> T |
getStreamOperator(ClassLoader cl) |
<T extends StreamOperatorFactory<?>> T |
getStreamOperatorFactory(ClassLoader cl) |
TimeCharacteristic |
getTimeCharacteristic() |
Map<Integer,StreamConfig> |
getTransitiveChainedTaskConfigs(ClassLoader cl) |
Map<Integer,StreamConfig> |
getTransitiveChainedTaskConfigsWithSelf(ClassLoader cl) |
<T> TypeSerializer<T> |
getTypeSerializerIn(int index,
ClassLoader cl) |
<T> TypeSerializer<T> |
getTypeSerializerIn1(ClassLoader cl)
Deprecated.
|
<T> TypeSerializer<T> |
getTypeSerializerIn2(ClassLoader cl)
Deprecated.
|
<T> TypeSerializer<T> |
getTypeSerializerOut(ClassLoader cl) |
<T> TypeSerializer<T> |
getTypeSerializerSideOut(OutputTag<?> outputTag,
ClassLoader cl) |
TypeSerializer<?>[] |
getTypeSerializersIn(ClassLoader cl) |
Integer |
getVertexID() |
boolean |
isChainEnd() |
boolean |
isChainStart() |
boolean |
isCheckpointingEnabled() |
boolean |
isExactlyOnceCheckpointMode() |
boolean |
isUnalignedCheckpointsEnabled() |
void |
setChainedOutputs(List<StreamEdge> chainedOutputs) |
void |
setChainEnd() |
void |
setChainIndex(int index) |
void |
setChainStart() |
void |
setCheckpointingEnabled(boolean enabled) |
void |
setCheckpointMode(CheckpointingMode mode) |
void |
setInPhysicalEdges(List<StreamEdge> inEdges) |
void |
setIterationId(String iterationId) |
void |
setIterationWaitTime(long time) |
void |
setManagedMemoryFraction(double managedMemFraction) |
void |
setNonChainedOutputs(List<StreamEdge> outputvertexIDs) |
void |
setNumberOfInputs(int numberOfInputs) |
void |
setNumberOfOutputs(int numberOfOutputs) |
void |
setOperatorID(OperatorID operatorID) |
void |
setOperatorName(String name) |
void |
setOutEdgesInOrder(List<StreamEdge> outEdgeList) |
void |
setOutputSelectors(List<OutputSelector<?>> outputSelectors) |
void |
setStateBackend(StateBackend backend) |
void |
setStateKeySerializer(TypeSerializer<?> serializer) |
void |
setStatePartitioner(int input,
KeySelector<?,?> partitioner) |
void |
setStreamOperator(StreamOperator<?> operator) |
void |
setStreamOperatorFactory(StreamOperatorFactory<?> factory) |
void |
setTimeCharacteristic(TimeCharacteristic characteristic) |
void |
setTransitiveChainedTaskConfigs(Map<Integer,StreamConfig> chainedTaskConfigs) |
void |
setTypeSerializerOut(TypeSerializer<?> serializer) |
void |
setTypeSerializerSideOut(OutputTag<?> outputTag,
TypeSerializer<?> serializer) |
void |
setTypeSerializersIn(TypeSerializer<?>... serializers) |
void |
setUnalignedCheckpointsEnabled(boolean enabled) |
void |
setVertexID(Integer vertexID) |
String |
toString() |