...
| Services | AppFabricServer | PreviewServer |
|---|---|---|
notificationService | Yes | No |
schedulerService | Yes | No |
applicationLifecycleService | Yes | Yes |
systemArtifactLoader | Yes | Yes |
programRuntimeService | Yes | Yes |
streamCoordinatorClient | Yes | Yes |
programLifecycleService | Yes | Yes |
pluginService | Yes | Yes |
httpService | Yes | Yes (but only with preview handler). |
...
PreviewDatasetFramework
Requirements:
1) Pipeline want's to read from a dataset source (or) pipeline wants to write to a dataset sink (or) transform uses a lookup table. These datasets are in CDAP Standalone space.
...
1) All Datasets in System Namespace will be using the "PreviewDatasetFrameworkLocalDatasetFramework"
2) All Datasets in User's Namespaces will be using the "StandaloneDatasetFrameworkRemoteDatasetFramework"
| Code Block | ||
|---|---|---|
| ||
... snippet
@Nullable
@Override
public <T extends Dataset> T getDataset(Id.DatasetInstance datasetInstanceId,
@Nullable Map<String, String> arguments,
@Nullable ClassLoader classLoader)
throws DatasetManagementException, IOException {
if (datasetInstanceId.getNamespace().equals(Id.Namespace.SYSTEM)) {
return previewDatasetFrameworklocalDatasetFramework.getDataset(datasetInstanceId, arguments, classLoader);
} else {
return standaloneDatasetFrameworkremoteDatasetFramework.getDataset(datasetInstanceId, arguments, classLoader);
}
} |
Adapting to Cluster