org.apache.beam.runners.fnexecution

Interface FnService

All Superinterfaces:

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

All Known Subinterfaces:

ArtifactRetrievalService

All Known Implementing Classes:

BeamFileSystemArtifactRetrievalService, BeamFileSystemArtifactStagingService, FnApiControlClientPoolService, GrpcDataService, GrpcLoggingService, GrpcStateService, InMemoryJobService, LocalFileSystemArtifactRetrievalService, LocalFileSystemArtifactStagerService, ReferenceRunnerJobService, StaticGrpcProvisionService, UnsupportedArtifactRetrievalService

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

An interface sharing common behavior with services used during execution of user Fns.

Method Summary

Modifier and Type	Method and Description
void	close() .

Methods inherited from interface org.apache.beam.vendor.grpc.v1_13_1.io.grpc.BindableService

bindService

Method Detail

close

void close()
    throws java.lang.Exception

.

There should be no more calls to any service method by the time a call to 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

Throws:

java.lang.Exception