Remove Optional from QueryStateMachine resourceGroup
resourceGroup is already required in QueryStateMachine
@@ -104,7 +104,7 @@ public class QueryStateMachine
private final Session session;
private final URI self;
private final Optional<QueryType> queryType;
- private final Optional<ResourceGroupId> resourceGroup;
+ private final ResourceGroupId resourceGroup;
private final TransactionManager transactionManager;
private final Metadata metadata;
private final QueryOutputManager outputManager;
@@ -156,7 +156,7 @@ public class QueryStateMachine
String query,
Session session,
URI self,
- Optional<ResourceGroupId> resourceGroup,
+ ResourceGroupId resourceGroup,
Optional<QueryType> queryType,
TransactionManager transactionManager,
Executor executor,
@@ -236,7 +236,7 @@ public class QueryStateMachine
query,
session,
self,
- Optional.of(resourceGroup),
+ resourceGroup,
queryType,
transactionManager,
executor,
@@ -373,7 +373,7 @@ public class QueryStateMachine
return new BasicQueryInfo(
queryId,
session.toSessionRepresentation(),
- resourceGroup,
+ Optional.of(resourceGroup),
state,
memoryPool.get().getId(),
stageStats.isScheduled(),
@@ -448,7 +448,7 @@ public class QueryStateMachine
inputs.get(),
output.get(),
completeInfo,
- resourceGroup,
+ Optional.of(resourceGroup),
queryType,
failedTasks);
}
