File tree Expand file tree Collapse file tree 2 files changed +16
-12
lines changed
tez-tools/tez-tfile-parser/src/main/java/org/apache/tez/tools Expand file tree Collapse file tree 2 files changed +16
-12
lines changed Original file line number Diff line number Diff line change 1818
1919package org .apache .tez .tools ;
2020
21- import com .google .common .base .Objects ;
21+ import java .io .IOException ;
22+ import java .util .regex .Pattern ;
23+
2224import org .apache .hadoop .io .Text ;
2325import org .apache .hadoop .mapreduce .InputFormat ;
2426import org .apache .hadoop .mapreduce .InputSplit ;
3638import org .apache .pig .data .Tuple ;
3739import org .apache .pig .data .TupleFactory ;
3840import org .apache .pig .impl .util .Utils ;
41+
42+ import com .google .common .base .Objects ;
43+
3944import org .slf4j .Logger ;
4045import org .slf4j .LoggerFactory ;
4146
42- import java .io .IOException ;
43- import java .util .regex .Pattern ;
44-
4547/**
4648 * Simple pig loader function (mainly loader) which reads TFile and emits every line as a tuple of
4749 * (machine, key, line). This would be beneficial if huge amount of logs need to be mined.
Original file line number Diff line number Diff line change 1818
1919package org .apache .tez .tools ;
2020
21- import com .google .common .annotations .VisibleForTesting ;
21+ import java .io .BufferedReader ;
22+ import java .io .EOFException ;
23+ import java .io .IOException ;
24+ import java .io .InputStreamReader ;
25+ import java .nio .charset .StandardCharsets ;
26+
2227import org .apache .commons .io .IOUtils ;
23- import org .slf4j .Logger ;
24- import org .slf4j .LoggerFactory ;
2528import org .apache .hadoop .fs .FSDataInputStream ;
2629import org .apache .hadoop .fs .FileStatus ;
2730import org .apache .hadoop .fs .FileSystem ;
3538import org .apache .hadoop .mapreduce .lib .input .FileSplit ;
3639import org .apache .hadoop .util .functional .FutureIO ;
3740
38- import java .io .BufferedReader ;
39- import java .io .EOFException ;
40- import java .io .IOException ;
41- import java .io .InputStreamReader ;
42- import java .nio .charset .StandardCharsets ;
41+ import com .google .common .annotations .VisibleForTesting ;
42+
43+ import org .slf4j .Logger ;
44+ import org .slf4j .LoggerFactory ;
4345
4446/**
4547 * Simple record reader which reads the TFile and emits it as key, value pair.
You can’t perform that action at this time.
0 commit comments