| Package | Description |
|---|---|
| co.cask.cdap.data.view | |
| co.cask.cdap.data2.metadata.store | |
| co.cask.cdap.data2.metadata.system | |
| co.cask.cdap.data2.transaction.queue.inmemory |
This package contains in memory implementation of queues.
|
| co.cask.cdap.data2.transaction.stream |
This package contains transaction stream consumer classes for maintaining stateful consumption of stream entries.
|
| Constructor and Description |
|---|
ViewAdmin(ViewStore store,
ExploreFacade explore,
ExploreTableNaming naming,
MetadataStore metadataStore) |
| Modifier and Type | Class and Description |
|---|---|
class |
DefaultMetadataStore
Implementation of
MetadataStore used in distributed mode. |
class |
NoOpMetadataStore
Implementation of
MetadataStore used in memory mode. |
| Constructor and Description |
|---|
AbstractSystemMetadataWriter(MetadataStore metadataStore,
Id.NamespacedId entityId) |
AppSystemMetadataWriter(MetadataStore metadataStore,
Id.Application entityId,
co.cask.cdap.api.app.ApplicationSpecification appSpec) |
ArtifactSystemMetadataWriter(MetadataStore metadataStore,
Id.Artifact artifactId,
ArtifactInfo artifactInfo) |
DatasetSystemMetadataWriter(MetadataStore metadataStore,
SystemDatasetInstantiatorFactory dsInstantiatorFactory,
Id.DatasetInstance dsInstance,
co.cask.cdap.api.dataset.DatasetProperties dsProperties,
String dsType) |
ProgramSystemMetadataWriter(MetadataStore metadataStore,
Id.Program programId,
co.cask.cdap.api.ProgramSpecification programSpec) |
StreamSystemMetadataWriter(MetadataStore metadataStore,
Id.Stream streamId,
StreamConfig config) |
ViewSystemMetadataWriter(MetadataStore metadataStore,
Id.Stream.View viewId,
ViewSpecification viewSpec) |
| Constructor and Description |
|---|
InMemoryStreamAdmin(InMemoryQueueService queueService,
UsageRegistry usageRegistry,
LineageWriter lineageWriter,
StreamMetaStore streamMetaStore,
MetadataStore metadataStore,
ViewAdmin viewAdmin) |
| Constructor and Description |
|---|
FileStreamAdmin(NamespacedLocationFactory namespacedLocationFactory,
CConfiguration cConf,
StreamCoordinatorClient streamCoordinatorClient,
StreamConsumerStateStoreFactory stateStoreFactory,
NotificationFeedManager notificationFeedManager,
UsageRegistry usageRegistry,
LineageWriter lineageWriter,
StreamMetaStore streamMetaStore,
ExploreTableNaming tableNaming,
MetadataStore metadataStore,
ViewAdmin viewAdmin) |
Copyright © 2016 Cask Data, Inc. Licensed under the Apache License, Version 2.0.