Packages

t

org.apache.spark.connect.proto

PipelineCommandOrBuilder

trait PipelineCommandOrBuilder extends MessageOrBuilder

Annotations
@Generated()
Linear Supertypes
MessageOrBuilder, MessageLiteOrBuilder, AnyRef, Any
Known Subclasses
PipelineCommand
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. PipelineCommandOrBuilder
  2. MessageOrBuilder
  3. MessageLiteOrBuilder
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Abstract Value Members

  1. abstract def findInitializationErrors(): List[String]
    Definition Classes
    MessageOrBuilder
  2. abstract def getAllFields(): Map[FieldDescriptor, AnyRef]
    Definition Classes
    MessageOrBuilder
  3. abstract def getCommandTypeCase(): CommandTypeCase
  4. abstract def getCreateDataflowGraph(): CreateDataflowGraph

    .spark.connect.PipelineCommand.CreateDataflowGraph create_dataflow_graph = 1;

    .spark.connect.PipelineCommand.CreateDataflowGraph create_dataflow_graph = 1;

    returns

    The createDataflowGraph.

  5. abstract def getCreateDataflowGraphOrBuilder(): CreateDataflowGraphOrBuilder

    .spark.connect.PipelineCommand.CreateDataflowGraph create_dataflow_graph = 1;

  6. abstract def getDefaultInstanceForType(): Message
    Definition Classes
    MessageOrBuilder → MessageLiteOrBuilder
  7. abstract def getDefineFlow(): DefineFlow

    .spark.connect.PipelineCommand.DefineFlow define_flow = 3;

    .spark.connect.PipelineCommand.DefineFlow define_flow = 3;

    returns

    The defineFlow.

  8. abstract def getDefineFlowOrBuilder(): DefineFlowOrBuilder

    .spark.connect.PipelineCommand.DefineFlow define_flow = 3;

  9. abstract def getDefineFlowQueryFunctionResult(): DefineFlowQueryFunctionResult

    .spark.connect.PipelineCommand.DefineFlowQueryFunctionResult define_flow_query_function_result = 8;

    .spark.connect.PipelineCommand.DefineFlowQueryFunctionResult define_flow_query_function_result = 8;

    returns

    The defineFlowQueryFunctionResult.

  10. abstract def getDefineFlowQueryFunctionResultOrBuilder(): DefineFlowQueryFunctionResultOrBuilder

    .spark.connect.PipelineCommand.DefineFlowQueryFunctionResult define_flow_query_function_result = 8;

  11. abstract def getDefineOutput(): DefineOutput

    .spark.connect.PipelineCommand.DefineOutput define_output = 2;

    .spark.connect.PipelineCommand.DefineOutput define_output = 2;

    returns

    The defineOutput.

  12. abstract def getDefineOutputOrBuilder(): DefineOutputOrBuilder

    .spark.connect.PipelineCommand.DefineOutput define_output = 2;

  13. abstract def getDefineSqlGraphElements(): DefineSqlGraphElements

    .spark.connect.PipelineCommand.DefineSqlGraphElements define_sql_graph_elements = 6;

    .spark.connect.PipelineCommand.DefineSqlGraphElements define_sql_graph_elements = 6;

    returns

    The defineSqlGraphElements.

  14. abstract def getDefineSqlGraphElementsOrBuilder(): DefineSqlGraphElementsOrBuilder

    .spark.connect.PipelineCommand.DefineSqlGraphElements define_sql_graph_elements = 6;

  15. abstract def getDescriptorForType(): Descriptor
    Definition Classes
    MessageOrBuilder
  16. abstract def getDropDataflowGraph(): DropDataflowGraph

    .spark.connect.PipelineCommand.DropDataflowGraph drop_dataflow_graph = 4;

    .spark.connect.PipelineCommand.DropDataflowGraph drop_dataflow_graph = 4;

    returns

    The dropDataflowGraph.

  17. abstract def getDropDataflowGraphOrBuilder(): DropDataflowGraphOrBuilder

    .spark.connect.PipelineCommand.DropDataflowGraph drop_dataflow_graph = 4;

  18. abstract def getExtension(): Any

    Reserved field for protocol extensions.
Used to support forward-compatibility by carrying additional command types
that are not yet defined in this version of the proto. During planning, the
engine will resolve and dispatch the concrete command contained in this field.


    Reserved field for protocol extensions.
Used to support forward-compatibility by carrying additional command types
that are not yet defined in this version of the proto. During planning, the
engine will resolve and dispatch the concrete command contained in this field.

    .google.protobuf.Any extension = 999;

    returns

    The extension.

  19. abstract def getExtensionOrBuilder(): AnyOrBuilder

    Reserved field for protocol extensions.
Used to support forward-compatibility by carrying additional command types
that are not yet defined in this version of the proto. During planning, the
engine will resolve and dispatch the concrete command contained in this field.


    Reserved field for protocol extensions.
