jixuan1989
/
IoTDB
mirror of https://github.com/apache/iotdb
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Revert "change hadoop package name (#452)" (#454) 

This reverts rename hadoop package , commit 42c62e7e15.
This commit is contained in:
Jialin Qiao 2019-10-17 20:32:20 +08:00 committed by GitHub
parent 42c62e7e15
commit 9f3ff8fb94
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
15 changed files with 21 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
docs/Documentation-CHN/UserGuide/9-Tools-Hadoop.md
View File

@ -152,7 +152,7 @@ TSFInputFormat将tsfile中的数据以多个`MapWritable`记录的形式返回
}
```
> 注意: 完整的代码示例可以在如下链接中找到：https://github.com/apache/incubator-iotdb/blob/master/example/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFMRReadExample.java
> 注意: 完整的代码示例可以在如下链接中找到：https://github.com/apache/incubator-iotdb/blob/master/example/hadoop/src/main/java/org/apache/iotdb/tsfile/hadoop/TSFMRReadExample.java
### 写示例: 计算平均数并写入Tsfile中
@ -213,4 +213,4 @@ TSFInputFormat将tsfile中的数据以多个`MapWritable`记录的形式返回
}
}
```
> 注意: 完整的代码示例可以在如下链接中找到：https://github.com/apache/incubator-iotdb/blob/master/example/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSMRWriteExample.java
> 注意: 完整的代码示例可以在如下链接中找到：https://github.com/apache/incubator-iotdb/blob/master/example/hadoop/src/main/java/org/apache/iotdb/tsfile/hadoop/TSMRWriteExample.java

4
docs/Documentation/UserGuide/9-Tools-Hadoop.md
View File

@ -149,7 +149,7 @@ Then, the `mapper` and `reducer` class is how you deal with the `MapWritable` pr
}
```
> Note: For the complete code, please see the following link: https://github.com/apache/incubator-iotdb/blob/master/example/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFMRReadExample.java
> Note: For the complete code, please see the following link: https://github.com/apache/incubator-iotdb/blob/master/example/hadoop/src/main/java/org/apache/iotdb/tsfile/hadoop/TSFMRReadExample.java
### Write Example: write the average into Tsfile
@ -210,4 +210,4 @@ Then, the `mapper` and `reducer` class is how you deal with the `MapWritable` pr
}
}
```
> Note: For the complete code, please see the following link: https://github.com/apache/incubator-iotdb/blob/master/example/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSMRWriteExample.java
> Note: For the complete code, please see the following link: https://github.com/apache/incubator-iotdb/blob/master/example/hadoop/src/main/java/org/apache/iotdb/tsfile/hadoop/TSMRWriteExample.java

2
example/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFMRReadExample.java → example/hadoop/src/main/java/org/apache/iotdb/tsfile/hadoop/TSFMRReadExample.java
View File

@ -16,7 +16,7 @@
* specific language governing permissions and limitations
* under the License.
*/
package org.apache.iotdb.hadoop.tsfile;
package org.apache.iotdb.tsfile.hadoop;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;

4
example/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSMRWriteExample.java → example/hadoop/src/main/java/org/apache/iotdb/tsfile/hadoop/TSMRWriteExample.java
View File

@ -16,7 +16,7 @@
* specific language governing permissions and limitations
* under the License.
*/
package org.apache.iotdb.hadoop.tsfile;
package org.apache.iotdb.tsfile.hadoop;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
@ -25,9 +25,9 @@ import org.apache.hadoop.io.*;
import org.apache.hadoop.mapreduce.Job;
import org.apache.hadoop.mapreduce.Mapper;
import org.apache.hadoop.mapreduce.Reducer;
import org.apache.iotdb.hadoop.tsfile.record.HDFSTSRecord;
import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;
import org.apache.iotdb.tsfile.file.metadata.enums.TSEncoding;
import org.apache.iotdb.tsfile.hadoop.record.HDFSTSRecord;
import org.apache.iotdb.tsfile.write.record.datapoint.DataPoint;
import org.apache.iotdb.tsfile.write.record.datapoint.DoubleDataPoint;
import org.apache.iotdb.tsfile.write.record.datapoint.LongDataPoint;

2
example/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TsFileHelper.java → example/hadoop/src/main/java/org/apache/iotdb/tsfile/hadoop/TsFileHelper.java
View File

@ -16,7 +16,7 @@
* specific language governing permissions and limitations
* under the License.
*/
package org.apache.iotdb.hadoop.tsfile;
package org.apache.iotdb.tsfile.hadoop;
import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;
import org.apache.iotdb.tsfile.file.metadata.enums.TSEncoding;

2
hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFHadoopException.java → hadoop/src/main/java/org/apache/iotdb/tsfile/hadoop/TSFHadoopException.java
View File

