pysail.spark.SparkConnectServer¶
- classpysail.spark.SparkConnectServer(ip:str='127.0.0.1', port:int=0)¶
The Spark Connect server that uses Sail as the computation engine.
- __init__(ip:str='127.0.0.1', port:int=0) → None¶
Create a new Spark Connect server. By default, the server will bind to localhost on a random port.
- Parameters:
ip – The IP address to bind the server to.
port – The port to bind the server to.
Methods
- init_telemetry() → None¶
Initialize OpenTelemetry for the server.
- start(*, background=True) → None¶
Start the server.
- Parameters:
background – Whether to start the server in a background thread.
- stop() → None¶
Stop the server.
Attributes
- listening_address¶
The address that the server is listening on, or
Noneif the server is not running. The address is a tuple of the IP address and port.
- running¶
Whether the server is running.