| Package | Description |
|---|---|
| be.bagofwords.iterator | |
| be.bagofwords.jobs |
| Modifier and Type | Method and Description |
|---|---|
static <T> DataIterable<KeyValue<T[]>> |
IterableUtils.createGroupingIterable(Class<T> objectClass,
List<DataIterable<KeyValue<T>>> iterables) |
static <T> DataIterable<T> |
IterableUtils.createIterable(Collection<T> collection) |
static <T> DataIterable<T> |
IterableUtils.createIterable(DataIterable<? extends T>... iterables) |
static <T> DataIterable<T> |
IterableUtils.createIterable(IterableUtils.CombineMethod combineMethod,
DataIterable<? extends T>... iterables) |
static <T> DataIterable<T> |
IterableUtils.createIterable(IterableUtils.CombineMethod combineMethod,
List<DataIterable<? extends T>> iterables) |
static <T> DataIterable<T> |
IterableUtils.createIterable(List<DataIterable<? extends T>> iterables) |
static <T> DataIterable<T> |
IterableUtils.maxSizeIterable(long maxIterations,
DataIterable<T> iterable) |
| Modifier and Type | Method and Description |
|---|---|
static <T> DataIterable<T> |
IterableUtils.createIterable(DataIterable<? extends T>... iterables) |
static <T> DataIterable<T> |
IterableUtils.createIterable(IterableUtils.CombineMethod combineMethod,
DataIterable<? extends T>... iterables) |
static <T> DataIterable<T> |
IterableUtils.maxSizeIterable(long maxIterations,
DataIterable<T> iterable) |
| Modifier and Type | Method and Description |
|---|---|
static <T> DataIterable<KeyValue<T[]>> |
IterableUtils.createGroupingIterable(Class<T> objectClass,
List<DataIterable<KeyValue<T>>> iterables) |
static <T> DataIterable<T> |
IterableUtils.createIterable(IterableUtils.CombineMethod combineMethod,
List<DataIterable<? extends T>> iterables) |
static <T> DataIterable<T> |
IterableUtils.createIterable(List<DataIterable<? extends T>> iterables) |
| Constructor and Description |
|---|
MultipleSwipesIterator(DataIterable<T> iterable,
int numOfSwipes) |
| Modifier and Type | Method and Description |
|---|---|
<T> void |
JobRunner.runJob(boolean printProgress,
int numOfThreads,
String name,
DataIterable<T> iterable,
Job<T> job) |
<T> void |
JobRunner.runJob(int numOfThreads,
String name,
DataIterable<T> iterable,
Job<T> job) |
<T> void |
JobRunner.runJob(String name,
DataIterable<T> iterable,
Job<T> job) |
<T> void |
JobRunner.runPartitionedJobs(boolean printProgress,
int numOfPartitions,
int numOfThreads,
String name,
DataIterable<T> iterable,
PartitionableJob<T> job) |
<T> void |
JobRunner.runPartitionedJobs(int numOfPartitions,
int numOfThreads,
String name,
DataIterable<T> iterable,
PartitionableJob<T> job) |
Copyright © 2015. All rights reserved.