Hi all,
I am planning on modifying AbstractProcessor to have 2 additional methods:
Public String getTableName
Public String getColumnFamily
This allows HBaseWriter to validate the output schema and add data to
different Htable. This should have no impact to existing demux.
Another approach is to use annotation and insert annotation to existing
parser class like:
Public class HadoopLogProcessor extends Abstract Processor {
@Table
public static final String recordType = ³HadoopLog²;
@ColumnFamily
public static final String nameNodeType = ³NameNode²;
@ColumnFamily
public static final String dataNodeType = ³DataNode²;
...
}
Which method makes more sense?
Regards,
Eric