Package com.hazelcast.jet

Class JobStateSnapshot

java.lang.Object

com.hazelcast.jet.JobStateSnapshot

public final class JobStateSnapshot
extends Object

A handle to an exported state snapshot created using Job.exportSnapshot(String).

Since:

Jet 3.0

Constructor Summary

Constructors

Constructor	Description
JobStateSnapshot(HazelcastInstance instance, String name, com.hazelcast.jet.impl.SnapshotValidationRecord record)	This constructor is a private API, use JetService.getJobStateSnapshot(String) instead.

Method Summary

Modifier and Type	Method	Description
long	creationTime()	Returns the time the snapshot was created.
String	dagJsonString()	Returns the JSON representation of the DAG of the job this snapshot was created from.
void	destroy()	Destroy the underlying distributed object.
long	jobId()	Returns the job ID of the job the snapshot was originally exported from.
String	jobName()	Returns the job name of the job the snapshot was originally exported from.
String	name()	Returns the snapshot name.
long	payloadSize()	Returns the size in bytes of the payload data of the state snapshot.

Methods inherited from class java.lang.Object

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

Constructor Details

JobStateSnapshot

@PrivateApi
public JobStateSnapshot(@Nonnull
 HazelcastInstance instance,
 @Nonnull
 String name,
 @Nonnull
 com.hazelcast.jet.impl.SnapshotValidationRecord record)

This constructor is a private API, use JetService.getJobStateSnapshot(String) instead.

Method Details

name

@Nonnull
public String name()

Returns the snapshot name. This is the name that was given to Job.exportSnapshot(String).

creationTime

public long creationTime()

Returns the time the snapshot was created.

jobId

public long jobId()

Returns the job ID of the job the snapshot was originally exported from.

jobName

@Nullable
public String jobName()

Returns the job name of the job the snapshot was originally exported from.

payloadSize

public long payloadSize()

Returns the size in bytes of the payload data of the state snapshot. Doesn't include storage overhead and especially doesn't account for backup copies.

dagJsonString

@Nonnull
public String dagJsonString()

Returns the JSON representation of the DAG of the job this snapshot was created from.

destroy

public void destroy()

Destroy the underlying distributed object.