Used to support forward-compatibility by carrying additional command types
that are not yet defined in this version of the proto. During planning, the
engine will resolve and dispatch the concrete command contained in this field.

    .google.protobuf.Any extension = 999;

  20. abstract def getField(field: FieldDescriptor): AnyRef
    Definition Classes
    MessageOrBuilder
  21. abstract def getGetQueryFunctionExecutionSignalStream(): GetQueryFunctionExecutionSignalStream

    .spark.connect.PipelineCommand.GetQueryFunctionExecutionSignalStream get_query_function_execution_signal_stream = 7;

    .spark.connect.PipelineCommand.GetQueryFunctionExecutionSignalStream get_query_function_execution_signal_stream = 7;

    returns

    The getQueryFunctionExecutionSignalStream.

  22. abstract def getGetQueryFunctionExecutionSignalStreamOrBuilder(): GetQueryFunctionExecutionSignalStreamOrBuilder

    .spark.connect.PipelineCommand.GetQueryFunctionExecutionSignalStream get_query_function_execution_signal_stream = 7;

  23. abstract def getInitializationErrorString(): String
    Definition Classes
    MessageOrBuilder
  24. abstract def getOneofFieldDescriptor(oneof: OneofDescriptor): FieldDescriptor
    Definition Classes
    MessageOrBuilder
  25. abstract def getRepeatedField(field: FieldDescriptor, index: Int): AnyRef
    Definition Classes
    MessageOrBuilder
  26. abstract def getRepeatedFieldCount(field: FieldDescriptor): Int
    Definition Classes
    MessageOrBuilder
  27. abstract def getStartRun(): StartRun

    .spark.connect.PipelineCommand.StartRun start_run = 5;

    .spark.connect.PipelineCommand.StartRun start_run = 5;

    returns

    The startRun.

  28. abstract def getStartRunOrBuilder(): StartRunOrBuilder

    .spark.connect.PipelineCommand.StartRun start_run = 5;

  29. abstract def getUnknownFields(): UnknownFieldSet
    Definition Classes
    MessageOrBuilder
  30. abstract def hasCreateDataflowGraph(): Boolean

    .spark.connect.PipelineCommand.CreateDataflowGraph create_dataflow_graph = 1;

    .spark.connect.PipelineCommand.CreateDataflowGraph create_dataflow_graph = 1;

    returns

    Whether the createDataflowGraph field is set.

  31. abstract def hasDefineFlow(): Boolean

    .spark.connect.PipelineCommand.DefineFlow define_flow = 3;

    .spark.connect.PipelineCommand.DefineFlow define_flow = 3;

    returns

    Whether the defineFlow field is set.

  32. abstract def hasDefineFlowQueryFunctionResult(): Boolean

    .spark.connect.PipelineCommand.DefineFlowQueryFunctionResult define_flow_query_function_result = 8;

    .spark.connect.PipelineCommand.DefineFlowQueryFunctionResult define_flow_query_function_result = 8;

    returns

    Whether the defineFlowQueryFunctionResult field is set.

  33. abstract def hasDefineOutput(): Boolean

    .spark.connect.PipelineCommand.DefineOutput define_output = 2;

    .spark.connect.PipelineCommand.DefineOutput define_output = 2;

    returns

    Whether the defineOutput field is set.

  34. abstract def hasDefineSqlGraphElements(): Boolean

    .spark.connect.PipelineCommand.DefineSqlGraphElements define_sql_graph_elements = 6;

    .spark.connect.PipelineCommand.DefineSqlGraphElements define_sql_graph_elements = 6;

    returns

    Whether the defineSqlGraphElements field is set.

  35. abstract def hasDropDataflowGraph(): Boolean

    .spark.connect.PipelineCommand.DropDataflowGraph drop_dataflow_graph = 4;

    .spark.connect.PipelineCommand.DropDataflowGraph drop_dataflow_graph = 4;

    returns

    Whether the dropDataflowGraph field is set.

  36. abstract def hasExtension(): Boolean

    Reserved field for protocol extensions.
Used to support forward-compatibility by carrying additional command types
that are not yet defined in this version of the proto. During planning, the
engine will resolve and dispatch the concrete command contained in this field.


    Reserved field for protocol extensions.
Used to support forward-compatibility by carrying additional command types
that are not yet defined in this version of the proto. During planning, the
engine will resolve and dispatch the concrete command contained in this field.

    .google.protobuf.Any extension = 999;

    returns

    Whether the extension field is set.

  37. abstract def hasField(field: FieldDescriptor): Boolean
    Definition Classes
    MessageOrBuilder
  38. abstract def hasGetQueryFunctionExecutionSignalStream(): Boolean

    .spark.connect.PipelineCommand.GetQueryFunctionExecutionSignalStream get_query_function_execution_signal_stream = 7;

    .spark.connect.PipelineCommand.GetQueryFunctionExecutionSignalStream get_query_function_execution_signal_stream = 7;

    returns

    Whether the getQueryFunctionExecutionSignalStream field is set.

  39. abstract def hasOneof(oneof: OneofDescriptor): Boolean
    Definition Classes
    MessageOrBuilder
  40. abstract def hasStartRun(): Boolean

    .spark.connect.PipelineCommand.StartRun start_run = 5;

    .spark.connect.PipelineCommand.StartRun start_run = 5;

    returns

    Whether the startRun field is set.

  41. abstract def isInitialized(): Boolean
    Definition Classes
    MessageLiteOrBuilder

Concrete Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
  6. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  8. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  9. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  10. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  11. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  12. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  13. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  14. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  15. def toString(): String
    Definition Classes
    AnyRef → Any
  16. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  17. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  18. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

    (Since version 9)

Inherited from MessageOrBuilder

Inherited from MessageLiteOrBuilder

Inherited from AnyRef

Inherited from Any

Ungrouped