pub enum TypeJob {
HadoopJob(HadoopJob),
SparkJob(SparkJob),
PysparkJob(PySparkJob),
HiveJob(HiveJob),
PigJob(PigJob),
SparkRJob(SparkRJob),
SparkSqlJob(SparkSqlJob),
PrestoJob(PrestoJob),
TrinoJob(TrinoJob),
}
Expand description
Required. The application/framework-specific portion of the job.
Variants§
HadoopJob(HadoopJob)
Optional. Job is a Hadoop job.
SparkJob(SparkJob)
Optional. Job is a Spark job.
PysparkJob(PySparkJob)
Optional. Job is a PySpark job.
HiveJob(HiveJob)
Optional. Job is a Hive job.
PigJob(PigJob)
Optional. Job is a Pig job.
SparkRJob(SparkRJob)
Optional. Job is a SparkR job.
SparkSqlJob(SparkSqlJob)
Optional. Job is a SparkSql job.
PrestoJob(PrestoJob)
Optional. Job is a Presto job.
TrinoJob(TrinoJob)
Optional. Job is a Trino job.
Implementations§
source§impl TypeJob
impl TypeJob
sourcepub fn merge<B>(
field: &mut Option<TypeJob>,
tag: u32,
wire_type: WireType,
buf: &mut B,
ctx: DecodeContext
) -> Result<(), DecodeError>where
B: Buf,
pub fn merge<B>(
field: &mut Option<TypeJob>,
tag: u32,
wire_type: WireType,
buf: &mut B,
ctx: DecodeContext
) -> Result<(), DecodeError>where
B: Buf,
Decodes an instance of the message from a buffer, and merges it into self.
sourcepub fn encoded_len(&self) -> usize
pub fn encoded_len(&self) -> usize
Returns the encoded length of the message without a length delimiter.
Trait Implementations§
source§impl PartialEq for TypeJob
impl PartialEq for TypeJob
impl StructuralPartialEq for TypeJob
Auto Trait Implementations§
impl Freeze for TypeJob
impl RefUnwindSafe for TypeJob
impl Send for TypeJob
impl Sync for TypeJob
impl Unpin for TypeJob
impl UnwindSafe for TypeJob
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request