com.google.cloud.dataflow.sdk.runners.worker.logging

Class DataflowWorkerLoggingMDC

java.lang.Object

com.google.cloud.dataflow.sdk.runners.worker.logging.DataflowWorkerLoggingMDC

public class DataflowWorkerLoggingMDC
extends Object

Mapped diagnostic context for the Dataflow worker.

Constructor Summary

Constructors

Constructor and Description
DataflowWorkerLoggingMDC()

Method Summary

Modifier and Type	Method and Description
static String	getJobId() Gets the Job ID of the current thread.
static String	getStageName() Gets the Stage Name of the current thread.
static String	getStepName() Gets the Step Name of the current thread.
static String	getWorkerId() Gets the Worker ID of the current thread.
static String	getWorkId() Gets the Work ID of the current thread.
static void	setJobId(String newJobId) Sets the Job ID of the current thread, which will be inherited by child threads.
static void	setStageName(String newStageName) Sets the Stage Name of the current thread, which will be inherited by child threads.
static void	setStepName(String newStepName) Sets the Step Name of the current thread, which will be inherited by child threads.
static void	setWorkerId(String newWorkerId) Sets the Worker ID of the current thread, which will be inherited by child threads.
static void	setWorkId(String newWorkId) Sets the Work ID of the current thread, which will be inherited by child threads.

Methods inherited from class java.lang.Object

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

Constructor Detail

DataflowWorkerLoggingMDC

public DataflowWorkerLoggingMDC()

Method Detail

setJobId

public static void setJobId(String newJobId)

Sets the Job ID of the current thread, which will be inherited by child threads.

setStageName

public static void setStageName(String newStageName)

Sets the Stage Name of the current thread, which will be inherited by child threads.

setStepName

public static void setStepName(String newStepName)

Sets the Step Name of the current thread, which will be inherited by child threads.

setWorkerId

public static void setWorkerId(String newWorkerId)

Sets the Worker ID of the current thread, which will be inherited by child threads.

setWorkId

public static void setWorkId(String newWorkId)

Sets the Work ID of the current thread, which will be inherited by child threads.

getJobId

public static String getJobId()

Gets the Job ID of the current thread.

getStageName

public static String getStageName()

Gets the Stage Name of the current thread.

getStepName

public static String getStepName()

Gets the Step Name of the current thread.

getWorkerId

public static String getWorkerId()

Gets the Worker ID of the current thread.

getWorkId

public static String getWorkId()

Gets the Work ID of the current thread.