Skip to content

Commit

Permalink
json-path parsing
Browse files Browse the repository at this point in the history
  • Loading branch information
liugddx committed Nov 22, 2022
1 parent 90d33c1 commit 3869359
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@
@AllArgsConstructor
public class DeserializationCollector {

private DeserializationSchema<SeaTunnelRow> deserializationSchema;
private final DeserializationSchema<SeaTunnelRow> deserializationSchema;

public void collect(byte[] message, Collector<SeaTunnelRow> out) throws IOException {
if (deserializationSchema instanceof JsonDeserializationSchema) {
Expand Down

0 comments on commit 3869359

Please sign in to comment.