|
@@ -183,7 +183,7 @@ public class TestHBaseStorageFlowRun {
|
|
.getEntityMinStartTime(minStartTs);
|
|
.getEntityMinStartTime(minStartTs);
|
|
|
|
|
|
try {
|
|
try {
|
|
- hbi = new HBaseTimelineWriterImpl(c1);
|
|
|
|
|
|
+ hbi = new HBaseTimelineWriterImpl();
|
|
hbi.init(c1);
|
|
hbi.init(c1);
|
|
hbi.write(cluster, user, flow, flowVersion, runid, appName, te);
|
|
hbi.write(cluster, user, flow, flowVersion, runid, appName, te);
|
|
|
|
|
|
@@ -289,7 +289,7 @@ public class TestHBaseStorageFlowRun {
|
|
HBaseTimelineWriterImpl hbi = null;
|
|
HBaseTimelineWriterImpl hbi = null;
|
|
Configuration c1 = util.getConfiguration();
|
|
Configuration c1 = util.getConfiguration();
|
|
try {
|
|
try {
|
|
- hbi = new HBaseTimelineWriterImpl(c1);
|
|
|
|
|
|
+ hbi = new HBaseTimelineWriterImpl();
|
|
hbi.init(c1);
|
|
hbi.init(c1);
|
|
String appName = "application_11111111111111_1111";
|
|
String appName = "application_11111111111111_1111";
|
|
hbi.write(cluster, user, flow, flowVersion, runid, appName, te);
|
|
hbi.write(cluster, user, flow, flowVersion, runid, appName, te);
|
|
@@ -558,7 +558,7 @@ public class TestHBaseStorageFlowRun {
|
|
HBaseTimelineWriterImpl hbi = null;
|
|
HBaseTimelineWriterImpl hbi = null;
|
|
Configuration c1 = util.getConfiguration();
|
|
Configuration c1 = util.getConfiguration();
|
|
try {
|
|
try {
|
|
- hbi = new HBaseTimelineWriterImpl(c1);
|
|
|
|
|
|
+ hbi = new HBaseTimelineWriterImpl();
|
|
hbi.init(c1);
|
|
hbi.init(c1);
|
|
String appName = "application_11111111111111_1111";
|
|
String appName = "application_11111111111111_1111";
|
|
hbi.write(cluster, user, flow, flowVersion, 1002345678919L, appName, te);
|
|
hbi.write(cluster, user, flow, flowVersion, 1002345678919L, appName, te);
|
|
@@ -643,7 +643,7 @@ public class TestHBaseStorageFlowRun {
|
|
HBaseTimelineWriterImpl hbi = null;
|
|
HBaseTimelineWriterImpl hbi = null;
|
|
Configuration c1 = util.getConfiguration();
|
|
Configuration c1 = util.getConfiguration();
|
|
try {
|
|
try {
|
|
- hbi = new HBaseTimelineWriterImpl(c1);
|
|
|
|
|
|
+ hbi = new HBaseTimelineWriterImpl();
|
|
hbi.init(c1);
|
|
hbi.init(c1);
|
|
String appName = "application_11111111111111_1111";
|
|
String appName = "application_11111111111111_1111";
|
|
hbi.write(cluster, user, flow, flowVersion, runid, appName, te);
|
|
hbi.write(cluster, user, flow, flowVersion, runid, appName, te);
|
|
@@ -736,7 +736,7 @@ public class TestHBaseStorageFlowRun {
|
|
TimelineEntity entityApp1 = null;
|
|
TimelineEntity entityApp1 = null;
|
|
TimelineEntity entityApp2 = null;
|
|
TimelineEntity entityApp2 = null;
|
|
try {
|
|
try {
|
|
- hbi = new HBaseTimelineWriterImpl(c1);
|
|
|
|
|
|
+ hbi = new HBaseTimelineWriterImpl();
|
|
hbi.init(c1);
|
|
hbi.init(c1);
|
|
|
|
|
|
for (int i = start; i < count; i++) {
|
|
for (int i = start; i < count; i++) {
|
|
@@ -825,7 +825,7 @@ public class TestHBaseStorageFlowRun {
|
|
HBaseTimelineWriterImpl hbi = null;
|
|
HBaseTimelineWriterImpl hbi = null;
|
|
Configuration c1 = util.getConfiguration();
|
|
Configuration c1 = util.getConfiguration();
|
|
try {
|
|
try {
|
|
- hbi = new HBaseTimelineWriterImpl(c1);
|
|
|
|
|
|
+ hbi = new HBaseTimelineWriterImpl();
|
|
hbi.init(c1);
|
|
hbi.init(c1);
|
|
hbi.write(cluster, user, flow, "CF7022C10F1354", 1002345678919L,
|
|
hbi.write(cluster, user, flow, "CF7022C10F1354", 1002345678919L,
|
|
"application_11111111111111_1111", te);
|
|
"application_11111111111111_1111", te);
|
|
@@ -907,7 +907,7 @@ public class TestHBaseStorageFlowRun {
|
|
HBaseTimelineWriterImpl hbi = null;
|
|
HBaseTimelineWriterImpl hbi = null;
|
|
Configuration c1 = util.getConfiguration();
|
|
Configuration c1 = util.getConfiguration();
|
|
try {
|
|
try {
|
|
- hbi = new HBaseTimelineWriterImpl(c1);
|
|
|
|
|
|
+ hbi = new HBaseTimelineWriterImpl();
|
|
hbi.init(c1);
|
|
hbi.init(c1);
|
|
hbi.write(cluster, user, flow, "CF7022C10F1354", 1002345678919L,
|
|
hbi.write(cluster, user, flow, "CF7022C10F1354", 1002345678919L,
|
|
"application_11111111111111_1111", te);
|
|
"application_11111111111111_1111", te);
|