This is an automated email from the ASF dual-hosted git repository.
lta pushed a change to branch refactor_iotdb_for_cluster
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.
from 44afe73 Merge branch 'refactor_iotdb_for_cluster' of
github.com:apache/incubator-iotdb into refactor_iotdb_for_cluster
add 3568b32 [IOTDB-64] TsFile-Spark-Connector update (#108)
add b1b35f6 fix bug about BOOLEAN
add bf62685 Update QueryConstant.java
add ec72e4e Merge pull request #173 from LeiRui/master
add 80f97e7 Merge branch 'master' into refactor_iotdb_for_cluster
No new revisions were added by this update.
Summary of changes:
.travis.yml | 27 +-
.../Documentation/UserGuideV0.7.0/7-Tools-spark.md | 286 ++++----
pom.xml | 6 +-
spark/README.md | 407 +++++++----
spark/pom.xml | 7 +-
.../org/apache/iotdb/tsfile/io/CreateTSFile.java | 150 ----
.../java/org/apache/iotdb/tsfile/io/HDFSInput.java | 147 ++++
.../apache/iotdb/tsfile/io/HDFSInputStream.java | 111 ---
.../io/{HDFSOutputStream.java => HDFSOutput.java} | 52 +-
.../apache/iotdb/tsfile/io/TsFileOutputFormat.java | 10 +-
.../apache/iotdb/tsfile/io/TsFileRecordWriter.java | 19 +-
.../java/org/apache/iotdb/tsfile/qp/Executor.java | 51 --
.../org/apache/iotdb/tsfile/qp/QueryProcessor.java | 153 -----
.../iotdb/tsfile/qp/common/BasicOperator.java | 75 --
.../iotdb/tsfile/qp/common/FilterOperator.java | 157 -----
.../apache/iotdb/tsfile/qp/common/Operator.java | 47 --
.../apache/iotdb/tsfile/qp/common/SQLConstant.java | 150 ----
.../apache/iotdb/tsfile/qp/common/SingleQuery.java | 63 --
.../apache/iotdb/tsfile/qp/common/TSQueryPlan.java | 63 --
.../qp/exception/BasicOperatorException.java | 34 -
.../tsfile/qp/exception/DNFOptimizeException.java | 34 -
.../qp/exception/LogicalOptimizeException.java | 33 -
.../tsfile/qp/exception/MergeFilterException.java | 30 -
.../qp/exception/QueryOperatorException.java | 29 -
.../qp/exception/QueryProcessorException.java | 41 --
.../tsfile/qp/exception/RemoveNotException.java | 34 -
.../tsfile/qp/optimizer/DNFFilterOptimizer.java | 157 -----
.../tsfile/qp/optimizer/IFilterOptimizer.java | 34 -
.../qp/optimizer/MergeSingleFilterOptimizer.java | 141 ----
.../tsfile/qp/optimizer/PhysicalOptimizer.java | 228 ------
.../tsfile/qp/optimizer/RemoveNotOptimizer.java | 108 ---
.../scala/org/apache/iotdb/tsfile/Converter.scala | 764 ++++++++++++---------
.../org/apache/iotdb/tsfile/DefaultSource.scala | 178 ++---
.../apache/iotdb/tsfile/TsFileOutputWriter.scala | 52 +-
.../apache/iotdb/tsfile/TsFileWriterFactory.scala | 42 +-
.../scala/org/apache/iotdb/tsfile/package.scala | 36 +-
spark/src/test/resources/test.tsfile | Bin 1406 -> 0 bytes
.../cn/edu/tsinghua/tsfile/ConverterTest.scala | 130 ----
.../scala/cn/edu/tsinghua/tsfile/TSFileSuit.scala | 194 ------
.../scala/org/apache/iotdb/tool/TsFileExample.java | 106 +++
.../scala/org/apache/iotdb/tool/TsFileWrite.java | 215 ++++++
.../org/apache/iotdb/tsfile/ConverterTest.scala | 266 +++++++
.../org/apache/iotdb/tsfile/HDFSInputTest.java | 79 +++
.../scala/org/apache/iotdb/tsfile/TSFileSuit.scala | 217 ++++++
.../tsfile/common/constant/QueryConstant.java | 9 +
.../iotdb/tsfile/read/TsFileSequenceReader.java | 2 +-
.../apache/iotdb/tsfile/read/common/TimeRange.java | 289 ++++++++
.../tsfile/read/controller/MetadataQuerier.java | 40 ++
.../read/controller/MetadataQuerierByFileImpl.java | 132 +++-
.../query/executor/ExecutorWithTimeGenerator.java | 33 +-
.../tsfile/read/query/executor/TsFileExecutor.java | 64 +-
.../apache/iotdb/tsfile/write/TsFileWriter.java | 12 +
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 11 +
.../iotdb/tsfile/read/ReadInPartitionTest.java | 158 +++++
.../org/apache/iotdb/tsfile/read/ReadTest.java | 2 +-
.../iotdb/tsfile/read/common/TimeRangeTest.java | 225 ++++++
.../controller/MetadataQuerierByFileImplTest.java | 57 +-
57 files changed, 3075 insertions(+), 3122 deletions(-)
delete mode 100755
spark/src/main/java/org/apache/iotdb/tsfile/io/CreateTSFile.java
create mode 100644
spark/src/main/java/org/apache/iotdb/tsfile/io/HDFSInput.java
delete mode 100644
spark/src/main/java/org/apache/iotdb/tsfile/io/HDFSInputStream.java
rename spark/src/main/java/org/apache/iotdb/tsfile/io/{HDFSOutputStream.java
=> HDFSOutput.java} (67%)
delete mode 100755 spark/src/main/java/org/apache/iotdb/tsfile/qp/Executor.java
delete mode 100755
spark/src/main/java/org/apache/iotdb/tsfile/qp/QueryProcessor.java
delete mode 100755
spark/src/main/java/org/apache/iotdb/tsfile/qp/common/BasicOperator.java
delete mode 100755
spark/src/main/java/org/apache/iotdb/tsfile/qp/common/FilterOperator.java
delete mode 100755
spark/src/main/java/org/apache/iotdb/tsfile/qp/common/Operator.java
delete mode 100644
spark/src/main/java/org/apache/iotdb/tsfile/qp/common/SQLConstant.java
delete mode 100755
spark/src/main/java/org/apache/iotdb/tsfile/qp/common/SingleQuery.java
delete mode 100755
spark/src/main/java/org/apache/iotdb/tsfile/qp/common/TSQueryPlan.java
delete mode 100755
spark/src/main/java/org/apache/iotdb/tsfile/qp/exception/BasicOperatorException.java
delete mode 100755
spark/src/main/java/org/apache/iotdb/tsfile/qp/exception/DNFOptimizeException.java
delete mode 100755
spark/src/main/java/org/apache/iotdb/tsfile/qp/exception/LogicalOptimizeException.java
delete mode 100644
spark/src/main/java/org/apache/iotdb/tsfile/qp/exception/MergeFilterException.java
delete mode 100644
spark/src/main/java/org/apache/iotdb/tsfile/qp/exception/QueryOperatorException.java
delete mode 100755
spark/src/main/java/org/apache/iotdb/tsfile/qp/exception/QueryProcessorException.java
delete mode 100755
spark/src/main/java/org/apache/iotdb/tsfile/qp/exception/RemoveNotException.java
delete mode 100755
spark/src/main/java/org/apache/iotdb/tsfile/qp/optimizer/DNFFilterOptimizer.java
delete mode 100755
spark/src/main/java/org/apache/iotdb/tsfile/qp/optimizer/IFilterOptimizer.java
delete mode 100755
spark/src/main/java/org/apache/iotdb/tsfile/qp/optimizer/MergeSingleFilterOptimizer.java
delete mode 100644
spark/src/main/java/org/apache/iotdb/tsfile/qp/optimizer/PhysicalOptimizer.java
delete mode 100755
spark/src/main/java/org/apache/iotdb/tsfile/qp/optimizer/RemoveNotOptimizer.java
delete mode 100644 spark/src/test/resources/test.tsfile
delete mode 100644
spark/src/test/scala/cn/edu/tsinghua/tsfile/ConverterTest.scala
delete mode 100644 spark/src/test/scala/cn/edu/tsinghua/tsfile/TSFileSuit.scala
create mode 100644
spark/src/test/scala/org/apache/iotdb/tool/TsFileExample.java
create mode 100644 spark/src/test/scala/org/apache/iotdb/tool/TsFileWrite.java
create mode 100644
spark/src/test/scala/org/apache/iotdb/tsfile/ConverterTest.scala
create mode 100644
spark/src/test/scala/org/apache/iotdb/tsfile/HDFSInputTest.java
create mode 100644
spark/src/test/scala/org/apache/iotdb/tsfile/TSFileSuit.scala
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/TimeRange.java
create mode 100644
tsfile/src/test/java/org/apache/iotdb/tsfile/read/ReadInPartitionTest.java
create mode 100644
tsfile/src/test/java/org/apache/iotdb/tsfile/read/common/TimeRangeTest.java
