blob: 8faef39e078d299fa25fcd4828cea87042057863 [file] [log] [blame]
/*
* 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.write.writer;
import org.apache.iotdb.tsfile.encoding.encoder.Encoder;
import org.apache.iotdb.tsfile.encoding.encoder.PlainEncoder;
import org.apache.iotdb.tsfile.file.metadata.enums.CompressionType;
import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;
import org.apache.iotdb.tsfile.file.metadata.enums.TSEncoding;
import org.apache.iotdb.tsfile.write.schema.VectorMeasurementSchema;
import java.io.OutputStream;
import java.nio.ByteBuffer;
import java.util.Arrays;
import java.util.List;
import java.util.Map;
public class VectorMeasurementSchemaStub extends VectorMeasurementSchema {
@Override
public String getMeasurementId() {
return "";
}
@Override
public CompressionType getCompressor() {
return CompressionType.UNCOMPRESSED;
}
@Override
public TSEncoding getEncodingType() {
return null;
}
@Override
public TSDataType getType() {
return TSDataType.VECTOR;
}
@Override
public void setType(TSDataType dataType) {
throw new UnsupportedOperationException("unsupported method for VectorMeasurementSchema");
}
@Override
public TSEncoding getTimeTSEncoding() {
return TSEncoding.PLAIN;
}
@Override
public Encoder getTimeEncoder() {
return new PlainEncoder(TSDataType.INT64, 0);
}
@Override
public Encoder getValueEncoder() {
return null;
}
@Override
public Map<String, String> getProps() {
return null;
}
@Override
public List<String> getSubMeasurementsList() {
return Arrays.asList("s1", "s2", "s3");
}
@Override
public List<TSDataType> getSubMeasurementsTSDataTypeList() {
return Arrays.asList(TSDataType.FLOAT, TSDataType.INT32, TSDataType.DOUBLE);
}
@Override
public List<TSEncoding> getSubMeasurementsTSEncodingList() {
return Arrays.asList(TSEncoding.PLAIN, TSEncoding.PLAIN, TSEncoding.PLAIN);
}
@Override
public List<Encoder> getSubMeasurementsEncoderList() {
return Arrays.asList(
new PlainEncoder(TSDataType.FLOAT, 0),
new PlainEncoder(TSDataType.INT32, 0),
new PlainEncoder(TSDataType.DOUBLE, 0));
}
@Override
public int serializeTo(ByteBuffer buffer) {
return 0;
}
@Override
public int serializeTo(OutputStream outputStream) {
return 0;
}
@Override
public int partialSerializeTo(OutputStream outputStream) {
return 0;
}
@Override
public int partialSerializeTo(ByteBuffer buffer) {
return 0;
}
@Override
public int getSubMeasurementIndex(String measurementId) {
return 0;
}
@Override
public int getSubMeasurementsCount() {
return 0;
}
@Override
public boolean containsSubMeasurement(String measurementId) {
return false;
}
}