-
Notifications
You must be signed in to change notification settings - Fork 390
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Feature/nifi integration type mapping #752
Feature/nifi integration type mapping #752
Conversation
between PlcType and Avro types. * Update PlcType to Avro type mapping * Added unit test for Plc4xSourceRecordProcessor * Added common test utils.
to Plc4xCommonTest
…egration-type-mapping
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks for the contribution! This is really nice, only the one comment on the type in the doc being 'bytes'
| PlcBigDecimal | float | | ||
| PlcBigInteger | long | | ||
| PlcBitString | string | | ||
|----------:|-----------| | ||
| PlcBOOL | boolean | |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
should be byte[]?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
In Avro specification (https://avro.apache.org/docs/1.11.1/specification/#primitive-types) the primitive type is called bytes
* Add explicit source of Avro types * Change output of example to actual output
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks, sorry for my misunderstanding.
Improvements in type mapping from Plc4x to Avro. Added unit test for record source processor.
Changes in mapping:
General improvements in
org.apache.plc4x.nifi.util.Plc4xCommon
: