@Internal public class BoundedStreamConfig extends StreamConfig
StreamConfig
with default settings.Constructor and Description |
---|
BoundedStreamConfig() |
BoundedStreamConfig(TypeSerializer<?> keySerializer,
KeySelector<IN,?> keySelector) |
getBufferTimeout, getChainedOutputs, getChainIndex, getCheckpointMode, getConfiguration, getInPhysicalEdges, getIterationId, getIterationWaitTime, getNonChainedOutputs, getNumberOfInputs, getNumberOfOutputs, getOperatorID, getOperatorName, getOutEdges, getOutEdgesInOrder, getOutputSelectors, getSerializedStateBackend, getStateBackend, getStateKeySerializer, getStatePartitioner, getStreamOperator, getStreamOperatorFactory, getTimeCharacteristic, getTransitiveChainedTaskConfigs, getTransitiveChainedTaskConfigsWithSelf, getTypeSerializerIn1, getTypeSerializerIn2, getTypeSerializerOut, getTypeSerializerSideOut, getVertexID, isChainEnd, isChainStart, isCheckpointingEnabled, isFlushAlwaysEnabled, setBufferTimeout, setChainedOutputs, setChainEnd, setChainIndex, setChainStart, setCheckpointingEnabled, setCheckpointMode, setInPhysicalEdges, setIterationId, setIterationWaitTime, setNonChainedOutputs, setNumberOfInputs, setNumberOfOutputs, setOperatorID, setOperatorName, setOutEdges, setOutEdgesInOrder, setOutputSelectors, setStateBackend, setStateKeySerializer, setStatePartitioner, setStreamOperator, setStreamOperatorFactory, setTimeCharacteristic, setTransitiveChainedTaskConfigs, setTypeSerializerIn1, setTypeSerializerIn2, setTypeSerializerOut, setTypeSerializerSideOut, setVertexID, toString
public BoundedStreamConfig()
public BoundedStreamConfig(TypeSerializer<?> keySerializer, KeySelector<IN,?> keySelector)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.