MCPcopy
hub / github.com/ray-project/ray / schema

Method schema

python/ray/data/datasource/datasource.py:371–372  ·  view source on GitHub ↗
(self)

Source from the content-addressed store, hash-verified

369 # TODO(justin): We want to remove schema from `ReadTask` later on
370 @property
371 def schema(self) -> Optional["Schema"]:
372 return self._schema
373
374 @property
375 def read_fn(self) -> Callable[[], Iterable[Block]]:

Callers 15

_partition_field_types_to_pa_schemaFunction · 0.45
test_input_data_buffer_does_not_free_inputsFunction · 0.45
_create_simple_schemaFunction · 0.45
_create_tensor_fixed_schemaFunction · 0.45
_create_tensor_variable_schemaFunction · 0.45
_create_object_schemaFunction · 0.45
_create_nested_struct_schemaFunction · 0.45
_create_deep_nested_schemaFunction · 0.45
_create_mixed_complex_schemaFunction · 0.45
test_custom_arrow_data_serializerFunction · 0.45
test_arrow_schema_ipc_serializationFunction · 0.45
test_register_arrow_typesFunction · 0.45

Calls

no outgoing calls

Tested by 15

test_input_data_buffer_does_not_free_inputsFunction · 0.36
_create_simple_schemaFunction · 0.36
_create_tensor_fixed_schemaFunction · 0.36
_create_tensor_variable_schemaFunction · 0.36
_create_object_schemaFunction · 0.36
_create_nested_struct_schemaFunction · 0.36
_create_deep_nested_schemaFunction · 0.36
_create_mixed_complex_schemaFunction · 0.36
test_custom_arrow_data_serializerFunction · 0.36
test_arrow_schema_ipc_serializationFunction · 0.36
test_register_arrow_typesFunction · 0.36
test_random_block_order_schemaFunction · 0.36