Skip to content

Commit

Permalink
merge conflict clean up
Browse files Browse the repository at this point in the history
  • Loading branch information
John Sanda committed May 26, 2015
1 parent d8c93ca commit 4046758
Showing 1 changed file with 0 additions and 16 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -34,11 +34,6 @@
import java.util.concurrent.TimeUnit;
import java.util.function.Predicate;

import javax.management.MBeanInfo;
import javax.management.MBeanServerConnection;
import javax.management.ObjectName;

import com.datastax.driver.core.Cluster;
import com.datastax.driver.core.ResultSet;
import com.datastax.driver.core.ResultSetFuture;
import com.datastax.driver.core.Row;
Expand All @@ -50,7 +45,6 @@
import com.google.common.util.concurrent.ListeningExecutorService;
import com.google.common.util.concurrent.MoreExecutors;
import com.google.common.util.concurrent.RateLimiter;

import org.hawkular.metrics.core.api.Availability;
import org.hawkular.metrics.core.api.AvailabilityBucketDataPoint;
import org.hawkular.metrics.core.api.AvailabilityData;
Expand All @@ -72,14 +66,12 @@
import org.hawkular.metrics.core.api.RetentionSettings;
import org.hawkular.metrics.core.api.Tenant;
import org.hawkular.metrics.core.api.TenantAlreadyExistsException;
import org.hawkular.metrics.schema.SchemaManager;
import org.hawkular.rx.cassandra.driver.RxUtil;
import org.joda.time.DateTime;
import org.joda.time.Duration;
import org.joda.time.Hours;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import rx.Observable;
import rx.functions.Func1;
import rx.subjects.PublishSubject;
Expand Down Expand Up @@ -729,12 +721,4 @@ private int getTTL(Metric<?> metric) {
return ttl;
}

private void updateSchemaIfNecessary(String schemaName) {
try {
SchemaManager schemaManager = new SchemaManager(session.get());
schemaManager.createSchema(schemaName);
} catch (IOException e) {
throw new RuntimeException("Schema creation failed", e);
}
}
}

0 comments on commit 4046758

Please sign in to comment.