public Metrics getMetrics() {
return new SparkUserMetrics(userMetrics);
}
@Override
public PluginContext getPluginContext() {
<BUG>return new SparkPluginContext(pluginInstantiator, programId, applicationSpecification.getPlugins());
</BUG>
}
@Override
public <T> T readFromDataset(String datasetName, Class<?> kClass, Class<?> vClass) {

public Metrics getMetrics() {
return new SparkUserMetrics(userMetrics);
}
@Override
public PluginContext getPluginContext() {
return new SparkPluginContext(pluginInstantiator, programId.toEntityId(), applicationSpecification.getPlugins());
}
@Override
public <T> T readFromDataset(String datasetName, Class<?> kClass, Class<?> vClass) {
