src/jvm/backtype/storm/spout/RawMultiScheme.java

package backtype.storm.spout;

import java.util.List;

import backtype.storm.tuple.Fields;


import static backtype.storm.utils.Utils.tuple;
import static java.util.Arrays.asList;

public class RawMultiScheme implements MultiScheme {
  @Override
  public Iterable<List<Object>> deserialize(byte[] ser) {
    return asList(tuple(ser));
  }

  @Override
  public Fields getOutputFields() {
    return new Fields("bytes");
  }
}