public final class TupleUtils extends Object
Modifier and Type | Method and Description |
---|---|
static <T> int |
chooseTaskIndex(List<T> keys,
int numTasks) |
static boolean |
isTick(Tuple tuple) |
static Map<String,Object> |
putTickFrequencyIntoComponentConfig(Map<String,Object> conf,
int tickFreqSecs) |
Copyright © 2020 The Apache Software Foundation. All rights reserved.