Permalink
Browse files

Rename com.cloudera.crunch -> org.apache.crunch in the Java core

Signed-off-by: Josh Wills <jwills@cloudera.com>
  • Loading branch information...
1 parent 9cf1945 commit 5accc9ac142740937e3114fb33b9a18d3beb1f43 @jwills jwills committed Jul 7, 2012
Showing with 5,274 additions and 4,329 deletions.
  1. +0 −35 src/main/java/com/cloudera/crunch/Emitter.java
  2. +0 −39 src/main/java/com/cloudera/crunch/MapFn.java
  3. +0 −37 src/main/java/com/cloudera/crunch/PGroupedTable.java
  4. +0 −24 src/main/java/com/cloudera/crunch/SourceTarget.java
  5. +0 −25 src/main/java/com/cloudera/crunch/TableSource.java
  6. +0 −28 src/main/java/com/cloudera/crunch/Target.java
  7. +0 −34 src/main/java/com/cloudera/crunch/Tuple.java
  8. +0 −41 src/main/java/com/cloudera/crunch/fn/ExtractKeyFn.java
  9. +0 −36 src/main/java/com/cloudera/crunch/fn/IdentityFn.java
  10. +0 −29 src/main/java/com/cloudera/crunch/fn/MapKeysFn.java
  11. +0 −29 src/main/java/com/cloudera/crunch/fn/MapValuesFn.java
  12. +0 −46 src/main/java/com/cloudera/crunch/impl/mr/emit/IntermediateEmitter.java
  13. +0 −51 src/main/java/com/cloudera/crunch/impl/mr/emit/OutputEmitter.java
  14. +0 −24 src/main/java/com/cloudera/crunch/impl/mr/plan/PlanningParameters.java
  15. +0 −24 src/main/java/com/cloudera/crunch/impl/mr/run/CrunchCombiner.java
  16. +0 −26 src/main/java/com/cloudera/crunch/impl/mr/run/CrunchRuntimeException.java
  17. +0 −30 src/main/java/com/cloudera/crunch/impl/mr/run/NodeContext.java
  18. +0 −31 src/main/java/com/cloudera/crunch/impl/mr/run/RuntimeParameters.java
  19. +0 −24 src/main/java/com/cloudera/crunch/io/FileReaderFactory.java
  20. +0 −25 src/main/java/com/cloudera/crunch/io/MapReduceTarget.java
  21. +0 −22 src/main/java/com/cloudera/crunch/io/OutputHandler.java
  22. +0 −21 src/main/java/com/cloudera/crunch/io/PathTarget.java
  23. +0 −25 src/main/java/com/cloudera/crunch/io/ReadableSource.java
  24. +0 −26 src/main/java/com/cloudera/crunch/io/ReadableSourceTarget.java
  25. +0 −52 src/main/java/com/cloudera/crunch/io/avro/AvroFileSource.java
  26. +0 −31 src/main/java/com/cloudera/crunch/io/avro/AvroFileSourceTarget.java
  27. +0 −36 src/main/java/com/cloudera/crunch/io/impl/FileTableSourceImpl.java
  28. +0 −37 src/main/java/com/cloudera/crunch/io/impl/ReadableSourcePathTargetImpl.java
  29. +0 −36 src/main/java/com/cloudera/crunch/io/impl/ReadableSourceTargetImpl.java
  30. +0 −41 src/main/java/com/cloudera/crunch/io/impl/SourcePathTargetImpl.java
  31. +0 −33 src/main/java/com/cloudera/crunch/io/impl/TableSourcePathTargetImpl.java
  32. +0 −33 src/main/java/com/cloudera/crunch/io/impl/TableSourceTargetImpl.java
  33. +0 −34 src/main/java/com/cloudera/crunch/io/seq/SeqFileHelper.java
  34. +0 −45 src/main/java/com/cloudera/crunch/io/seq/SeqFileSource.java
  35. +0 −35 src/main/java/com/cloudera/crunch/io/seq/SeqFileSourceTarget.java
  36. +0 −45 src/main/java/com/cloudera/crunch/io/seq/SeqFileTableSourceTarget.java
  37. +0 −47 src/main/java/com/cloudera/crunch/io/seq/SeqFileTarget.java
  38. +0 −35 src/main/java/com/cloudera/crunch/io/text/TextFileSourceTarget.java
  39. +0 −51 src/main/java/com/cloudera/crunch/io/text/TextFileTarget.java
  40. +0 −47 src/main/java/com/cloudera/crunch/materialize/MaterializableMap.java
  41. +0 −39 src/main/java/com/cloudera/crunch/test/FileHelper.java
  42. +0 −52 src/main/java/com/cloudera/crunch/test/InMemoryEmitter.java
  43. +0 −38 src/main/java/com/cloudera/crunch/test/TestCounters.java
  44. +0 −38 src/main/java/com/cloudera/crunch/types/Converter.java
  45. +0 −42 src/main/java/com/cloudera/crunch/types/PTableType.java
  46. +0 −36 src/main/java/com/cloudera/crunch/types/avro/ReflectDataFactory.java
  47. +14 −12 src/main/java/{com/cloudera → org/apache}/crunch/CombineFn.java
  48. +14 −12 src/main/java/{com/cloudera → org/apache}/crunch/DoFn.java
  49. +37 −0 src/main/java/org/apache/crunch/Emitter.java
  50. +13 −11 src/main/java/{com/cloudera → org/apache}/crunch/FilterFn.java
  51. +13 −11 src/main/java/{com/cloudera → org/apache}/crunch/GroupingOptions.java
  52. +41 −0 src/main/java/org/apache/crunch/MapFn.java
  53. +16 −14 src/main/java/{com/cloudera → org/apache}/crunch/PCollection.java
  54. +39 −0 src/main/java/org/apache/crunch/PGroupedTable.java
  55. +15 −13 src/main/java/{com/cloudera → org/apache}/crunch/PTable.java
  56. +13 −11 src/main/java/{com/cloudera → org/apache}/crunch/Pair.java
  57. +13 −10 src/main/java/{com/cloudera → org/apache}/crunch/Pipeline.java
  58. +13 −10 src/main/java/{com/cloudera → org/apache}/crunch/PipelineResult.java
  59. +14 −11 src/main/java/{com/cloudera → org/apache}/crunch/Source.java
  60. +27 −0 src/main/java/org/apache/crunch/SourceTarget.java
  61. +28 −0 src/main/java/org/apache/crunch/TableSource.java
  62. +31 −0 src/main/java/org/apache/crunch/Target.java
  63. +36 −0 src/main/java/org/apache/crunch/Tuple.java
  64. +13 −11 src/main/java/{com/cloudera → org/apache}/crunch/Tuple3.java
  65. +13 −11 src/main/java/{com/cloudera → org/apache}/crunch/Tuple4.java
  66. +13 −11 src/main/java/{com/cloudera → org/apache}/crunch/TupleN.java
  67. +15 −12 src/main/java/{com/cloudera → org/apache}/crunch/fn/CompositeMapFn.java
  68. +44 −0 src/main/java/org/apache/crunch/fn/ExtractKeyFn.java
  69. +39 −0 src/main/java/org/apache/crunch/fn/IdentityFn.java
  70. +32 −0 src/main/java/org/apache/crunch/fn/MapKeysFn.java
  71. +32 −0 src/main/java/org/apache/crunch/fn/MapValuesFn.java
  72. +16 −13 src/main/java/{com/cloudera → org/apache}/crunch/fn/PairMapFn.java
  73. +28 −25 src/main/java/{com/cloudera → org/apache}/crunch/impl/mem/MemPipeline.java
  74. +30 −27 src/main/java/{com/cloudera → org/apache}/crunch/impl/mem/collect/MemCollection.java
  75. +24 −21 src/main/java/{com/cloudera → org/apache}/crunch/impl/mem/collect/MemGroupedTable.java
  76. +26 −23 src/main/java/{com/cloudera → org/apache}/crunch/impl/mem/collect/MemTable.java
  77. +37 −35 src/main/java/{com/cloudera → org/apache}/crunch/impl/mr/MRPipeline.java
  78. +16 −13 src/main/java/{com/cloudera → org/apache}/crunch/impl/mr/collect/DoCollectionImpl.java
  79. +20 −17 src/main/java/{com/cloudera → org/apache}/crunch/impl/mr/collect/DoTableImpl.java
  80. +17 −14 src/main/java/{com/cloudera → org/apache}/crunch/impl/mr/collect/InputCollection.java
  81. +19 −16 src/main/java/{com/cloudera → org/apache}/crunch/impl/mr/collect/InputTable.java
  82. +31 −28 src/main/java/{com/cloudera → org/apache}/crunch/impl/mr/collect/PCollectionImpl.java
  83. +23 −20 src/main/java/{com/cloudera → org/apache}/crunch/impl/mr/collect/PGroupedTableImpl.java
  84. +24 −21 src/main/java/{com/cloudera → org/apache}/crunch/impl/mr/collect/PTableBase.java
  85. +16 −13 src/main/java/{com/cloudera → org/apache}/crunch/impl/mr/collect/UnionCollection.java
  86. +18 −15 src/main/java/{com/cloudera → org/apache}/crunch/impl/mr/collect/UnionTable.java
  87. +49 −0 src/main/java/org/apache/crunch/impl/mr/emit/IntermediateEmitter.java
  88. +16 −13 src/main/java/{com/cloudera → org/apache}/crunch/impl/mr/emit/MultipleOutputEmitter.java
  89. +54 −0 src/main/java/org/apache/crunch/impl/mr/emit/OutputEmitter.java
  90. +15 −12 src/main/java/{com/cloudera → org/apache}/crunch/impl/mr/exec/CrunchJob.java
  91. +14 −11 src/main/java/{com/cloudera → org/apache}/crunch/impl/mr/exec/MRExecutor.java
  92. +20 −17 src/main/java/{com/cloudera → org/apache}/crunch/impl/mr/plan/DoNode.java
  93. +13 −10 src/main/java/{com/cloudera → org/apache}/crunch/impl/mr/plan/JobNameBuilder.java
  94. +26 −23 src/main/java/{com/cloudera → org/apache}/crunch/impl/mr/plan/JobPrototype.java
  95. +18 −15 src/main/java/{com/cloudera → org/apache}/crunch/impl/mr/plan/MSCROutputHandler.java
  96. +24 −21 src/main/java/{com/cloudera → org/apache}/crunch/impl/mr/plan/MSCRPlanner.java
  97. +14 −11 src/main/java/{com/cloudera → org/apache}/crunch/impl/mr/plan/NodePath.java
  98. +27 −0 src/main/java/org/apache/crunch/impl/mr/plan/PlanningParameters.java
  99. +27 −0 src/main/java/org/apache/crunch/impl/mr/run/CrunchCombiner.java
  100. +2 −3 src/main/java/{com/cloudera → org/apache}/crunch/impl/mr/run/CrunchInputFormat.java
  101. +1 −2 src/main/java/{com/cloudera → org/apache}/crunch/impl/mr/run/CrunchInputSplit.java
  102. +2 −3 src/main/java/{com/cloudera → org/apache}/crunch/impl/mr/run/CrunchInputs.java
  103. +13 −10 src/main/java/{com/cloudera → org/apache}/crunch/impl/mr/run/CrunchMapper.java
  104. +1 −2 src/main/java/{com/cloudera → org/apache}/crunch/impl/mr/run/CrunchRecordReader.java
  105. +13 −10 src/main/java/{com/cloudera → org/apache}/crunch/impl/mr/run/CrunchReducer.java
  106. +43 −0 src/main/java/org/apache/crunch/impl/mr/run/CrunchRuntimeException.java
  107. +15 −12 src/main/java/{com/cloudera → org/apache}/crunch/impl/mr/run/CrunchTaskContext.java
  108. +33 −0 src/main/java/org/apache/crunch/impl/mr/run/NodeContext.java
  109. +19 −16 src/main/java/{com/cloudera → org/apache}/crunch/impl/mr/run/RTNode.java
  110. +34 −0 src/main/java/org/apache/crunch/impl/mr/run/RuntimeParameters.java
  111. +13 −10 src/main/java/{com/cloudera → org/apache}/crunch/impl/mr/run/TaskAttemptContextFactory.java
  112. +23 −20 src/main/java/{com/cloudera → org/apache}/crunch/io/At.java
  113. +13 −10 src/main/java/{com/cloudera → org/apache}/crunch/io/CompositePathIterable.java
  114. +27 −0 src/main/java/org/apache/crunch/io/FileReaderFactory.java
  115. +26 −23 src/main/java/{com/cloudera → org/apache}/crunch/io/From.java
  116. +28 −0 src/main/java/org/apache/crunch/io/MapReduceTarget.java
  117. +25 −0 src/main/java/org/apache/crunch/io/OutputHandler.java
  118. +24 −0 src/main/java/org/apache/crunch/io/PathTarget.java
  119. +19 −2 src/main/java/{com/cloudera → org/apache}/crunch/io/PathTargetImpl.java
  120. +28 −0 src/main/java/org/apache/crunch/io/ReadableSource.java
  121. +29 −0 src/main/java/org/apache/crunch/io/ReadableSourceTarget.java
  122. +13 −10 src/main/java/{com/cloudera → org/apache}/crunch/io/SourceTargetHelper.java
  123. +19 −16 src/main/java/{com/cloudera → org/apache}/crunch/io/To.java
  124. +16 −13 src/main/java/{com/cloudera → org/apache}/crunch/io/avro/AvroFileReaderFactory.java
  125. +55 −0 src/main/java/org/apache/crunch/io/avro/AvroFileSource.java
  126. +34 −0 src/main/java/org/apache/crunch/io/avro/AvroFileSourceTarget.java
  127. +20 −17 src/main/java/{com/cloudera → org/apache}/crunch/io/avro/AvroFileTarget.java
  128. +20 −17 src/main/java/{com/cloudera → org/apache}/crunch/io/hbase/HBaseSourceTarget.java
  129. +18 −15 src/main/java/{com/cloudera → org/apache}/crunch/io/hbase/HBaseTarget.java
  130. +17 −14 src/main/java/{com/cloudera → org/apache}/crunch/io/impl/FileSourceImpl.java
  131. +39 −0 src/main/java/org/apache/crunch/io/impl/FileTableSourceImpl.java
  132. +18 −15 src/main/java/{com/cloudera → org/apache}/crunch/io/impl/FileTargetImpl.java
  133. +13 −10 src/main/java/{com/cloudera → org/apache}/crunch/io/impl/InputBundle.java
  134. +40 −0 src/main/java/org/apache/crunch/io/impl/ReadableSourcePathTargetImpl.java
  135. +39 −0 src/main/java/org/apache/crunch/io/impl/ReadableSourceTargetImpl.java
  136. +44 −0 src/main/java/org/apache/crunch/io/impl/SourcePathTargetImpl.java
  137. +18 −15 src/main/java/{com/cloudera → org/apache}/crunch/io/impl/SourceTargetImpl.java
  138. +36 −0 src/main/java/org/apache/crunch/io/impl/TableSourcePathTargetImpl.java
  139. +36 −0 src/main/java/org/apache/crunch/io/impl/TableSourceTargetImpl.java
  140. +37 −0 src/main/java/org/apache/crunch/io/seq/SeqFileHelper.java
  141. +16 −13 src/main/java/{com/cloudera → org/apache}/crunch/io/seq/SeqFileReaderFactory.java
  142. +48 −0 src/main/java/org/apache/crunch/io/seq/SeqFileSource.java
  143. +38 −0 src/main/java/org/apache/crunch/io/seq/SeqFileSourceTarget.java
  144. +18 −15 src/main/java/{com/cloudera → org/apache}/crunch/io/seq/SeqFileTableReaderFactory.java
  145. +18 −15 src/main/java/{com/cloudera → org/apache}/crunch/io/seq/SeqFileTableSource.java
  146. +48 −0 src/main/java/org/apache/crunch/io/seq/SeqFileTableSourceTarget.java
  147. +50 −0 src/main/java/org/apache/crunch/io/seq/SeqFileTarget.java
  148. +1 −1 src/main/java/{com/cloudera → org/apache}/crunch/io/text/BZip2TextInputFormat.java
  149. +1 −60 src/main/java/{com/cloudera → org/apache}/crunch/io/text/CBZip2InputStream.java
  150. +18 −15 src/main/java/{com/cloudera → org/apache}/crunch/io/text/TextFileReaderFactory.java
  151. +19 −16 src/main/java/{com/cloudera → org/apache}/crunch/io/text/TextFileSource.java
  152. +38 −0 src/main/java/org/apache/crunch/io/text/TextFileSourceTarget.java
  153. +54 −0 src/main/java/org/apache/crunch/io/text/TextFileTarget.java
  154. +24 −21 src/main/java/{com/cloudera → org/apache}/crunch/lib/Aggregate.java
  155. +20 −17 src/main/java/{com/cloudera → org/apache}/crunch/lib/Cartesian.java
  156. +20 −17 src/main/java/{com/cloudera → org/apache}/crunch/lib/Cogroup.java
  157. +26 −23 src/main/java/{com/cloudera → org/apache}/crunch/lib/Join.java
  158. +22 −19 src/main/java/{com/cloudera → org/apache}/crunch/lib/PTables.java
  159. +16 −13 src/main/java/{com/cloudera → org/apache}/crunch/lib/Sample.java
  160. +21 −18 src/main/java/{com/cloudera → org/apache}/crunch/lib/Set.java
  161. +30 −27 src/main/java/{com/cloudera → org/apache}/crunch/lib/Sort.java
  162. +18 −15 src/main/java/{com/cloudera → org/apache}/crunch/lib/join/FullOuterJoinFn.java
  163. +18 −15 src/main/java/{com/cloudera → org/apache}/crunch/lib/join/InnerJoinFn.java
  164. +20 −17 src/main/java/{com/cloudera → org/apache}/crunch/lib/join/JoinFn.java
  165. +16 −13 src/main/java/{com/cloudera → org/apache}/crunch/lib/join/JoinUtils.java
  166. +18 −15 src/main/java/{com/cloudera → org/apache}/crunch/lib/join/LeftOuterJoinFn.java
  167. +28 −11 src/main/java/{com/cloudera → org/apache}/crunch/lib/join/MapsideJoin.java
  168. +18 −15 src/main/java/{com/cloudera → org/apache}/crunch/lib/join/RightOuterJoinFn.java
  169. +16 −13 src/main/java/{com/cloudera → org/apache}/crunch/materialize/MaterializableIterable.java
  170. +50 −0 src/main/java/org/apache/crunch/materialize/MaterializableMap.java
  171. +42 −0 src/main/java/org/apache/crunch/test/FileHelper.java
  172. +55 −0 src/main/java/org/apache/crunch/test/InMemoryEmitter.java
  173. +41 −0 src/main/java/org/apache/crunch/test/TestCounters.java
  174. +24 −21 src/main/java/{com/cloudera → org/apache}/crunch/tool/CrunchTool.java
  175. +41 −0 src/main/java/org/apache/crunch/types/Converter.java
  176. +18 −16 src/main/java/{com/cloudera → org/apache}/crunch/types/PGroupedTableType.java
  177. +44 −0 src/main/java/org/apache/crunch/types/PTableType.java
  178. +17 −15 src/main/java/{com/cloudera → org/apache}/crunch/types/PType.java
  179. +19 −17 src/main/java/{com/cloudera → org/apache}/crunch/types/PTypeFamily.java
  180. +18 −15 src/main/java/{com/cloudera → org/apache}/crunch/types/PTypeUtils.java
  181. +19 −16 src/main/java/{com/cloudera → org/apache}/crunch/types/TupleFactory.java
  182. +19 −2 src/main/java/{com/cloudera → org/apache}/crunch/types/avro/AvroDeepCopier.java
  183. +20 −17 src/main/java/{com/cloudera → org/apache}/crunch/types/avro/AvroGroupedTableType.java
  184. +1 −2 src/main/java/{com/cloudera → org/apache}/crunch/types/avro/AvroInputFormat.java
  185. +14 −11 src/main/java/{com/cloudera → org/apache}/crunch/types/avro/AvroKeyConverter.java
  186. +3 −4 src/main/java/{com/cloudera → org/apache}/crunch/types/avro/AvroOutputFormat.java
  187. +15 −12 src/main/java/{com/cloudera → org/apache}/crunch/types/avro/AvroPairConverter.java
  188. +1 −2 src/main/java/{com/cloudera → org/apache}/crunch/types/avro/AvroRecordReader.java
  189. +19 −16 src/main/java/{com/cloudera → org/apache}/crunch/types/avro/AvroTableType.java
  190. +20 −17 src/main/java/{com/cloudera → org/apache}/crunch/types/avro/AvroType.java
  191. +24 −21 src/main/java/{com/cloudera → org/apache}/crunch/types/avro/AvroTypeFamily.java
  192. +1 −1 src/main/java/{com/cloudera → org/apache}/crunch/types/avro/AvroUtf8InputFormat.java
  193. +25 −22 src/main/java/{com/cloudera → org/apache}/crunch/types/avro/Avros.java
  194. +39 −0 src/main/java/org/apache/crunch/types/avro/ReflectDataFactory.java
  195. +1 −2 src/main/java/{com/cloudera → org/apache}/crunch/types/avro/SafeAvroSerialization.java
  196. +14 −11 src/main/java/{com/cloudera → org/apache}/crunch/types/writable/GenericArrayWritable.java
  197. +13 −11 src/main/java/{com/cloudera → org/apache}/crunch/types/writable/TextMapWritable.java
  198. +1 −2 src/main/java/{com/cloudera → org/apache}/crunch/types/writable/TupleWritable.java
  199. +19 −16 src/main/java/{com/cloudera → org/apache}/crunch/types/writable/WritableGroupedTableType.java
  200. +15 −12 src/main/java/{com/cloudera → org/apache}/crunch/types/writable/WritablePairConverter.java
  201. +24 −21 src/main/java/{com/cloudera → org/apache}/crunch/types/writable/WritableTableType.java
  202. +20 −17 src/main/java/{com/cloudera → org/apache}/crunch/types/writable/WritableType.java
  203. +25 −22 src/main/java/{com/cloudera → org/apache}/crunch/types/writable/WritableTypeFamily.java
  204. +14 −11 src/main/java/{com/cloudera → org/apache}/crunch/types/writable/WritableValueConverter.java
  205. +25 −22 src/main/java/{com/cloudera → org/apache}/crunch/types/writable/Writables.java
  206. +13 −10 src/main/java/{com/cloudera → org/apache}/crunch/util/Collects.java
  207. +14 −11 src/main/java/{com/cloudera → org/apache}/crunch/util/DistCache.java
  208. +17 −14 src/main/java/{com/cloudera → org/apache}/crunch/util/PTypes.java
  209. +16 −13 src/main/java/{com/cloudera → org/apache}/crunch/util/Protos.java
  210. +17 −14 src/main/java/{com/cloudera → org/apache}/crunch/util/Tuples.java
  211. +0 −1 src/main/java/org/apache/hadoop/mapreduce/lib/jobcontrol/CrunchControlledJob.java
  212. +0 −1 src/main/java/org/apache/hadoop/mapreduce/lib/jobcontrol/CrunchJobControl.java
  213. +1 −1 src/main/java/org/apache/hadoop/mapreduce/lib/output/CrunchMultipleOutputs.java
  214. +1 −1 src/main/resources/log4j.properties
  215. +0 −43 src/test/java/com/cloudera/crunch/fn/ExtractKeyFnTest.java
  216. +0 −38 src/test/java/com/cloudera/crunch/fn/StoreLastEmitter.java
  217. +0 −38 src/test/java/com/cloudera/crunch/impl/mr/plan/JobNameBuilderTest.java
  218. +0 −20 src/test/java/com/cloudera/crunch/lib/SampleTest.java
  219. +0 −35 src/test/java/com/cloudera/crunch/types/avro/AvroTableTypeTest.java
  220. +0 −30 src/test/java/com/cloudera/crunch/types/writable/WritableTableTypeTest.java
  221. +0 −29 src/test/java/com/cloudera/crunch/types/writable/WritableTypeTest.java
  222. +19 −16 src/test/java/{com/cloudera → org/apache}/crunch/CollectionsTest.java
  223. +39 −36 src/test/java/{com/cloudera → org/apache}/crunch/CombineFnTest.java
  224. +13 −10 src/test/java/{com/cloudera → org/apache}/crunch/FilterFnTest.java
  225. +23 −6 src/test/java/{com/cloudera → org/apache}/crunch/MapsTest.java
  226. +24 −7 src/test/java/{com/cloudera → org/apache}/crunch/MaterializeTest.java
  227. +17 −14 src/test/java/{com/cloudera → org/apache}/crunch/MaterializeToMapTest.java
  228. +19 −16 src/test/java/{com/cloudera → org/apache}/crunch/MultipleOutputTest.java
  229. +25 −8 src/test/java/{com/cloudera → org/apache}/crunch/PCollectionGetSizeTest.java
  230. +24 −7 src/test/java/{com/cloudera → org/apache}/crunch/PTableKeyValueTest.java
  231. +23 −20 src/test/java/{com/cloudera → org/apache}/crunch/PageRankTest.java
  232. +13 −10 src/test/java/{com/cloudera → org/apache}/crunch/PairTest.java
  233. +20 −17 src/test/java/{com/cloudera → org/apache}/crunch/TFIDFTest.java
  234. +21 −18 src/test/java/{com/cloudera → org/apache}/crunch/TermFrequencyTest.java
  235. +17 −14 src/test/java/{com/cloudera → org/apache}/crunch/TextPairTest.java
  236. +17 −14 src/test/java/{com/cloudera → org/apache}/crunch/TupleNClassCastBugTest.java
  237. +14 −11 src/test/java/{com/cloudera → org/apache}/crunch/TupleTest.java
  238. +19 −16 src/test/java/{com/cloudera → org/apache}/crunch/WordCountHBaseTest.java
  239. +21 −18 src/test/java/{com/cloudera → org/apache}/crunch/WordCountTest.java
  240. +46 −0 src/test/java/org/apache/crunch/fn/ExtractKeyFnTest.java
  241. +14 −11 src/test/java/{com/cloudera → org/apache}/crunch/fn/MapKeysTest.java
  242. +14 −11 src/test/java/{com/cloudera → org/apache}/crunch/fn/MapValuesTest.java
  243. +15 −12 src/test/java/{com/cloudera → org/apache}/crunch/fn/PairMapTest.java
  244. +41 −0 src/test/java/org/apache/crunch/fn/StoreLastEmitter.java
  245. +15 −12 src/test/java/{com/cloudera → org/apache}/crunch/impl/mem/MemPipelineFileWritingTest.java
  246. +22 −5 src/test/java/{com/cloudera → org/apache}/crunch/impl/mr/MRPipelineTest.java
  247. +23 −6 src/test/java/{com/cloudera → org/apache}/crunch/impl/mr/collect/DoCollectionImplTest.java
  248. +24 −7 src/test/java/{com/cloudera → org/apache}/crunch/impl/mr/collect/DoTableImplTest.java
  249. +30 −13 src/test/java/{com/cloudera → org/apache}/crunch/impl/mr/collect/UnionCollectionTest.java
  250. +41 −0 src/test/java/org/apache/crunch/impl/mr/plan/JobNameBuilderTest.java
  251. +21 −4 src/test/java/{com/cloudera → org/apache}/crunch/io/CompositePathIterableTest.java
  252. +18 −1 src/test/java/{com/cloudera → org/apache}/crunch/io/SourceTargetHelperTest.java
  253. +15 −12 src/test/java/{com/cloudera → org/apache}/crunch/io/avro/AvroFileReaderFactoryTest.java
  254. +20 −17 src/test/java/{com/cloudera → org/apache}/crunch/io/avro/AvroFileSourceTargetTest.java
  255. +16 −13 src/test/java/{com/cloudera → org/apache}/crunch/io/avro/AvroFileSourceTest.java
  256. +24 −7 src/test/java/{com/cloudera → org/apache}/crunch/io/avro/AvroReflectTest.java
  257. +30 −27 src/test/java/{com/cloudera → org/apache}/crunch/lib/AggregateTest.java
  258. +14 −12 src/test/java/{com/cloudera → org/apache}/crunch/lib/AvroIndexedRecordPartitionerTest.java
  259. +21 −18 src/test/java/{com/cloudera → org/apache}/crunch/lib/AvroTypeSortTest.java
  260. +22 −5 src/test/java/{com/cloudera → org/apache}/crunch/lib/CartesianTest.java
  261. +29 −26 src/test/java/{com/cloudera → org/apache}/crunch/lib/CogroupTest.java
  262. +37 −0 src/test/java/org/apache/crunch/lib/SampleTest.java
  263. +22 −19 src/test/java/{com/cloudera → org/apache}/crunch/lib/SetTest.java
  264. +33 −30 src/test/java/{com/cloudera → org/apache}/crunch/lib/SortTest.java
  265. +23 −20 src/test/java/{com/cloudera → org/apache}/crunch/lib/SpecificAvroGroupByTest.java
  266. +20 −3 src/test/java/{com/cloudera → org/apache}/crunch/lib/TupleWritablePartitionerTest.java
  267. +15 −12 src/test/java/{com/cloudera → org/apache}/crunch/lib/join/FullOuterJoinTest.java
  268. +15 −12 src/test/java/{com/cloudera → org/apache}/crunch/lib/join/InnerJoinTest.java
  269. +27 −24 src/test/java/{com/cloudera → org/apache}/crunch/lib/join/JoinTester.java
  270. +15 −12 src/test/java/{com/cloudera → org/apache}/crunch/lib/join/LeftOuterJoinTest.java
  271. +28 −11 src/test/java/{com/cloudera → org/apache}/crunch/lib/join/MapsideJoinTest.java
  272. +23 −20 src/test/java/{com/cloudera → org/apache}/crunch/lib/join/MultiAvroSchemaJoinTest.java
  273. +15 −12 src/test/java/{com/cloudera → org/apache}/crunch/lib/join/RightOuterJoinTest.java
  274. +15 −12 src/test/java/{com/cloudera → org/apache}/crunch/test/CountersTest.java
  275. +33 −21 src/test/java/{com/cloudera → org/apache}/crunch/test/Employee.java
  276. +33 −21 src/test/java/{com/cloudera → org/apache}/crunch/test/Person.java
  277. +20 −17 src/test/java/{com/cloudera → org/apache}/crunch/types/PTypeUtilsTest.java
  278. +20 −3 src/test/java/{com/cloudera → org/apache}/crunch/types/avro/AvroDeepCopierTest.java
  279. +21 −4 src/test/java/{com/cloudera → org/apache}/crunch/types/avro/AvroGroupedTableTypeTest.java
  280. +52 −0 src/test/java/org/apache/crunch/types/avro/AvroTableTypeTest.java
  281. +19 −2 src/test/java/{com/cloudera → org/apache}/crunch/types/avro/AvroTypeTest.java
  282. +20 −17 src/test/java/{com/cloudera → org/apache}/crunch/types/avro/AvrosTest.java
  283. +20 −3 src/test/java/{com/cloudera → org/apache}/crunch/types/writable/WritableGroupedTableTypeTest.java
  284. +47 −0 src/test/java/org/apache/crunch/types/writable/WritableTableTypeTest.java
  285. +46 −0 src/test/java/org/apache/crunch/types/writable/WritableTypeTest.java
  286. +19 −16 src/test/java/{com/cloudera → org/apache}/crunch/types/writable/WritablesTest.java
  287. +13 −10 src/test/java/{com/cloudera → org/apache}/crunch/util/DistCacheTest.java
