@VisibleForTesting public static class KafkaShuffleFetcher.KafkaShuffleWatermark extends KafkaShuffleFetcher.KafkaShuffleElement
Modifier and Type | Method and Description |
---|---|
int |
getSubtask() |
long |
getWatermark() |
asRecord, asWatermark, isRecord, isWatermark
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.