org.infinispan.spark

rdd

package rdd

Visibility
  1. Public
  2. All

Type Members

  1. class FilteredInfinispanRDD[K, V, R] extends RDD[(K, R)]

    Infinispan RDD based on pre-filtered data in a cache, either by a Query or a filter previously deployed in the server

  2. class InfinispanIterator[K, V] extends Iterator[(K, V)]

  3. class InfinispanJavaRDD[K, V] extends JavaPairRDD[K, V]

  4. class InfinispanPartition extends Partition

  5. class InfinispanRDD[K, V] extends RDD[(K, V)]

  6. class Location extends Serializable

  7. class PerServerSplitter extends Splitter

    Create one or more partition per server so that: - Each partition will only contain segments owned by the associated server - A segment is unique across partitions

  8. class PreferredServerBalancingStrategy extends FailoverRequestBalancingStrategy with Logging

    Balancing strategy biased towards a pre-chosen server

  9. class SingleServerPartition extends InfinispanPartition

  10. trait Splitter extends AnyRef

Value Members

  1. object InfinispanJavaRDD extends Serializable

  2. object InfinispanRDD extends Serializable

  3. object Location extends Serializable

Ungrouped