Skip to content

Make RowCoder a sub-class of SchemaCoder<Row> - #9424

Merged
reuvenlax merged 5 commits into
apache:masterfrom
TheNeuralBit:row-coder-swap
Oct 5, 2019
Merged

Make RowCoder a sub-class of SchemaCoder<Row>#9424
reuvenlax merged 5 commits into
apache:masterfrom
TheNeuralBit:row-coder-swap

Conversation

@TheNeuralBit

Copy link
Copy Markdown
Member

... so that it can be used as the java implementation of
beam:coder:row:v1 in a later change

Some of RowCoder's functionality has been removed (estimatedSizeBytes),
and some has been moved to SchemaCoder and RowCoderGenerator.

Post-Commit Tests Status (on master branch)

LangSDKApexDataflowFlinkGearpumpSamzaSpark
GoBuild Status------Build Status------Build Status
JavaBuild StatusBuild StatusBuild StatusBuild Status
Build Status
Build Status
Build StatusBuild StatusBuild Status
Build Status
PythonBuild Status
Build Status
Build Status
Build Status
---Build Status
Build Status
Build Status------Build Status
XLang---------Build Status---------

Pre-Commit Tests Status (on master branch)

---JavaPythonGoWebsite
Non-portableBuild StatusBuild StatusBuild StatusBuild Status
Portable---Build Status------

See .test-infra/jenkins/README for trigger phrase, status and link of all Jenkins jobs.

@TheNeuralBit

Copy link
Copy Markdown
MemberAuthor

R: @reuvenlax could you review this or suggest someone else?

... so that it can be used as the java implementation of
beam:coder:row:v1 in a later change
All of its remaining functionality has been moved to SchemaCoder and
RowCoderGenerator.
@TheNeuralBit

TheNeuralBit commented Sep 27, 2019

Copy link
Copy Markdown
MemberAuthor

Rebased onto master, and split out the RowSize/estimatedSizeBytes removal into its own commit for clarity.

@reuvenlax

Copy link
Copy Markdown
Contributor

still appears to be conflicting files?

@TheNeuralBit

Copy link
Copy Markdown
MemberAuthor

Oh probably because #9446 was just merged. I'll fix it now.

Comment on lines +276 to +293
private static class RowIdentity implements SerializableFunction<Row, Row> {
@Override
public Row apply(Row input) {
return input;
}

@Override
public int hashCode() {
return Objects.hash(getClass());
}

@Override
public boolean equals(Object o) {
if (this == o) {
return true;
}
return o != null && getClass() == o.getClass();
}

Copy link
Copy Markdown
MemberAuthor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Note I moved this RowIdentity class here just to make CloudObjectsTest happy until #9493 is in, and we can pass in some real SchemaCoder instances created by the providers.

@reuvenlax
reuvenlax merged commit 7abf88c into apache:masterOct 5, 2019
Sign up for freeto join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants

@TheNeuralBit@reuvenlax