| /* |
| * 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.commons.pipe.config.constant; |
| |
| public class PipeExtractorConstant { |
| |
| public static final String EXTRACTOR_KEY = "extractor"; |
| public static final String SOURCE_KEY = "source"; |
| |
| public static final String EXTRACTOR_INCLUSION_KEY = "extractor.inclusion"; |
| public static final String SOURCE_INCLUSION_KEY = "source.inclusion"; |
| public static final String EXTRACTOR_INCLUSION_DEFAULT_VALUE = "data.insert"; |
| |
| public static final String EXTRACTOR_EXCLUSION_KEY = "extractor.inclusion.exclusion"; |
| public static final String SOURCE_EXCLUSION_KEY = "source.inclusion.exclusion"; |
| public static final String EXTRACTOR_EXCLUSION_DEFAULT_VALUE = ""; |
| |
| public static final String EXTRACTOR_PATTERN_KEY = "extractor.pattern"; |
| public static final String SOURCE_PATTERN_KEY = "source.pattern"; |
| public static final String EXTRACTOR_PATH_KEY = "extractor.path"; |
| public static final String SOURCE_PATH_KEY = "source.path"; |
| public static final String EXTRACTOR_PATTERN_FORMAT_KEY = "extractor.pattern.format"; |
| public static final String SOURCE_PATTERN_FORMAT_KEY = "source.pattern.format"; |
| public static final String EXTRACTOR_PATTERN_FORMAT_PREFIX_VALUE = "prefix"; |
| public static final String EXTRACTOR_PATTERN_FORMAT_IOTDB_VALUE = "iotdb"; |
| public static final String EXTRACTOR_PATTERN_PREFIX_DEFAULT_VALUE = "root"; |
| public static final String EXTRACTOR_PATTERN_IOTDB_DEFAULT_VALUE = "root.**"; |
| |
| public static final String EXTRACTOR_FORWARDING_PIPE_REQUESTS_KEY = |
| "extractor.forwarding-pipe-requests"; |
| public static final String SOURCE_FORWARDING_PIPE_REQUESTS_KEY = |
| "source.forwarding-pipe-requests"; |
| public static final boolean EXTRACTOR_FORWARDING_PIPE_REQUESTS_DEFAULT_VALUE = true; |
| |
| public static final String EXTRACTOR_HISTORY_ENABLE_KEY = "extractor.history.enable"; |
| public static final String SOURCE_HISTORY_ENABLE_KEY = "source.history.enable"; |
| public static final boolean EXTRACTOR_HISTORY_ENABLE_DEFAULT_VALUE = true; |
| public static final String EXTRACTOR_HISTORY_START_TIME_KEY = "extractor.history.start-time"; |
| public static final String SOURCE_HISTORY_START_TIME_KEY = "source.history.start-time"; |
| public static final String EXTRACTOR_HISTORY_END_TIME_KEY = "extractor.history.end-time"; |
| public static final String SOURCE_HISTORY_END_TIME_KEY = "source.history.end-time"; |
| public static final String EXTRACTOR_HISTORY_LOOSE_RANGE_KEY = "extractor.history.loose-range"; |
| public static final String SOURCE_HISTORY_LOOSE_RANGE_KEY = "source.history.loose-range"; |
| public static final String EXTRACTOR_MODS_ENABLE_KEY = "extractor.mods.enable"; |
| public static final String SOURCE_MODS_ENABLE_KEY = "source.mods.enable"; |
| public static final boolean EXTRACTOR_MODS_ENABLE_DEFAULT_VALUE = false; |
| |
| public static final String EXTRACTOR_REALTIME_ENABLE_KEY = "extractor.realtime.enable"; |
| public static final String SOURCE_REALTIME_ENABLE_KEY = "source.realtime.enable"; |
| public static final boolean EXTRACTOR_REALTIME_ENABLE_DEFAULT_VALUE = true; |
| public static final String EXTRACTOR_REALTIME_MODE_KEY = "extractor.realtime.mode"; |
| public static final String SOURCE_REALTIME_MODE_KEY = "source.realtime.mode"; |
| public static final String EXTRACTOR_REALTIME_MODE_HYBRID_VALUE = "hybrid"; |
| public static final String EXTRACTOR_REALTIME_MODE_FILE_VALUE = "file"; |
| public static final String EXTRACTOR_REALTIME_MODE_LOG_VALUE = "log"; |
| public static final String EXTRACTOR_REALTIME_MODE_FORCED_LOG_VALUE = "forced-log"; |
| public static final String EXTRACTOR_REALTIME_MODE_STREAM_MODE_VALUE = "stream"; |
| public static final String EXTRACTOR_REALTIME_MODE_BATCH_MODE_VALUE = "batch"; |
| |
| public static final String EXTRACTOR_START_TIME_KEY = "extractor.start-time"; |
| public static final String SOURCE_START_TIME_KEY = "source.start-time"; |
| public static final String EXTRACTOR_END_TIME_KEY = "extractor.end-time"; |
| public static final String SOURCE_END_TIME_KEY = "source.end-time"; |
| |
| public static final String EXTRACTOR_WATERMARK_INTERVAL_KEY = "extractor.watermark-interval-ms"; |
| public static final String SOURCE_WATERMARK_INTERVAL_KEY = "source.watermark-interval-ms"; |
| public static final long EXTRACTOR_WATERMARK_INTERVAL_DEFAULT_VALUE = -1; // -1 means no watermark |
| |
| private PipeExtractorConstant() { |
| throw new IllegalStateException("Utility class"); |
| } |
| } |