com.google.api.services.dataproc.model

Class FlinkJob

java.lang.Object

java.util.AbstractMap<String,Object>

com.google.api.client.util.GenericData

com.google.api.client.json.GenericJson

com.google.api.services.dataproc.model.FlinkJob

All Implemented Interfaces:

Cloneable, Map<String,Object>

public final class FlinkJob
extends com.google.api.client.json.GenericJson

A Dataproc job for running Apache Flink applications on YARN.

This is the Java data model class that specifies how to parse/serialize into the JSON that is transmitted over HTTP when working with the Cloud Dataproc API. For a detailed explanation see: https://developers.google.com/api-client-library/java/google-http-java-client/json

Author:

Google, Inc.

Nested Class Summary

Nested classes/interfaces inherited from class com.google.api.client.util.GenericData

com.google.api.client.util.GenericData.Flags

Nested classes/interfaces inherited from class java.util.AbstractMap

AbstractMap.SimpleEntry<K,V>, AbstractMap.SimpleImmutableEntry<K,V>

Nested classes/interfaces inherited from interface java.util.Map

Map.Entry<K,V>

Constructor Summary

Constructors

Constructor and Description
FlinkJob()

Method Summary

Modifier and Type	Method and Description
FlinkJob	clone()
List<String>	getArgs() Optional.
List<String>	getJarFileUris() Optional.
LoggingConfig	getLoggingConfig() Optional.
String	getMainClass() The name of the driver's main class.
String	getMainJarFileUri() The HCFS URI of the jar file that contains the main class.
Map<String,String>	getProperties() Optional.
String	getSavepointUri() Optional.
FlinkJob	set(String fieldName, Object value)
FlinkJob	setArgs(List<String> args) Optional.
FlinkJob	setJarFileUris(List<String> jarFileUris) Optional.
FlinkJob	setLoggingConfig(LoggingConfig loggingConfig) Optional.
FlinkJob	setMainClass(String mainClass) The name of the driver's main class.
FlinkJob	setMainJarFileUri(String mainJarFileUri) The HCFS URI of the jar file that contains the main class.
FlinkJob	setProperties(Map<String,String> properties) Optional.
FlinkJob	setSavepointUri(String savepointUri) Optional.

Methods inherited from class com.google.api.client.json.GenericJson

getFactory, setFactory, toPrettyString, toString

Methods inherited from class com.google.api.client.util.GenericData

entrySet, equals, get, getClassInfo, getUnknownKeys, hashCode, put, putAll, remove, setUnknownKeys

Methods inherited from class java.util.AbstractMap

clear, containsKey, containsValue, isEmpty, keySet, size, values

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.Map

compute, computeIfAbsent, computeIfPresent, forEach, getOrDefault, merge, putIfAbsent, remove, replace, replace, replaceAll

Constructor Detail

FlinkJob

public FlinkJob()

Method Detail

getArgs

public List<String> getArgs()

Optional. The arguments to pass to the driver. Do not include arguments, such as --conf, that can be set as job properties, since a collision might occur that causes an incorrect job submission.

Returns:

value or null for none

setArgs

public FlinkJob setArgs(List<String> args)

Optional. The arguments to pass to the driver. Do not include arguments, such as --conf, that can be set as job properties, since a collision might occur that causes an incorrect job submission.

Parameters:

args - args or null for none

getJarFileUris

public List<String> getJarFileUris()

Optional. HCFS URIs of jar files to add to the CLASSPATHs of the Flink driver and tasks.

Returns:

value or null for none

setJarFileUris

public FlinkJob setJarFileUris(List<String> jarFileUris)

Optional. HCFS URIs of jar files to add to the CLASSPATHs of the Flink driver and tasks.

Parameters:

jarFileUris - jarFileUris or null for none

getLoggingConfig

public LoggingConfig getLoggingConfig()

Optional. The runtime log config for job execution.

Returns:

value or null for none

setLoggingConfig

public FlinkJob setLoggingConfig(LoggingConfig loggingConfig)

Optional. The runtime log config for job execution.

Parameters:

loggingConfig - loggingConfig or null for none

getMainClass

public String getMainClass()

The name of the driver's main class. The jar file that contains the class must be in the default CLASSPATH or specified in jarFileUris.

Returns:

value or null for none

setMainClass

public FlinkJob setMainClass(String mainClass)

The name of the driver's main class. The jar file that contains the class must be in the default CLASSPATH or specified in jarFileUris.

Parameters:

mainClass - mainClass or null for none

getMainJarFileUri

public String getMainJarFileUri()

The HCFS URI of the jar file that contains the main class.

Returns:

value or null for none

setMainJarFileUri

public FlinkJob setMainJarFileUri(String mainJarFileUri)

The HCFS URI of the jar file that contains the main class.

Parameters:

mainJarFileUri - mainJarFileUri or null for none

getProperties

public Map<String,String> getProperties()

Optional. A mapping of property names to values, used to configure Flink. Properties that conflict with values set by the Dataproc API might beoverwritten. Can include properties set in/etc/flink/conf/flink-defaults.conf and classes in user code.

Returns:

value or null for none

setProperties

public FlinkJob setProperties(Map<String,String> properties)

Optional. A mapping of property names to values, used to configure Flink. Properties that conflict with values set by the Dataproc API might beoverwritten. Can include properties set in/etc/flink/conf/flink-defaults.conf and classes in user code.

Parameters:

properties - properties or null for none

getSavepointUri

public String getSavepointUri()

Optional. HCFS URI of the savepoint, which contains the last saved progress for starting the current job.

Returns:

value or null for none

setSavepointUri

public FlinkJob setSavepointUri(String savepointUri)

Optional. HCFS URI of the savepoint, which contains the last saved progress for starting the current job.

Parameters:

savepointUri - savepointUri or null for none

set

public FlinkJob set(String fieldName,
                    Object value)

Overrides:

set in class com.google.api.client.json.GenericJson

clone

public FlinkJob clone()

Overrides:

clone in class com.google.api.client.json.GenericJson