-
Notifications
You must be signed in to change notification settings - Fork 308
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
[ADAM-1615] Add transform and transmute APIs to Java, R, and Python #1627
[ADAM-1615] Add transform and transmute APIs to Java, R, and Python #1627
Conversation
Test PASSed. |
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.
Looks good!
} | ||
import org.bdgenomics.adam.sql._ | ||
import scala.reflect.runtime.universe._ | ||
import scala.reflect.runtime.universe.TypeTag |
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.
Can this line be removed?
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.
Ah yeah, it should be removed.
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.
There are a few more instances of this in this PR.
@@ -42,6 +42,8 @@ import org.bdgenomics.utils.interval.array.{ | |||
import scala.collection.JavaConversions._ | |||
import scala.math.max | |||
import scala.reflect.ClassTag | |||
import scala.reflect.runtime.universe._ | |||
import scala.reflect.runtime.universe.TypeTag |
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.
This line can be removed also.
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.
Will review again after rebase
dfFn = self._wrapTransformation(tFn) | ||
|
||
# if no conversion function is provided, try to infer | ||
if convFn is None: |
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.
This method name stuff is brittle, but I can't see any other way to do it
Resolves bigdatagenomics#1615. Adds `GenomicDatasetConversion` class to adam-core API, along with accompanying implementations in `org.bdgenomics.adam.api.java` package. Adds `transformDataFrame` and `transmuteDataFrame` to `GenomicRDD` API. To enable use from Python and R, we provide a `DataFrameConversionWrapper` that wraps the product of an R/Python function in a Spark Java API `Function`.
b5b9a5f
to
6778abd
Compare
Test PASSed. |
Thank you, @fnothaft! |
Resolves #1615. Adds
GenomicDatasetConversion
class to adam-core API, along with accompanying implementations inorg.bdgenomics.adam.api.java
package. AddstransformDataFrame
andtransmuteDataFrame
toGenomicRDD
API. To enable use from Python and R, we provide aDataFrameConversionWrapper
that wraps the product of an R/Python function in a Spark Java APIFunction
.GenomicDataset
.