support for #249

xsql/plans/preprocessor.go

@@ -61,8 +61,6 @@ func (p *Preprocessor) Apply(ctx api.StreamContext, data interface{}, fv *xsql.F
 	} else {
 		if p.isSelectAll {
 			result = tuple.Message
-		} else {
-			result = xsql.LowercaseKeyMap(tuple.Message)
 		}
 	}
 

xsql/plans/preprocessor_test.go

@@ -827,7 +827,7 @@ func TestPreprocessorEventtime_Apply(t *testing.T) {
 	ctx := contexts.WithValue(contexts.Background(), contexts.LoggerKey, contextLogger)
 	for i, tt := range tests {
 
-		pp, err := NewPreprocessor(tt.stmt, nil, true)
+		pp, err := NewPreprocessor(tt.stmt, nil, true, false)
 		if err != nil {
 			t.Error(err)
 		}