Uses of Class
org.aksw.commons.collector.core.AggInputSplit

Packages that use AggInputSplit
Package
Description
org.aksw.commons.collector.core
 

  • Uses of AggInputSplit in org.aksw.commons.collector.core

    Methods in org.aksw.commons.collector.core that return AggInputSplit
    Modifier and Type
    Method
    Description
    static <I, E, K, J, O, ACC extends Accumulator<J, E, O>, AGG extends ParallelAggregator<J, E, O, ACC>>
    AggInputSplit<I,E,K,J,O,ACC,AGG>
    AggBuilder.inputSplit(Set<K> fixedKeys, boolean considerNewKeys, org.aksw.commons.lambda.serializable.SerializableFunction<? super I,? extends Set<? extends K>> keyMapper, org.aksw.commons.lambda.serializable.SerializableBiFunction<? super I,? super K,? extends J> valueMapper, AGG state)
     
    static <I, E, K, J, O, ACC extends Accumulator<J, E, O>, AGG extends ParallelAggregator<J, E, O, ACC>>
    AggInputSplit<I,E,K,J,O,ACC,AGG>
    AggBuilder.inputSplit(org.aksw.commons.lambda.serializable.SerializableFunction<? super I,? extends Set<? extends K>> keyMapper, org.aksw.commons.lambda.serializable.SerializableBiFunction<? super I,? super K,? extends J> valueMapper, AGG state)
    InputSplit: Create the same accumulator type for each split of the input
    static <I, E, K, O, ACC extends Accumulator<I, E, O>, AGG extends ParallelAggregator<I, E, O, ACC>>
    AggInputSplit<I,E,K,I,O,ACC,AGG>
    AggBuilder.inputSplit(org.aksw.commons.lambda.serializable.SerializableFunction<? super I,? extends K> keyMapper, AGG state)
    Simple input split: Partition input by a key derived from it
    Methods in org.aksw.commons.collector.core that return types with arguments of type AggInputSplit
    Modifier and Type
    Method
    Description
    static <I, E, K, J, O, SUBACC extends Accumulator<J, E, O>, SUBAGG extends ParallelAggregator<J, E, O, SUBACC>>
    org.aksw.commons.lambda.serializable.SerializableFunction<SUBAGG,AggInputSplit<I,E,K,J,O,SUBACC,SUBAGG>>
    AggBuilderFn.inputSplit(org.aksw.commons.lambda.serializable.SerializableFunction<? super I,? extends Set<? extends K>> keyMapper, org.aksw.commons.lambda.serializable.SerializableBiFunction<? super I,? super K,? extends J> valueMapper)