org.apache.beam.runners.fnexecution.logging

Class GrpcLoggingService

java.lang.Object

org.apache.beam.model.fnexecution.v1.BeamFnLoggingGrpc.BeamFnLoggingImplBase

org.apache.beam.runners.fnexecution.logging.GrpcLoggingService

All Implemented Interfaces:

io.grpc.BindableService, java.lang.AutoCloseable, FnService

public class GrpcLoggingService
extends org.apache.beam.model.fnexecution.v1.BeamFnLoggingGrpc.BeamFnLoggingImplBase
implements FnService

An implementation of the Beam Fn Logging Service over gRPC.

Method Summary

Modifier and Type	Method and Description
void	close() .
static GrpcLoggingService	forWriter(LogWriter writer)
io.grpc.stub.StreamObserver<org.apache.beam.model.fnexecution.v1.BeamFnApi.LogEntry.List>	logging(io.grpc.stub.StreamObserver<org.apache.beam.model.fnexecution.v1.BeamFnApi.LogControl> outboundObserver)

Methods inherited from class org.apache.beam.model.fnexecution.v1.BeamFnLoggingGrpc.BeamFnLoggingImplBase

bindService

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.grpc.BindableService

bindService

Method Detail

forWriter

public static GrpcLoggingService forWriter(LogWriter writer)

close

public void close()
           throws java.lang.Exception

Description copied from interface: FnService

.

There should be no more calls to any service method by the time a call to FnService.close() begins. Specifically, this means that a Server that this service is bound to should have completed a call to the Server.shutdown() method, and all future incoming calls will be rejected.

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface FnService

Throws:

java.lang.Exception

logging

public io.grpc.stub.StreamObserver<org.apache.beam.model.fnexecution.v1.BeamFnApi.LogEntry.List> logging(io.grpc.stub.StreamObserver<org.apache.beam.model.fnexecution.v1.BeamFnApi.LogControl> outboundObserver)

Overrides:

logging in class org.apache.beam.model.fnexecution.v1.BeamFnLoggingGrpc.BeamFnLoggingImplBase