@ -16,7 +16,7 @@
* specific language governing permissions and limitations
* under the License.
*/
package org.apache.iotdb.hadoop.tsfile;
package org.apache.iotdb.tsfile.hadoop;
public class TSFHadoopException extends Exception {

2
hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFInputFormat.java → hadoop/src/main/java/org/apache/iotdb/tsfile/hadoop/TSFInputFormat.java
View File

@ -16,7 +16,7 @@
* specific language governing permissions and limitations
* under the License.
*/
package org.apache.iotdb.hadoop.tsfile;
package org.apache.iotdb.tsfile.hadoop;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.BlockLocation;

2
hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFInputSplit.java → hadoop/src/main/java/org/apache/iotdb/tsfile/hadoop/TSFInputSplit.java
View File

@ -16,7 +16,7 @@
* specific language governing permissions and limitations
* under the License.
*/
package org.apache.iotdb.hadoop.tsfile;
package org.apache.iotdb.tsfile.hadoop;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.Writable;

4
hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFOutputFormat.java → hadoop/src/main/java/org/apache/iotdb/tsfile/hadoop/TSFOutputFormat.java
View File

@ -16,14 +16,14 @@
* specific language governing permissions and limitations
* under the License.
*/
package org.apache.iotdb.hadoop.tsfile;
package org.apache.iotdb.tsfile.hadoop;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.NullWritable;
import org.apache.hadoop.mapreduce.RecordWriter;
import org.apache.hadoop.mapreduce.TaskAttemptContext;
import org.apache.hadoop.mapreduce.lib.output.FileOutputFormat;
import org.apache.iotdb.hadoop.tsfile.record.HDFSTSRecord;
import org.apache.iotdb.tsfile.hadoop.record.HDFSTSRecord;
import org.apache.iotdb.tsfile.write.schema.Schema;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

2
hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFRecordReader.java → hadoop/src/main/java/org/apache/iotdb/tsfile/hadoop/TSFRecordReader.java
View File

@ -16,7 +16,7 @@
* specific language governing permissions and limitations
* under the License.
*/
package org.apache.iotdb.hadoop.tsfile;
package org.apache.iotdb.tsfile.hadoop;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.io.*;

4
hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFRecordWriter.java → hadoop/src/main/java/org/apache/iotdb/tsfile/hadoop/TSFRecordWriter.java
View File

@ -16,15 +16,15 @@
* specific language governing permissions and limitations
* under the License.
*/
package org.apache.iotdb.hadoop.tsfile;
package org.apache.iotdb.tsfile.hadoop;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.NullWritable;
import org.apache.hadoop.mapreduce.RecordWriter;
import org.apache.hadoop.mapreduce.TaskAttemptContext;
import org.apache.iotdb.hadoop.tsfile.record.HDFSTSRecord;
import org.apache.iotdb.tsfile.exception.write.WriteProcessException;
import org.apache.iotdb.tsfile.fileSystem.HDFSOutput;
import org.apache.iotdb.tsfile.hadoop.record.HDFSTSRecord;
import org.apache.iotdb.tsfile.write.TsFileWriter;
import org.apache.iotdb.tsfile.write.schema.Schema;
import org.slf4j.Logger;

2
hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/record/HDFSTSRecord.java → hadoop/src/main/java/org/apache/iotdb/tsfile/hadoop/record/HDFSTSRecord.java
View File

@ -16,7 +16,7 @@
* specific language governing permissions and limitations
* under the License.
*/
package org.apache.iotdb.hadoop.tsfile.record;
package org.apache.iotdb.tsfile.hadoop.record;
import org.apache.hadoop.io.Writable;
import org.apache.iotdb.tsfile.exception.write.UnSupportedDataTypeException;

2
hadoop/src/test/java/org/apache/iotdb/hadoop/tsfile/TSFHadoopTest.java → hadoop/src/test/java/org/apache/iotdb/tsfile/hadoop/TSFHadoopTest.java
View File

@ -16,7 +16,7 @@
* specific language governing permissions and limitations
* under the License.
*/
package org.apache.iotdb.hadoop.tsfile;
package org.apache.iotdb.tsfile.hadoop;
import org.apache.hadoop.io.*;
import org.apache.hadoop.mapreduce.InputSplit;

4
hadoop/src/test/java/org/apache/iotdb/hadoop/tsfile/TSFInputSplitTest.java → hadoop/src/test/java/org/apache/iotdb/tsfile/hadoop/TSFInputSplitTest.java
View File

@ -16,7 +16,7 @@
* specific language governing permissions and limitations
* under the License.
*/
package org.apache.iotdb.hadoop.tsfile;
package org.apache.iotdb.tsfile.hadoop;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.DataInputBuffer;
@ -32,7 +32,7 @@ import static org.hamcrest.core.Is.is;
import static org.junit.Assert.*;
/**
* Test the {@link TSFInputSplit}
* Test the {@link org.apache.iotdb.tsfile.hadoop.TSFInputSplit}
* Assert the readFields function and write function is right
*
* @author Yuan Tian

2
hadoop/src/test/java/org/apache/iotdb/hadoop/tsfile/TsFileTestHelper.java → hadoop/src/test/java/org/apache/iotdb/tsfile/hadoop/TsFileTestHelper.java
View File

@ -16,7 +16,7 @@
* specific language governing permissions and limitations
* under the License.
*/
package org.apache.iotdb.hadoop.tsfile;
package org.apache.iotdb.tsfile.hadoop;
import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;
import org.apache.iotdb.tsfile.file.metadata.enums.TSEncoding;