-
Notifications
You must be signed in to change notification settings - Fork 309
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
make adamLoad public #688
make adamLoad public #688
Conversation
@@ -126,7 +126,7 @@ class ADAMContext(val sc: SparkContext) extends Serializable with Logging { | |||
* @tparam T The type of records to return | |||
* @return An RDD with records of the specified type | |||
*/ | |||
private[rdd] def adamLoad[T](filePath: String, predicate: Option[FilterPredicate] = None, projection: Option[Schema] = None)(implicit ev1: T => SpecificRecord, ev2: Manifest[T]): RDD[T] = { | |||
def adamLoad[T](filePath: String, predicate: Option[FilterPredicate] = None, projection: Option[Schema] = None)(implicit ev1: T => SpecificRecord, ev2: Manifest[T]): RDD[T] = { |
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.
Howabouts we rename this function from adamLoad
to loadParquet
?
Looks good! I think we made it package private under the assumption that you'd use |
Sorry, accidentally closed this! |
Sorry, accidentally closed this! |
@fnothaft any idea what's causing these build failures? The last two failed builds here both had errors like:
This last time it was just scala 2.10 x hadoop 1.0.4, whereas previously it was all 2.10 builds |
fixes bigdatagenomics#687 - remove out-of-date @param scaladocs
rebased and squashed |
Merged! Thanks @ryan-williams! |
fixes #687