import storm.trident.partition.IdentityGrouping; //导入依赖的package包/类
private static boolean isIdentityPartition(PartitionNode n) {
    Grouping g = n.thriftGrouping;
    if(g.is_set_custom_serialized()) {
        CustomStreamGrouping csg = (CustomStreamGrouping) Utils.deserialize(g.get_custom_serialized());
        return csg instanceof IdentityGrouping;
    }
    return false;
}
 

import storm.trident.partition.IdentityGrouping; //导入依赖的package包/类
private static boolean isIdentityPartition(PartitionNode n) {
    Grouping g = n.thriftGrouping;
    if(g.is_set_custom_serialized()) {
        CustomStreamGrouping csg = (CustomStreamGrouping) Utils.javaDeserialize(g.get_custom_serialized(), Serializable.class);
        return csg instanceof IdentityGrouping;
    }
    return false;
}
 

import storm.trident.partition.IdentityGrouping; //导入依赖的package包/类
public Stream identityPartition() {
    return partition(new IdentityGrouping());
}
 

import storm.trident.partition.IdentityGrouping; //导入依赖的package包/类
private static PartitionNode makeIdentityPartition(Node basis) {
    return new PartitionNode(basis.streamId, basis.name, basis.allOutputFields,
        Grouping.custom_serialized(Utils.serialize(new IdentityGrouping())));
}
 

import storm.trident.partition.IdentityGrouping; //导入依赖的package包/类
private static PartitionNode makeIdentityPartition(Node basis) {
    return new PartitionNode(basis.streamId, basis.name, basis.allOutputFields,
        Grouping.custom_serialized(Utils.javaSerialize(new IdentityGrouping())));
}
 

import storm.trident.partition.IdentityGrouping; //导入依赖的package包/类
/**
 * ## Repartitioning Operation
 *
 * @return
 */
public Stream identityPartition() {
    return partition(new IdentityGrouping());
}