| Package | Description |
|---|---|
| co.cask.cdap.data2.metadata.lineage | |
| co.cask.cdap.data2.metadata.writer | |
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
static AccessType |
AccessType.fromType(char type) |
AccessType |
Relation.getAccess() |
static AccessType |
AccessType.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static AccessType[] |
AccessType.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
| Modifier and Type | Method and Description |
|---|---|
void |
LineageStore.addAccess(Id.Run run,
Id.DatasetInstance datasetInstance,
AccessType accessType,
long accessTimeMillis)
Add a program-dataset access.
|
void |
LineageDataset.addAccess(Id.Run run,
Id.DatasetInstance datasetInstance,
AccessType accessType,
long accessTimeMillis)
Add a program-dataset access.
|
void |
LineageStore.addAccess(Id.Run run,
Id.DatasetInstance datasetInstance,
AccessType accessType,
long accessTimeMillis,
Id.NamespacedId component)
Add a program-dataset access.
|
void |
LineageDataset.addAccess(Id.Run run,
Id.DatasetInstance datasetInstance,
AccessType accessType,
long accessTimeMillis,
Id.NamespacedId component)
Add a program-dataset access.
|
void |
LineageStore.addAccess(Id.Run run,
Id.Stream stream,
AccessType accessType,
long accessTimeMillis)
Add a program-stream access.
|
void |
LineageDataset.addAccess(Id.Run run,
Id.Stream stream,
AccessType accessType,
long accessTimeMillis)
Add a program-stream access.
|
void |
LineageStore.addAccess(Id.Run run,
Id.Stream stream,
AccessType accessType,
long accessTimeMillis,
Id.NamespacedId component)
Add a program-stream access.
|
void |
LineageDataset.addAccess(Id.Run run,
Id.Stream stream,
AccessType accessType,
long accessTimeMillis,
Id.NamespacedId component)
Add a program-stream access.
|
| Constructor and Description |
|---|
Relation(Id.DatasetInstance data,
Id.Program program,
AccessType access,
RunId run) |
Relation(Id.DatasetInstance data,
Id.Program program,
AccessType access,
RunId run,
Set<? extends Id.NamespacedId> components) |
Relation(Id.Stream stream,
Id.Program program,
AccessType access,
RunId run) |
Relation(Id.Stream stream,
Id.Program program,
AccessType access,
RunId run,
Set<? extends Id.NamespacedId> components) |
| Modifier and Type | Method and Description |
|---|---|
void |
NoOpLineageWriter.addAccess(Id.Run run,
Id.DatasetInstance datasetInstance,
AccessType accessType) |
void |
LineageWriter.addAccess(Id.Run run,
Id.DatasetInstance datasetInstance,
AccessType accessType)
Add a program-dataset access.
|
void |
BasicLineageWriter.addAccess(Id.Run run,
Id.DatasetInstance datasetInstance,
AccessType accessType) |
void |
NoOpLineageWriter.addAccess(Id.Run run,
Id.DatasetInstance datasetInstance,
AccessType accessType,
Id.NamespacedId component) |
void |
LineageWriter.addAccess(Id.Run run,
Id.DatasetInstance datasetInstance,
AccessType accessType,
Id.NamespacedId component)
Add a program-dataset access.
|
void |
BasicLineageWriter.addAccess(Id.Run run,
Id.DatasetInstance datasetInstance,
AccessType accessType,
Id.NamespacedId component) |
void |
NoOpLineageWriter.addAccess(Id.Run run,
Id.Stream stream,
AccessType accessType) |
void |
LineageWriter.addAccess(Id.Run run,
Id.Stream stream,
AccessType accessType)
Add a program-stream access.
|
void |
BasicLineageWriter.addAccess(Id.Run run,
Id.Stream stream,
AccessType accessType) |
void |
NoOpLineageWriter.addAccess(Id.Run run,
Id.Stream stream,
AccessType accessType,
Id.NamespacedId component) |
void |
LineageWriter.addAccess(Id.Run run,
Id.Stream stream,
AccessType accessType,
Id.NamespacedId component)
Add a program-stream access.
|
void |
BasicLineageWriter.addAccess(Id.Run run,
Id.Stream stream,
AccessType accessType,
Id.NamespacedId component) |
| Modifier and Type | Method and Description |
|---|---|
void |
InMemoryStreamAdmin.addAccess(Id.Run run,
Id.Stream streamId,
AccessType accessType) |
| Modifier and Type | Method and Description |
|---|---|
void |
FileStreamAdmin.addAccess(Id.Run run,
Id.Stream streamId,
AccessType accessType) |
void |
StreamAdmin.addAccess(Id.Run run,
Id.Stream streamId,
AccessType accessType)
Record access of stream by a program run for lineage computation.
|
Copyright © 2016 Cask Data, Inc. Licensed under the Apache License, Version 2.0.