@@ -1,35 +0,0 @@
-/**
- * Copyright (c) 2011, Cloudera, Inc. All Rights Reserved.
- *
- * Cloudera, Inc. licenses this file to you under the Apache License,
- * Version 2.0 (the "License"). You may not use this file except in
- * compliance with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * This software is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
- * CONDITIONS OF ANY KIND, either express or implied. See the License for
- * the specific language governing permissions and limitations under the
- * License.
- */
-
-package com.cloudera.crunch;
-
-/**
- * Interface for writing outputs from a {@link DoFn}.
- *
- */
-public interface Emitter<T> {
- /**
- * Write the emitted value to the next stage of the pipeline.
- *
- * @param emitted The value to write
- */
- void emit(T emitted);
-
- /**
- * Flushes any values cached by this emitter. Called during the
- * cleanup stage.
- */
- void flush();
-}
@@ -1,39 +0,0 @@
-/**
- * Copyright (c) 2011, Cloudera, Inc. All Rights Reserved.
- *
- * Cloudera, Inc. licenses this file to you under the Apache License,
- * Version 2.0 (the "License"). You may not use this file except in
- * compliance with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * This software is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
- * CONDITIONS OF ANY KIND, either express or implied. See the License for
- * the specific language governing permissions and limitations under the
- * License.
- */
-
-package com.cloudera.crunch;
-
-/**
- * A {@link DoFn} for the common case of emitting exactly one value
- * for each input record.
- *
- */
-public abstract class MapFn<S, T> extends DoFn<S, T> {
-
- /**
- * Maps the given input into an instance of the output type.
- */
- public abstract T map(S input);
-
- @Override
- public void process(S input, Emitter<T> emitter) {
- emitter.emit(map(input));
- }
-
- @Override
- public float scaleFactor() {
- return 1.0f;
- }
-}
@@ -1,37 +0,0 @@
-/**
- * Copyright (c) 2011, Cloudera, Inc. All Rights Reserved.
- *
- * Cloudera, Inc. licenses this file to you under the Apache License,
- * Version 2.0 (the "License"). You may not use this file except in
- * compliance with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * This software is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
- * CONDITIONS OF ANY KIND, either express or implied. See the License for
- * the specific language governing permissions and limitations under the
- * License.
- */
-
-package com.cloudera.crunch;
-
-/**
- * The Crunch representation of a grouped {@link PTable}.
- *
- */
-public interface PGroupedTable<K, V> extends PCollection<Pair<K, Iterable<V>>> {
- /**
- * Combines the values of this grouping using the given {@code CombineFn}.
- *
- * @param combineFn The combiner function
- * @return A {@code PTable} where each key has a single value
- */
- PTable<K, V> combineValues(CombineFn<K, V> combineFn);
-
- /**
- * Convert this grouping back into a multimap.
- *
- * @return an ungrouped version of the data in this {@code PGroupedTable}.
- */
- PTable<K, V> ungroup();
-}
@@ -1,24 +0,0 @@
-/**
- * Copyright (c) 2011, Cloudera, Inc. All Rights Reserved.
- *
- * Cloudera, Inc. licenses this file to you under the Apache License,
- * Version 2.0 (the "License"). You may not use this file except in
- * compliance with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * This software is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
- * CONDITIONS OF ANY KIND, either express or implied. See the License for
- * the specific language governing permissions and limitations under the
- * License.
- */
-package com.cloudera.crunch;
-
-
-/**
- * An interface for classes that implement both the {@code Source} and
- * the {@code Target} interfaces.
- *
- */
-public interface SourceTarget<T> extends Source<T>, Target {
-}
@@ -1,25 +0,0 @@
-/**
- * Copyright (c) 2011, Cloudera, Inc. All Rights Reserved.
- *
- * Cloudera, Inc. licenses this file to you under the Apache License,
- * Version 2.0 (the "License"). You may not use this file except in
- * compliance with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * This software is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
- * CONDITIONS OF ANY KIND, either express or implied. See the License for
- * the specific language governing permissions and limitations under the
- * License.
- */
-package com.cloudera.crunch;
-
-import com.cloudera.crunch.types.PTableType;
-
-/**
- * The interface {@code Source} implementations that return a {@link PTable}.
- *
- */
-public interface TableSource<K, V> extends Source<Pair<K, V>> {
- PTableType<K, V> getTableType();
-}
@@ -1,28 +0,0 @@
-/**
- * Copyright (c) 2011, Cloudera, Inc. All Rights Reserved.
- *
- * Cloudera, Inc. licenses this file to you under the Apache License,
- * Version 2.0 (the "License"). You may not use this file except in
- * compliance with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * This software is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
- * CONDITIONS OF ANY KIND, either express or implied. See the License for
- * the specific language governing permissions and limitations under the
- * License.
- */
-package com.cloudera.crunch;
-
-import com.cloudera.crunch.io.OutputHandler;
-import com.cloudera.crunch.types.PType;
-
-/**
- * A {@code Target} represents the output destination of a Crunch job.
- *
- */
-public interface Target {
- boolean accept(OutputHandler handler, PType<?> ptype);
-
- <T> SourceTarget<T> asSourceTarget(PType<T> ptype);
-}
@@ -1,34 +0,0 @@
-/**
- * Copyright (c) 2011, Cloudera, Inc. All Rights Reserved.
- *
- * Cloudera, Inc. licenses this file to you under the Apache License,
- * Version 2.0 (the "License"). You may not use this file except in
- * compliance with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * This software is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
- * CONDITIONS OF ANY KIND, either express or implied. See the License for
- * the specific language governing permissions and limitations under the
- * License.
- */
-
-package com.cloudera.crunch;
-
-/**
- * A fixed-size collection of Objects, used in Crunch for representing
- * joins between {@code PCollection}s.
- *
- */
-public interface Tuple {
-
- /**
- * Returns the Object at the given index.
- */
- Object get(int index);
-
- /**
- * Returns the number of elements in this Tuple.
- */
- int size();
-}
@@ -1,41 +0,0 @@
-/**
- * Copyright (c) 2012, Cloudera, Inc. All Rights Reserved.
- *
- * Cloudera, Inc. licenses this file to you under the Apache License,
- * Version 2.0 (the "License"). You may not use this file except in
- * compliance with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * This software is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
- * CONDITIONS OF ANY KIND, either express or implied. See the License for
- * the specific language governing permissions and limitations under the
- * License.
- */
-package com.cloudera.crunch.fn;
-
-import com.cloudera.crunch.MapFn;
-import com.cloudera.crunch.Pair;
-
-/**
- * Wrapper function for converting a {@code MapFn} into a key-value pair that
- * is used to convert from a {@code PCollection<V>} to a {@code PTable<K, V>}.
- */
-public class ExtractKeyFn<K, V> extends MapFn<V, Pair<K, V>> {
-
- private final MapFn<V, K> mapFn;
-
- public ExtractKeyFn(MapFn<V, K> mapFn) {
- this.mapFn = mapFn;
- }
-
- @Override
- public void initialize() {
- this.mapFn.setContext(getContext());
- }
-
- @Override
- public Pair<K, V> map(V input) {
- return Pair.of(mapFn.map(input), input);
- }
-}
@@ -1,36 +0,0 @@
-/**
- * Copyright (c) 2011, Cloudera, Inc. All Rights Reserved.
- *
- * Cloudera, Inc. licenses this file to you under the Apache License,
- * Version 2.0 (the "License"). You may not use this file except in
- * compliance with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * This software is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
- * CONDITIONS OF ANY KIND, either express or implied. See the License for
- * the specific language governing permissions and limitations under the
- * License.
- */
-package com.cloudera.crunch.fn;
-
-import com.cloudera.crunch.MapFn;
-
-public class IdentityFn<T> extends MapFn<T, T> {
-
- private static final IdentityFn<Object> INSTANCE = new IdentityFn<Object>();
-
- @SuppressWarnings("unchecked")
- public static <T> IdentityFn<T> getInstance() {
- return (IdentityFn<T>) INSTANCE;
- }
-
- // Non-instantiable
- private IdentityFn() {
- }
-
- @Override
- public T map(T input) {
- return input;
- }
-}
@@ -1,29 +0,0 @@
-/**
- * Copyright (c) 2011, Cloudera, Inc. All Rights Reserved.
- *
- * Cloudera, Inc. licenses this file to you under the Apache License,
- * Version 2.0 (the "License"). You may not use this file except in
- * compliance with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * This software is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
- * CONDITIONS OF ANY KIND, either express or implied. See the License for
- * the specific language governing permissions and limitations under the
- * License.
- */
-package com.cloudera.crunch.fn;
-
-import com.cloudera.crunch.DoFn;
-import com.cloudera.crunch.Emitter;
-import com.cloudera.crunch.Pair;
-
-public abstract class MapKeysFn<K1, K2, V> extends DoFn<Pair<K1, V>, Pair<K2, V>> {
-
- @Override
- public void process(Pair<K1, V> input, Emitter<Pair<K2, V>> emitter) {
- emitter.emit(Pair.of(map(input.first()), input.second()));
- }
-
- public abstract K2 map(K1 k1);
-}
@@ -1,29 +0,0 @@
-/**
- * Copyright (c) 2011, Cloudera, Inc. All Rights Reserved.
- *
- * Cloudera, Inc. licenses this file to you under the Apache License,
- * Version 2.0 (the "License"). You may not use this file except in
- * compliance with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * This software is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
- * CONDITIONS OF ANY KIND, either express or implied. See the License for
- * the specific language governing permissions and limitations under the
- * License.
- */
-package com.cloudera.crunch.fn;
-
-import com.cloudera.crunch.DoFn;
-import com.cloudera.crunch.Emitter;
-import com.cloudera.crunch.Pair;
-
-public abstract class MapValuesFn<K, V1, V2> extends DoFn<Pair<K, V1>, Pair<K, V2>> {
-
- @Override
- public void process(Pair<K, V1> input, Emitter<Pair<K, V2>> emitter) {
- emitter.emit(Pair.of(input.first(), map(input.second())));
- }
-
- public abstract V2 map(V1 v);
-}
Oops, something went wrong.

0 comments on commit 5accc9a

Please sign in to comment.