public class GpfdistMessageHandler extends AbstractGpfdistMessageHandler
MessageHandler
.Constructor and Description |
---|
GpfdistMessageHandler(int port,
int flushCount,
int flushTime,
int batchTimeout,
int batchCount,
int batchPeriod,
String delimiter,
org.springframework.data.hadoop.util.net.HostInfoDiscovery hostInfoDiscovery)
Instantiates a new gpfdist message handler.
|
Modifier and Type | Method and Description |
---|---|
protected void |
doStart()
Subclasses may override this method with the start behaviour.
|
protected void |
doStop()
Subclasses may override this method with the stop behaviour.
|
protected void |
doWrite(org.springframework.messaging.Message<?> message)
Subclasses need to implement this method to handle
Message in its writer. |
protected void |
onInit() |
void |
setGreenplumLoad(GreenplumLoad greenplumLoad)
Sets the greenplum load.
|
void |
setRateInterval(int rateInterval)
Sets the rate interval.
|
void |
setSqlTaskScheduler(org.springframework.scheduling.TaskScheduler sqlTaskScheduler)
Sets the sql task scheduler.
|
getPhase, handleMessageInternal, isAutoStartup, isRunning, setAutoStartup, setPhase, start, stop, stop
configureMetrics, getActiveCount, getActiveCountLong, getComponentType, getDuration, getErrorCount, getErrorCountLong, getHandleCount, getHandleCountLong, getManagedName, getManagedType, getMaxDuration, getMeanDuration, getMinDuration, getOrder, getStandardDeviationDuration, handleMessage, isCountsEnabled, isLoggingEnabled, isStatsEnabled, reset, setCountsEnabled, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, setStatsEnabled
afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setTaskScheduler, toString
public GpfdistMessageHandler(int port, int flushCount, int flushTime, int batchTimeout, int batchCount, int batchPeriod, String delimiter, org.springframework.data.hadoop.util.net.HostInfoDiscovery hostInfoDiscovery)
port
- the portflushCount
- the flush countflushTime
- the flush timebatchTimeout
- the batch timeoutbatchCount
- the batch countbatchPeriod
- the batch perioddelimiter
- the delimiterhostInfoDiscovery
- the host info discoveryprotected void doWrite(org.springframework.messaging.Message<?> message) throws Exception
AbstractGpfdistMessageHandler
Message
in its writer.doWrite
in class AbstractGpfdistMessageHandler
message
- the message to writeException
protected void onInit() throws Exception
onInit
in class org.springframework.integration.handler.AbstractMessageHandler
Exception
protected void doStart()
AbstractGpfdistMessageHandler
AbstractGpfdistMessageHandler.lifecycleLock
.doStart
in class AbstractGpfdistMessageHandler
protected void doStop()
AbstractGpfdistMessageHandler
AbstractGpfdistMessageHandler.lifecycleLock
.doStop
in class AbstractGpfdistMessageHandler
public void setSqlTaskScheduler(org.springframework.scheduling.TaskScheduler sqlTaskScheduler)
sqlTaskScheduler
- the new sql task schedulerpublic void setGreenplumLoad(GreenplumLoad greenplumLoad)
greenplumLoad
- the new greenplum loadpublic void setRateInterval(int rateInterval)
rateInterval
- the new rate intervalCopyright © 2016 Pivotal Software, Inc.. All rights reserved.