Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package dataflux.persister.schema;
package dataflux.persister;

public class Constants {
public static final String HBASE_QUORUM_IP = "hbase.zookeeper.quorum";
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -108,7 +108,7 @@ public boolean isOpen() {

public static void main(String[] args) {
List<WebTxnData> txnData = new ArrayList<>();
for(int indx = 1; indx < 100; indx++) {
for(int indx = 1; indx < 1000; indx++) {
WebTxnData webTxn = new WebTxnData();
webTxn.setTxnId(1);
webTxn.setClientAgent("Mozilla");
Expand Down
2 changes: 2 additions & 0 deletions dataflux-persister/src/main/resources/conf/config.properties
Original file line number Diff line number Diff line change
@@ -0,0 +1,2 @@
hbase.zookeeper.quorum=10.1.1.155
hbase.zookeeper.property.clientPort=2222
20 changes: 20 additions & 0 deletions dataflux-persister/src/main/resources/conf/log4j.properties
Original file line number Diff line number Diff line change
@@ -0,0 +1,20 @@
#log4j.debug=true

log4j.rootCategory=INFO, stdout, DRFA

# Stdout
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=%d{ISO8601} %p %c: %m%n
# Debugging pattern
#log4j.appender.stdout.layout.ConversionPattern=[%d{ISO8601}]%5p%6.6r[%t]%x - %C.%M(%F:%L) - %m%n

# File
log4j.appender.DRFA=org.apache.log4j.DailyRollingFileAppender
log4j.appender.DRFA.File=\user\hduser\dataflux\logs\persister.log
log4j.appender.DRFA.DatePattern=.yyyy-MM-dd
log4j.appender.DRFA.Append=true
log4j.appender.DRFA.layout=org.apache.log4j.PatternLayout
log4j.appender.DRFA.layout.ConversionPattern=%d{ISO8601} %p %c: %m%n
# Debugging Pattern format
#log4j.appender.DRFA.layout.ConversionPattern=%d{ISO8601} %-5p %c{2} (%F:%M(%L)) - %m%n