import storm.trident.partition.IndexHashGrouping; //导入依赖的package包/类
public Stream batchGlobal() {
    // the first field is the batch id
    return partition(new IndexHashGrouping(0));
}
 

import storm.trident.partition.IndexHashGrouping; //导入依赖的package包/类
@Override
public int partitionIndex(Object batchId, int numPartitions) {
    return IndexHashGrouping.objectToIndex(batchId, numPartitions);
}
 

import storm.trident.partition.IndexHashGrouping; //导入依赖的package包/类
/**
 * ## Repartitioning Operation
 *
 *  All tuples in the batch are sent to the same partition. Different batches in the stream may go to different
 *  partitions.
 *
 * @return
 */
public Stream batchGlobal() {
    // the first field is the batch id
    return partition(new IndexHashGrouping(0));
}