/*
 *  Licensed under the Apache License, Version 2.0 (the "License");
 *  you may not use this file except in compliance with the License.
 *  You may obtain a copy of the License at
 *
 *  http://www.apache.org/licenses/LICENSE-2.0
 *
 *  Unless required by applicable law or agreed to in writing, software
 *  distributed under the License is distributed on an "AS IS" BASIS,
 *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 *  See the License for the specific language governing permissions and
 *  limitations under the License.
 */
package com.github.sakserv.storm.scheme;

import backtype.storm.spout.Scheme;
import backtype.storm.tuple.Fields;
import backtype.storm.tuple.Values;

import java.util.List;

public class AvroScheme implements Scheme {

        private static final long serialVersionUID = -2990121166902741545L;

        @Override
        public List<Object> deserialize(byte[] bytes) {
            String msg = bytes.toString();
            return new Values(msg);
        }

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

@@ -711,16 +711,41 @@
 alues;%0A%0A
+import java.util.Arrays;%0A
 import j
@@ -981,20 +981,21 @@
 g msg = 
-byte
+Array
 s.toStri
@@ -997,16 +997,21 @@
 oString(
+bytes
 );%0A     

properly convert byte array to string