import storm.trident.partition.GlobalGrouping; //导入依赖的package包/类
public Stream global() {
    // use this instead of storm's built in one so that we can specify a singleemitbatchtopartition
    // without knowledge of storm's internals
    return partition(new GlobalGrouping());
}
 

import storm.trident.partition.GlobalGrouping; //导入依赖的package包/类
/**
 * ## Repartitioning Operation
 *
 * All tuples are sent to the same partition. The same partition is chosen for all batches in the stream.
 * @return
 */
public Stream global() {
    // use this instead of storm's built in one so that we can specify a single emit batch to partition
    // without knowledge of storm's internals
    return partition(new GlobalGrouping());
}