The API is roughly:
class CustomConverter:
def to_custom(table: pa.RecordBatch) -> pa.RecordBatch:
pass
def from_custom(table: pa.RecordBatch) -> pa.RecordBatch:
pass
They should be registered to a Message type with a schema. Schema will be enforced.
The API is roughly:
They should be registered to a Message type with a schema. Schema will be enforced.