Package | Description |
---|---|
org.kitesdk.data |
Provides interfaces and classes for reading and writing datasets.
|
org.kitesdk.data.crunch |
Provides helper classes for working with datasets using Crunch.
|
Modifier and Type | Interface and Description |
---|---|
interface |
RandomAccessDataset<E>
A
Dataset that supports random access operations on entities. |
Modifier and Type | Method and Description |
---|---|
static <D extends Dataset<GenericRecord>> |
Datasets.update(String uri,
DatasetDescriptor descriptor)
Update a
Dataset for the given dataset or view URI string. |
static <E,D extends Dataset<E>> |
Datasets.update(String uri,
DatasetDescriptor descriptor,
Class<E> type)
Update a
Dataset for the given dataset or view URI string. |
static <D extends Dataset<GenericRecord>> |
Datasets.update(URI uri,
DatasetDescriptor descriptor)
Update a
Dataset for the given dataset or view URI. |
static <E,D extends Dataset<E>> |
Datasets.update(URI uri,
DatasetDescriptor descriptor,
Class<E> type)
Update a
Dataset for the given dataset or view URI. |
Modifier and Type | Method and Description |
---|---|
Dataset<E> |
View.getDataset()
Returns the underlying
Dataset for the
View . |
Modifier and Type | Method and Description |
---|---|
static <E> PCollection<E> |
CrunchDatasets.partition(PCollection<E> collection,
Dataset<E> dataset)
Partitions
collection to be stored efficiently in dataset . |
static <E> PCollection<E> |
CrunchDatasets.partition(PCollection<E> collection,
Dataset<E> dataset,
int numWriters)
Deprecated.
will be removed in 0.19.0; use partition(PCollection, View, int)
|
Copyright © 2013–2015. All rights reserved.