alluxio.master.file

Class ListStatusResultStream

java.lang.Object

alluxio.master.file.ListStatusResultStream

All Implemented Interfaces:

ResultStream<FileInfo>

@ThreadSafe
public class ListStatusResultStream
extends Object
implements ResultStream<FileInfo>

Used to define a single batch of listing.

Constructor Summary

Constructors

Constructor and Description
ListStatusResultStream(int batchSize, io.grpc.stub.StreamObserver<ListStatusPResponse> clientObserver) Creates a new result streamer for listStatus call.

Method Summary

Modifier and Type	Method and Description
void	complete() Used to complete the stream.
void	fail(Throwable error) Used to fail streaming with an error.
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

ListStatusResultStream

public ListStatusResultStream(int batchSize,
                              io.grpc.stub.StreamObserver<ListStatusPResponse> clientObserver)

Creates a new result streamer for listStatus call.

Parameters:

batchSize - batch size

clientObserver - client stream

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

complete

public void complete()

Used to complete the stream. It sends any remaining items and closes the underlying stream.

fail

public void fail(Throwable error)

Used to fail streaming with an error.

Parameters:

error - streaming error