public class HdfsDataStoreMessageHandler extends HdfsStoreMessageHandler
| コンストラクターと説明 |
|---|
HdfsDataStoreMessageHandler(org.springframework.data.hadoop.store.DataStoreWriter<java.lang.String> storeWriter) 新しい HDFs データストアメッセージハンドラーをインスタンス化します。 |
| 修飾子と型 | メソッドと説明 |
|---|---|
protected void | doStop() サブクラスは、停止動作でこのメソッドをオーバーライドできます。 |
protected void | doWrite(org.springframework.messaging.Message<?> message) サブクラスは、そのライターで Message を処理するためにこのメソッドを実装する必要があります。 |
protected void | onInit() |
doStart, getPhase, handleMessageInternal, isAutoStartup, isRunning, setAutoStartup, setPhase, start, stop, stopconfigureMetrics, 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, setStatsEnabledafterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setTaskScheduler, toStringpublic HdfsDataStoreMessageHandler(org.springframework.data.hadoop.store.DataStoreWriter<java.lang.String> storeWriter)
storeWriter - ストアライター protected void onInit()
throws java.lang.Exceptionorg.springframework.integration.handler.AbstractMessageHandler の onInit java.lang.Exceptionprotected void doStop()
HdfsStoreMessageHandlerHdfsStoreMessageHandler.lifecycleLock を保持している間に呼び出されます。HdfsStoreMessageHandler の doStop protected void doWrite(org.springframework.messaging.Message<?> message)
throws java.lang.ExceptionHdfsStoreMessageHandlerMessage を処理するためにこのメソッドを実装する必要があります。HdfsStoreMessageHandler の doWrite message - 書き込むメッセージ java.lang.Exception