API for javierluraschi/sparkworker
R Worker for Apache Spark
| Global functions | |
|---|---|
| .onLoad | Source code |
| attach_connection | Source code |
| cleanup.jobj | Source code |
| clearJobjs | Source code |
| compile_sparkworker_jars | Source code |
| connection_is_open | Source code |
| debug_backend | Source code |
| getJobj | Source code |
| getSerdeType | Source code |
| hello | Man page |
| invoke_method | Source code |
| isValidJobj | Source code |
| jobj_create | Source code |
| jobj_info | Source code |
| jobj_inspect | Source code |
| jobj_subclass | Source code |
| jobj_subclass.shell_backend | Source code |
| listToStruct | Source code |
| log | Source code |
| log_error | Source code |
| log_format | Source code |
| log_level | Source code |
| log_session | Source code |
| log_warning | Source code |
| print.spark_jobj | Source code |
| print_jobj | Source code |
| query_gateway_for_port | Source code |
| readArray | Source code |
| readBoolean | Source code |
| readDate | Source code |
| readDeserialize | Source code |
| readDouble | Source code |
| readEnv | Source code |
| readInt | Source code |
| readList | Source code |
| readMultipleObjects | Source code |
| readObject | Source code |
| readRaw | Source code |
| readRawLen | Source code |
| readRowList | Source code |
| readString | Source code |
| readStruct | Source code |
| readTime | Source code |
| readType | Source code |
| readTypedObject | Source code |
| sdf_along | Man page Source code |
| sdf_len | Man page Source code |
| sdf_seq | Man page Source code |
| serializeRow | Source code |
| spark_apply | Source code |
| spark_config_value | Source code |
| spark_connect_gateway | Source code |
| spark_dependencies | Source code |
| spark_gateway_commands | Source code |
| spark_jobj | Source code |
| spark_jobj.default | Source code |
| spark_jobj.spark_jobj | Source code |
| spark_schema_from_rdd | Source code |
| spark_worker_apply | Source code |
| spark_worker_collect | Source code |
| spark_worker_connect | Source code |
| spark_worker_main | Source code |
| update_sources_class | Source code |
| wait_connect_gateway | Source code |
| worker_connection | Source code |
| worker_connection.spark_jobj | Source code |
| worker_invoke | Source code |
| worker_invoke.worker_jobj | Source code |
| worker_invoke_new | Source code |
| worker_invoke_static | Source code |
| writeArgs | Source code |
| writeArray | Source code |
| writeBoolean | Source code |
| writeDate | Source code |
| writeDouble | Source code |
| writeEnv | Source code |
| writeFactor | Source code |
| writeInt | Source code |
| writeJobj | Source code |
| writeList | Source code |
| writeObject | Source code |
| writeRaw | Source code |
| writeRawSerialize | Source code |
| writeRowSerialize | Source code |
| writeString | Source code |
| writeTime | Source code |
| writeType | Source code |
| writeVoid | Source code |
