com.splicemachine.pipeline.utils

Class PipelineUtils

java.lang.Object

com.splicemachine.pipeline.utils.PipelineUtils

public class PipelineUtils
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static PreFlushHook	noOpFlushHook
static int[]	RETRY_BACKOFF

Constructor Summary

Constructors

Constructor and Description
PipelineUtils()

Method Summary

Modifier and Type	Method and Description
static java.util.Collection<KVPair>	doPartialRetry(BulkWrite bulkWrite, BulkWriteResult response, long id)
static long	getPauseTime(int tries, long pause) Get Pause time in millis (Mirrors Hbase)

Methods inherited from class java.lang.Object

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

Field Detail

RETRY_BACKOFF

public static final int[] RETRY_BACKOFF

noOpFlushHook

public static final PreFlushHook noOpFlushHook

Constructor Detail

PipelineUtils

public PipelineUtils()

Method Detail

doPartialRetry

public static java.util.Collection<KVPair> doPartialRetry(BulkWrite bulkWrite,
                                                          BulkWriteResult response,
                                                          long id)
                                                   throws java.lang.Exception

Throws:

java.lang.Exception

getPauseTime

public static long getPauseTime(int tries,
                                long pause)

Get Pause time in millis (Mirrors Hbase)

Parameters:

pause -

tries -

Returns: