remove unthrowed exception

This commit is contained in:
qiaojialin 2019-09-21 18:57:51 +08:00
parent 93584319ce
commit 9a2507a97f
57 changed files with 1 additions and 253 deletions

View File

@ -20,9 +20,6 @@ package org.apache.iotdb.kafka;
import org.apache.iotdb.jdbc.Config;
/**
* @author lta
*/
public class Constant {
public static final String TOPIC = "Kafka-Test";

View File

@ -33,8 +33,6 @@ import kafka.utils.VerifiableProperties;
/**
* The class is to show how to get data from kafka through multi-threads. The data is sent by class
* KafkaProducer.
*
* @author lta
*/
public class KafkaConsumer {

View File

@ -27,9 +27,6 @@ import kafka.message.MessageAndMetadata;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* @author lta
*/
public class KafkaConsumerThread implements Runnable {
private Connection connection = null;

View File

@ -27,8 +27,6 @@ import org.slf4j.LoggerFactory;
/**
* The class is to show how to send data to kafka through multi-threads.
*
* @author lta
*/
public class KafkaProducer {

View File

@ -37,8 +37,6 @@ import org.apache.iotdb.tsfile.hadoop.TSFOutputFormat;
* One example for reading TsFile with MapReduce.
* This MR Job is used to get the result of count("root.car.d1") in the tsfile.
* The source of tsfile can be generated by <code>TsFileHelper</code>.
* @author liukun
*
*/
public class TSFMRReadExample {

View File

@ -36,8 +36,6 @@ import org.junit.Test;
/**
* Test the {@link org.apache.iotdb.tsfile.hadoop.TSFInputSplit}
* Assert the readFields function and write function is right
*
* @author liukun
*/
public class TSFInputSplitTest {

View File

@ -27,8 +27,6 @@ import org.apache.thrift.server.TThreadPoolServer.Args;
/**
* This class is used to create thread pool which must contain the pool name.
*
* @author liukun
*/
public class IoTDBThreadPoolFactory {
private IoTDBThreadPoolFactory() {}

View File

@ -21,8 +21,6 @@ package org.apache.iotdb.db.exception;
/**
* This Exception is the parent class for all delta engine runtime exceptions.<br> This Exception
* extends super class {@link java.lang.RuntimeException}
*
* @author CGF
*/
public abstract class DeltaEngineRunningException extends RuntimeException {

View File

@ -21,8 +21,6 @@ package org.apache.iotdb.db.exception;
/**
* If query metadata constructs schema but passes illegal parameters to EncodingConvertor or
* DataTypeConvertor,this exception will be threw.
*
* @author kangrong
*/
public class MetadataErrorException extends Exception {

View File

@ -155,7 +155,7 @@ public class QueryProcessExecutor extends AbstractQueryProcessExecutor {
@Override
public QueryDataSet fill(List<Path> fillPaths, long queryTime, Map<TSDataType, IFill> fillTypes,
QueryContext context)
throws ProcessorException, IOException, PathErrorException, StorageEngineException {
throws IOException, PathErrorException, StorageEngineException {
return queryRouter.fill(fillPaths, queryTime, fillTypes, context);
}

View File

@ -52,7 +52,6 @@ public class DeviceMetaDataCacheTest {
private String measurementId3 = "s3";
private String measurementId4 = "s4";
private String measurementId5 = "s5";
private String measurementId100 = "s100";
private StorageGroupProcessor storageGroupProcessor;
private String systemDir = "data/info";
@ -82,7 +81,6 @@ public class DeviceMetaDataCacheTest {
record.addTuple(DataPoint.getDataPoint(TSDataType.FLOAT, measurementId2, String.valueOf(num)));
record.addTuple(DataPoint.getDataPoint(TSDataType.DOUBLE, measurementId3, String.valueOf(num)));
record.addTuple(DataPoint.getDataPoint(TSDataType.BOOLEAN, measurementId4, "True"));
// record.addTuple(DataPoint.getDataPoint(TSDataType.TEXT, measurementId5, String.valueOf(num)));
storageGroupProcessor.insert(new InsertPlan(record));
}

View File

@ -34,8 +34,6 @@ import org.slf4j.LoggerFactory;
/**
* TSFileDescriptor is used to load TSFileConfig and provide configure information.
*
* @author kangrong
*/
public class TSFileDescriptor {

View File

@ -36,7 +36,6 @@ package org.apache.iotdb.tsfile.encoding.bitpacking;
* +-----------------------+ +-----------------------+ +-----------------------+
* +-----+ +-----+ +---------+ +-----+ +-----+ +---------+ +-----+ +-----+ 5 4 7 3 0 1 3 2
*
* @author Zhang Jinrui
*/
public class IntPacker {

View File

@ -36,7 +36,6 @@ package org.apache.iotdb.tsfile.encoding.bitpacking;
* +-----------------------+ +-----------------------+ +-----+ +-----+ +---------+ +-----+ +-----+
* +---------+ +-----+ +-----+ 5 4 7 3 0 1 3 2
*
* @author Zhang Jinrui
*/
public class LongPacker {

View File

@ -31,7 +31,6 @@ import org.apache.iotdb.tsfile.utils.ReadWriteIOUtils;
* This class is a decoder for decoding the byte array that encoded by {@code
* RegularDataEncoder}. RegularDataDecoder only supports integer and long values.<br>.
*
* @author tsunghantsai
* @see RegularDataEncoder
*/
public abstract class RegularDataDecoder extends Decoder {

View File

@ -39,8 +39,6 @@ import org.slf4j.LoggerFactory;
* all two_diff values are positive. Then it statistics the longest bit length {@code m} it takes
* for each two_diff value, which means the bit length that maximum two_diff value takes. Only the
* low m bits are saved into result byte array for all two_diff values. </p>
*
* @author kangrong
*/
public abstract class DeltaBinaryEncoder extends Encoder {

View File

@ -28,8 +28,6 @@ import org.apache.iotdb.tsfile.utils.Binary;
/**
* This class is the parent class of all Encoders. Every encoder has a specific {@code
* <encoderType>} which represents the type of this encoder
*
* @author Zhang Jinrui
*/
public abstract class Encoder {

View File

@ -37,8 +37,6 @@ import org.slf4j.LoggerFactory;
* If there is, create a bitmap for this block to denote the position of missing points. Next, store
* the data info (the data size, the minimum delta value and the first data point of this block) and the
* bitmap with its info into the result byte array output stream.</p>
*
* @author tsunghantsai
*/
public abstract class RegularDataEncoder extends Encoder {

View File

@ -21,8 +21,6 @@ package org.apache.iotdb.tsfile.exception;
/**
* This Exception is the parent class for all runtime exceptions.<br> This Exception extends super
* class {@link java.lang.RuntimeException}
*
* @author kangrong
*/
public abstract class TsFileRuntimeException extends RuntimeException {

View File

@ -24,8 +24,6 @@ import org.apache.iotdb.tsfile.exception.TsFileRuntimeException;
/**
* This Exception is used while decoding failed. <br> This Exception extends super class {@link
* TsFileRuntimeException}
*
* @author kangrong
*/
public class TsFileDecodingException extends TsFileRuntimeException {

View File

@ -1,43 +0,0 @@
/**
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF 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
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License 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 org.apache.iotdb.tsfile.exception.filter;
/**
* This Exception is used while filter data type is not consistent with the series type. <br>
* e.g. you want to get result from a Double series used Integer filter.<br>
* This Exception extends super class {@link FilterDataTypeException}
*
* @author CGF
*/
public class FilterDataTypeException extends RuntimeException {
private static final long serialVersionUID = 1888878519023495363L;
public FilterDataTypeException(String message, Throwable cause) {
super(message, cause);
}
public FilterDataTypeException(String message) {
super(message);
}
public FilterDataTypeException(Throwable cause) {
super(cause);
}
}

View File

@ -1,42 +0,0 @@
/**
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF 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
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License 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 org.apache.iotdb.tsfile.exception.filter;
/**
* This Exception is used while invoke UnarySeriesFilter's accept method. <br>
* This Exception extends super class {@link FilterInvokeException}
*
* @author CGF
*/
public class FilterInvokeException extends RuntimeException {
private static final long serialVersionUID = 1888878519023495363L;
public FilterInvokeException(String message, Throwable cause) {
super(message, cause);
}
public FilterInvokeException(String message) {
super(message);
}
public FilterInvokeException(Throwable cause) {
super(cause);
}
}

View File

@ -1,35 +0,0 @@
/**
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF 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
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License 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 org.apache.iotdb.tsfile.exception.metadata;
/**
* If query metadata constructs schema but passes illegal parameters to EncodingConvertor or DataTypeConvertor,this
* exception will be threw.
*
* @author kangrong
*/
public class MetadataArgsErrorException extends Exception {
private static final long serialVersionUID = 3415275599091623570L;
public MetadataArgsErrorException(String msg) {
super(msg);
}
}

View File

@ -1,34 +0,0 @@
/**
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF 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
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License 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 org.apache.iotdb.tsfile.exception.write;
/**
* This exception is thrown if the file schema in json format is invalid, for reasons like
* missing necessary fields.
*
* @author kangrong
*/
public class InvalidJsonSchemaException extends WriteProcessException {
private static final long serialVersionUID = -4469810656988557000L;
public InvalidJsonSchemaException(String msg) {
super(msg);
}
}

View File

@ -23,8 +23,6 @@ import org.apache.iotdb.tsfile.exception.TsFileRuntimeException;
/**
* This Exception is used while getting an unknown column type. <br> This Exception extends super
* class {@link TsFileRuntimeException}
*
* @author kangrong
*/
public class UnknownColumnTypeException extends TsFileRuntimeException {

View File

@ -20,8 +20,6 @@ package org.apache.iotdb.tsfile.exception.write;
/**
* This exception is threw while meeting error in writing procession.
*
* @author kangrong
*/
public class WriteProcessException extends Exception {

View File

@ -28,8 +28,6 @@ import org.apache.iotdb.tsfile.utils.ReadWriteIOUtils;
/**
* Statistics for string type.
*
* @author CGF
*/
public class BinaryStatistics extends Statistics<Binary> {

View File

@ -26,8 +26,6 @@ import org.apache.iotdb.tsfile.utils.ReadWriteIOUtils;
/**
* Boolean Statistics.
*
* @author CGF
*/
public class BooleanStatistics extends Statistics<Boolean> {

View File

@ -26,8 +26,6 @@ import org.apache.iotdb.tsfile.utils.ReadWriteIOUtils;
/**
* Statistics for double type.
*
* @author kangrong
*/
public class DoubleStatistics extends Statistics<Double> {

View File

@ -26,8 +26,6 @@ import org.apache.iotdb.tsfile.utils.ReadWriteIOUtils;
/**
* Statistics for float type.
*
* @author kangrong
*/
public class FloatStatistics extends Statistics<Float> {

View File

@ -26,8 +26,6 @@ import org.apache.iotdb.tsfile.utils.ReadWriteIOUtils;
/**
* Statistics for int type.
*
* @author kangrong
*/
public class IntegerStatistics extends Statistics<Integer> {

View File

@ -26,8 +26,6 @@ import org.apache.iotdb.tsfile.utils.ReadWriteIOUtils;
/**
* Statistics for long type.
*
* @author kangrong
*/
public class LongStatistics extends Statistics<Long> {

View File

@ -26,8 +26,6 @@ import org.apache.iotdb.tsfile.utils.ReadWriteIOUtils;
/**
* This statistic is used as Unsupported data type. It just return a 0-byte array while asked max or
* min.
*
* @author kangrong
*/
public class NoStatistics extends Statistics<Long> {

View File

@ -38,7 +38,6 @@ import org.slf4j.LoggerFactory;
* super class.<br>
*
* @param <T> data type for Statistics
* @author kangrong
* @since 0.0.1
*/
public abstract class Statistics<T> {

View File

@ -25,8 +25,6 @@ import org.apache.iotdb.tsfile.utils.StringContainer;
/**
* This class define an Object named Path to represent a series in IoTDB. AndExpression in batch read, this definition
* is also used in query processing. Note that, Path is unmodified after a new object has been created.
*
* @author Kangrong
*/
public class Path implements Serializable {

View File

@ -31,8 +31,6 @@ import org.apache.iotdb.tsfile.read.filter.TimeFilter;
* interval [min,max] of long data type
*
* Reference: http://www.java2s.com/Code/Java/Collections-Data-Structure/Anumericalinterval.htm
*
* @author ryanm
*/
public class TimeRange implements Comparable<TimeRange> {

View File

@ -18,9 +18,6 @@
*/
package org.apache.iotdb.tsfile.read.expression;
/**
* @author Jinrui Zhang
*/
public interface IBinaryExpression extends IExpression {
IExpression getLeft();

View File

@ -25,7 +25,6 @@ import org.apache.iotdb.tsfile.read.filter.factory.FilterType;
* Definition for unary filter operations.
*
* @param <T> comparable data type
* @author CGF
*/
public abstract class UnaryFilter<T extends Comparable<T>> implements Filter, Serializable {

View File

@ -20,8 +20,6 @@ package org.apache.iotdb.tsfile.read.query.timegenerator.node;
/**
* Type of the node.
*
* @author Jinrui Zhang
*/
public enum NodeType {
AND, OR, LEAF

View File

@ -26,8 +26,6 @@ import org.apache.iotdb.tsfile.common.conf.TSFileConfig;
/**
* Override compareTo() and equals() function to Binary class. This class is used to accept Java
* String type
*
* @author xuyi
*/
public class Binary implements Comparable<Binary>, Serializable {

View File

@ -26,7 +26,6 @@ import java.io.Serializable;
*
* @param <L> L type
* @param <R> R type
* @author kangrong
*/
public class Pair<L, R> implements Serializable {

View File

@ -34,8 +34,6 @@ import org.apache.iotdb.tsfile.read.reader.TsFileInput;
/**
* ConverterUtils is a utility class. It provide conversion between normal datatype and byte array.
*
* @author East
*/
public class ReadWriteIOUtils {

View File

@ -20,13 +20,10 @@ package org.apache.iotdb.tsfile.utils;
import java.util.ArrayList;
import java.util.List;
import org.apache.iotdb.tsfile.common.conf.TSFileConfig;
/**
* this class is used to contact String effectively.It contains a StringBuider and initialize it
* until {@code toString} is called. Note:it's not thread safety
*
* @author kangrong
*/
public class StringContainer {

View File

@ -35,8 +35,6 @@ import org.slf4j.LoggerFactory;
/**
* Store current pages in this chunk.
*
* @author kangrong
*/
public class ChunkBuffer {

View File

@ -37,7 +37,6 @@ import org.slf4j.LoggerFactory;
* A implementation of {@code IChunkWriter}. {@code ChunkWriterImpl} consists of a {@code
* ChunkBuffer}, a {@code PageWriter}, and two {@code Statistics}.
*
* @author kangrong
* @see IChunkWriter IChunkWriter
*/
public class ChunkWriterImpl implements IChunkWriter {

View File

@ -32,8 +32,6 @@ import org.apache.iotdb.tsfile.write.writer.TsFileIOWriter;
* A chunk group in TsFile contains several series. A ChunkGroupWriter should implement
* write method which takes a timestamp(in TimeValue class) and a list of data points as input.
* It should also provide flushing method for serializing to local file system or HDFS.
*
* @author kangrong
*/
public interface IChunkGroupWriter {

View File

@ -26,8 +26,6 @@ import org.apache.iotdb.tsfile.write.writer.TsFileIOWriter;
/**
* IChunkWriter provides a list of writing methods for different value types.
*
* @author kangrong
*/
public interface IChunkWriter {

View File

@ -30,8 +30,6 @@ import org.apache.iotdb.tsfile.write.schema.MeasurementSchema;
/**
* This function is used to write time-value into a page. It consists of a time encoder, a value encoder and respective
* OutputStream.
*
* @author kangrong
*/
public class PageWriter {

View File

@ -27,7 +27,6 @@ import org.slf4j.LoggerFactory;
/**
* a subclass for Boolean data type extends DataPoint.
*
* @author kangrong
* @see DataPoint DataPoint
*/
public class BooleanDataPoint extends DataPoint {

View File

@ -31,8 +31,6 @@ import org.apache.iotdb.tsfile.write.chunk.IChunkWriter;
* This is a abstract class representing a data point. DataPoint consists of a measurement id and a
* data type. subclass of DataPoint need override method {@code write(long time, IChunkWriter
* writer)} .Every subclass has its data type and overrides a setting method for its data type.
*
* @author kangrong
*/
public abstract class DataPoint {

View File

@ -27,7 +27,6 @@ import org.slf4j.LoggerFactory;
/**
* a subclass for Float data type extends DataPoint.
*
* @author kangrong
* @see DataPoint DataPoint
*/
public class FloatDataPoint extends DataPoint {

View File

@ -27,7 +27,6 @@ import org.slf4j.LoggerFactory;
/**
* a subclass for Long data type extends DataPoint.
*
* @author kangrong
* @see DataPoint DataPoint
*/
public class LongDataPoint extends DataPoint {

View File

@ -28,7 +28,6 @@ import org.slf4j.LoggerFactory;
/**
* a subclass for Integer data type extends DataPoint.
*
* @author kangrong
* @see DataPoint DataPoint
*/
public class StringDataPoint extends DataPoint {

View File

@ -59,8 +59,6 @@ import org.slf4j.LoggerFactory;
/**
* TSFileIOWriter is used to construct metadata and write data stored in memory to output stream.
*
* @author kangrong
*/
public class TsFileIOWriter {

View File

@ -46,8 +46,6 @@ import org.slf4j.LoggerFactory;
/**
* This is used for performance test, no asserting. User could change {@code ROW_COUNT} for larger data test.
*
* @author kangrong
*/
public class PerfTest {

View File

@ -49,8 +49,6 @@ import org.slf4j.LoggerFactory;
/**
* test writing processing correction combining writing process and reading process.
*
* @author kangrong
*/
public class WriteTest {

View File

@ -32,9 +32,6 @@ import org.apache.iotdb.tsfile.write.schema.MeasurementSchema;
import org.apache.iotdb.tsfile.write.schema.SchemaBuilder;
import org.junit.Test;
/**
* @author qiaojialin
*/
public class SchemaBuilderTest {
@Test