@@ -0,0 +1,1070 @@
+/*%0ACopyright 2012 Twitter, Inc.%0A%0ALicensed under the Apache License, Version 2.0 (the %22License%22);%0Ayou may not use this file except in compliance with the License.%0AYou may obtain a copy of the License at%0A%0Ahttp://www.apache.org/licenses/LICENSE-2.0%0A%0AUnless required by applicable law or agreed to in writing, software%0Adistributed under the License is distributed on an %22AS IS%22 BASIS,%0AWITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.%0ASee the License for the specific language governing permissions and%0Alimitations under the License.%0A*/%0A%0Apackage backtype.storm.spout;%0A%0Aimport java.util.Arrays;%0Aimport java.util.List;%0A%0Aimport backtype.storm.tuple.Fields;%0A%0A/**%0A *%0A */%0Apublic class SchemeAsMultiScheme implements MultiScheme %7B%0A  public final Scheme scheme;%0A%0A  public SchemeAsMultiScheme(Scheme scheme) %7B%0A    this.scheme = scheme;%0A  %7D%0A%0A  @Override public Iterable%3CList%3CObject%3E%3E deserialize(final byte%5B%5D ser) %7B%0A    return Arrays.asList(scheme.deserialize(ser));%0A  %7D%0A%0A  @Override public Fields getOutputFields() %7B%0A    return scheme.getOutputFields();%0A  %7D%0A%7D%0A

add SchemeAsMultiScheme