alluxio.master.file

Class ListStatusPartialResultStream

java.lang.Object

alluxio.master.file.ListStatusPartialResultStream

All Implemented Interfaces:

ResultStream<FileInfo>

public class ListStatusPartialResultStream
extends Object
implements ResultStream<FileInfo>

Used to track the results of a call to a partial listing.

Constructor Summary

Constructors

Constructor and Description
ListStatusPartialResultStream(io.grpc.stub.StreamObserver<ListStatusPartialPResponse> observer, ListStatusContext context) Create a result stream for a partial listing.

Method Summary

Modifier and Type	Method and Description
void	complete() Called once the listing is complete, and sends the response to the client.
void	onError(Throwable t) Called if an error occurs during a partial listing.
void	submit(FileInfo item) Submits a new item to stream.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ListStatusPartialResultStream

public ListStatusPartialResultStream(io.grpc.stub.StreamObserver<ListStatusPartialPResponse> observer,
                                     ListStatusContext context)

Create a result stream for a partial listing.

Parameters:

observer - the response observer

context - the listing context

Method Detail

submit

public void submit(FileInfo item)

Description copied from interface: ResultStream

Submits a new item to stream.

Specified by:

submit in interface ResultStream<FileInfo>

Parameters:

item - the next item

onError

public void onError(Throwable t)

Called if an error occurs during a partial listing.

Parameters:

t - the error

complete

public void complete()

Called once the listing is complete, and sends the response to the client.