public class ExtraCountFunction<T extends SequenceElement> extends java.lang.Object implements org.apache.spark.api.java.function.Function<Sequence<T>,Pair<Sequence<T>,java.lang.Long>>
Modifier and Type | Field and Description |
---|---|
protected org.apache.spark.Accumulator<ExtraCounter<java.lang.Long>> |
accumulator |
protected boolean |
fetchLabels |
Constructor and Description |
---|
ExtraCountFunction(org.apache.spark.Accumulator<ExtraCounter<java.lang.Long>> accumulator,
boolean fetchLabels) |
Modifier and Type | Method and Description |
---|---|
Pair<Sequence<T>,java.lang.Long> |
call(Sequence<T> sequence) |
protected org.apache.spark.Accumulator<ExtraCounter<java.lang.Long>> accumulator
protected boolean fetchLabels
public ExtraCountFunction(@NonNull org.apache.spark.Accumulator<ExtraCounter<java.lang.Long>> accumulator, boolean fetchLabels)