gravitino.api.function.java_impl.JavaImpl

class gravitino.api.function.java_impl.JavaImpl(runtime: RuntimeType, class_name: str, resources: FunctionResources | None = None, properties: Dict[str, str] | None = None)

Bases: FunctionImpl

Java implementation with class name.

__init__(runtime: RuntimeType, class_name: str, resources: FunctionResources | None = None, properties: Dict[str, str] | None = None)

Create a JavaImpl instance.

Args:

runtime: The runtime of the function implementation. class_name: The fully qualified class name. resources: The resources required by the function implementation. properties: The properties of the function implementation.

Raises:

ValueError: If class_name is null or empty.

Methods

__init__(runtime, class_name[, resources, ...])

Create a JavaImpl instance.

builder()

Returns a new Builder for JavaImpl.

class_name()

Returns the fully qualified class name.

language()

Returns the implementation language.

properties()

Returns the additional properties of this implementation.

resources()

Returns the external resources required by this implementation.

runtime()

Returns the target runtime.

class Builder

Bases: object

Builder for JavaImpl.

build() JavaImpl

Builds a JavaImpl instance.

Returns:

A new JavaImpl instance.

Raises:

IllegalArgumentException: If required fields are not set.

with_class_name(class_name: str) Builder

Sets the class name.

Args:

class_name: The fully qualified class name.

Returns:

The builder instance.

with_properties(properties: Dict[str, str]) Builder

Sets the properties.

Args:

properties: The properties of the function implementation.

Returns:

The builder instance.

with_resources(resources: FunctionResources) Builder

Sets the resources.

Args:

resources: The resources required by the function implementation.

Returns:

The builder instance.

with_runtime_type(runtime: RuntimeType) Builder

Sets the runtime type.

Args:

runtime: The runtime of the function implementation.

Returns:

The builder instance.

class Language(value, names=<not given>, *values, module=None, qualname=None, type=None, start=1, boundary=None)

Bases: Enum

Supported implementation languages.

JAVA = 'JAVA'

Java implementation.

PYTHON = 'PYTHON'

Python implementation.

SQL = 'SQL'

SQL implementation.

class RuntimeType(value, names=<not given>, *values, module=None, qualname=None, type=None, start=1, boundary=None)

Bases: Enum

Supported execution runtimes for function implementations.

SPARK = 'SPARK'

Spark runtime.

TRINO = 'TRINO'

Trino runtime.

classmethod from_string(value: str) RuntimeType

Parse a runtime value from string.

Args:

value: Runtime name.

Returns:

Parsed runtime.

Raises:

ValueError: If the runtime is not supported.

static builder() Builder

Returns a new Builder for JavaImpl.

class_name() str

Returns the fully qualified class name.

language() Language

Returns the implementation language.

properties() Dict[str, str]

Returns the additional properties of this implementation.

resources() FunctionResources

Returns the external resources required by this implementation.

runtime() RuntimeType

Returns the target runtime.