public class AggregateDataMigrator extends AbstractMigrationWorker implements CallableMigrationWorker
MAX_AGGREGATE_BATCH_TO_CASSANDRA, MAX_NUMBER_OF_FAILURES, MAX_RAW_BATCH_TO_CASSANDRA, MAX_RECORDS_TO_LOAD_FROM_SQL, NUMBER_OF_BATCHES_FOR_ESTIMATION
Constructor and Description |
---|
AggregateDataMigrator(MetricsTable metricsTable,
DataMigrator.DataMigratorConfiguration config) |
Modifier and Type | Method and Description |
---|---|
long |
estimate() |
void |
migrate() |
closeSQLSession, getExistingDataSource, getRawDataTables, getSQLSession, prepareSQLSession
public AggregateDataMigrator(MetricsTable metricsTable, DataMigrator.DataMigratorConfiguration config) throws Exception
query
- metricsTable
- Exception
public long estimate() throws Exception
estimate
in interface CallableMigrationWorker
Exception
public void migrate() throws Exception
migrate
in interface CallableMigrationWorker
Exception
Copyright © 2008-2014 Red Hat, Inc.. All Rights Reserved.