trait UDFWorkerPropertiesOrBuilder extends MessageOrBuilder
Ordering
- Alphabetic
- By Inheritance
Inherited
- UDFWorkerPropertiesOrBuilder
- MessageOrBuilder
- MessageLiteOrBuilder
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Abstract Value Members
- abstract def findInitializationErrors(): List[String]
- Definition Classes
- MessageOrBuilder
- abstract def getAllFields(): Map[FieldDescriptor, AnyRef]
- Definition Classes
- MessageOrBuilder
- abstract def getConnection(): WorkerConnection
The connection this [[DirectWorker]] supports. Note that a single connection is sufficient to run multiple UDFs and (gRPC) services. On [[DirectWorker]] creation, connection information is passed to the callable as a string parameter. The string format depends on the [[WorkerConnection]]: For example, when using TCP, the callable argument will be: --connection PORT Here is a concrete example --connection 8080 For the format of each specific transport type, see the comments below. (Required)
The connection this [[DirectWorker]] supports. Note that a single connection is sufficient to run multiple UDFs and (gRPC) services. On [[DirectWorker]] creation, connection information is passed to the callable as a string parameter. The string format depends on the [[WorkerConnection]]: For example, when using TCP, the callable argument will be: --connection PORT Here is a concrete example --connection 8080 For the format of each specific transport type, see the comments below. (Required)
.org.apache.spark.udf.worker.WorkerConnection connection = 3;- returns
The connection.
- abstract def getConnectionOrBuilder(): WorkerConnectionOrBuilder
The connection this [[DirectWorker]] supports. Note that a single connection is sufficient to run multiple UDFs and (gRPC) services. On [[DirectWorker]] creation, connection information is passed to the callable as a string parameter. The string format depends on the [[WorkerConnection]]: For example, when using TCP, the callable argument will be: --connection PORT Here is a concrete example --connection 8080 For the format of each specific transport type, see the comments below. (Required)
The connection this [[DirectWorker]] supports. Note that a single connection is sufficient to run multiple UDFs and (gRPC) services. On [[DirectWorker]] creation, connection information is passed to the callable as a string parameter. The string format depends on the [[WorkerConnection]]: For example, when using TCP, the callable argument will be: --connection PORT Here is a concrete example --connection 8080 For the format of each specific transport type, see the comments below. (Required)
.org.apache.spark.udf.worker.WorkerConnection connection = 3; - abstract def getDefaultInstanceForType(): Message
- Definition Classes
- MessageOrBuilder → MessageLiteOrBuilder
- abstract def getDescriptorForType(): Descriptor
- Definition Classes
- MessageOrBuilder
- abstract def getField(field: FieldDescriptor): AnyRef
- Definition Classes
- MessageOrBuilder
- abstract def getGracefulTerminationTimeoutMs(): Int
Used for graceful engine-initiated termination signaled via SIGTERM. After this time, the worker process should have terminated itself. Otherwise, the process will be forcefully killed using SIGKILL. The engine will use this timeout, if it does not exceed an engine-configurable maximum time (e.g. 30 seconds). (Optional)
Used for graceful engine-initiated termination signaled via SIGTERM. After this time, the worker process should have terminated itself. Otherwise, the process will be forcefully killed using SIGKILL. The engine will use this timeout, if it does not exceed an engine-configurable maximum time (e.g. 30 seconds). (Optional)
optional int32 graceful_termination_timeout_ms = 2;- returns
The gracefulTerminationTimeoutMs.
- abstract def getInitializationErrorString(): String
- Definition Classes
- MessageOrBuilder
- abstract def getInitializationTimeoutMs(): Int
Maximum amount of time to wait until the worker can accept connections. The engine will use this timeout, if it does not exceed an engine-configurable maximum time (e.g. 30 seconds). (Optional)
Maximum amount of time to wait until the worker can accept connections. The engine will use this timeout, if it does not exceed an engine-configurable maximum time (e.g. 30 seconds). (Optional)
optional int32 initialization_timeout_ms = 1;- returns
The initializationTimeoutMs.
- abstract def getOneofFieldDescriptor(oneof: OneofDescriptor): FieldDescriptor
- Definition Classes
- MessageOrBuilder
- abstract def getRepeatedField(field: FieldDescriptor, index: Int): AnyRef
- Definition Classes
- MessageOrBuilder
- abstract def getRepeatedFieldCount(field: FieldDescriptor): Int
- Definition Classes
- MessageOrBuilder
- abstract def getUnknownFields(): UnknownFieldSet
- Definition Classes
- MessageOrBuilder
- abstract def hasConnection(): Boolean
The connection this [[DirectWorker]] supports. Note that a single connection is sufficient to run multiple UDFs and (gRPC) services. On [[DirectWorker]] creation, connection information is passed to the callable as a string parameter. The string format depends on the [[WorkerConnection]]: For example, when using TCP, the callable argument will be: --connection PORT Here is a concrete example --connection 8080 For the format of each specific transport type, see the comments below. (Required)
The connection this [[DirectWorker]] supports. Note that a single connection is sufficient to run multiple UDFs and (gRPC) services. On [[DirectWorker]] creation, connection information is passed to the callable as a string parameter. The string format depends on the [[WorkerConnection]]: For example, when using TCP, the callable argument will be: --connection PORT Here is a concrete example --connection 8080 For the format of each specific transport type, see the comments below. (Required)
.org.apache.spark.udf.worker.WorkerConnection connection = 3;- returns
Whether the connection field is set.
- abstract def hasField(field: FieldDescriptor): Boolean
- Definition Classes
- MessageOrBuilder
- abstract def hasGracefulTerminationTimeoutMs(): Boolean
Used for graceful engine-initiated termination signaled via SIGTERM. After this time, the worker process should have terminated itself. Otherwise, the process will be forcefully killed using SIGKILL. The engine will use this timeout, if it does not exceed an engine-configurable maximum time (e.g. 30 seconds). (Optional)
Used for graceful engine-initiated termination signaled via SIGTERM. After this time, the worker process should have terminated itself. Otherwise, the process will be forcefully killed using SIGKILL. The engine will use this timeout, if it does not exceed an engine-configurable maximum time (e.g. 30 seconds). (Optional)
optional int32 graceful_termination_timeout_ms = 2;- returns
Whether the gracefulTerminationTimeoutMs field is set.
- abstract def hasInitializationTimeoutMs(): Boolean
Maximum amount of time to wait until the worker can accept connections. The engine will use this timeout, if it does not exceed an engine-configurable maximum time (e.g. 30 seconds). (Optional)
Maximum amount of time to wait until the worker can accept connections. The engine will use this timeout, if it does not exceed an engine-configurable maximum time (e.g. 30 seconds). (Optional)
optional int32 initialization_timeout_ms = 1;- returns
Whether the initializationTimeoutMs field is set.
- abstract def hasOneof(oneof: OneofDescriptor): Boolean
- Definition Classes
- MessageOrBuilder
- abstract def isInitialized(): Boolean
- Definition Classes
- MessageLiteOrBuilder
Concrete Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)