ComputeJob (venice API)

All Superinterfaces:: AutoCloseable, Closeable

All Known Implementing Classes:: AbstractDataWriterSparkJob, DataWriterComputeJob, DataWriterMRJob, DataWriterSparkJob

public interface ComputeJob extends Closeable

An interface to abstract executing and monitoring a compute job running on any batch compute engine

Nested Class Summary

Nested Classes

Modifier and Type

Interface

Description

static enum

ComputeJob.Status
Method Summary

Modifier and Type

Method

Description

default void

close()

void

configure(VeniceProperties properties)

Throwable

getFailureReason()

ComputeJob.Status

getStatus()

default void

kill()

void

runJob()

Method Details
- configure
  
  void configure(VeniceProperties properties)
- runJob
  
  void runJob()
- getStatus
  
  ComputeJob.Status getStatus()
- getFailureReason
  
  Throwable getFailureReason()
- kill
  
  default void kill()
- close
  
  default void close() throws IOException
  
  Specified by:
  
  close in interface AutoCloseable
  
  Specified by:
  
  close in interface Closeable
  
  Throws:
  
  IOException