com.github.panhongan.util.kafka

类 MessageLocalWriter

java.lang.Object

com.github.panhongan.util.kafka.AbstractMessageProcessor

com.github.panhongan.util.kafka.MessageLocalWriter

所有已实现的接口:

Lifecycleable

public class MessageLocalWriter
extends AbstractMessageProcessor

构造器概要

构造器

构造器和说明
MessageLocalWriter(String data_dir, int minutes_window)
MessageLocalWriter(String data_dir, String name, int minutes_window)

方法概要

方法

限定符和类型	方法和说明
protected String	constructFileName(String topic, int partition_id)
String	getDataDir()
boolean	init()
Object	processMessage(String topic, int partition_id, List<String> msg_list)
Object	processMessage(String topic, int partition_id, String message)
void	uninit()

从类继承的方法 com.github.panhongan.util.kafka.AbstractMessageProcessor

getName, setName

从类继承的方法 java.lang.Object

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

构造器详细资料

MessageLocalWriter

public MessageLocalWriter(String data_dir,
                  int minutes_window)

MessageLocalWriter

public MessageLocalWriter(String data_dir,
                  String name,
                  int minutes_window)

方法详细资料

getDataDir

public String getDataDir()

init

public boolean init()

uninit

public void uninit()

processMessage

public Object processMessage(String topic,
                    int partition_id,
                    String message)

指定者:

processMessage 在类中 AbstractMessageProcessor

参数:

topic - : data source topic

partition_id - : data source topic partition

message - : message

返回:

Object

processMessage

public Object processMessage(String topic,
                    int partition_id,
                    List<String> msg_list)

指定者:

processMessage 在类中 AbstractMessageProcessor

参数:

topic - : data source topic

partition_id - : data source topic partition

msg_list - : message set

返回:

Object

constructFileName

protected String constructFileName(String topic,
                       int partition_id)