...
| Code Block | ||
|---|---|---|
| ||
interface PreviewContext {
PreviewEmitter getEmitter
// all records from the stage identified by identifier
<T> Iterator<T> getOutputRecords(String identifier);
// all metrics from the stage identified by identifier
Collection<MetricTimeSeries> getMetrics(String identifier);
// all logs from the stage identified by identifier
String getLogs(String identifier);
} |
| Code Block | ||
|---|---|---|
| ||
interface PreviewEmitter {
void emit(T record);
Iterator<T> getEmittedRecords();
} |
Implementation:
SDK:
...
| Service | Standalone (Yes/No) | Preview (Yes/No) |
|---|---|---|
userInterfaceService | Yes | No |
trackerAppCreationService | Yes | No |
router | Yes | No |
streamService | Yes | Yes |
exploreExecutorService | Yes | No |
exploreClient | Yes | No |
metadataService | Yes | No |
serviceStore (set/get service instances) | Yes | No |
appFabricServer | Yes | No |
previewServer | No | Yes |
datasetService | Yes | Yes |
metricsQueryService | YesYes | No (Can call MetricStore query) |
txService | Yes | Yes |
externalAuthenticationServer (if security enabled) | Yes | Yes |
logAppenderInitializer | Yes | Yes |
kafkaClient(if audit enabled) | Yes | No |
zkClient (if audit enabled) | Yes | No |
authorizerInstantiator (started by default) | Yes | Yes? |
...