@Internal public interface StreamInputProcessor extends AvailabilityProvider, Closeable
StreamTask
.AvailabilityProvider.AvailabilityHelper
AVAILABLE
Modifier and Type | Method and Description |
---|---|
InputStatus |
processInput() |
getAvailableFuture, isApproximatelyAvailable, isAvailable
InputStatus processInput() throws Exception
AvailabilityProvider.getAvailableFuture()
.Exception
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.