com.github.hackerwin7.jlib.utils.executors

Class ZkCheckpointMagpieJob

java.lang.Object

com.github.hackerwin7.jlib.utils.executors.ZkCheckpointMagpieJob

public class ZkCheckpointMagpieJob
extends Object

set zk checkpoint to tracker and parser Created by fff on 10/28/15.

Field Summary

Fields

Modifier and Type	Field and Description
static String	CHECKPOINT_PATH
static String	JOB_LIST
static String	SET_CMD
static String	SHELL_CONF

Constructor Summary

Constructors

Constructor and Description
ZkCheckpointMagpieJob()

Method Summary

Modifier and Type	Method and Description
static void	execute(ZkClient zk, String jobId, String cmd, String val)
static boolean	isTracker(String jobId)
static void	main(String[] args)
static void	set(ZkClient zk, String jobId, String val)
static void	verify(ZkClient zk, String jobId)

Methods inherited from class java.lang.Object

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

Field Detail

JOB_LIST

public static final String JOB_LIST

See Also:

Constant Field Values

SHELL_CONF

public static final String SHELL_CONF

See Also:

Constant Field Values

SET_CMD

public static final String SET_CMD

See Also:

Constant Field Values

CHECKPOINT_PATH

public static final String CHECKPOINT_PATH

See Also:

Constant Field Values

Constructor Detail

ZkCheckpointMagpieJob

public ZkCheckpointMagpieJob()

Method Detail

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception

execute

public static void execute(ZkClient zk,
                           String jobId,
                           String cmd,
                           String val)
                    throws Exception

Throws:

Exception

set

public static void set(ZkClient zk,
                       String jobId,
                       String val)
                throws Exception

Throws:

Exception

isTracker

public static boolean isTracker(String jobId)
                         throws Exception

Throws:

Exception

verify

public static void verify(ZkClient zk,
                          String jobId)
                   throws Exception

Throws:

Exception