hnail edited a comment on issue #4747:
URL: https://github.com/apache/pulsar/issues/4747#issuecomment-684831626


   I commited my  _WIP  prototype code_ 
`https://github.com/hnail/pulsar/commit/1c67266918168d0c373a2839384362960b5afe4a
 ` without unit-tests to my private repository instead of pull request to 
official master repository . Because i think the change may contain some 
structural adjustment and beyond expectation . 
   so is there pulsar-sql committer or familiar with pulsar-sql can help 
preview the code  and discuss with me ? appreciate you if can  give me some 
suggests or opinions , glad you call me on slack @hnail or comment on this 
issues ,  I will detailedly explain  the modifications ?  
   
   ---
   **code Index:**
   `SchemaInfo -> RowDecoder `(**PulsarRecordCursor**) : 
[PulsarDispatchingRowDecoderFactory.create(SchemaInfo schemaInfo, 
Set<DecoderColumnHandle> 
columns)](https://github.com/hnail/pulsar/blob/sql_support_arrays_maps/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarDispatchingRowDecoderFactory.java#L52)
   `SchemaInfo -> ColumnMetadata `( **PulsarMetadata**): 
[PulsarDispatchingRowDecoderFactory. extractColumnMetadata(SchemaInfo 
schemaInfo, PulsarColumnHandle.HandleKeyValueType handleKeyValueType)  
](https://github.com/hnail/pulsar/blob/sql_support_arrays_maps/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarDispatchingRowDecoderFactory.java#L76)
   
   ---
   code reference `presto-kafka` , With the purpose of  fix  issues-7652 \ 
issues-4747 and support other non-avro schema encoder。
   


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Reply via email to