org.apache.ignite.ml.dataset.impl.cache

Class CacheBasedDatasetBuilder<K,V>

java.lang.Object

org.apache.ignite.ml.dataset.impl.cache.CacheBasedDatasetBuilder<K,V>

Type Parameters:

K - Type of a key in upstream data.

V - Type of a value in upstream data.

All Implemented Interfaces:

DatasetBuilder<K,V>

public class CacheBasedDatasetBuilder<K,V>
extends Object
implements DatasetBuilder<K,V>

A dataset builder that makes CacheBasedDataset. Encapsulate logic of building cache based dataset such as allocation required data structures and initialization of context part of partitions.

Constructor Summary

Constructors

Constructor and Description
CacheBasedDatasetBuilder(Ignite ignite, IgniteCache<K,V> upstreamCache) Constructs a new instance of cache based dataset builder that makes CacheBasedDataset with default predicate that passes all upstream entries to dataset.
CacheBasedDatasetBuilder(Ignite ignite, IgniteCache<K,V> upstreamCache, IgniteBiPredicate<K,V> filter) Constructs a new instance of cache based dataset builder that makes CacheBasedDataset.

Method Summary

Modifier and Type	Method and Description
<C extends Serializable,D extends AutoCloseable> CacheBasedDataset<K,V,C,D>	build(PartitionContextBuilder<K,V,C> partCtxBuilder, PartitionDataBuilder<K,V,C,D> partDataBuilder) Constructs a new instance of Dataset that includes allocation required data structures and initialization of context part of partitions.
DatasetBuilder<K,V>	withFilter(IgniteBiPredicate<K,V> filterToAdd) Returns new instance of DatasetBuilder using conjunction of internal filter and filterToAdd.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CacheBasedDatasetBuilder

public CacheBasedDatasetBuilder(Ignite ignite,
                                IgniteCache<K,V> upstreamCache)

Constructs a new instance of cache based dataset builder that makes CacheBasedDataset with default predicate that passes all upstream entries to dataset.

Parameters:

ignite - Ignite instance.

upstreamCache - Ignite Cache with upstream data.

CacheBasedDatasetBuilder

public CacheBasedDatasetBuilder(Ignite ignite,
                                IgniteCache<K,V> upstreamCache,
                                IgniteBiPredicate<K,V> filter)

Constructs a new instance of cache based dataset builder that makes CacheBasedDataset.

Parameters:

ignite - Ignite instance.

upstreamCache - Ignite Cache with upstream data.

filter - Filter for upstream data.

Method Detail

build

public <C extends Serializable,D extends AutoCloseable> CacheBasedDataset<K,V,C,D> build(PartitionContextBuilder<K,V,C> partCtxBuilder,
                                                                                         PartitionDataBuilder<K,V,C,D> partDataBuilder)

Constructs a new instance of Dataset that includes allocation required data structures and initialization of context part of partitions.

Specified by:

build in interface DatasetBuilder<K,V>

Type Parameters:

C - Type of a partition context.

D - Type of a partition data.

Parameters:

partCtxBuilder - Partition context builder.

partDataBuilder - Partition data builder.

Returns:

Dataset.

withFilter

public DatasetBuilder<K,V> withFilter(IgniteBiPredicate<K,V> filterToAdd)

Returns new instance of DatasetBuilder using conjunction of internal filter and filterToAdd.

Specified by:

withFilter in interface DatasetBuilder<K,V>

Parameters:

filterToAdd - Additional filter.