Skip to content

Commit

Permalink
formatting updates.
Browse files Browse the repository at this point in the history
  • Loading branch information
sritchie committed Dec 15, 2011
1 parent d1ca64b commit 185c23f
Show file tree
Hide file tree
Showing 7 changed files with 25 additions and 32 deletions.
5 changes: 4 additions & 1 deletion .gitignore
Expand Up @@ -14,6 +14,9 @@ autodoc
.settings/
.project
.lein-failures
.lein-deps-sum
.DS_Store
backtype
*.iml
*.ipr
*.iws
.idea
9 changes: 3 additions & 6 deletions src/jvm/backtype/cascading/tap/NullTap.java
Expand Up @@ -2,18 +2,15 @@

import cascading.scheme.Scheme;
import cascading.tap.Tap;
import cascading.tuple.Fields;
import cascading.tuple.Tuple;
import cascading.tuple.TupleEntry;
import cascading.tuple.TupleEntryCollector;
import cascading.tuple.TupleEntryIterator;
import java.io.IOException;
import cascading.tuple.*;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.NullWritable;
import org.apache.hadoop.mapred.JobConf;
import org.apache.hadoop.mapred.OutputCollector;
import org.apache.hadoop.mapred.lib.NullOutputFormat;

import java.io.IOException;


public class NullTap extends Tap {

Expand Down
20 changes: 7 additions & 13 deletions src/jvm/backtype/cascading/tap/PailTap.java
@@ -1,13 +1,6 @@
package backtype.cascading.tap;

import backtype.hadoop.pail.BinaryPailStructure;
import backtype.hadoop.pail.DefaultPailStructure;
import backtype.hadoop.pail.Pail;
import backtype.hadoop.pail.PailFormatFactory;
import backtype.hadoop.pail.PailOutputFormat;
import backtype.hadoop.pail.PailPathLister;
import backtype.hadoop.pail.PailSpec;
import backtype.hadoop.pail.PailStructure;
import backtype.hadoop.pail.*;
import backtype.support.CascadingUtils;
import backtype.support.Utils;
import cascading.flow.Flow;
Expand All @@ -20,11 +13,6 @@
import cascading.tuple.Tuple;
import cascading.tuple.TupleEntry;
import cascading.tuple.hadoop.TupleSerialization;
import java.io.IOException;
import java.io.Serializable;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.BytesWritable;
Expand All @@ -34,6 +22,12 @@
import org.apache.hadoop.mapred.OutputCollector;
import org.apache.log4j.Logger;

import java.io.IOException;
import java.io.Serializable;
import java.util.HashSet;
import java.util.List;
import java.util.Set;


public class PailTap extends Hfs implements FlowListener {
private static Logger LOG = Logger.getLogger(PailTap.class);
Expand Down
4 changes: 2 additions & 2 deletions src/jvm/backtype/cascading/tap/RawSequenceFile.java
@@ -1,17 +1,17 @@
package backtype.cascading.tap;

import cascading.scheme.Scheme;

import cascading.tap.Tap;
import cascading.tap.TapException;
import cascading.tuple.Fields;
import cascading.tuple.Tuple;
import cascading.tuple.TupleEntry;
import java.io.IOException;
import org.apache.hadoop.mapred.JobConf;
import org.apache.hadoop.mapred.OutputCollector;
import org.apache.hadoop.mapred.SequenceFileInputFormat;

import java.io.IOException;


public class RawSequenceFile extends Scheme
{
Expand Down
1 change: 1 addition & 0 deletions src/jvm/backtype/support/CascadingUtils.java
Expand Up @@ -7,6 +7,7 @@
import cascading.pipe.Pipe;
import cascading.tap.Tap;
import cascading.tuple.Fields;

import java.util.Map.Entry;


Expand Down
1 change: 1 addition & 0 deletions test/jvm/backtype/cascading/tap/NullTapTest.java
Expand Up @@ -12,6 +12,7 @@
import cascading.tuple.Tuple;
import cascading.tuple.TupleEntryCollector;
import org.apache.hadoop.mapred.JobConf;

import static backtype.support.TestUtils.*;


Expand Down
17 changes: 7 additions & 10 deletions test/jvm/backtype/cascading/tap/PailTapTest.java
Expand Up @@ -7,27 +7,24 @@
import cascading.flow.FlowConnector;
import cascading.flow.FlowException;
import cascading.flow.FlowProcess;
import cascading.operation.BaseOperation;
import cascading.operation.Filter;
import cascading.operation.FilterCall;
import cascading.operation.Function;
import cascading.operation.FunctionCall;
import cascading.operation.Identity;
import cascading.operation.*;
import cascading.pipe.Each;
import cascading.pipe.Pipe;
import cascading.tap.Tap;
import cascading.tuple.Fields;
import cascading.tuple.Tuple;
import cascading.tuple.TupleEntry;
import java.io.IOException;
import java.util.HashSet;
import java.util.Set;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.BytesWritable;

import java.io.IOException;
import java.util.HashSet;
import java.util.Set;

import static backtype.support.CascadingUtils.identityFlow;
import static backtype.support.TestUtils.*;
import static backtype.support.CascadingUtils.*;


public class PailTapTest extends FSTestCase {
Expand Down

0 comments on commit 185c23f

Please sign in to comment.