Skip to content

Commit

Permalink
Fix non-serializable InputColumn use when expecting serializable
Browse files Browse the repository at this point in the history
  • Loading branch information
qqndrew committed Sep 6, 2023
1 parent e5b4868 commit 1238d79
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 2 deletions.
2 changes: 1 addition & 1 deletion pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@

<groupId>org.ohnlp.medtagger</groupId>
<artifactId>medtagger</artifactId>
<version>1.0.68</version>
<version>1.0.69</version>
<description>The MedTagger biomedical information extraction pipeline</description>


Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -50,10 +50,11 @@ public PCollection<Row> expand(PCollection<Row> input) {
Schema returnSchema = Schema.of(
Schema.Field.of("header", Schema.FieldType.STRING),
Schema.Field.of("count", Schema.FieldType.INT32));
String col = noteText.getSourceColumnName();
return input.apply("Extract Header Candidates", ParDo.of(new DoFn<Row, KV<String, Integer>>() {
@ProcessElement
public void process(ProcessContext pc) {
String raw = pc.element().getString(noteText.getSourceColumnName());
String raw = pc.element().getString(col);
if (raw == null) {
return;
}
Expand Down

0 comments on commit 1238d79

Please sign in to comment.