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:

java.lang.AutoCloseable, FnService, org.apache.beam.vendor.grpc.v1_13_1.io.grpc.BindableService

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)
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.stub.StreamObserver<org.apache.beam.model.fnexecution.v1.BeamFnApi.LogEntry.List>	logging(org.apache.beam.vendor.grpc.v1_13_1.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 org.apache.beam.vendor.grpc.v1_13_1.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 org.apache.beam.vendor.grpc.v1_13_1.io.grpc.stub.StreamObserver<org.apache.beam.model.fnexecution.v1.BeamFnApi.LogEntry.List> logging(org.apache.beam.vendor.grpc.v1_13_1.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