@VisibleForTesting public abstract static class KafkaShuffleFetcher.KafkaShuffleElement extends Object
Constructor and Description |
---|
KafkaShuffleElement() |
Modifier and Type | Method and Description |
---|---|
<T> KafkaShuffleFetcher.KafkaShuffleRecord<T> |
asRecord() |
KafkaShuffleFetcher.KafkaShuffleWatermark |
asWatermark() |
boolean |
isRecord() |
boolean |
isWatermark() |
public boolean isRecord()
public boolean isWatermark()
public <T> KafkaShuffleFetcher.KafkaShuffleRecord<T> asRecord()
public KafkaShuffleFetcher.KafkaShuffleWatermark asWatermark()
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.