Packages

package planner

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Type Members

  1. class PythonStreamingQueryListener extends StreamingQueryListener with Logging

    A helper class for handling StreamingQueryListener related functionality in Spark Connect.

    A helper class for handling StreamingQueryListener related functionality in Spark Connect. Each instance of this class starts a python process, inside which has the python handling logic. When a new event is received, it is serialized to json, and passed to the python process.

  2. class SparkConnectPlanner extends Logging
  3. class SparkConnectStreamingQueryListenerHandler extends Logging

    Handle long-running streaming query listener events.

Value Members

  1. object InvalidInputErrors
  2. object LiteralExpressionProtoConverter
  3. object SaveModeConverter

    Helper class for conversions between SaveMode and proto.WriteOperation.SaveMode.

  4. object StreamingForeachBatchHelper extends Logging

    A helper class for handling ForeachBatch related functionality in Spark Connect servers

  5. object TableSaveMethodConverter

    Helper class for conversions between save table method string and proto.WriteOperation.SaveTable.TableSaveMethod.

Ungrouped