public class SqlDatasetBuilder extends CacheBasedDatasetBuilder<Object,BinaryObject>
CacheBasedDatasetBuilder
that should be used to work with SQL tables.DEFAULT_NUMBER_OF_RETRIES
Constructor and Description |
---|
SqlDatasetBuilder(Ignite ignite,
String upstreamCache)
Constructs a new instance of cache based dataset builder that makes
CacheBasedDataset with default
predicate that passes all upstream entries to dataset. |
SqlDatasetBuilder(Ignite ignite,
String upstreamCache,
IgniteBiPredicate<Object,BinaryObject> filter)
Constructs a new instance of cache based dataset builder that makes
CacheBasedDataset . |
SqlDatasetBuilder(Ignite ignite,
String upstreamCache,
IgniteBiPredicate<Object,BinaryObject> filter,
UpstreamTransformerBuilder transformerBuilder)
Constructs a new instance of cache based dataset builder that makes
CacheBasedDataset . |
build, withFilter, withKeepBinary, withRetriesNumber, withUpstreamTransformer
public SqlDatasetBuilder(Ignite ignite, String upstreamCache)
CacheBasedDataset
with default
predicate that passes all upstream entries to dataset.ignite
- Ignite instance.upstreamCache
- Name of Ignite Cache with upstream
data.public SqlDatasetBuilder(Ignite ignite, String upstreamCache, IgniteBiPredicate<Object,BinaryObject> filter)
CacheBasedDataset
.ignite
- Ignite instance.upstreamCache
- Name of Ignite Cache with upstream
data.filter
- Filter for upstream
data.public SqlDatasetBuilder(Ignite ignite, String upstreamCache, IgniteBiPredicate<Object,BinaryObject> filter, UpstreamTransformerBuilder transformerBuilder)
CacheBasedDataset
.ignite
- Ignite instance.upstreamCache
- Name of Ignite Cache with upstream
data.filter
- Filter for upstream
data.
GridGain In-Memory Computing Platform : ver. 8.9.15 Release Date : December 3 2024