@Internal public interface NullableAsyncDataInput<T> extends AvailabilityListener
AsyncDataInput
that for performance reasons returns null
from
pollNextNullable()
instead returning Optional.empty()
from
AsyncDataInput.pollNext()
.AVAILABLE
Modifier and Type | Method and Description |
---|---|
T |
pollNextNullable()
Poll the next element.
|
isAvailable, isFinished
@Nullable T pollNextNullable() throws Exception
null
will be returned if there is no data to return or
if AvailabilityListener.isFinished()
returns true. Otherwise return element
.Exception
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.