Config

Value Members

1. final def !=(arg0: Any): Boolean

   

   Definition Classes

   AnyRef → Any

2. final def ##(): Int

   

   Definition Classes

   AnyRef → Any

3. final def ==(arg0: Any): Boolean

   

   Definition Classes

   AnyRef → Any

4. val CascadingAppId: String

   

5. val CascadingAppName: String

   

6. val CascadingSerializationTokens: String

   

7. val FlowListeners: String

   

8. val FlowStepListeners: String

   

9. val FlowStepStrategies: String

   

10. val HRavenHistoryUserName: String

    

11. val HadoopNumReducers: String

    

    Parameter that actually controls the number of reduce tasks.

    Parameter that actually controls the number of reduce tasks. Be sure to set this in the JobConf for the *step* not the flow.

12. val HashJoinAutoForceRight: String

    

    Parameter that can be used to determine behavior on the rhs of a hashJoin.

    Parameter that can be used to determine behavior on the rhs of a hashJoin. If true, we try to guess when to auto force to disk before a hashJoin else (the default) we don't try to infer this and the behavior can be dictated by the user manually calling forceToDisk on the rhs or not as they wish.

13. val IoSerializationsKey: String

    

14. val PipeDescriptions: String

    

    Manual description for use in .dot and MR step names set using a withDescription.

15. val ReducerEstimatorOverride: String

    

    Whether estimator should override manually-specified reducers.

16. val ReducerEstimators: String

    

    Name of parameter to specify which class to use as the default estimator.

17. val ScaldingExecutionId: String

    

18. val ScaldingFlowClassName: String

    

19. val ScaldingFlowClassSignature: String

    

20. val ScaldingFlowSubmittedTimestamp: String

    

21. val ScaldingJobArgs: String

    

22. val ScaldingJobArgsSerialized: String

    

23. val ScaldingRequireOrderedSerialization: String

    

24. val ScaldingVersion: String

    

25. val StepDescriptions: String

    

26. val VerboseFileSourceLoggingKey: String

    

27. val WithReducersSetExplicitly: String

    

    Whether the number of reducers has been set explicitly using a withReducers

28. def apply(m: Map[String, String]): Config

    

29. final def asInstanceOf[T0]: T0

    

    Definition Classes

    Any

30. def clone(): AnyRef

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

31. def default: Config

    

32. def defaultFrom(mode: Mode): Config

    

    Merge Config.default with Hadoop config from the mode (if in Hadoop mode)

33. def disjointUnion[K >: String, V >: String](m: Map[K, V], conf: Config): Either[Set[String], Map[K, V]]

    

    Either union these two, or return the keys that overlap

34. val empty: Config

    

35. final def eq(arg0: AnyRef): Boolean

    

    Definition Classes

    AnyRef

36. def equals(arg0: Any): Boolean

    

    Definition Classes

    AnyRef → Any

37. def finalize(): Unit

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

38. implicit def from(m: Map[String, String]): Config

    

39. def fromHadoop(conf: Configuration): Config

    

40. final def getClass(): Class[_]

    

    Definition Classes

    AnyRef → Any

41. def hadoopWithDefaults(conf: Configuration): Config

    

42. def hashCode(): Int

    

    Definition Classes

    AnyRef → Any

43. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

44. def md5Identifier(clazz: Class[_]): String

    

45. final def ne(arg0: AnyRef): Boolean

    

    Definition Classes

    AnyRef

46. final def notify(): Unit

    

    Definition Classes

    AnyRef

47. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

48. def overwrite[K >: String, V >: String](m: Map[K, V], conf: Config): Map[K, V]

    

    This overwrites any keys in m that exist in config.

49. def stringsFrom[K >: String, V >: String](m: Map[K, V]): (Map[K, V], Map[String, String])

    

    Returns all the non-string keys on the left, the string keys/values on the right

50. final def synchronized[T0](arg0: ⇒ T0): T0

    

    Definition Classes

    AnyRef

51. def toString(): String

    

    Definition Classes

    AnyRef → Any

52. def tryFrom(maybeConf: Map[AnyRef, AnyRef]): Try[Config]

    

53. def unitTestDefault: Config

    

54. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

55. final def wait(arg0: Long, arg1: Int): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

56. final def wait(arg0: Long): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )