public void createTransactInvokers() {
if (transactInvokers == null) {
try {
- transactInvokers = new HashMap<DatabaseSchema,TransactInvoker>();
+ transactInvokers = new HashMap<>();
List<String> databases = getDatabases().get();
for (String database : databases) {
DatabaseSchema dbSchema = getSchema(database).get();
}
Set<String> tables = dbSchema.getTables();
if (tables != null) {
- List<MonitorRequest<GenericTableSchema>> monitorRequests = Lists.newArrayList();
+ List<MonitorRequest> monitorRequests = Lists.newArrayList();
for (String tableName : tables) {
LOG.debug("HwvtepSouthbound monitoring table {} in {}", tableName, dbSchema.getName());
GenericTableSchema tableSchema = dbSchema.table(tableName, GenericTableSchema.class);
}
public <E extends TableSchema<E>> TableUpdates monitor(DatabaseSchema schema,
- List<MonitorRequest<E>> monitorRequests, MonitorCallBack callback) {
+ List<MonitorRequest> monitorRequests, MonitorCallBack callback) {
return client.monitor(schema, monitorRequests, callback);
}
@Override
public <E extends TableSchema<E>> TableUpdates monitor(DatabaseSchema schema,
- List<MonitorRequest<E>> monitorRequests, MonitorHandle monitorHandle, MonitorCallBack callback) {
+ List<MonitorRequest> monitorRequests, MonitorHandle monitorHandle, MonitorCallBack callback) {
return null;
}
}
public Boolean getHasDeviceOwnership() {
- return Boolean.valueOf(hasDeviceOwnership);
+ return hasDeviceOwnership;
}
public void setHasDeviceOwnership(Boolean hasDeviceOwnership) {
if (hasDeviceOwnership != null) {
- this.hasDeviceOwnership = hasDeviceOwnership.booleanValue();
+ this.hasDeviceOwnership = hasDeviceOwnership;
}
}