blob: fe784af25d24e2d7464c6e38254e1bb99bad7a91 [file] [log] [blame]
package backtype.storm.drpc;
import backtype.storm.topology.ComponentConfigurationDeclarer;
import backtype.storm.tuple.Fields;
public interface LinearDRPCInputDeclarer extends ComponentConfigurationDeclarer<LinearDRPCInputDeclarer> {
public LinearDRPCInputDeclarer fieldsGrouping(Fields fields);
public LinearDRPCInputDeclarer fieldsGrouping(String streamId, Fields fields);
public LinearDRPCInputDeclarer globalGrouping();
public LinearDRPCInputDeclarer globalGrouping(String streamId);
public LinearDRPCInputDeclarer shuffleGrouping();
public LinearDRPCInputDeclarer shuffleGrouping(String streamId);
public LinearDRPCInputDeclarer noneGrouping();
public LinearDRPCInputDeclarer noneGrouping(String streamId);
public LinearDRPCInputDeclarer allGrouping();
public LinearDRPCInputDeclarer allGrouping(String streamId);
public LinearDRPCInputDeclarer directGrouping();
public LinearDRPCInputDeclarer directGrouping(String streamId);
}