Uses of Package
org.apache.flink.runtime.io.network.api
-
Classes in org.apache.flink.runtime.io.network.api used by org.apache.flink.runtime.io.network.api Class Description CheckpointBarrier Checkpoint barriers are used to align checkpoints throughout the streaming topology.EndOfPartitionEvent This event marks a subpartition as fully consumed.EndOfSegmentEvent EndOfSegmentEventis used to notify the downstream switch tiers in tiered storage shuffle mode.EndOfSuperstepEvent Marks the end of a superstep of one particular iteration superstep.StopMode Tells if the job is stopping because of consuming all data. -
Classes in org.apache.flink.runtime.io.network.api used by org.apache.flink.runtime.io.network.api.writer Class Description StopMode Tells if the job is stopping because of consuming all data. -
Classes in org.apache.flink.runtime.io.network.api used by org.apache.flink.runtime.io.network.partition Class Description StopMode Tells if the job is stopping because of consuming all data. -
Classes in org.apache.flink.runtime.io.network.api used by org.apache.flink.runtime.io.network.partition.consumer Class Description CheckpointBarrier Checkpoint barriers are used to align checkpoints throughout the streaming topology. -
Classes in org.apache.flink.runtime.io.network.api used by org.apache.flink.runtime.io.network.partition.hybrid Class Description StopMode Tells if the job is stopping because of consuming all data. -
Classes in org.apache.flink.runtime.io.network.api used by org.apache.flink.runtime.io.network.partition.hybrid.tiered.shuffle Class Description StopMode Tells if the job is stopping because of consuming all data.