19
19
import com .fasterxml .jackson .core .JsonParser ;
20
20
import com .fasterxml .jackson .databind .DeserializationContext ;
21
21
import com .fasterxml .jackson .databind .JsonNode ;
22
- import com .fasterxml .jackson .databind .ObjectMapper ;
23
22
import com .fasterxml .jackson .databind .deser .std .StdDeserializer ;
24
23
import io .serverlessworkflow .api .datainputschema .DataInputSchema ;
25
24
import io .serverlessworkflow .api .interfaces .WorkflowPropertySource ;
26
- import org .slf4j .Logger ;
27
- import org .slf4j .LoggerFactory ;
28
-
29
25
import java .io .IOException ;
30
26
31
27
public class DataInputSchemaDeserializer extends StdDeserializer <DataInputSchema > {
32
28
33
29
private static final long serialVersionUID = 510l ;
34
- private static Logger logger = LoggerFactory .getLogger (DataInputSchema .class );
35
-
36
- private WorkflowPropertySource context ;
37
30
38
31
public DataInputSchemaDeserializer () {
39
32
this (DataInputSchema .class );
@@ -45,14 +38,12 @@ public DataInputSchemaDeserializer(Class<?> vc) {
45
38
46
39
public DataInputSchemaDeserializer (WorkflowPropertySource context ) {
47
40
this (DataInputSchema .class );
48
- this .context = context ;
49
41
}
50
42
51
43
@ Override
52
44
public DataInputSchema deserialize (JsonParser jp ,
53
45
DeserializationContext ctxt ) throws IOException {
54
46
55
- ObjectMapper mapper = (ObjectMapper ) jp .getCodec ();
56
47
JsonNode node = jp .getCodec ().readTree (jp );
57
48
58
49
DataInputSchema dataInputSchema = new DataInputSchema ();
0 commit comments