Package org.springframework.cloud.dataflow.server.repository

Class JdbcDataflowTaskExecutionMetadataDao

java.lang.Object

org.springframework.cloud.dataflow.server.repository.JdbcDataflowTaskExecutionMetadataDao

All Implemented Interfaces:

DataflowTaskExecutionMetadataDao

public class JdbcDataflowTaskExecutionMetadataDao
extends Object
implements DataflowTaskExecutionMetadataDao

JDBC implementation for the DataflowTaskExecutionMetadataDao

Since:

2.3

Author:

Michael Minella, Corneil du Plessis

See Also:

• DataflowTaskExecutionMetadataDao

Constructor Summary

Constructors

Constructor	Description
JdbcDataflowTaskExecutionMetadataDao(DataSource dataSource, DataFieldMaxValueIncrementer incrementer, String prefix)

Method Summary

Modifier and Type	Method	Description
int	deleteManifestsByTaskExecutionIds(Set<Long> taskExecutionIds)	Deletes the task manifest records associated with the collection of task execution ids provided.
TaskManifest	findManifestById(Long id)	Returns the manifest for the given execution id.
Map<Long,TaskManifest>	findManifestByIds(Set<Long> ids)	Returns a collection of manifests mapped by id for the supplied ids.
TaskManifest	getLatestManifest(String taskName)	Returns the manifest for the most recently launched instance of the task name requested.
void	save(org.springframework.cloud.task.repository.TaskExecution taskExecution, TaskManifest manifest)	Saves a TaskManifest related to the supplied TaskExecution

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

JdbcDataflowTaskExecutionMetadataDao

public JdbcDataflowTaskExecutionMetadataDao(DataSource dataSource,
 DataFieldMaxValueIncrementer incrementer,
 String prefix)

Method Details

save

public void save(org.springframework.cloud.task.repository.TaskExecution taskExecution,
 TaskManifest manifest)

Description copied from interface: DataflowTaskExecutionMetadataDao

Saves a TaskManifest related to the supplied TaskExecution

Specified by:

save in interface DataflowTaskExecutionMetadataDao

Parameters:

taskExecution - execution this manifest is associated with

manifest - manifest

getLatestManifest

public TaskManifest getLatestManifest(String taskName)

Description copied from interface: DataflowTaskExecutionMetadataDao

Returns the manifest for the most recently launched instance of the task name requested.

Specified by:

getLatestManifest in interface DataflowTaskExecutionMetadataDao

Parameters:

taskName - name of task defintion

Returns:

TaskManifest

findManifestById

public TaskManifest findManifestById(Long id)

Description copied from interface: DataflowTaskExecutionMetadataDao

Returns the manifest for the given execution id.

Specified by:

findManifestById in interface DataflowTaskExecutionMetadataDao

Parameters:

id - execution id

Returns:

TaskManifest

findManifestByIds

public Map<Long,TaskManifest> findManifestByIds(Set<Long> ids)

Description copied from interface: DataflowTaskExecutionMetadataDao

Returns a collection of manifests mapped by id for the supplied ids.

Specified by:

findManifestByIds in interface DataflowTaskExecutionMetadataDao

Parameters:

ids - list of task execution ids.

Returns:

map of manifests with id as key.

deleteManifestsByTaskExecutionIds

public int deleteManifestsByTaskExecutionIds(Set<Long> taskExecutionIds)

Description copied from interface: DataflowTaskExecutionMetadataDao

Deletes the task manifest records associated with the collection of task execution ids provided.

Specified by:

deleteManifestsByTaskExecutionIds in interface DataflowTaskExecutionMetadataDao

Parameters:

taskExecutionIds - collection of ids to delete the manifests for

Returns:

number of manifests deleted