org.apache.beam.sdk.fn.stream

Class StreamObserverFactory

java.lang.Object

org.apache.beam.sdk.fn.stream.StreamObserverFactory

public abstract class StreamObserverFactory
extends java.lang.Object

Creates factories which determine an underlying StreamObserver implementation to use in to interact with fn execution APIs.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	StreamObserverFactory.StreamObserverClientFactory<RequestT,ResponseT> A factory which creates StreamObservers based on the input stream observer.

Constructor Summary

Constructors

Constructor and Description
StreamObserverFactory()

Method Summary

Modifier and Type	Method and Description
static StreamObserverFactory	buffered(java.util.concurrent.ExecutorService executorService) Create a buffering StreamObserverFactory with the specified ExecutorService and the default buffer size.
static StreamObserverFactory	buffered(java.util.concurrent.ExecutorService executorService, int bufferSize) Create a buffering StreamObserverFactory with the specified ExecutorService and buffer size.
static StreamObserverFactory	direct() Create the default StreamObserverFactory.
abstract <ReqT,RespT> io.grpc.stub.StreamObserver<RespT>	from(StreamObserverFactory.StreamObserverClientFactory<ReqT,RespT> clientFactory, io.grpc.stub.StreamObserver<ReqT> responseObserver)

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamObserverFactory

public StreamObserverFactory()

Method Detail

buffered

public static StreamObserverFactory buffered(java.util.concurrent.ExecutorService executorService)

Create a buffering StreamObserverFactory with the specified ExecutorService and the default buffer size.

buffered

public static StreamObserverFactory buffered(java.util.concurrent.ExecutorService executorService,
                                             int bufferSize)

Create a buffering StreamObserverFactory with the specified ExecutorService and buffer size.

direct

public static StreamObserverFactory direct()

Create the default StreamObserverFactory.

from

public abstract <ReqT,RespT> io.grpc.stub.StreamObserver<RespT> from(StreamObserverFactory.StreamObserverClientFactory<ReqT,RespT> clientFactory,
                                                                     io.grpc.stub.StreamObserver<ReqT> responseObserver)